[fio.git] / server.c

#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <unistd.h>
#include <limits.h>
#include <errno.h>
#include <fcntl.h>
#include <sys/poll.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <syslog.h>
#include <signal.h>

#include "fio.h"
#include "server.h"
#include "crc/crc16.h"
#include "ieee754.h"

int fio_net_port = 8765;

int exit_backend = 0;

static int server_fd = -1;

int fio_send_data(int sk, const void *p, unsigned int len)
{
	assert(len <= sizeof(struct fio_net_cmd) + FIO_SERVER_MAX_PDU);

	do {
		int ret = send(sk, p, len, 0);

		if (ret > 0) {
			len -= ret;
			if (!len)
				break;
			p += ret;
			continue;
		} else if (!ret)
			break;
		else if (errno == EAGAIN || errno == EINTR)
			continue;
	} while (!exit_backend);

	if (!len)
		return 0;

	return 1;
}

int fio_recv_data(int sk, void *p, unsigned int len)
{
	do {
		int ret = recv(sk, p, len, MSG_WAITALL);

		if (ret > 0) {
			len -= ret;
			if (!len)
				break;
			p += ret;
			continue;
		} else if (!ret)
			break;
		else if (errno == EAGAIN || errno == EINTR)
			continue;
	} while (!exit_backend);

	if (!len)
		return 0;

	return -1;
}

static int verify_convert_cmd(struct fio_net_cmd *cmd)
{
	uint16_t crc;

	cmd->cmd_crc16 = le16_to_cpu(cmd->cmd_crc16);
	cmd->pdu_crc16 = le16_to_cpu(cmd->pdu_crc16);

	crc = crc16(cmd, FIO_NET_CMD_CRC_SZ);
	if (crc != cmd->cmd_crc16) {
		log_err("fio: server bad crc on command (got %x, wanted %x)\n",
				cmd->cmd_crc16, crc);
		return 1;
	}

	cmd->version	= le16_to_cpu(cmd->version);
	cmd->opcode	= le16_to_cpu(cmd->opcode);
	cmd->flags	= le32_to_cpu(cmd->flags);
	cmd->serial	= le64_to_cpu(cmd->serial);
	cmd->pdu_len	= le32_to_cpu(cmd->pdu_len);

	switch (cmd->version) {
	case FIO_SERVER_VER1:
		break;
	default:
		log_err("fio: bad server cmd version %d\n", cmd->version);
		return 1;
	}

	if (cmd->pdu_len > FIO_SERVER_MAX_PDU) {
		log_err("fio: command payload too large: %u\n", cmd->pdu_len);
		return 1;
	}

	return 0;
}

/*
 * Read (and defragment, if necessary) incoming commands
 */
struct fio_net_cmd *fio_net_recv_cmd(int sk)
{
	struct fio_net_cmd cmd, *cmdret = NULL;
	size_t cmd_size = 0, pdu_offset = 0;
	uint16_t crc;
	int ret, first = 1;
	void *pdu = NULL;

	do {
		ret = fio_recv_data(sk, &cmd, sizeof(cmd));
		if (ret)
			break;

		/* We have a command, verify it and swap if need be */
		ret = verify_convert_cmd(&cmd);
		if (ret)
			break;

		if (first) {
			/* if this is text, add room for \0 at the end */
			cmd_size = sizeof(cmd) + cmd.pdu_len + 1;
			assert(!cmdret);
		} else
			cmd_size += cmd.pdu_len;

		cmdret = realloc(cmdret, cmd_size);

		if (first)
			memcpy(cmdret, &cmd, sizeof(cmd));
		else
			assert(cmdret->opcode == cmd.opcode);

		if (!cmd.pdu_len)
			break;

		/* There's payload, get it */
		pdu = (void *) cmdret->payload + pdu_offset;
		ret = fio_recv_data(sk, pdu, cmd.pdu_len);
		if (ret)
			break;

		/* Verify payload crc */
		crc = crc16(pdu, cmd.pdu_len);
		if (crc != cmd.pdu_crc16) {
			log_err("fio: server bad crc on payload ");
			log_err("(got %x, wanted %x)\n", cmd.pdu_crc16, crc);
			ret = 1;
			break;
		}

		pdu_offset += cmd.pdu_len;
		if (!first)
			cmdret->pdu_len += cmd.pdu_len;
		first = 0;
	} while (cmd.flags & FIO_NET_CMD_F_MORE);

	if (ret) {
		free(cmdret);
		cmdret = NULL;
	} else if (cmdret) {
		/* zero-terminate text input */
		if (cmdret->pdu_len && (cmdret->opcode == FIO_NET_CMD_TEXT ||
		    cmdret->opcode == FIO_NET_CMD_JOB)) {
			char *buf = (char *) cmdret->payload;

			buf[cmdret->pdu_len ] = '\0';
		}
		/* frag flag is internal */
		cmdret->flags &= ~FIO_NET_CMD_F_MORE;
	}

	return cmdret;
}

void fio_net_cmd_crc(struct fio_net_cmd *cmd)
{
	uint32_t pdu_len;

	cmd->cmd_crc16 = __cpu_to_le16(crc16(cmd, FIO_NET_CMD_CRC_SZ));

	pdu_len = le32_to_cpu(cmd->pdu_len);
	if (pdu_len)
		cmd->pdu_crc16 = __cpu_to_le16(crc16(cmd->payload, pdu_len));
}

int fio_net_send_cmd(int fd, uint16_t opcode, const void *buf, off_t size)
{
	struct fio_net_cmd *cmd;
	size_t this_len;
	int ret;

	do {
		this_len = size;
		if (this_len > FIO_SERVER_MAX_PDU)
			this_len = FIO_SERVER_MAX_PDU;

		cmd = malloc(sizeof(*cmd) + this_len);

		fio_init_net_cmd(cmd, opcode, buf, this_len);

		if (this_len < size)
			cmd->flags = __cpu_to_le32(FIO_NET_CMD_F_MORE);

		fio_net_cmd_crc(cmd);

		ret = fio_send_data(fd, cmd, sizeof(*cmd) + this_len);
		free(cmd);
		size -= this_len;
		buf += this_len;
	} while (!ret && size);

	return ret;
}

int fio_net_send_simple_cmd(int sk, uint16_t opcode, uint64_t serial)
{
	struct fio_net_cmd cmd = {
		.version	= __cpu_to_le16(FIO_SERVER_VER1),
		.opcode		= cpu_to_le16(opcode),
		.serial		= cpu_to_le64(serial),
	};

	fio_net_cmd_crc(&cmd);

	return fio_send_data(sk, &cmd, sizeof(cmd));
}

