X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=server.h;h=173aadce44f487415628deaee0a65287db84b8ae;hp=6747bf0241e1b6c523a912ef9c57ac21487f3043;hb=d685adfb27d3f2f94a6623c774a246bcaac2f853;hpb=9d2c74d7fe5482beb148520171e1dde9a89ee673 diff --git a/server.h b/server.h index 6747bf02..173aadce 100644 --- a/server.h +++ b/server.h @@ -38,7 +38,7 @@ struct fio_net_cmd_reply { }; enum { - FIO_SERVER_VER = 49, + FIO_SERVER_VER = 57, FIO_SERVER_MAX_FRAGMENT_PDU = 1024, FIO_SERVER_MAX_CMD_MB = 2048, @@ -64,7 +64,8 @@ enum { FIO_NET_CMD_LOAD_FILE = 19, FIO_NET_CMD_VTRIGGER = 20, FIO_NET_CMD_SENDFILE = 21, - FIO_NET_CMD_NR = 22, + FIO_NET_CMD_JOB_OPT = 22, + FIO_NET_CMD_NR = 23, FIO_NET_CMD_F_MORE = 1UL << 0, @@ -74,7 +75,7 @@ enum { FIO_NET_NAME_MAX = 256, - FIO_NET_CLIENT_TIMEOUT = 30000, + FIO_NET_CLIENT_TIMEOUT = 5000, FIO_PROBE_FLAG_ZLIB = 1UL << 0, }; @@ -171,6 +172,11 @@ struct cmd_text_pdu { uint8_t buf[0]; }; +enum { + XMIT_COMPRESSED = 1U, + STORE_COMPRESSED = 2U, +}; + struct cmd_iolog_pdu { uint64_t nr_samples; uint32_t thread_number; @@ -181,6 +187,14 @@ struct cmd_iolog_pdu { struct io_sample samples[0]; }; +struct cmd_job_option { + uint16_t global; + uint16_t truncated; + uint32_t groupid; + uint8_t name[64]; + uint8_t value[128]; +}; + extern int fio_start_server(char *); extern int fio_server_text_output(int, const char *, size_t); extern int fio_net_send_cmd(int, uint16_t, const void *, off_t, uint64_t *, struct flist_head *); @@ -196,15 +210,19 @@ 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 int fio_server_get_verify_state(const char *, int, void **, int *); +extern void fio_server_send_job_options(struct flist_head *, unsigned int); +extern int fio_server_get_verify_state(const char *, int, void **); -extern struct fio_net_cmd *fio_net_recv_cmd(int sk); +extern struct fio_net_cmd *fio_net_recv_cmd(int sk, bool wait); extern int fio_send_iolog(struct thread_data *, struct io_log *, const char *); extern void fio_server_send_add_job(struct thread_data *); extern void fio_server_send_start(struct thread_data *); extern int fio_net_send_quit(int sk); +extern int fio_server_create_sk_key(void); +extern void fio_server_destroy_sk_key(void); + extern int exit_backend; extern int fio_net_port;