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
|
#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 "os/os.h"
#include "diskutil.h"
/*
* 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[0]; /* payload */
};
struct fio_net_int_cmd {
struct fio_net_cmd cmd;
struct flist_head list;
struct timeval tv;
uint64_t saved_tag;
};
enum {
FIO_SERVER_VER = 8,
FIO_SERVER_MAX_PDU = 1024,
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_RUN = 14,
FIO_NET_CMD_NR = 15,
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_CLIENT_TIMEOUT = 5000,
};
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_probe_pdu {
uint8_t hostname[64];
uint8_t bigendian;
uint8_t fio_version[32];
uint8_t os;
uint8_t arch;
uint8_t bpp;
};
struct cmd_single_line_pdu {
uint16_t len;
uint8_t text[0];
};
struct cmd_line_pdu {
uint16_t lines;
struct cmd_single_line_pdu options[0];
};
struct cmd_start_pdu {
uint32_t jobs;
};
struct cmd_end_pdu {
uint32_t error;
};
extern int fio_start_server(char *);
extern int fio_server_text_output(const char *, size_t);
extern int fio_server_log(const char *format, ...);
extern int fio_net_send_cmd(int, uint16_t, const void *, off_t, uint64_t);
extern int fio_net_send_simple_cmd(int, uint16_t, uint64_t, struct flist_head *);
extern void fio_server_set_arg(const char *);
extern int fio_server_parse_string(const char *, char **, int *, int *, struct in_addr *, struct in6_addr *, int *);
extern const char *fio_server_op(unsigned int);
extern void fio_server_got_signal(int);
struct thread_stat;
struct group_run_stats;
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_idle_loop(void);
extern int fio_clients_connect(void);
extern int fio_clients_send_ini(const char *);
extern int fio_handle_clients(void);
extern int fio_client_add(const char *, void **);
extern void fio_client_add_cmd_option(void *, const char *);
extern int fio_recv_data(int sk, void *p, unsigned int len);
extern int fio_send_data(int sk, const void *p, unsigned int len);
extern void fio_net_cmd_crc(struct fio_net_cmd *);
extern struct fio_net_cmd *fio_net_recv_cmd(int sk);
extern int exit_backend;
extern int fio_net_port;
static inline void fio_init_net_cmd(struct fio_net_cmd *cmd, uint16_t opcode,
const void *pdu, uint32_t pdu_len,
uint64_t tag)
{
memset(cmd, 0, sizeof(*cmd));
cmd->version = __cpu_to_le16(FIO_SERVER_VER);
cmd->opcode = cpu_to_le16(opcode);
cmd->tag = cpu_to_le64(tag);
if (pdu) {
cmd->pdu_len = cpu_to_le32(pdu_len);
memcpy(&cmd->payload, pdu, pdu_len);
}
}
#endif
|
