X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;ds=sidebyside;f=client.h;h=30228161fc2f479e66340ff5f65e8674e87b4d30;hb=f5ed765adadc5dca61efb5fc103fa5cd0310bcec;hp=caeb432a1bc4fb9bf4f95311e1f505afdcea2921;hpb=343cb4a98200757bdcb0c5203e9120bb777625a8;p=fio.git diff --git a/client.h b/client.h index caeb432a..30228161 100644 --- a/client.h +++ b/client.h @@ -45,6 +45,7 @@ struct fio_client { int error; int ipv6; int sent_job; + uint32_t type; struct flist_head eta_list; struct client_eta *eta_in_flight; @@ -58,32 +59,32 @@ struct fio_client { void *client_data; }; -typedef void (*client_text_op_func)(struct fio_client *client, struct fio_net_cmd *cmd); -typedef void (*client_disk_util_op_func)(struct fio_client *client, struct fio_net_cmd *cmd); -typedef void (*client_thread_status_op)(struct fio_client *client, struct fio_net_cmd *cmd); -typedef void (*client_group_stats_op)(struct fio_client *client, struct fio_net_cmd *cmd); -typedef void (*client_eta_op)(struct jobs_eta *je); -typedef void (*client_jobs_eta_op)(struct fio_client *client, struct jobs_eta *je); -typedef void (*client_probe_op)(struct fio_client *client, struct fio_net_cmd *cmd); -typedef void (*client_thread_status_display_op)(char *status_message, double perc); -typedef void (*client_quit_op)(struct fio_client *); -typedef void (*client_add_job_op)(struct fio_client *, struct fio_net_cmd *); -typedef void (*client_timed_out)(struct fio_client *); -typedef void (*client_stop_op)(struct fio_client *, struct fio_net_cmd *); +struct cmd_iolog_pdu; +typedef void (client_cmd_op)(struct fio_client *, struct fio_net_cmd *); +typedef void (client_eta_op)(struct jobs_eta *je); +typedef void (client_timed_out_op)(struct fio_client *); +typedef void (client_jobs_eta_op)(struct fio_client *client, struct jobs_eta *je); +typedef void (client_iolog_op)(struct fio_client *client, struct cmd_iolog_pdu *); struct client_ops { - client_text_op_func text_op; - client_disk_util_op_func disk_util; - client_thread_status_op thread_status; - client_group_stats_op group_stats; - client_jobs_eta_op jobs_eta; - client_eta_op eta; - client_probe_op probe; - client_quit_op quit; - client_add_job_op add_job; - client_timed_out timed_out; - client_stop_op stop; + client_cmd_op *text; + client_cmd_op *disk_util; + client_cmd_op *thread_status; + client_cmd_op *group_stats; + client_jobs_eta_op *jobs_eta; + client_eta_op *eta; + client_cmd_op *probe; + client_cmd_op *quit; + client_cmd_op *add_job; + client_timed_out_op *timed_out; + client_cmd_op *stop; + client_cmd_op *start; + client_cmd_op *job_start; + client_iolog_op *iolog; + + unsigned int eta_msec; int stay_connected; + uint32_t client_type; }; extern struct client_ops fio_client_ops; @@ -118,5 +119,12 @@ extern void fio_clients_terminate(void); extern struct fio_client *fio_get_client(struct fio_client *); extern void fio_put_client(struct fio_client *); +#define FIO_CLIENT_DEF_ETA_MSEC 900 + +enum { + FIO_CLIENT_TYPE_CLI = 1, + FIO_CLIENT_TYPE_GUI = 2, +}; + #endif