static int fio_server_send_quit_cmd(void)
{
	dprint(FD_NET, "server: sending quit\n");
	return fio_net_send_simple_cmd(server_fd, FIO_NET_CMD_QUIT, 0);
}

static int handle_job_cmd(struct fio_net_cmd *cmd)
{
	char *buf = (char *) cmd->payload;
	int ret;

	if (parse_jobs_ini(buf, 1, 0)) {
		fio_server_send_quit_cmd();
		return -1;
	}

	fio_net_send_simple_cmd(server_fd, FIO_NET_CMD_START, 0);

	ret = exec_run();
	fio_server_send_quit_cmd();
	reset_fio_state();
	return ret;
}

static int handle_jobline_cmd(struct fio_net_cmd *cmd)
{
	struct cmd_line_pdu *pdu = (struct cmd_line_pdu *) cmd->payload;
	char *argv[FIO_NET_CMD_JOBLINE_ARGV];
	int ret, i;

	pdu->argc = le16_to_cpu(pdu->argc);

	dprint(FD_NET, "server: %d command line args\n", pdu->argc);

	for (i = 0; i < pdu->argc; i++) {
		argv[i] = (char *) pdu->argv[i];
		dprint(FD_NET, "server: %d: %s\n", i, argv[i]);
	}

	if (parse_cmd_line(pdu->argc, argv)) {
		fio_server_send_quit_cmd();
		return -1;
	}

	fio_net_send_simple_cmd(server_fd, FIO_NET_CMD_START, 0);

	ret = exec_run();
	fio_server_send_quit_cmd();
	reset_fio_state();
	return ret;
}

static int handle_probe_cmd(struct fio_net_cmd *cmd)
{
	struct cmd_probe_pdu probe;

	memset(&probe, 0, sizeof(probe));
	gethostname((char *) probe.hostname, sizeof(probe.hostname));
#ifdef FIO_BIG_ENDIAN
	probe.bigendian = 1;
#endif
	probe.fio_major = FIO_MAJOR;
	probe.fio_minor = FIO_MINOR;
	probe.fio_patch = FIO_PATCH;

	return fio_net_send_cmd(server_fd, FIO_NET_CMD_PROBE, &probe, sizeof(probe));
}

static int handle_command(struct fio_net_cmd *cmd)
{
	int ret;

	dprint(FD_NET, "server: got opcode %d\n", cmd->opcode);

	switch (cmd->opcode) {
	case FIO_NET_CMD_QUIT:
		fio_terminate_threads(TERMINATE_ALL);
		return -1;
	case FIO_NET_CMD_EXIT:
		exit_backend = 1;
		return -1;
	case FIO_NET_CMD_JOB:
		ret = handle_job_cmd(cmd);
		break;
	case FIO_NET_CMD_JOBLINE:
		ret = handle_jobline_cmd(cmd);
		break;
	case FIO_NET_CMD_PROBE:
		ret = handle_probe_cmd(cmd);
		break;
	default:
		log_err("fio: unknown opcode: %d\n", cmd->opcode);
		ret = 1;
	}

	return ret;
}

static int handle_connection(int sk, int block)
{
	struct fio_net_cmd *cmd = NULL;
	int ret = 0;

	/* read forever */
	while (!exit_backend) {
		struct pollfd pfd = {
			.fd	= sk,
			.events	= POLLIN,
		};

		ret = 0;
		do {
			ret = poll(&pfd, 1, 100);
			if (ret < 0) {
				if (errno == EINTR)
					break;
				log_err("fio: poll: %s\n", strerror(errno));
				break;
			} else if (!ret) {
				if (!block)
					return 0;
				continue;
			}

			if (pfd.revents & POLLIN)
				break;
			if (pfd.revents & (POLLERR|POLLHUP)) {
				ret = 1;
				break;
			}
		} while (!exit_backend);

		if (ret < 0)
			break;

		cmd = fio_net_recv_cmd(sk);
		if (!cmd) {
			ret = -1;
			break;
		}

		ret = handle_command(cmd);
		if (ret)
			break;

		free(cmd);
		cmd = NULL;
	}

	if (cmd)
		free(cmd);

	return ret;
}

void fio_server_idle_loop(void)
{
	if (server_fd != -1)
		handle_connection(server_fd, 0);
}

static int accept_loop(int listen_sk)
{
	struct sockaddr_in addr;
	fio_socklen_t len = sizeof(addr);
	struct pollfd pfd;
	int ret, sk, flags, exitval = 0;

	dprint(FD_NET, "server enter accept loop\n");

	flags = fcntl(listen_sk, F_GETFL);
	flags |= O_NONBLOCK;
	fcntl(listen_sk, F_SETFL, flags);
again:
	pfd.fd = listen_sk;
	pfd.events = POLLIN;
	do {
		ret = poll(&pfd, 1, 100);
		if (ret < 0) {
			if (errno == EINTR)
				break;
			log_err("fio: poll: %s\n", strerror(errno));
			goto out;
		} else if (!ret)
			continue;

		if (pfd.revents & POLLIN)
			break;
	} while (!exit_backend);

	if (exit_backend)
		goto out;

	sk = accept(listen_sk, (struct sockaddr *) &addr, &len);
	if (sk < 0) {
		log_err("fio: accept: %s\n", strerror(errno));
		return -1;
	}

	dprint(FD_NET, "server: connect from %s\n", inet_ntoa(addr.sin_addr));

	server_fd = sk;

	exitval = handle_connection(sk, 1);

	server_fd = -1;
	close(sk);

	if (!exit_backend)
		goto again;

out:
	return exitval;
}

int fio_server_text_output(const char *buf, unsigned int len)
{
	if (server_fd != -1)
		return fio_net_send_cmd(server_fd, FIO_NET_CMD_TEXT, buf, len);

	return fwrite(buf, len, 1, f_err);
}

static void convert_io_stat(struct io_stat *dst, struct io_stat *src)
{
	dst->max_val	= cpu_to_le64(src->max_val);
	dst->min_val	= cpu_to_le64(src->min_val);
	dst->samples	= cpu_to_le64(src->samples);

	/*
	 * Encode to IEEE 754 for network transfer
	 */
	dst->mean.u.i	= __cpu_to_le64(fio_double_to_uint64(src->mean.u.f));
	dst->S.u.i	= __cpu_to_le64(fio_double_to_uint64(src->S.u.f));
}

static void convert_gs(struct group_run_stats *dst, struct group_run_stats *src)
{
	int i;

	for (i = 0; i < 2; i++) {
		dst->max_run[i]		= cpu_to_le64(src->max_run[i]);
		dst->min_run[i]		= cpu_to_le64(src->min_run[i]);
		dst->max_bw[i]		= cpu_to_le64(src->max_bw[i]);
		dst->min_bw[i]		= cpu_to_le64(src->min_bw[i]);
		dst->io_kb[i]		= cpu_to_le64(src->io_kb[i]);
		dst->agg[i]		= cpu_to_le64(src->agg[i]);
	}

	dst->kb_base	= cpu_to_le32(src->kb_base);
	dst->groupid	= cpu_to_le32(src->groupid);
}

