blob: 10d6ec36cac34f1de66e5cc0951cd191c9375e33 [file] [log] [blame]
Stephen M. Camerondd366722012-02-24 08:17:30 +01001#ifndef CLIENT_H
2#define CLIENT_H
3
Jens Axboe0f92bd22012-02-29 11:44:34 +01004#include <sys/socket.h>
5#include <sys/un.h>
6#include <netinet/in.h>
7#include <arpa/inet.h>
8
Jens Axboe3e47bd22012-02-29 13:45:02 +01009#include "stat.h"
10
Stephen M. Camerondd366722012-02-24 08:17:30 +010011struct fio_net_cmd;
Jens Axboea5276612012-03-04 15:15:08 +010012struct client_ops;
Stephen M. Camerondd366722012-02-24 08:17:30 +010013
Jens Axboeb9d2f302012-03-08 20:36:28 +010014enum {
15 Client_created = 0,
16 Client_connected = 1,
17 Client_started = 2,
18 Client_running = 3,
19 Client_stopped = 4,
20 Client_exited = 5,
21};
22
Jens Axboe0f92bd22012-02-29 11:44:34 +010023struct fio_client {
24 struct flist_head list;
25 struct flist_head hash_list;
26 struct flist_head arg_list;
27 union {
28 struct sockaddr_in addr;
29 struct sockaddr_in6 addr6;
30 struct sockaddr_un addr_un;
31 };
32 char *hostname;
33 int port;
34 int fd;
Jens Axboe5121a9a2012-03-05 13:32:47 +010035 unsigned int refs;
Jens Axboe0f92bd22012-02-29 11:44:34 +010036
37 char *name;
38
39 int state;
40
41 int skip_newline;
42 int is_sock;
43 int disk_stats_shown;
44 unsigned int jobs;
Jens Axboe1e5324e2012-11-14 14:25:31 -070045 unsigned int nr_stat;
Jens Axboe0f92bd22012-02-29 11:44:34 +010046 int error;
Jens Axboe122c7722012-03-19 09:13:15 +010047 int signal;
Jens Axboe0f92bd22012-02-29 11:44:34 +010048 int ipv6;
49 int sent_job;
Jens Axboe1e5324e2012-11-14 14:25:31 -070050 int did_stat;
Jens Axboe46bcd492012-03-14 11:31:21 +010051 uint32_t type;
Jens Axboe0f92bd22012-02-29 11:44:34 +010052
Jens Axboe40c60512012-03-27 16:03:04 +020053 uint32_t thread_number;
54 uint32_t groupid;
55
Jens Axboe0f92bd22012-02-29 11:44:34 +010056 struct flist_head eta_list;
57 struct client_eta *eta_in_flight;
58
59 struct flist_head cmd_list;
60
61 uint16_t argc;
62 char **argv;
Jens Axboe3ec62ec2012-03-01 12:01:29 +010063
Jens Axboea5276612012-03-04 15:15:08 +010064 struct client_ops *ops;
Jens Axboe3ec62ec2012-03-01 12:01:29 +010065 void *client_data;
Jens Axboe14ea90e2012-08-26 17:33:34 +020066
67 char **ini_file;
68 unsigned int nr_ini_file;
Jens Axboe0f92bd22012-02-29 11:44:34 +010069};
70
Jens Axboe1b427252012-03-14 15:03:03 +010071struct cmd_iolog_pdu;
Jens Axboe35c0ba72012-03-14 10:56:40 +010072typedef void (client_cmd_op)(struct fio_client *, struct fio_net_cmd *);
73typedef void (client_eta_op)(struct jobs_eta *je);
74typedef void (client_timed_out_op)(struct fio_client *);
75typedef void (client_jobs_eta_op)(struct fio_client *client, struct jobs_eta *je);
Jens Axboe1b427252012-03-14 15:03:03 +010076typedef void (client_iolog_op)(struct fio_client *client, struct cmd_iolog_pdu *);
Jens Axboe3ec62ec2012-03-01 12:01:29 +010077
Stephen M. Camerondd366722012-02-24 08:17:30 +010078struct client_ops {
Jens Axboe35c0ba72012-03-14 10:56:40 +010079 client_cmd_op *text;
80 client_cmd_op *disk_util;
81 client_cmd_op *thread_status;
82 client_cmd_op *group_stats;
83 client_jobs_eta_op *jobs_eta;
84 client_eta_op *eta;
85 client_cmd_op *probe;
86 client_cmd_op *quit;
87 client_cmd_op *add_job;
Jens Axboe40c60512012-03-27 16:03:04 +020088 client_cmd_op *update_job;
Jens Axboe35c0ba72012-03-14 10:56:40 +010089 client_timed_out_op *timed_out;
90 client_cmd_op *stop;
91 client_cmd_op *start;
92 client_cmd_op *job_start;
Jens Axboe1b427252012-03-14 15:03:03 +010093 client_iolog_op *iolog;
Jens Axboe0cf3ece2012-03-21 10:15:20 +010094 client_timed_out_op *removed;
Jens Axboe35c0ba72012-03-14 10:56:40 +010095
Jens Axboe6433ee02012-03-09 20:10:51 +010096 unsigned int eta_msec;
Jens Axboe3ec62ec2012-03-01 12:01:29 +010097 int stay_connected;
Jens Axboe46bcd492012-03-14 11:31:21 +010098 uint32_t client_type;
Stephen M. Camerondd366722012-02-24 08:17:30 +010099};
100
101extern struct client_ops fio_client_ops;
102
Jens Axboe3e47bd22012-02-29 13:45:02 +0100103struct client_eta {
104 struct jobs_eta eta;
105 unsigned int pending;
106};
107
Jens Axboea5276612012-03-04 15:15:08 +0100108extern int fio_handle_client(struct fio_client *);
109extern void fio_client_dec_jobs_eta(struct client_eta *eta, client_eta_op fn);
Jens Axboe3e47bd22012-02-29 13:45:02 +0100110extern void fio_client_sum_jobs_eta(struct jobs_eta *dst, struct jobs_eta *je);
Jens Axboe3e47bd22012-02-29 13:45:02 +0100111
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100112enum {
113 Fio_client_ipv4 = 1,
114 Fio_client_ipv6,
115 Fio_client_socket,
116};
117
Jens Axboe2f99deb2012-03-09 14:37:29 +0100118extern int fio_client_connect(struct fio_client *);
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100119extern int fio_clients_connect(void);
Jens Axboeb9d2f302012-03-08 20:36:28 +0100120extern int fio_start_client(struct fio_client *);
121extern int fio_start_all_clients(void);
Jens Axboe9988ca72012-03-09 15:14:06 +0100122extern int fio_client_send_ini(struct fio_client *, const char *);
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100123extern int fio_clients_send_ini(const char *);
Jens Axboea5276612012-03-04 15:15:08 +0100124extern int fio_handle_clients(struct client_ops *);
125extern int fio_client_add(struct client_ops *, const char *, void **);
126extern struct fio_client *fio_client_add_explicit(struct client_ops *, const char *, int, int);
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100127extern void fio_client_add_cmd_option(void *, const char *);
Jens Axboe14ea90e2012-08-26 17:33:34 +0200128extern void fio_client_add_ini_file(void *, const char *);
Jens Axboe0cf3ece2012-03-21 10:15:20 +0100129extern int fio_client_terminate(struct fio_client *);
Jens Axboedf06f222012-03-02 13:32:04 +0100130extern void fio_clients_terminate(void);
Jens Axboe343cb4a2012-03-09 17:16:51 +0100131extern struct fio_client *fio_get_client(struct fio_client *);
132extern void fio_put_client(struct fio_client *);
Jens Axboe40c60512012-03-27 16:03:04 +0200133extern int fio_client_update_options(struct fio_client *, struct thread_options *, uint64_t *);
134extern int fio_client_wait_for_reply(struct fio_client *, uint64_t);
Jens Axboedf06f222012-03-02 13:32:04 +0100135
Jens Axboe6433ee02012-03-09 20:10:51 +0100136#define FIO_CLIENT_DEF_ETA_MSEC 900
137
Jens Axboe46bcd492012-03-14 11:31:21 +0100138enum {
139 FIO_CLIENT_TYPE_CLI = 1,
140 FIO_CLIENT_TYPE_GUI = 2,
141};
142
Stephen M. Camerondd366722012-02-24 08:17:30 +0100143#endif
144