Gitiles
Code Review Sign In
gerrit-public.fairphone.software / platform / external / fio / refs/tags/20.10.1-beta.0 / . / client.h
blob: fc9c19693a9ff0c60bfcee6429755344b72cdfdf [file] [log] [blame]
Stephen M. Camerondd366722012-02-24 08:17:30 +0100[diff] [blame]1#ifndef CLIENT_H
2#define CLIENT_H
3
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]4#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 +0100[diff] [blame]9#include "stat.h"
10
Stephen M. Camerondd366722012-02-24 08:17:30 +0100[diff] [blame]11struct fio_net_cmd;
Jens Axboea5276612012-03-04 15:15:08 +0100[diff] [blame]12struct client_ops;
Stephen M. Camerondd366722012-02-24 08:17:30 +0100[diff] [blame]13
Jens Axboeb9d2f302012-03-08 20:36:28 +0100[diff] [blame]14enum {
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 Axboe35899182014-10-07 20:56:28 -0600[diff] [blame]23struct client_file {
24 char *file;
Elliott Hugheseda3a602017-05-19 18:53:02 -0700[diff] [blame]25 bool remote;
Jens Axboe35899182014-10-07 20:56:28 -0600[diff] [blame]26};
27
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]28struct fio_client {
29 struct flist_head list;
30 struct flist_head hash_list;
31 struct flist_head arg_list;
32 union {
33 struct sockaddr_in addr;
34 struct sockaddr_in6 addr6;
35 struct sockaddr_un addr_un;
36 };
37 char *hostname;
38 int port;
39 int fd;
Jens Axboe5121a9a2012-03-05 13:32:47 +0100[diff] [blame]40 unsigned int refs;
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]41
42 char *name;
43
Elliott Hugheseda3a602017-05-19 18:53:02 -0700[diff] [blame]44 struct flist_head *opt_lists;
45
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]46 int state;
47
48 int skip_newline;
49 int is_sock;
50 int disk_stats_shown;
51 unsigned int jobs;
Jens Axboe30f8e312014-10-13 11:33:27 -0600[diff] [blame]52 unsigned int nr_stat;
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]53 int error;
Jens Axboe122c7722012-03-19 09:13:15 +0100[diff] [blame]54 int signal;
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]55 int ipv6;
56 int sent_job;
Jens Axboe1e5324e2012-11-14 14:25:31 -0700[diff] [blame]57 int did_stat;
Jens Axboe46bcd492012-03-14 11:31:21 +0100[diff] [blame]58 uint32_t type;
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]59
Jens Axboe40c60512012-03-27 16:03:04 +0200[diff] [blame]60 uint32_t thread_number;
61 uint32_t groupid;
62
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]63 struct flist_head eta_list;
64 struct client_eta *eta_in_flight;
Elliott Hugheseda3a602017-05-19 18:53:02 -0700[diff] [blame]65 unsigned int eta_timeouts;
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]66
67 struct flist_head cmd_list;
68
69 uint16_t argc;
70 char **argv;
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]71
Jens Axboea5276612012-03-04 15:15:08 +0100[diff] [blame]72 struct client_ops *ops;
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]73 void *client_data;
Jens Axboe14ea90e2012-08-26 17:33:34 +0200[diff] [blame]74
Jens Axboe35899182014-10-07 20:56:28 -0600[diff] [blame]75 struct client_file *files;
76 unsigned int nr_files;
Jens Axboe0f92bd22012-02-29 11:44:34 +0100[diff] [blame]77};
78
Jens Axboe35c0ba72012-03-14 10:56:40 +0100[diff] [blame]79typedef void (client_cmd_op)(struct fio_client *, struct fio_net_cmd *);
80typedef void (client_eta_op)(struct jobs_eta *je);
81typedef void (client_timed_out_op)(struct fio_client *);
82typedef void (client_jobs_eta_op)(struct fio_client *client, struct jobs_eta *je);
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]83
Stephen M. Camerondd366722012-02-24 08:17:30 +0100[diff] [blame]84struct client_ops {
Jens Axboe35c0ba72012-03-14 10:56:40 +0100[diff] [blame]85 client_cmd_op *text;
86 client_cmd_op *disk_util;
87 client_cmd_op *thread_status;
88 client_cmd_op *group_stats;
89 client_jobs_eta_op *jobs_eta;
90 client_eta_op *eta;
91 client_cmd_op *probe;
92 client_cmd_op *quit;
93 client_cmd_op *add_job;
Jens Axboe40c60512012-03-27 16:03:04 +0200[diff] [blame]94 client_cmd_op *update_job;
Jens Axboe35c0ba72012-03-14 10:56:40 +0100[diff] [blame]95 client_timed_out_op *timed_out;
96 client_cmd_op *stop;
97 client_cmd_op *start;
98 client_cmd_op *job_start;
Jens Axboe0cf3ece2012-03-21 10:15:20 +0100[diff] [blame]99 client_timed_out_op *removed;
Jens Axboe35c0ba72012-03-14 10:56:40 +0100[diff] [blame]100
Jens Axboe6433ee02012-03-09 20:10:51 +0100[diff] [blame]101 unsigned int eta_msec;
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]102 int stay_connected;
Jens Axboe46bcd492012-03-14 11:31:21 +0100[diff] [blame]103 uint32_t client_type;
Stephen M. Camerondd366722012-02-24 08:17:30 +0100[diff] [blame]104};
105
106extern struct client_ops fio_client_ops;
107
Jens Axboe3e47bd22012-02-29 13:45:02 +0100[diff] [blame]108struct client_eta {
Jens Axboe3e47bd22012-02-29 13:45:02 +0100[diff] [blame]109 unsigned int pending;
Jens Axboe166fb522013-04-11 13:45:51 +0200[diff] [blame]110 struct jobs_eta eta;
Jens Axboe3e47bd22012-02-29 13:45:02 +0100[diff] [blame]111};
112
Jens Axboea5276612012-03-04 15:15:08 +0100[diff] [blame]113extern int fio_handle_client(struct fio_client *);
Jens Axboe3e47bd22012-02-29 13:45:02 +0100[diff] [blame]114extern void fio_client_sum_jobs_eta(struct jobs_eta *dst, struct jobs_eta *je);
Jens Axboe3e47bd22012-02-29 13:45:02 +0100[diff] [blame]115
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]116enum {
117 Fio_client_ipv4 = 1,
118 Fio_client_ipv6,
119 Fio_client_socket,
120};
121
Jens Axboe2f99deb2012-03-09 14:37:29 +0100[diff] [blame]122extern int fio_client_connect(struct fio_client *);
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]123extern int fio_clients_connect(void);
Jens Axboeb9d2f302012-03-08 20:36:28 +0100[diff] [blame]124extern int fio_start_client(struct fio_client *);
125extern int fio_start_all_clients(void);
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]126extern int fio_clients_send_ini(const char *);
Elliott Hugheseda3a602017-05-19 18:53:02 -0700[diff] [blame]127extern int fio_client_send_ini(struct fio_client *, const char *, bool);
Jens Axboea5276612012-03-04 15:15:08 +0100[diff] [blame]128extern int fio_handle_clients(struct client_ops *);
129extern int fio_client_add(struct client_ops *, const char *, void **);
130extern struct fio_client *fio_client_add_explicit(struct client_ops *, const char *, int, int);
Jens Axboe3ec62ec2012-03-01 12:01:29 +0100[diff] [blame]131extern void fio_client_add_cmd_option(void *, const char *);
Elliott Hugheseda3a602017-05-19 18:53:02 -0700[diff] [blame]132extern int fio_client_add_ini_file(void *, const char *, bool);
Jens Axboe0cf3ece2012-03-21 10:15:20 +0100[diff] [blame]133extern int fio_client_terminate(struct fio_client *);
Jens Axboe343cb4a2012-03-09 17:16:51 +0100[diff] [blame]134extern struct fio_client *fio_get_client(struct fio_client *);
135extern void fio_put_client(struct fio_client *);
Jens Axboe40c60512012-03-27 16:03:04 +0200[diff] [blame]136extern int fio_client_update_options(struct fio_client *, struct thread_options *, uint64_t *);
137extern int fio_client_wait_for_reply(struct fio_client *, uint64_t);
Jens Axboede54cfd2014-11-10 20:34:00 -0700[diff] [blame]138extern int fio_clients_send_trigger(const char *);
Jens Axboedf06f222012-03-02 13:32:04 +0100[diff] [blame]139
Jens Axboe6433ee02012-03-09 20:10:51 +0100[diff] [blame]140#define FIO_CLIENT_DEF_ETA_MSEC 900
141
Jens Axboe46bcd492012-03-14 11:31:21 +0100[diff] [blame]142enum {
143 FIO_CLIENT_TYPE_CLI = 1,
144 FIO_CLIENT_TYPE_GUI = 2,
145};
146
Elliott Hugheseda3a602017-05-19 18:53:02 -0700[diff] [blame]147extern int sum_stat_clients;
148extern struct thread_stat client_ts;
149extern struct group_run_stats client_gs;
150
Stephen M. Camerondd366722012-02-24 08:17:30 +0100[diff] [blame]151#endif
152