/*
 * Send a CMD_TS, which packs struct thread_stat and group_run_stats
 * into a single payload.
 */
void fio_server_send_ts(struct thread_stat *ts, struct group_run_stats *rs)
{
	struct cmd_ts_pdu p;
	int i, j;

	dprint(FD_NET, "server sending end stats\n");

	memset(&p, 0, sizeof(p));

	strcpy(p.ts.name, ts->name);
	strcpy(p.ts.verror, ts->verror);
	strcpy(p.ts.description, ts->description);

	p.ts.error	= cpu_to_le32(ts->error);
	p.ts.groupid	= cpu_to_le32(ts->groupid);
	p.ts.pid	= cpu_to_le32(ts->pid);
	p.ts.members	= cpu_to_le32(ts->members);

	for (i = 0; i < 2; i++) {
		convert_io_stat(&p.ts.clat_stat[i], &ts->clat_stat[i]);
		convert_io_stat(&p.ts.slat_stat[i], &ts->slat_stat[i]);
		convert_io_stat(&p.ts.lat_stat[i], &ts->lat_stat[i]);
		convert_io_stat(&p.ts.bw_stat[i], &ts->bw_stat[i]);
	}

	p.ts.usr_time		= cpu_to_le64(ts->usr_time);
	p.ts.sys_time		= cpu_to_le64(ts->sys_time);
	p.ts.ctx		= cpu_to_le64(ts->ctx);
	p.ts.minf		= cpu_to_le64(ts->minf);
	p.ts.majf		= cpu_to_le64(ts->majf);
	p.ts.clat_percentiles	= cpu_to_le64(ts->clat_percentiles);

	for (i = 0; i < FIO_IO_U_LIST_MAX_LEN; i++) {
		fio_fp64_t *fp = &p.ts.percentile_list[i];

		fp->u.i = __cpu_to_le64(fio_double_to_uint64(fp->u.f));
	}

	for (i = 0; i < FIO_IO_U_MAP_NR; i++) {
		p.ts.io_u_map[i]	= cpu_to_le32(ts->io_u_map[i]);
		p.ts.io_u_submit[i]	= cpu_to_le32(ts->io_u_submit[i]);
		p.ts.io_u_complete[i]	= cpu_to_le32(ts->io_u_complete[i]);
	}

	for (i = 0; i < FIO_IO_U_LAT_U_NR; i++) {
		p.ts.io_u_lat_u[i]	= cpu_to_le32(ts->io_u_lat_u[i]);
		p.ts.io_u_lat_m[i]	= cpu_to_le32(ts->io_u_lat_m[i]);
	}

	for (i = 0; i < 2; i++)
		for (j = 0; j < FIO_IO_U_PLAT_NR; j++)
			p.ts.io_u_plat[i][j] = cpu_to_le32(ts->io_u_plat[i][j]);

	for (i = 0; i < 3; i++) {
		p.ts.total_io_u[i]	= cpu_to_le64(ts->total_io_u[i]);
		p.ts.short_io_u[i]	= cpu_to_le64(ts->short_io_u[i]);
	}

	p.ts.total_submit	= cpu_to_le64(ts->total_submit);
	p.ts.total_complete	= cpu_to_le64(ts->total_complete);

	for (i = 0; i < 2; i++) {
		p.ts.io_bytes[i]	= cpu_to_le64(ts->io_bytes[i]);
		p.ts.runtime[i]		= cpu_to_le64(ts->runtime[i]);
	}

	p.ts.total_run_time	= cpu_to_le64(ts->total_run_time);
	p.ts.continue_on_error	= cpu_to_le16(ts->continue_on_error);
	p.ts.total_err_count	= cpu_to_le64(ts->total_err_count);
	p.ts.first_error	= cpu_to_le32(ts->first_error);
	p.ts.kb_base		= cpu_to_le32(ts->kb_base);

	convert_gs(&p.rs, rs);

	fio_net_send_cmd(server_fd, FIO_NET_CMD_TS, &p, sizeof(p));
}

void fio_server_send_gs(struct group_run_stats *rs)
{
	struct group_run_stats gs;

	dprint(FD_NET, "server sending group run stats\n");

	convert_gs(&gs, rs);
	fio_net_send_cmd(server_fd, FIO_NET_CMD_GS, &gs, sizeof(gs));
}

void fio_server_send_status(void)
{
	struct jobs_eta *je;
	size_t size;
	void *buf;
	int i;

	size = sizeof(*je) + thread_number * sizeof(char);
	buf = malloc(size);
	memset(buf, 0, size);
	je = buf;

	if (!calc_thread_status(je)) {
		free(je);
		return;
	}

	dprint(FD_NET, "server sending status\n");

	je->nr_running		= cpu_to_le32(je->nr_running);
	je->nr_ramp		= cpu_to_le32(je->nr_ramp);
	je->nr_pending		= cpu_to_le32(je->nr_pending);
	je->files_open		= cpu_to_le32(je->files_open);
	je->m_rate		= cpu_to_le32(je->m_rate);
	je->t_rate		= cpu_to_le32(je->t_rate);
	je->m_iops		= cpu_to_le32(je->m_iops);
	je->t_iops		= cpu_to_le32(je->t_iops);

	for (i = 0; i < 2; i++) {
		je->rate[i]	= cpu_to_le32(je->rate[i]);
		je->iops[i]	= cpu_to_le32(je->iops[i]);
	}

	je->elapsed_sec		= cpu_to_le32(je->nr_running);
	je->eta_sec		= cpu_to_le64(je->eta_sec);

	fio_net_send_cmd(server_fd, FIO_NET_CMD_ETA, buf, size);
	free(je);
}

int fio_server_log(const char *format, ...)
{
	char buffer[1024];
	va_list args;
	size_t len;

	dprint(FD_NET, "server log\n");

	va_start(args, format);
	len = vsnprintf(buffer, sizeof(buffer), format, args);
	va_end(args);

	return fio_server_text_output(buffer, len);
}

static int fio_server(void)
{
	struct sockaddr_in saddr_in;
	struct sockaddr addr;
	fio_socklen_t len;
	int sk, opt, ret;

	dprint(FD_NET, "starting server\n");

	sk = socket(AF_INET, SOCK_STREAM, 0);
	if (sk < 0) {
		log_err("fio: socket: %s\n", strerror(errno));
		return -1;
	}

	opt = 1;
	if (setsockopt(sk, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) < 0) {
		log_err("fio: setsockopt: %s\n", strerror(errno));
		return -1;
	}
#ifdef SO_REUSEPORT
	if (setsockopt(sk, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt)) < 0) {
		log_err("fio: setsockopt: %s\n", strerror(errno));
		return -1;
	}
