1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
|
#ifndef FIO_SERVER_H
#define FIO_SERVER_H
#include <inttypes.h>
#include <string.h>
#include <sys/time.h>
#include <netinet/in.h>
#include "stat.h"
#include "diskutil.h"
#define FIO_NET_PORT 8765
struct sk_out {
unsigned int refs; /* frees sk_out when it drops to zero.
* protected by below ->lock */
#ifdef WIN32
HANDLE hProcess; /* process handle of handle_connection_process*/
#endif
int sk; /* socket fd to talk to client */
struct fio_sem lock; /* protects ref and below list */
struct flist_head list; /* list of pending transmit work */
struct fio_sem wait; /* wake backend when items added to list */
struct fio_sem xmit; /* held while sending data */
};
/*
* On-wire encoding is little endian
*/
struct fio_net_cmd {
uint16_t version; /* protocol version */
uint16_t opcode; /* command opcode */
uint32_t flags; /* modifier flags */
uint64_t tag; /* passed back on reply */
uint32_t pdu_len; /* length of post-cmd layload */
/*
* These must be immediately before the payload, anything before
* these fields are checksummed.
*/
uint16_t cmd_crc16; /* cmd checksum */
uint16_t pdu_crc16; /* payload checksum */
uint8_t payload[]; /* payload */
};
struct fio_net_cmd_reply {
struct flist_head list;
struct timespec ts;
uint64_t saved_tag;
uint16_t opcode;
};
enum {
FIO_SERVER_VER = 104,
FIO_SERVER_MAX_FRAGMENT_PDU = 1024,
FIO_SERVER_MAX_CMD_MB = 2048,
FIO_NET_CMD_QUIT = 1,
FIO_NET_CMD_EXIT = 2,
FIO_NET_CMD_JOB = 3,
FIO_NET_CMD_JOBLINE = 4,
FIO_NET_CMD_TEXT = 5,
FIO_NET_CMD_TS = 6,
FIO_NET_CMD_GS = 7,
FIO_NET_CMD_SEND_ETA = 8,
FIO_NET_CMD_ETA = 9,
FIO_NET_CMD_PROBE = 10,
FIO_NET_CMD_START = 11,
FIO_NET_CMD_STOP = 12,
FIO_NET_CMD_DU = 13,
FIO_NET_CMD_SERVER_START = 14,
FIO_NET_CMD_ADD_JOB = 15,
FIO_NET_CMD_RUN = 16,
FIO_NET_CMD_IOLOG = 17,
FIO_NET_CMD_UPDATE_JOB = 18,
FIO_NET_CMD_LOAD_FILE = 19,
FIO_NET_CMD_VTRIGGER = 20,
FIO_NET_CMD_SENDFILE = 21,
FIO_NET_CMD_JOB_OPT = 22,
FIO_NET_CMD_NR = 23,
FIO_NET_CMD_F_MORE = 1UL << 0,
/* crc does not include the crc fields */
FIO_NET_CMD_CRC_SZ = sizeof(struct fio_net_cmd) -
2 * sizeof(uint16_t),
FIO_NET_NAME_MAX = 256,
FIO_NET_CLIENT_TIMEOUT = 5000,
FIO_PROBE_FLAG_ZLIB = 1UL << 0,
};
struct cmd_sendfile {
uint8_t path[FIO_NET_NAME_MAX];
};
struct cmd_sendfile_reply {
uint32_t size;
uint32_t error;
uint8_t data[0];
};
/*
* Client sends this to server on VTRIGGER, server sends back a full
* all_io_list structure.
*/
struct cmd_vtrigger_pdu {
uint16_t len;
uint8_t cmd[];
};
struct cmd_load_file_pdu {
uint16_t name_len;
uint16_t client_type;
uint8_t file[];
};
struct cmd_ts_pdu {
struct thread_stat ts;
struct group_run_stats rs;
};
struct cmd_du_pdu {
struct disk_util_stat dus;
struct disk_util_agg agg;
};
struct cmd_client_probe_pdu {
uint64_t flags;
uint8_t server[128];
};
struct cmd_probe_reply_pdu {
uint8_t hostname[64];
uint8_t bigendian;
uint8_t fio_version[32];
uint8_t os;
uint8_t arch;
uint8_t bpp;
uint32_t cpus;
uint64_t flags;
};
struct cmd_single_line_pdu {
uint16_t len;
uint8_t text[];
};
struct cmd_line_pdu {
uint16_t lines;
uint16_t client_type;
struct cmd_single_line_pdu options[];
};
struct cmd_job_pdu {
uint32_t buf_len;
uint32_t client_type;
uint8_t buf[0];
};
struct cmd_start_pdu {
uint32_t jobs;
uint32_t stat_outputs;
};
struct cmd_end_pdu {
uint32_t error;
uint32_t signal;
};
struct cmd_add_job_pdu {
uint32_t thread_number;
uint32_t groupid;
struct thread_options_pack top;
};
struct cmd_text_pdu {
uint32_t level;
uint32_t buf_len;
uint64_t log_sec;
uint64_t log_usec;
uint8_t buf[0];
};
enum {
XMIT_COMPRESSED = 1U,
STORE_COMPRESSED = 2U,
};
struct cmd_iolog_pdu {
uint64_t nr_samples;
uint32_t thread_number;
uint32_t log_type;
uint32_t compressed;
uint32_t log_offset;
uint32_t log_prio;
uint32_t log_hist_coarseness;
uint32_t per_job_logs;
uint8_t name[FIO_NET_NAME_MAX];
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 *);
extern int fio_net_send_simple_cmd(int, uint16_t, uint64_t, struct flist_head *);
extern void fio_server_set_arg(const char *);
extern void fio_server_internal_set(const char *);
extern int fio_server_parse_string(const char *, char **, bool *, int *, struct in_addr *, struct in6_addr *, int *);
extern int fio_server_parse_host(const char *, int, struct in_addr *, struct in6_addr *);
extern const char *fio_server_op(unsigned int);
extern void fio_server_got_signal(int);
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 void fio_server_send_job_options(struct flist_head *, unsigned int);
extern int fio_server_get_verify_state(const char *, int, void **);
extern bool fio_server_poll_fd(int fd, short events, int timeout);
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 bool exit_backend;
extern int fio_net_port;
#endif
|
