Lines Matching refs:cmdret
225 struct fio_net_cmd cmd, *tmp, *cmdret = NULL; in fio_net_recv_cmd() local
244 assert(!cmdret); in fio_net_recv_cmd()
254 tmp = realloc(cmdret, cmd_size); in fio_net_recv_cmd()
260 cmdret = tmp; in fio_net_recv_cmd()
263 memcpy(cmdret, &cmd, sizeof(cmd)); in fio_net_recv_cmd()
264 else if (cmdret->opcode != cmd.opcode) { in fio_net_recv_cmd()
266 cmdret->opcode, cmd.opcode); in fio_net_recv_cmd()
275 pdu = (void *) cmdret->payload + pdu_offset; in fio_net_recv_cmd()
291 cmdret->pdu_len += cmd.pdu_len; in fio_net_recv_cmd()
296 free(cmdret); in fio_net_recv_cmd()
297 cmdret = NULL; in fio_net_recv_cmd()
298 } else if (cmdret) { in fio_net_recv_cmd()
300 if (cmdret->pdu_len) { in fio_net_recv_cmd()
301 if (cmdret->opcode == FIO_NET_CMD_TEXT) { in fio_net_recv_cmd()
302 struct cmd_text_pdu *__pdu = (struct cmd_text_pdu *) cmdret->payload; in fio_net_recv_cmd()
306 } else if (cmdret->opcode == FIO_NET_CMD_JOB) { in fio_net_recv_cmd()
307 struct cmd_job_pdu *__pdu = (struct cmd_job_pdu *) cmdret->payload; in fio_net_recv_cmd()
316 cmdret->flags &= ~FIO_NET_CMD_F_MORE; in fio_net_recv_cmd()
319 return cmdret; in fio_net_recv_cmd()