#endif

	saddr_in.sin_family = AF_INET;
	saddr_in.sin_addr.s_addr = htonl(INADDR_ANY);
	saddr_in.sin_port = htons(fio_net_port);

	if (bind(sk, (struct sockaddr *) &saddr_in, sizeof(saddr_in)) < 0) {
		log_err("fio: bind: %s\n", strerror(errno));
		return -1;
	}

	if (listen(sk, 1) < 0) {
		log_err("fio: listen: %s\n", strerror(errno));
		return -1;
	}

	len = sizeof(addr);
	if (getsockname(sk, &addr, &len) < 0) {
		log_err("fio: getsockname: %s\n", strerror(errno));
		return -1;
	}

	ret = accept_loop(sk);
	close(sk);
	return ret;
}

static void sig_int(int sig)
{
	fio_terminate_threads(TERMINATE_ALL);
	exit_backend = 1;
}

static void server_signal_handler(void)
{
	struct sigaction act;

	memset(&act, 0, sizeof(act));
	act.sa_handler = sig_int;
	act.sa_flags = SA_RESTART;
	sigaction(SIGINT, &act, NULL);

	memset(&act, 0, sizeof(act));
	act.sa_handler = sig_int;
	act.sa_flags = SA_RESTART;
	sigaction(SIGTERM, &act, NULL);
}

int fio_start_server(int daemonize)
{
	pid_t pid;

	server_signal_handler();

	if (!daemonize)
		return fio_server();

	openlog("fio", LOG_NDELAY|LOG_NOWAIT|LOG_PID, LOG_USER);
	pid = fork();
	if (pid < 0) {
		syslog(LOG_ERR, "failed server fork");
		return -1;
	} else if (pid)
		exit(0);

	setsid();
	close(STDIN_FILENO);
	close(STDOUT_FILENO);
	close(STDERR_FILENO);
	f_out = NULL;
	f_err = NULL;
	log_syslog = 1;
	return fio_server();
}
Commit	Line	Data
50d16976 JA	1	#include <stdio.h>
50d16976 JA	2	#include <stdlib.h>
142575e6	3	#include <stdarg.h>
50d16976 JA	4	#include <unistd.h>
50d16976 JA	5	#include <limits.h>
50d16976 JA	6	#include <errno.h>
	7	#include <fcntl.h>
	8	#include <sys/poll.h>
50d16976 JA	9	#include <sys/types.h>
50d16976 JA	10	#include <sys/wait.h>
d05c4a03	11	#include <sys/socket.h>
50d16976 JA	12	#include <netinet/in.h>
	13	#include <arpa/inet.h>
	14	#include <netdb.h>
e46d8091	15	#include <syslog.h>
9e22ecb0	16	#include <signal.h>
50d16976 JA	17
50d16976 JA	18	#include "fio.h"
132159a5	19	#include "server.h"
fcee5ff6	20	#include "crc/crc16.h"
802ad4a8	21	#include "ieee754.h"
50d16976	22
132159a5	23	int fio_net_port = 8765;
50d16976	24
009b1be4 JA	25	int exit_backend = 0;
009b1be4 JA	26
46c48f1f	27	static int server_fd = -1;
37db14fe	28
132159a5 JA	29	int fio_send_data(int sk, const void *p, unsigned int len)
132159a5 JA	30	{
794d69ca JA	31	assert(len <= sizeof(struct fio_net_cmd) + FIO_SERVER_MAX_PDU);
794d69ca JA	32
132159a5 JA	33	do {
	34	int ret = send(sk, p, len, 0);
	35
	36	if (ret > 0) {
	37	len -= ret;
	38	if (!len)
	39	break;
	40	p += ret;
	41	continue;
	42	} else if (!ret)
	43	break;
	44	else if (errno == EAGAIN \|\| errno == EINTR)
	45	continue;
	46	} while (!exit_backend);
	47
	48	if (!len)
	49	return 0;
	50
	51	return 1;
	52	}
	53
	54	int fio_recv_data(int sk, void *p, unsigned int len)
	55	{
	56	do {
	57	int ret = recv(sk, p, len, MSG_WAITALL);
	58
	59	if (ret > 0) {
	60	len -= ret;
	61	if (!len)
	62	break;
	63	p += ret;
	64	continue;
	65	} else if (!ret)
	66	break;
	67	else if (errno == EAGAIN \|\| errno == EINTR)
	68	continue;
	69	} while (!exit_backend);
	70
	71	if (!len)
	72	return 0;
	73
	74	return -1;
	75	}
	76
	77	static int verify_convert_cmd(struct fio_net_cmd *cmd)
	78	{
fcee5ff6	79	uint16_t crc;
132159a5	80
fcee5ff6 JA	81	cmd->cmd_crc16 = le16_to_cpu(cmd->cmd_crc16);
fcee5ff6 JA	82	cmd->pdu_crc16 = le16_to_cpu(cmd->pdu_crc16);
132159a5	83
fcee5ff6 JA	84	crc = crc16(cmd, FIO_NET_CMD_CRC_SZ);
fcee5ff6 JA	85	if (crc != cmd->cmd_crc16) {
132159a5	86	log_err("fio: server bad crc on command (got %x, wanted %x)\n",
fcee5ff6	87	cmd->cmd_crc16, crc);
132159a5 JA	88	return 1;
	89	}
	90
	91	cmd->version = le16_to_cpu(cmd->version);
	92	cmd->opcode = le16_to_cpu(cmd->opcode);
	93	cmd->flags = le32_to_cpu(cmd->flags);
	94	cmd->serial = le64_to_cpu(cmd->serial);
	95	cmd->pdu_len = le32_to_cpu(cmd->pdu_len);
	96
	97	switch (cmd->version) {
	98	case FIO_SERVER_VER1:
	99	break;
	100	default:
	101	log_err("fio: bad server cmd version %d\n", cmd->version);
	102	return 1;
	103	}
	104
	105	if (cmd->pdu_len > FIO_SERVER_MAX_PDU) {
	106	log_err("fio: command payload too large: %u\n", cmd->pdu_len);
	107	return 1;
	108	}
	109
	110	return 0;
	111	}
	112
a64e88da JA	113	/*
	114	* Read (and defragment, if necessary) incoming commands
	115	*/
