X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=server.h;h=57e15d72ff1829c8f18d992e84f525168618d4ac;hb=da0a7bd224bb9331f27bb4b20394dd5c8fa3acb0;hp=d56d498a149903d50159da0552455d2a707f8201;hpb=40c605169e60d32fc321a2f9f465e76cba745489;p=fio.git diff --git a/server.h b/server.h index d56d498a..57e15d72 100644 --- a/server.h +++ b/server.h @@ -27,7 +27,7 @@ struct fio_net_cmd { */ uint16_t cmd_crc16; /* cmd checksum */ uint16_t pdu_crc16; /* payload checksum */ - uint8_t payload[0]; /* payload */ + uint8_t payload[]; /* payload */ }; struct fio_net_cmd_reply { @@ -38,7 +38,7 @@ struct fio_net_cmd_reply { }; enum { - FIO_SERVER_VER = 14, + FIO_SERVER_VER = 30, FIO_SERVER_MAX_FRAGMENT_PDU = 1024, @@ -71,6 +71,8 @@ enum { FIO_NET_NAME_MAX = 256, FIO_NET_CLIENT_TIMEOUT = 5000, + + FIO_PROBE_FLAG_ZLIB = 1UL << 0, }; struct cmd_ts_pdu { @@ -83,26 +85,30 @@ struct cmd_du_pdu { struct disk_util_agg agg; }; -struct cmd_probe_pdu { +struct cmd_client_probe_pdu { + uint64_t flags; +}; + +struct cmd_probe_reply_pdu { uint8_t hostname[64]; uint8_t bigendian; - uint8_t fio_major; - uint8_t fio_minor; - uint8_t fio_patch; + uint8_t fio_version[32]; uint8_t os; uint8_t arch; uint8_t bpp; + uint32_t cpus; + uint64_t flags; }; struct cmd_single_line_pdu { uint16_t len; - uint8_t text[0]; + uint8_t text[]; }; struct cmd_line_pdu { uint16_t lines; uint16_t client_type; - struct cmd_single_line_pdu options[0]; + struct cmd_single_line_pdu options[]; }; struct cmd_job_pdu { @@ -113,6 +119,7 @@ struct cmd_job_pdu { struct cmd_start_pdu { uint32_t jobs; + uint32_t stat_outputs; }; struct cmd_end_pdu { @@ -138,6 +145,7 @@ struct cmd_iolog_pdu { uint32_t thread_number; uint32_t nr_samples; uint32_t log_type; + uint32_t compressed; uint8_t name[FIO_NET_NAME_MAX]; struct io_sample samples[0]; }; @@ -157,6 +165,12 @@ struct group_run_stats; extern void fio_server_send_ts(struct thread_stat *, struct group_run_stats *); extern void fio_server_send_gs(struct group_run_stats *); extern void fio_server_send_du(void); +extern void fio_server_idle_loop(void); + +extern int fio_clients_connect(void); +extern int fio_clients_send_ini(const char *); +extern void fio_client_add_cmd_option(void *, const char *); +extern void fio_client_add_ini_file(void *, const char *); extern int fio_recv_data(int sk, void *p, unsigned int len); extern int fio_send_data(int sk, const void *p, unsigned int len);