cmd = malloc(sizeof(*cmd) + size);
- fio_init_net_cmd(cmd);
- cmd->opcode = cpu_to_le16(FIO_NET_CMD_JOB_END);
- cmd->pdu_len = cpu_to_le32(size);
-
- memcpy(&cmd->payload, buf, size);
-
+ fio_init_net_cmd(cmd, FIO_NET_CMD_JOB_END, buf, size);
fio_net_cmd_crc(cmd);
ret = fio_send_data(fio_client_fd, cmd, sizeof(*cmd) + size);
while (!exit_backend) {
cmd = fio_net_cmd_read(fio_client_fd);
+ if (!cmd)
+ continue;
if (cmd->opcode == FIO_NET_CMD_ACK) {
free(cmd);
free(cmd);
continue;
}
- printf("%s", cmd->payload);
+ fwrite(cmd->payload, cmd->pdu_len, 1, stdout);
fflush(stdout);
free(cmd);
}