e951bdc4	116	struct fio_net_cmd *fio_net_recv_cmd(int sk)
132159a5	117	{
a64e88da JA	118	struct fio_net_cmd cmd, *cmdret = NULL;
a64e88da JA	119	size_t cmd_size = 0, pdu_offset = 0;
fcee5ff6	120	uint16_t crc;
a64e88da JA	121	int ret, first = 1;
a64e88da JA	122	void *pdu = NULL;
132159a5	123
a64e88da JA	124	do {
	125	ret = fio_recv_data(sk, &cmd, sizeof(cmd));
	126	if (ret)
	127	break;
132159a5	128
a64e88da JA	129	/* We have a command, verify it and swap if need be */
	130	ret = verify_convert_cmd(&cmd);
	131	if (ret)
	132	break;
132159a5	133
0b8f30a5 JA	134	if (first) {
	135	/* if this is text, add room for \0 at the end */
	136	cmd_size = sizeof(cmd) + cmd.pdu_len + 1;
	137	assert(!cmdret);
	138	} else
a64e88da	139	cmd_size += cmd.pdu_len;
132159a5	140
a64e88da	141	cmdret = realloc(cmdret, cmd_size);
132159a5	142
a64e88da JA	143	if (first)
	144	memcpy(cmdret, &cmd, sizeof(cmd));
	145	else
	146	assert(cmdret->opcode == cmd.opcode);
	147
	148	if (!cmd.pdu_len)
	149	break;
	150
	151	/* There's payload, get it */
	152	pdu = (void *) cmdret->payload + pdu_offset;
	153	ret = fio_recv_data(sk, pdu, cmd.pdu_len);
	154	if (ret)
	155	break;
	156
	157	/* Verify payload crc */
	158	crc = crc16(pdu, cmd.pdu_len);
	159	if (crc != cmd.pdu_crc16) {
	160	log_err("fio: server bad crc on payload ");
	161	log_err("(got %x, wanted %x)\n", cmd.pdu_crc16, crc);
	162	ret = 1;
	163	break;
	164	}
	165
	166	pdu_offset += cmd.pdu_len;
817f06bb JA	167	if (!first)
817f06bb JA	168	cmdret->pdu_len += cmd.pdu_len;
a64e88da JA	169	first = 0;
a64e88da JA	170	} while (cmd.flags & FIO_NET_CMD_F_MORE);
132159a5	171
a64e88da JA	172	if (ret) {
	173	free(cmdret);
	174	cmdret = NULL;
0b8f30a5 JA	175	} else if (cmdret) {
	176	/* zero-terminate text input */
	177	if (cmdret->pdu_len && (cmdret->opcode == FIO_NET_CMD_TEXT \|\|
	178	cmdret->opcode == FIO_NET_CMD_JOB)) {
	179	char buf = (char ) cmdret->payload;
	180
	181	buf[cmdret->pdu_len ] = '\0';
	182	}
	183	/* frag flag is internal */
a64e88da	184	cmdret->flags &= ~FIO_NET_CMD_F_MORE;
0b8f30a5	185	}
a64e88da JA	186
a64e88da JA	187	return cmdret;
132159a5 JA	188	}
	189
	190	void fio_net_cmd_crc(struct fio_net_cmd *cmd)
	191	{
	192	uint32_t pdu_len;
	193
ddcc0b69	194	cmd->cmd_crc16 = __cpu_to_le16(crc16(cmd, FIO_NET_CMD_CRC_SZ));
132159a5 JA	195
	196	pdu_len = le32_to_cpu(cmd->pdu_len);
	197	if (pdu_len)
ddcc0b69	198	cmd->pdu_crc16 = __cpu_to_le16(crc16(cmd->payload, pdu_len));
132159a5 JA	199	}
132159a5 JA	200
a64e88da	201	int fio_net_send_cmd(int fd, uint16_t opcode, const void *buf, off_t size)
794d69ca JA	202	{
	203	struct fio_net_cmd *cmd;
	204	size_t this_len;
	205	int ret;
	206
	207	do {
	208	this_len = size;
	209	if (this_len > FIO_SERVER_MAX_PDU)
	210	this_len = FIO_SERVER_MAX_PDU;
	211
	212	cmd = malloc(sizeof(*cmd) + this_len);
	213
	214	fio_init_net_cmd(cmd, opcode, buf, this_len);
	215
	216	if (this_len < size)
ddcc0b69	217	cmd->flags = __cpu_to_le32(FIO_NET_CMD_F_MORE);
794d69ca JA	218
	219	fio_net_cmd_crc(cmd);
	220
	221	ret = fio_send_data(fd, cmd, sizeof(*cmd) + this_len);
	222	free(cmd);
	223	size -= this_len;
	224	buf += this_len;
	225	} while (!ret && size);
	226
	227	return ret;
	228	}
	229
cc0df00a	230	int fio_net_send_simple_cmd(int sk, uint16_t opcode, uint64_t serial)
132159a5 JA	231	{
132159a5 JA	232	struct fio_net_cmd cmd = {
ddcc0b69	233	.version = __cpu_to_le16(FIO_SERVER_VER1),
132159a5	234	.opcode = cpu_to_le16(opcode),
bdab4441	235	.serial = cpu_to_le64(serial),
132159a5 JA	236	};
	237
	238	fio_net_cmd_crc(&cmd);
	239
	240	return fio_send_data(sk, &cmd, sizeof(cmd));
	241	}
	242
9abea48b	243	static int fio_server_send_quit_cmd(void)
437377e1	244	{
46c48f1f	245	dprint(FD_NET, "server: sending quit\n");
cc0df00a	246	return fio_net_send_simple_cmd(server_fd, FIO_NET_CMD_QUIT, 0);
437377e1 JA	247	}
437377e1 JA	248
0b8f30a5	249	static int handle_job_cmd(struct fio_net_cmd *cmd)
132159a5	250	{
0b8f30a5	251	char buf = (char ) cmd->payload;
a64e88da	252	int ret;
132159a5	253
e6d1c668 JA	254	if (parse_jobs_ini(buf, 1, 0)) {
e6d1c668 JA	255	fio_server_send_quit_cmd();
81179eec	256	return -1;
e6d1c668	257	}
81179eec JA	258
	259	fio_net_send_simple_cmd(server_fd, FIO_NET_CMD_START, 0);
	260
	261	ret = exec_run();
9abea48b	262	fio_server_send_quit_cmd();
81179eec JA	263	reset_fio_state();
	264	return ret;
	265	}
	266
	267	static int handle_jobline_cmd(struct fio_net_cmd *cmd)
	268	{
	269	struct cmd_line_pdu pdu = (struct cmd_line_pdu ) cmd->payload;
	270	char *argv[FIO_NET_CMD_JOBLINE_ARGV];
	271	int ret, i;
	272
	273	pdu->argc = le16_to_cpu(pdu->argc);
	274
39e8e016 JA	275	dprint(FD_NET, "server: %d command line args\n", pdu->argc);
	276
	277	for (i = 0; i < pdu->argc; i++) {
81179eec	278	argv[i] = (char *) pdu->argv[i];
39e8e016 JA	279	dprint(FD_NET, "server: %d: %s\n", i, argv[i]);
39e8e016 JA	280	}
81179eec	281
e6d1c668 JA	282	if (parse_cmd_line(pdu->argc, argv)) {
e6d1c668 JA	283	fio_server_send_quit_cmd();
81179eec	284	return -1;
e6d1c668	285	}
81179eec JA	286
	287	fio_net_send_simple_cmd(server_fd, FIO_NET_CMD_START, 0);
	288
794d69ca	289	ret = exec_run();
9abea48b	290	fio_server_send_quit_cmd();
794d69ca	291	reset_fio_state();
132159a5 JA	292	return ret;
	293	}
	294
