strcpy((char *) dst->run_str, (char *) je->run_str);
}
-static void remove_reply_cmd(struct fio_client *client, struct fio_net_cmd *cmd)
+static bool remove_reply_cmd(struct fio_client *client, struct fio_net_cmd *cmd)
{
struct fio_net_cmd_reply *reply = NULL;
struct flist_head *entry;
if (!reply) {
log_err("fio: client: unable to find matching tag (%llx)\n", (unsigned long long) cmd->tag);
- return;
+ return false;
}
flist_del(&reply->list);
cmd->tag = reply->saved_tag;
free(reply);
+ return true;
}
int fio_client_wait_for_reply(struct fio_client *client, uint64_t tag)
}
/* allocate buffer big enough for next sprintf() call */
- log_pathname = malloc( 10 +
- strlen((char * )pdu->name) +
+ log_pathname = malloc(10 + strlen((char *)pdu->name) +
strlen(client->hostname));
if (!log_pathname) {
log_err("fio: memory allocation of unique pathname failed");
fd = open((const char *) log_pathname,
O_WRONLY | O_CREAT | O_TRUNC, 0644);
if (fd < 0) {
- log_err("fio: open log %s: %s\n",
+ log_err("fio: open log %s: %s\n",
log_pathname, strerror(errno));
return 1;
}
FILE *f;
f = fopen((const char *) log_pathname, "w");
if (!f) {
- log_err("fio: fopen log %s : %s\n",
+ log_err("fio: fopen log %s : %s\n",
log_pathname, strerror(errno));
return 1;
}
case FIO_NET_CMD_ETA: {
struct jobs_eta *je = (struct jobs_eta *) cmd->payload;
- remove_reply_cmd(client, cmd);
+ if (!remove_reply_cmd(client, cmd))
+ break;
convert_jobs_eta(je);
handle_eta(client, cmd);
break;