int is_sock;
int disk_stats_shown;
unsigned int jobs;
+ unsigned int nr_stat;
int error;
+ int signal;
int ipv6;
int sent_job;
+ int did_stat;
uint32_t type;
+ uint32_t thread_number;
+ uint32_t groupid;
+
struct flist_head eta_list;
struct client_eta *eta_in_flight;
struct client_ops *ops;
void *client_data;
+
+ char **ini_file;
+ unsigned int nr_ini_file;
};
struct cmd_iolog_pdu;
client_cmd_op *probe;
client_cmd_op *quit;
client_cmd_op *add_job;
+ client_cmd_op *update_job;
client_timed_out_op *timed_out;
client_cmd_op *stop;
client_cmd_op *start;
client_cmd_op *job_start;
client_iolog_op *iolog;
+ client_timed_out_op *removed;
unsigned int eta_msec;
int stay_connected;
extern struct client_ops fio_client_ops;
struct client_eta {
- struct jobs_eta eta;
unsigned int pending;
+ struct jobs_eta eta;
};
extern int fio_handle_client(struct fio_client *);
extern int fio_client_add(struct client_ops *, const char *, void **);
extern struct fio_client *fio_client_add_explicit(struct client_ops *, const char *, int, int);
extern void fio_client_add_cmd_option(void *, const char *);
-extern void fio_client_terminate(struct fio_client *);
+extern void fio_client_add_ini_file(void *, const char *);
+extern int fio_client_terminate(struct fio_client *);
extern void fio_clients_terminate(void);
extern struct fio_client *fio_get_client(struct fio_client *);
extern void fio_put_client(struct fio_client *);
+extern int fio_client_update_options(struct fio_client *, struct thread_options *, uint64_t *);
+extern int fio_client_wait_for_reply(struct fio_client *, uint64_t);
#define FIO_CLIENT_DEF_ETA_MSEC 900