c28e8e8c JA	295	static int handle_probe_cmd(struct fio_net_cmd *cmd)
	296	{
	297	struct cmd_probe_pdu probe;
	298
	299	memset(&probe, 0, sizeof(probe));
	300	gethostname((char *) probe.hostname, sizeof(probe.hostname));
6eb24791 JA	301	#ifdef FIO_BIG_ENDIAN
	302	probe.bigendian = 1;
	303	#endif
81179eec JA	304	probe.fio_major = FIO_MAJOR;
	305	probe.fio_minor = FIO_MINOR;
	306	probe.fio_patch = FIO_PATCH;
c28e8e8c JA	307
	308	return fio_net_send_cmd(server_fd, FIO_NET_CMD_PROBE, &probe, sizeof(probe));
	309	}
	310
132159a5 JA	311	static int handle_command(struct fio_net_cmd *cmd)
	312	{
	313	int ret;
	314
46c48f1f JA	315	dprint(FD_NET, "server: got opcode %d\n", cmd->opcode);
46c48f1f JA	316
132159a5 JA	317	switch (cmd->opcode) {
132159a5 JA	318	case FIO_NET_CMD_QUIT:
cc0df00a	319	fio_terminate_threads(TERMINATE_ALL);
c28e8e8c	320	return -1;
d7959186	321	case FIO_NET_CMD_EXIT:
132159a5	322	exit_backend = 1;
c28e8e8c	323	return -1;
132159a5	324	case FIO_NET_CMD_JOB:
0b8f30a5	325	ret = handle_job_cmd(cmd);
132159a5	326	break;
81179eec JA	327	case FIO_NET_CMD_JOBLINE:
	328	ret = handle_jobline_cmd(cmd);
	329	break;
c28e8e8c JA	330	case FIO_NET_CMD_PROBE:
	331	ret = handle_probe_cmd(cmd);
	332	break;
132159a5 JA	333	default:
	334	log_err("fio: unknown opcode: %d\n", cmd->opcode);
	335	ret = 1;
	336	}
	337
	338	return ret;
	339	}
	340
70e0c316	341	static int handle_connection(int sk, int block)
132159a5 JA	342	{
	343	struct fio_net_cmd *cmd = NULL;
	344	int ret = 0;
	345
	346	/* read forever */
	347	while (!exit_backend) {
e951bdc4 JA	348	struct pollfd pfd = {
	349	.fd = sk,
	350	.events = POLLIN,
	351	};
	352
	353	ret = 0;
	354	do {
	355	ret = poll(&pfd, 1, 100);
	356	if (ret < 0) {
	357	if (errno == EINTR)
	358	break;
	359	log_err("fio: poll: %s\n", strerror(errno));
	360	break;
19c65179 JA	361	} else if (!ret) {
	362	if (!block)
	363	return 0;
e951bdc4	364	continue;
19c65179	365	}
e951bdc4 JA	366
	367	if (pfd.revents & POLLIN)
	368	break;
	369	if (pfd.revents & (POLLERR\|POLLHUP)) {
	370	ret = 1;
	371	break;
	372	}
19c65179	373	} while (!exit_backend);
e951bdc4 JA	374
	375	if (ret < 0)
	376	break;
	377
	378	cmd = fio_net_recv_cmd(sk);
132159a5	379	if (!cmd) {
c28e8e8c	380	ret = -1;
132159a5 JA	381	break;
	382	}
	383
132159a5 JA	384	ret = handle_command(cmd);
	385	if (ret)
	386	break;
	387
	388	free(cmd);
c77a99e7	389	cmd = NULL;
132159a5 JA	390	}
	391
	392	if (cmd)
	393	free(cmd);
	394
	395	return ret;
	396	}
	397
