X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=server.h;h=67ba38d216d92464ef6b70614b011d04697730dc;hp=a838126fff0f97e1847907308e914f5d9b3dc80b;hb=976a77566d8b735fd0c064f33332aa4e0204122c;hpb=c41a9d06a1957ba7c5a019e3d6088a5e8e8e0a47 diff --git a/server.h b/server.h index a838126f..67ba38d2 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,9 +38,10 @@ struct fio_net_cmd_reply { }; enum { - FIO_SERVER_VER = 17, + FIO_SERVER_VER = 37, FIO_SERVER_MAX_FRAGMENT_PDU = 1024, + FIO_SERVER_MAX_CMD_MB = 2048, FIO_NET_CMD_QUIT = 1, FIO_NET_CMD_EXIT = 2, @@ -60,7 +61,8 @@ enum { FIO_NET_CMD_RUN = 16, FIO_NET_CMD_IOLOG = 17, FIO_NET_CMD_UPDATE_JOB = 18, - FIO_NET_CMD_NR = 19, + FIO_NET_CMD_LOAD_FILE = 19, + FIO_NET_CMD_NR = 20, FIO_NET_CMD_F_MORE = 1UL << 0, @@ -71,6 +73,14 @@ enum { FIO_NET_NAME_MAX = 256, FIO_NET_CLIENT_TIMEOUT = 5000, + + FIO_PROBE_FLAG_ZLIB = 1UL << 0, +}; + +struct cmd_load_file_pdu { + uint16_t name_len; + uint16_t client_type; + uint8_t file[]; }; struct cmd_ts_pdu { @@ -83,7 +93,11 @@ 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_version[32]; @@ -96,13 +110,13 @@ struct cmd_probe_pdu { 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 +127,7 @@ struct cmd_job_pdu { struct cmd_start_pdu { uint32_t jobs; + uint32_t stat_outputs; }; struct cmd_end_pdu { @@ -135,9 +150,11 @@ struct cmd_text_pdu { }; struct cmd_iolog_pdu { + uint64_t nr_samples; uint32_t thread_number; - uint32_t nr_samples; uint32_t log_type; + uint32_t compressed; + uint32_t log_offset; uint8_t name[FIO_NET_NAME_MAX]; struct io_sample samples[0]; }; @@ -148,7 +165,7 @@ extern int fio_net_send_cmd(int, uint16_t, const void *, off_t, uint64_t *, stru extern int fio_net_send_simple_cmd(int, uint16_t, uint64_t, struct flist_head *); extern void fio_server_set_arg(const char *); extern int fio_server_parse_string(const char *, char **, int *, int *, struct in_addr *, struct in6_addr *, int *); -extern int fio_server_parse_host(const char *, int *, struct in_addr *, struct in6_addr *); +extern int fio_server_parse_host(const char *, int, struct in_addr *, struct in6_addr *); extern const char *fio_server_op(unsigned int); extern void fio_server_got_signal(int); @@ -157,6 +174,7 @@ 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_recv_data(int sk, void *p, unsigned int len); extern int fio_send_data(int sk, const void *p, unsigned int len);