projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
zbd: rename zbd_zone_idx() and zbd_zone_nr()
[fio.git]
/
server.c
diff --git
a/server.c
b/server.c
index 248a2d44899c5c6191f83248209057e1980f01e2..90c52e01ac231f4972bbd94e91361d3fe61ad132 100644
(file)
--- a/
server.c
+++ b/
server.c
@@
-409,8
+409,9
@@
struct fio_net_cmd *fio_net_recv_cmd(int sk, bool wait)
if (cmdret->opcode == FIO_NET_CMD_TEXT) {
struct cmd_text_pdu *__pdu = (struct cmd_text_pdu *) cmdret->payload;
char *buf = (char *) __pdu->buf;
if (cmdret->opcode == FIO_NET_CMD_TEXT) {
struct cmd_text_pdu *__pdu = (struct cmd_text_pdu *) cmdret->payload;
char *buf = (char *) __pdu->buf;
+ int len = le32_to_cpu(__pdu->buf_len);
- buf[
__pdu->buf_
len] = '\0';
+ buf[len] = '\0';
} else if (cmdret->opcode == FIO_NET_CMD_JOB) {
struct cmd_job_pdu *__pdu = (struct cmd_job_pdu *) cmdret->payload;
char *buf = (char *) __pdu->buf;
} else if (cmdret->opcode == FIO_NET_CMD_JOB) {
struct cmd_job_pdu *__pdu = (struct cmd_job_pdu *) cmdret->payload;
char *buf = (char *) __pdu->buf;
@@
-950,7
+951,7
@@
static int handle_update_job_cmd(struct fio_net_cmd *cmd)
return 0;
}
return 0;
}
- td =
&threads[tnumber - 1]
;
+ td =
tnumber_to_td(tnumber)
;
convert_thread_options_to_cpu(&td->o, &pdu->top);
send_update_job_reply(cmd->tag, 0);
return 0;
convert_thread_options_to_cpu(&td->o, &pdu->top);
send_update_job_reply(cmd->tag, 0);
return 0;
@@
-1909,7
+1910,7
@@
static int fio_append_iolog_gz(struct sk_entry *first, struct io_log *log)
break;
}
flist_add_tail(&entry->list, &first->next);
break;
}
flist_add_tail(&entry->list, &first->next);
- }
while (ret != Z_STREAM_END);
+ }
ret = deflateEnd(&stream);
if (ret == Z_OK)
ret = deflateEnd(&stream);
if (ret == Z_OK)
@@
-2456,6
+2457,11
@@
static void set_sig_handlers(void)
};
sigaction(SIGINT, &act, NULL);
};
sigaction(SIGINT, &act, NULL);
+
+ /* Windows uses SIGBREAK as a quit signal from other applications */
+#ifdef WIN32
+ sigaction(SIGBREAK, &act, NULL);
+#endif
}
void fio_server_destroy_sk_key(void)
}
void fio_server_destroy_sk_key(void)
@@
-2564,6
+2570,7
@@
static int write_pid(pid_t pid, const char *pidfile)
*/
int fio_start_server(char *pidfile)
{
*/
int fio_start_server(char *pidfile)
{
+ FILE *file;
pid_t pid;
int ret;
pid_t pid;
int ret;
@@
-2596,14
+2603,28
@@
int fio_start_server(char *pidfile)
setsid();
openlog("fio", LOG_NDELAY|LOG_NOWAIT|LOG_PID, LOG_USER);
log_syslog = true;
setsid();
openlog("fio", LOG_NDELAY|LOG_NOWAIT|LOG_PID, LOG_USER);
log_syslog = true;
- close(STDIN_FILENO);
- close(STDOUT_FILENO);
- close(STDERR_FILENO);
+
+ file = freopen("/dev/null", "r", stdin);
+ if (!file)
+ perror("freopen");
+
+ file = freopen("/dev/null", "w", stdout);
+ if (!file)
+ perror("freopen");
+
+ file = freopen("/dev/null", "w", stderr);
+ if (!file)
+ perror("freopen");
+
f_out = NULL;
f_err = NULL;
ret = fio_server();
f_out = NULL;
f_err = NULL;
ret = fio_server();
+ fclose(stdin);
+ fclose(stdout);
+ fclose(stderr);
+
closelog();
unlink(pidfile);
free(pidfile);
closelog();
unlink(pidfile);
free(pidfile);