cc0df00a JA	398	void fio_server_idle_loop(void)
	399	{
	400	if (server_fd != -1)
70e0c316	401	handle_connection(server_fd, 0);
cc0df00a JA	402	}
cc0df00a JA	403
50d16976 JA	404	static int accept_loop(int listen_sk)
50d16976 JA	405	{
bb447a27	406	struct sockaddr_in addr;
5ba13ea6	407	fio_socklen_t len = sizeof(addr);
009b1be4	408	struct pollfd pfd;
132159a5	409	int ret, sk, flags, exitval = 0;
50d16976	410
60efd14e JA	411	dprint(FD_NET, "server enter accept loop\n");
60efd14e JA	412
009b1be4 JA	413	flags = fcntl(listen_sk, F_GETFL);
	414	flags \|= O_NONBLOCK;
	415	fcntl(listen_sk, F_SETFL, flags);
50d16976	416	again:
009b1be4 JA	417	pfd.fd = listen_sk;
	418	pfd.events = POLLIN;
	419	do {
	420	ret = poll(&pfd, 1, 100);
	421	if (ret < 0) {
	422	if (errno == EINTR)
	423	break;
fcee5ff6	424	log_err("fio: poll: %s\n", strerror(errno));
009b1be4 JA	425	goto out;
	426	} else if (!ret)
	427	continue;
	428
	429	if (pfd.revents & POLLIN)
	430	break;
	431	} while (!exit_backend);
	432
	433	if (exit_backend)
	434	goto out;
	435
6b976bfc	436	sk = accept(listen_sk, (struct sockaddr *) &addr, &len);
50d16976	437	if (sk < 0) {
690e09ae	438	log_err("fio: accept: %s\n", strerror(errno));
50d16976 JA	439	return -1;
	440	}
	441
bb447a27	442	dprint(FD_NET, "server: connect from %s\n", inet_ntoa(addr.sin_addr));
46c48f1f	443
37db14fe JA	444	server_fd = sk;
37db14fe JA	445
70e0c316	446	exitval = handle_connection(sk, 1);
50d16976	447
37db14fe	448	server_fd = -1;
50d16976	449	close(sk);
5c341e9a	450
009b1be4	451	if (!exit_backend)
5c341e9a JA	452	goto again;
5c341e9a JA	453
009b1be4	454	out:
132159a5	455	return exitval;
50d16976 JA	456	}
50d16976 JA	457
142575e6	458	int fio_server_text_output(const char *buf, unsigned int len)
37db14fe	459	{
337d75a8 JA	460	if (server_fd != -1)
	461	return fio_net_send_cmd(server_fd, FIO_NET_CMD_TEXT, buf, len);
	462
5037b845	463	return fwrite(buf, len, 1, f_err);
142575e6 JA	464	}
142575e6 JA	465
a64e88da JA	466	static void convert_io_stat(struct io_stat dst, struct io_stat src)
	467	{
	468	dst->max_val = cpu_to_le64(src->max_val);
	469	dst->min_val = cpu_to_le64(src->min_val);
	470	dst->samples = cpu_to_le64(src->samples);
802ad4a8 JA	471
	472	/*
	473	* Encode to IEEE 754 for network transfer
	474	*/
	475	dst->mean.u.i = __cpu_to_le64(fio_double_to_uint64(src->mean.u.f));
	476	dst->S.u.i = __cpu_to_le64(fio_double_to_uint64(src->S.u.f));
a64e88da JA	477	}
	478
	479	static void convert_gs(struct group_run_stats dst, struct group_run_stats src)
	480	{
	481	int i;
	482
	483	for (i = 0; i < 2; i++) {
	484	dst->max_run[i] = cpu_to_le64(src->max_run[i]);
	485	dst->min_run[i] = cpu_to_le64(src->min_run[i]);
	486	dst->max_bw[i] = cpu_to_le64(src->max_bw[i]);
	487	dst->min_bw[i] = cpu_to_le64(src->min_bw[i]);
	488	dst->io_kb[i] = cpu_to_le64(src->io_kb[i]);
	489	dst->agg[i] = cpu_to_le64(src->agg[i]);
	490	}
	491
	492	dst->kb_base = cpu_to_le32(src->kb_base);
	493	dst->groupid = cpu_to_le32(src->groupid);
	494	}
	495
	496	/*
	497	* Send a CMD_TS, which packs struct thread_stat and group_run_stats
	498	* into a single payload.
	499	*/
	500	void fio_server_send_ts(struct thread_stat ts, struct group_run_stats rs)
	501	{
	502	struct cmd_ts_pdu p;
	503	int i, j;
	504
60efd14e JA	505	dprint(FD_NET, "server sending end stats\n");
60efd14e JA	506
317b3c8b JA	507	memset(&p, 0, sizeof(p));
317b3c8b JA	508
a64e88da JA	509	strcpy(p.ts.name, ts->name);
	510	strcpy(p.ts.verror, ts->verror);
	511	strcpy(p.ts.description, ts->description);
	512
ddcc0b69	513	p.ts.error = cpu_to_le32(ts->error);
a64e88da	514	p.ts.groupid = cpu_to_le32(ts->groupid);
ddcc0b69	515	p.ts.pid = cpu_to_le32(ts->pid);
a64e88da JA	516	p.ts.members = cpu_to_le32(ts->members);
	517
	518	for (i = 0; i < 2; i++) {
	519	convert_io_stat(&p.ts.clat_stat[i], &ts->clat_stat[i]);
	520	convert_io_stat(&p.ts.slat_stat[i], &ts->slat_stat[i]);
	521	convert_io_stat(&p.ts.lat_stat[i], &ts->lat_stat[i]);
	522	convert_io_stat(&p.ts.bw_stat[i], &ts->bw_stat[i]);
	523	}
	524
	525	p.ts.usr_time = cpu_to_le64(ts->usr_time);
	526	p.ts.sys_time = cpu_to_le64(ts->sys_time);
	527	p.ts.ctx = cpu_to_le64(ts->ctx);
	528	p.ts.minf = cpu_to_le64(ts->minf);
	529	p.ts.majf = cpu_to_le64(ts->majf);
	530	p.ts.clat_percentiles = cpu_to_le64(ts->clat_percentiles);
802ad4a8 JA	531
	532	for (i = 0; i < FIO_IO_U_LIST_MAX_LEN; i++) {
	533	fio_fp64_t *fp = &p.ts.percentile_list[i];
	534
	535	fp->u.i = __cpu_to_le64(fio_double_to_uint64(fp->u.f));
	536	}
a64e88da JA	537
	538	for (i = 0; i < FIO_IO_U_MAP_NR; i++) {
	539	p.ts.io_u_map[i] = cpu_to_le32(ts->io_u_map[i]);
	540	p.ts.io_u_submit[i] = cpu_to_le32(ts->io_u_submit[i]);
	541	p.ts.io_u_complete[i] = cpu_to_le32(ts->io_u_complete[i]);
	542	}
	543
	544	for (i = 0; i < FIO_IO_U_LAT_U_NR; i++) {
	545	p.ts.io_u_lat_u[i] = cpu_to_le32(ts->io_u_lat_u[i]);
	546	p.ts.io_u_lat_m[i] = cpu_to_le32(ts->io_u_lat_m[i]);
	547	}
	548
	549	for (i = 0; i < 2; i++)
	550	for (j = 0; j < FIO_IO_U_PLAT_NR; j++)
	551	p.ts.io_u_plat[i][j] = cpu_to_le32(ts->io_u_plat[i][j]);
	552
	553	for (i = 0; i < 3; i++) {
	554	p.ts.total_io_u[i] = cpu_to_le64(ts->total_io_u[i]);
93eee04a	555	p.ts.short_io_u[i] = cpu_to_le64(ts->short_io_u[i]);
a64e88da JA	556	}
a64e88da JA	557
93eee04a	558	p.ts.total_submit = cpu_to_le64(ts->total_submit);
a64e88da JA	559	p.ts.total_complete = cpu_to_le64(ts->total_complete);
	560
	561	for (i = 0; i < 2; i++) {
	562	p.ts.io_bytes[i] = cpu_to_le64(ts->io_bytes[i]);
	563	p.ts.runtime[i] = cpu_to_le64(ts->runtime[i]);
	564	}
	565
	566	p.ts.total_run_time = cpu_to_le64(ts->total_run_time);
	567	p.ts.continue_on_error = cpu_to_le16(ts->continue_on_error);
	568	p.ts.total_err_count = cpu_to_le64(ts->total_err_count);
ddcc0b69 JA	569	p.ts.first_error = cpu_to_le32(ts->first_error);
ddcc0b69 JA	570	p.ts.kb_base = cpu_to_le32(ts->kb_base);
a64e88da JA	571
	572	convert_gs(&p.rs, rs);
	573
	574	fio_net_send_cmd(server_fd, FIO_NET_CMD_TS, &p, sizeof(p));
	575	}
	576
	577	void fio_server_send_gs(struct group_run_stats *rs)
	578	{
	579	struct group_run_stats gs;
	580
60efd14e JA	581	dprint(FD_NET, "server sending group run stats\n");
60efd14e JA	582
a64e88da JA	583	convert_gs(&gs, rs);
	584	fio_net_send_cmd(server_fd, FIO_NET_CMD_GS, &gs, sizeof(gs));
	585	}
	586
