if (connect(fd, (struct sockaddr *) &client->addr, sizeof(client->addr)) < 0) {
log_err("fio: connect: %s\n", strerror(errno));
+ log_err("fio: failed to connect to %s\n", client->hostname);
return 1;
}
for (i = 0; i < 3; i++) {
dst->total_io_u[i] = le64_to_cpu(src->total_io_u[i]);
- dst->short_io_u[i] = le64_to_cpu(src->total_io_u[i]);
+ dst->short_io_u[i] = le64_to_cpu(src->short_io_u[i]);
}
dst->total_submit = le64_to_cpu(src->total_submit);
display_thread_status(je);
}
+static void handle_probe(struct fio_net_cmd *cmd)
+{
+ struct cmd_probe_pdu *probe = (struct cmd_probe_pdu *) cmd->payload;
+
+ log_info("Probe: %s: %u.%u.%u\n", probe->hostname, probe->fio_major,
+ probe->fio_minor, probe->fio_patch);
+}
+
static int handle_client(struct fio_client *client)
{
struct fio_net_cmd *cmd;
int done = 0;
- while ((cmd = fio_net_recv_cmd(client->fd)) != NULL) {
+ while ((cmd = fio_net_recv_cmd(client->fd, 1)) != NULL) {
dprint(FD_NET, "%s: got cmd op %d\n", client->hostname,
cmd->opcode);
switch (cmd->opcode) {
- case FIO_NET_CMD_ACK:
- free(cmd);
- break;
case FIO_NET_CMD_QUIT:
remove_client(client);
free(cmd);
handle_eta(cmd);
free(cmd);
break;
+ case FIO_NET_CMD_PROBE:
+ handle_probe(cmd);
+ free(cmd);
+ break;
default:
log_err("fio: unknown client op: %d\n", cmd->opcode);
free(cmd);