cf451d1e JA	587	void fio_server_send_status(void)
cf451d1e JA	588	{
1d1f45ae JA	589	struct jobs_eta *je;
	590	size_t size;
	591	void *buf;
cf451d1e JA	592	int i;
cf451d1e JA	593
1d1f45ae JA	594	size = sizeof(je) + thread_number sizeof(char);
	595	buf = malloc(size);
	596	memset(buf, 0, size);
	597	je = buf;
	598
	599	if (!calc_thread_status(je)) {
	600	free(je);
cf451d1e	601	return;
1d1f45ae	602	}
cf451d1e	603
60efd14e JA	604	dprint(FD_NET, "server sending status\n");
60efd14e JA	605
1d1f45ae JA	606	je->nr_running = cpu_to_le32(je->nr_running);
	607	je->nr_ramp = cpu_to_le32(je->nr_ramp);
	608	je->nr_pending = cpu_to_le32(je->nr_pending);
	609	je->files_open = cpu_to_le32(je->files_open);
	610	je->m_rate = cpu_to_le32(je->m_rate);
	611	je->t_rate = cpu_to_le32(je->t_rate);
	612	je->m_iops = cpu_to_le32(je->m_iops);
	613	je->t_iops = cpu_to_le32(je->t_iops);
cf451d1e JA	614
cf451d1e JA	615	for (i = 0; i < 2; i++) {
1d1f45ae JA	616	je->rate[i] = cpu_to_le32(je->rate[i]);
1d1f45ae JA	617	je->iops[i] = cpu_to_le32(je->iops[i]);
cf451d1e JA	618	}
cf451d1e JA	619
1d1f45ae JA	620	je->elapsed_sec = cpu_to_le32(je->nr_running);
1d1f45ae JA	621	je->eta_sec = cpu_to_le64(je->eta_sec);
cf451d1e	622
1d1f45ae JA	623	fio_net_send_cmd(server_fd, FIO_NET_CMD_ETA, buf, size);
1d1f45ae JA	624	free(je);
cf451d1e JA	625	}
cf451d1e JA	626
142575e6 JA	627	int fio_server_log(const char *format, ...)
	628	{
	629	char buffer[1024];
	630	va_list args;
82fa6b21	631	size_t len;
142575e6	632
60efd14e JA	633	dprint(FD_NET, "server log\n");
60efd14e JA	634
142575e6	635	va_start(args, format);
82fa6b21	636	len = vsnprintf(buffer, sizeof(buffer), format, args);
142575e6 JA	637	va_end(args);
142575e6 JA	638
82fa6b21	639	return fio_server_text_output(buffer, len);
37db14fe	640	}
e46d8091	641
81179eec JA	642	static int fio_server(void)
	643	{
	644	struct sockaddr_in saddr_in;
	645	struct sockaddr addr;
5ba13ea6	646	fio_socklen_t len;
81179eec JA	647	int sk, opt, ret;
	648
	649	dprint(FD_NET, "starting server\n");
	650
	651	sk = socket(AF_INET, SOCK_STREAM, 0);
	652	if (sk < 0) {
	653	log_err("fio: socket: %s\n", strerror(errno));
	654	return -1;
	655	}
	656
	657	opt = 1;
	658	if (setsockopt(sk, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) < 0) {
	659	log_err("fio: setsockopt: %s\n", strerror(errno));
	660	return -1;
	661	}
	662	#ifdef SO_REUSEPORT
6eb24791	663	if (setsockopt(sk, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt)) < 0) {
81179eec JA	664	log_err("fio: setsockopt: %s\n", strerror(errno));
	665	return -1;
	666	}
	667	#endif
	668
	669	saddr_in.sin_family = AF_INET;
	670	saddr_in.sin_addr.s_addr = htonl(INADDR_ANY);
	671	saddr_in.sin_port = htons(fio_net_port);
	672
	673	if (bind(sk, (struct sockaddr *) &saddr_in, sizeof(saddr_in)) < 0) {
	674	log_err("fio: bind: %s\n", strerror(errno));
	675	return -1;
	676	}
	677
	678	if (listen(sk, 1) < 0) {
	679	log_err("fio: listen: %s\n", strerror(errno));
	680	return -1;
	681	}
	682
	683	len = sizeof(addr);
	684	if (getsockname(sk, &addr, &len) < 0) {
	685	log_err("fio: getsockname: %s\n", strerror(errno));
	686	return -1;
	687	}
	688
	689	ret = accept_loop(sk);
	690	close(sk);
	691	return ret;
	692	}
	693
9abea48b JA	694	static void sig_int(int sig)
	695	{
	696	fio_terminate_threads(TERMINATE_ALL);
	697	exit_backend = 1;
	698	}
	699
	700	static void server_signal_handler(void)
	701	{
	702	struct sigaction act;
	703
	704	memset(&act, 0, sizeof(act));
	705	act.sa_handler = sig_int;
	706	act.sa_flags = SA_RESTART;
	707	sigaction(SIGINT, &act, NULL);
	708
	709	memset(&act, 0, sizeof(act));
	710	act.sa_handler = sig_int;
	711	act.sa_flags = SA_RESTART;
	712	sigaction(SIGTERM, &act, NULL);
	713	}
	714
e46d8091 JA	715	int fio_start_server(int daemonize)
	716	{
	717	pid_t pid;
	718
9abea48b JA	719	server_signal_handler();
9abea48b JA	720
e46d8091 JA	721	if (!daemonize)
	722	return fio_server();
	723
	724	openlog("fio", LOG_NDELAY\|LOG_NOWAIT\|LOG_PID, LOG_USER);
	725	pid = fork();
	726	if (pid < 0) {
	727	syslog(LOG_ERR, "failed server fork");
c28e8e8c	728	return -1;
e46d8091 JA	729	} else if (pid)
	730	exit(0);
	731
	732	setsid();
	733	close(STDIN_FILENO);
	734	close(STDOUT_FILENO);
	735	close(STDERR_FILENO);
	736	f_out = NULL;
	737	f_err = NULL;
	738	log_syslog = 1;
	739	return fio_server();
	740	}