[fio.git] / engines / net.c

/*
 * net engine
 *
 * IO engine that reads/writes to/from sockets.
 *
 */
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <assert.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <sys/poll.h>

#include "../fio.h"

struct netio_data {
	int listenfd;
	int send_to_net;
	int use_splice;
	int pipes[2];
	char host[64];
	struct sockaddr_in addr;
};

static int fio_netio_prep(struct thread_data *td, struct io_u *io_u)
{
	struct netio_data *nd = td->io_ops->data;
	struct fio_file *f = io_u->file;

	/*
	 * Make sure we don't see spurious reads to a receiver, and vice versa
	 */
	if ((nd->send_to_net && io_u->ddir == DDIR_READ) ||
	    (!nd->send_to_net && io_u->ddir == DDIR_WRITE)) {
		td_verror(td, EINVAL, "bad direction");
		return 1;
	}
		
	if (io_u->ddir == DDIR_SYNC)
		return 0;
	if (io_u->offset == f->last_completed_pos)
		return 0;

	/*
	 * If offset is different from last end position, it's a seek.
	 * As network io is purely sequential, we don't allow seeks.
	 */
	td_verror(td, EINVAL, "cannot seek");
	return 1;
}

static int splice_io_u(int fdin, int fdout, unsigned int len)
{
	int bytes = 0;

	while (len) {
		int ret = splice(fdin, NULL, fdout, NULL, len, 0);

		if (ret < 0) {
			if (!bytes)
				bytes = ret;

			break;
		} else if (!ret)
			break;

		bytes += ret;
		len -= ret;
	}

	return bytes;
}

/*
 * Receive bytes from a socket and fill them into the internal pipe
 */
static int splice_in(struct thread_data *td, struct io_u *io_u)
{
	struct netio_data *nd = td->io_ops->data;

	return splice_io_u(io_u->file->fd, nd->pipes[1], io_u->xfer_buflen);
}

/*
 * Transmit 'len' bytes from the internal pipe
 */
static int splice_out(struct thread_data *td, struct io_u *io_u,
		      unsigned int len)
{
	struct netio_data *nd = td->io_ops->data;

	return splice_io_u(nd->pipes[0], io_u->file->fd, len);
}

static int vmsplice_io_u(struct io_u *io_u, int fd, unsigned int len)
{
	struct iovec iov = {
		.iov_base = io_u->xfer_buf,
		.iov_len = len,
	};
	int bytes = 0;

	while (iov.iov_len) {
		int ret = vmsplice(fd, &iov, 1, SPLICE_F_MOVE);

		if (ret < 0) {
			if (!bytes)
				bytes = ret;
			break;
		} else if (!ret)
			break;

		iov.iov_len -= ret;
		iov.iov_base += ret;
		bytes += ret;
	}

	return bytes;

}

/*
 * vmsplice() pipe to io_u buffer
 */
static int vmsplice_io_u_out(struct thread_data *td, struct io_u *io_u,
			     unsigned int len)
{
	struct netio_data *nd = td->io_ops->data;

	return vmsplice_io_u(io_u, nd->pipes[0], len);
}

/*
 * vmsplice() io_u to pipe
 */
static int vmsplice_io_u_in(struct thread_data *td, struct io_u *io_u)
{
	struct netio_data *nd = td->io_ops->data;

	return vmsplice_io_u(io_u, nd->pipes[1], io_u->xfer_buflen);
}

/*
 * splice receive - transfer socket data into a pipe using splice, then map
 * that pipe data into the io_u using vmsplice.
 */
static int fio_netio_splice_in(struct thread_data *td, struct io_u *io_u)
{
	int ret;

	ret = splice_in(td, io_u);
	if (ret > 0)
		return vmsplice_io_u_out(td, io_u, ret);

	return ret;
}

/*
 * splice transmit - map data from the io_u into a pipe by using vmsplice,
 * then transfer that pipe to a socket using splice.
 */
static int fio_netio_splice_out(struct thread_data *td, struct io_u *io_u)
{
	int ret;

	ret = vmsplice_io_u_in(td, io_u);
	if (ret > 0)
		return splice_out(td, io_u, ret);

	return ret;
}

static int fio_netio_send(struct thread_data *td, struct io_u *io_u)
{
	int flags = 0;

	/*
	 * if we are going to write more, set MSG_MORE
	 */
	if (td->this_io_bytes[DDIR_WRITE] + io_u->xfer_buflen < td->o.size)
		flags = MSG_MORE;

	return send(io_u->file->fd, io_u->xfer_buf, io_u->xfer_buflen, flags);
}

static int fio_netio_recv(struct io_u *io_u)
{
	int flags = MSG_WAITALL;

	return recv(io_u->file->fd, io_u->xfer_buf, io_u->xfer_buflen, flags);
}

static int fio_netio_queue(struct thread_data *td, struct io_u *io_u)
{
	struct netio_data *nd = td->io_ops->data;
	int ret;

	fio_ro_check(td, io_u);

	if (io_u->ddir == DDIR_WRITE) {
		if (nd->use_splice)
			ret = fio_netio_splice_out(td, io_u);
		else
			ret = fio_netio_send(td, io_u);
	} else if (io_u->ddir == DDIR_READ) {
		if (nd->use_splice)
			ret = fio_netio_splice_in(td, io_u);
		else
			ret = fio_netio_recv(io_u);
	} else
		ret = 0;	/* must be a SYNC */

	if (ret != (int) io_u->xfer_buflen) {
		if (ret >= 0) {
			io_u->resid = io_u->xfer_buflen - ret;
			io_u->error = 0;
			return FIO_Q_COMPLETED;
		} else
			io_u->error = errno;
	}

	if (io_u->error)
		td_verror(td, io_u->error, "xfer");

	return FIO_Q_COMPLETED;
}

static int fio_netio_connect(struct thread_data *td, struct fio_file *f)
{
	struct netio_data *nd = td->io_ops->data;

	f->fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	if (f->fd < 0) {
		td_verror(td, errno, "socket");
		return 1;
	}

	if (connect(f->fd, (struct sockaddr *) &nd->addr, sizeof(nd->addr)) < 0) {
		td_verror(td, errno, "connect");
		return 1;
	}

	return 0;
}

static int fio_netio_accept(struct thread_data *td, struct fio_file *f)
{
	struct netio_data *nd = td->io_ops->data;
	socklen_t socklen = sizeof(nd->addr);
	struct pollfd pfd;
	int ret;

	log_info("fio: waiting for connection\n");

	/*
	 * Accept loop. poll for incoming events, accept them. Repeat until we
	 * have all connections.
	 */
	while (!td->terminate) {
		pfd.fd = nd->listenfd;
		pfd.events = POLLIN;

		ret = poll(&pfd, 1, -1);
		printf("got ret %d\n", ret);
		if (ret < 0) {
			if (errno == EINTR)
				continue;

			td_verror(td, errno, "poll");
			break;
		} else if (!ret)
			continue;

		/*
		 * should be impossible
		 */
		if (!(pfd.revents & POLLIN))
			continue;

		f->fd = accept(nd->listenfd, (struct sockaddr *) &nd->addr, &socklen);
		if (f->fd < 0) {
			td_verror(td, errno, "accept");
			return 1;
		}
		break;
	}

	return 0;
}

static int fio_netio_open_file(struct thread_data *td, struct fio_file *f)
{
	if (td_read(td))
		return fio_netio_accept(td, f);
	else
		return fio_netio_connect(td, f);
}

static int fio_netio_setup_connect(struct thread_data *td, const char *host,
				   unsigned short port)
{
	struct netio_data *nd = td->io_ops->data;

	nd->addr.sin_family = AF_INET;
	nd->addr.sin_port = htons(port);

	if (inet_aton(host, &nd->addr.sin_addr) != 1) {
		struct hostent *hent;

		hent = gethostbyname(host);
		if (!hent) {
			td_verror(td, errno, "gethostbyname");
			return 1;
		}

		memcpy(&nd->addr.sin_addr, hent->h_addr, 4);
	}

	return 0;
}

static int fio_netio_setup_listen(struct thread_data *td, short port)
{
	struct netio_data *nd = td->io_ops->data;
	int fd, opt;

	fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	if (fd < 0) {
		td_verror(td, errno, "socket");
		return 1;
	}

	opt = 1;
	if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) < 0) {
		td_verror(td, errno, "setsockopt");
		return 1;
	}
#ifdef SO_REUSEPORT
	if (setsockopt(fd, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt)) < 0) {
		td_verror(td, errno, "setsockopt");
		return 1;
	}
#endif

	nd->addr.sin_family = AF_INET;
	nd->addr.sin_addr.s_addr = htonl(INADDR_ANY);
	nd->addr.sin_port = htons(port);

	if (bind(fd, (struct sockaddr *) &nd->addr, sizeof(nd->addr)) < 0) {
		td_verror(td, errno, "bind");
		return 1;
	}
	if (listen(fd, 1) < 0) {
		td_verror(td, errno, "listen");
		return 1;
	}

	nd->listenfd = fd;
	return 0;
}

static int fio_netio_init(struct thread_data *td)
{
	struct netio_data *nd = td->io_ops->data;
	unsigned short port;
	char host[64], buf[128];
	char *sep;
	int ret;

	if (td_rw(td)) {
		log_err("fio: network connections must be read OR write\n");
		return 1;
	}
	if (td_random(td)) {
		log_err("fio: network IO can't be random\n");
		return 1;
	}

	strcpy(buf, td->o.filename);

	sep = strchr(buf, '/');
	if (!sep) {
		log_err("fio: bad network host/port <<%s>>\n", td->o.filename);
		return 1;
	}

	*sep = '\0';
	sep++;
	strcpy(host, buf);
	port = atoi(sep);

	if (td_read(td)) {
		nd->send_to_net = 0;
		ret = fio_netio_setup_listen(td, port);
	} else {
		nd->send_to_net = 1;
		ret = fio_netio_setup_connect(td, host, port);
	}

	return ret;
}

static void fio_netio_cleanup(struct thread_data *td)
{
	struct netio_data *nd = td->io_ops->data;

	if (nd) {
		if (nd->listenfd != -1)
			close(nd->listenfd);
		if (nd->pipes[0] != -1)
			close(nd->pipes[0]);
		if (nd->pipes[1] != -1)
			close(nd->pipes[1]);

		free(nd);
		td->io_ops->data = NULL;
	}
}

static int fio_netio_setup(struct thread_data *td)
{
	struct netio_data *nd;

	if (!td->io_ops->data) {
		nd = malloc(sizeof(*nd));;

		memset(nd, 0, sizeof(*nd));
		nd->listenfd = -1;
		nd->pipes[0] = nd->pipes[1] = -1;
		td->io_ops->data = nd;
	}

	return 0;
}

static int fio_netio_setup_splice(struct thread_data *td)
{
	struct netio_data *nd;

	fio_netio_setup(td);

	nd = td->io_ops->data;
	if (nd) {
		if (pipe(nd->pipes) < 0)
			return 1;

		nd->use_splice = 1;
		return 0;
	}

	return 1;
}

static struct ioengine_ops ioengine_rw = {
	.name		= "net",
	.version	= FIO_IOOPS_VERSION,
	.prep		= fio_netio_prep,
	.queue		= fio_netio_queue,
	.setup		= fio_netio_setup,
	.init		= fio_netio_init,
	.cleanup	= fio_netio_cleanup,
	.open_file	= fio_netio_open_file,
	.close_file	= generic_close_file,
	.flags		= FIO_SYNCIO | FIO_DISKLESSIO | FIO_UNIDIR |
			  FIO_SIGQUIT,
};

static struct ioengine_ops ioengine_splice = {
	.name		= "netsplice",
	.version	= FIO_IOOPS_VERSION,
	.prep		= fio_netio_prep,
	.queue		= fio_netio_queue,
	.setup		= fio_netio_setup_splice,
	.init		= fio_netio_init,
	.cleanup	= fio_netio_cleanup,
	.open_file	= fio_netio_open_file,
	.close_file	= generic_close_file,
	.flags		= FIO_SYNCIO | FIO_DISKLESSIO | FIO_UNIDIR |
			  FIO_SIGQUIT,
};

static void fio_init fio_netio_register(void)
{
	register_ioengine(&ioengine_rw);
	register_ioengine(&ioengine_splice);
}

static void fio_exit fio_netio_unregister(void)
{
	unregister_ioengine(&ioengine_rw);
	unregister_ioengine(&ioengine_splice);
}
Commit	Line	Data
ed92ac0c	1	/*
da751ca9 JA	2	* net engine
	3	*
	4	* IO engine that reads/writes to/from sockets.
	5	*
ed92ac0c JA	6	*/
	7	#include <stdio.h>
	8	#include <stdlib.h>
	9	#include <unistd.h>
	10	#include <errno.h>
	11	#include <assert.h>
	12	#include <netinet/in.h>
	13	#include <arpa/inet.h>
	14	#include <netdb.h>
5fdd124a	15	#include <sys/poll.h>
ed92ac0c JA	16
ed92ac0c JA	17	#include "../fio.h"
ed92ac0c	18
b5af8293 JA	19	struct netio_data {
	20	int listenfd;
	21	int send_to_net;
9cce02e8 JA	22	int use_splice;
9cce02e8 JA	23	int pipes[2];
b5af8293 JA	24	char host[64];
	25	struct sockaddr_in addr;
	26	};
ed92ac0c JA	27
	28	static int fio_netio_prep(struct thread_data td, struct io_u io_u)
	29	{
b5af8293	30	struct netio_data *nd = td->io_ops->data;
ed92ac0c JA	31	struct fio_file *f = io_u->file;
ed92ac0c JA	32
7a6499da JA	33	/*
	34	* Make sure we don't see spurious reads to a receiver, and vice versa
	35	*/
b5af8293 JA	36	if ((nd->send_to_net && io_u->ddir == DDIR_READ) \|\|
b5af8293 JA	37	(!nd->send_to_net && io_u->ddir == DDIR_WRITE)) {
e1161c32	38	td_verror(td, EINVAL, "bad direction");
7a6499da	39	return 1;
ed92ac0c	40	}
7a6499da	41
ed92ac0c JA	42	if (io_u->ddir == DDIR_SYNC)
	43	return 0;
	44	if (io_u->offset == f->last_completed_pos)
	45	return 0;
	46
e01547d2 JA	47	/*
	48	* If offset is different from last end position, it's a seek.
	49	* As network io is purely sequential, we don't allow seeks.
	50	*/
e1161c32	51	td_verror(td, EINVAL, "cannot seek");
ed92ac0c JA	52	return 1;
	53	}
	54
cd963e18	55	static int splice_io_u(int fdin, int fdout, unsigned int len)
ed92ac0c	56	{
9cce02e8	57	int bytes = 0;
7a6499da	58
9cce02e8	59	while (len) {
cd963e18	60	int ret = splice(fdin, NULL, fdout, NULL, len, 0);
9cce02e8 JA	61
	62	if (ret < 0) {
	63	if (!bytes)
	64	bytes = ret;
	65
	66	break;
	67	} else if (!ret)
	68	break;
	69
	70	bytes += ret;
f657a2fb	71	len -= ret;
9cce02e8 JA	72	}
	73
	74	return bytes;
	75	}
	76
	77	/*
cd963e18	78	* Receive bytes from a socket and fill them into the internal pipe
9cce02e8	79	*/
cd963e18	80	static int splice_in(struct thread_data td, struct io_u io_u)
9cce02e8 JA	81	{
9cce02e8 JA	82	struct netio_data *nd = td->io_ops->data;
9cce02e8	83
cd963e18	84	return splice_io_u(io_u->file->fd, nd->pipes[1], io_u->xfer_buflen);
9cce02e8 JA	85	}
	86
	87	/*
cd963e18	88	* Transmit 'len' bytes from the internal pipe
9cce02e8	89	*/
cd963e18 JA	90	static int splice_out(struct thread_data td, struct io_u io_u,
cd963e18 JA	91	unsigned int len)
9cce02e8 JA	92	{
9cce02e8 JA	93	struct netio_data *nd = td->io_ops->data;
cd963e18 JA	94
	95	return splice_io_u(nd->pipes[0], io_u->file->fd, len);
	96	}
	97
	98	static int vmsplice_io_u(struct io_u *io_u, int fd, unsigned int len)
	99	{
9cce02e8 JA	100	struct iovec iov = {
	101	.iov_base = io_u->xfer_buf,
	102	.iov_len = len,
	103	};
	104	int bytes = 0;
	105
	106	while (iov.iov_len) {
cd963e18	107	int ret = vmsplice(fd, &iov, 1, SPLICE_F_MOVE);
9cce02e8 JA	108
	109	if (ret < 0) {
	110	if (!bytes)
	111	bytes = ret;
	112	break;
	113	} else if (!ret)
	114	break;
	115
	116	iov.iov_len -= ret;
cd963e18	117	iov.iov_base += ret;
f657a2fb	118	bytes += ret;
9cce02e8 JA	119	}
	120
	121	return bytes;
cd963e18	122
9cce02e8 JA	123	}
	124
	125	/*
cd963e18	126	* vmsplice() pipe to io_u buffer
9cce02e8	127	*/
cd963e18 JA	128	static int vmsplice_io_u_out(struct thread_data td, struct io_u io_u,
cd963e18 JA	129	unsigned int len)
9cce02e8 JA	130	{
9cce02e8 JA	131	struct netio_data *nd = td->io_ops->data;
9cce02e8	132
cd963e18 JA	133	return vmsplice_io_u(io_u, nd->pipes[0], len);
cd963e18 JA	134	}
9cce02e8	135
cd963e18 JA	136	/*
	137	* vmsplice() io_u to pipe
	138	*/
	139	static int vmsplice_io_u_in(struct thread_data td, struct io_u io_u)
	140	{
	141	struct netio_data *nd = td->io_ops->data;
ed92ac0c	142
cd963e18	143	return vmsplice_io_u(io_u, nd->pipes[1], io_u->xfer_buflen);
9cce02e8 JA	144	}
9cce02e8 JA	145
cd963e18 JA	146	/*
	147	* splice receive - transfer socket data into a pipe using splice, then map
	148	* that pipe data into the io_u using vmsplice.
	149	*/
9cce02e8 JA	150	static int fio_netio_splice_in(struct thread_data td, struct io_u io_u)
	151	{
	152	int ret;
	153
	154	ret = splice_in(td, io_u);
cd963e18 JA	155	if (ret > 0)
cd963e18 JA	156	return vmsplice_io_u_out(td, io_u, ret);
9cce02e8	157
cd963e18	158	return ret;
9cce02e8 JA	159	}
9cce02e8 JA	160
cd963e18 JA	161	/*
	162	* splice transmit - map data from the io_u into a pipe by using vmsplice,
	163	* then transfer that pipe to a socket using splice.
	164	*/
9cce02e8 JA	165	static int fio_netio_splice_out(struct thread_data td, struct io_u io_u)
	166	{
	167	int ret;
	168
	169	ret = vmsplice_io_u_in(td, io_u);
cd963e18 JA	170	if (ret > 0)
cd963e18 JA	171	return splice_out(td, io_u, ret);
9cce02e8	172
cd963e18	173	return ret;
9cce02e8 JA	174	}
	175
	176	static int fio_netio_send(struct thread_data td, struct io_u io_u)
	177	{
	178	int flags = 0;
	179
	180	/*
	181	* if we are going to write more, set MSG_MORE
	182	*/
	183	if (td->this_io_bytes[DDIR_WRITE] + io_u->xfer_buflen < td->o.size)
	184	flags = MSG_MORE;
	185
	186	return send(io_u->file->fd, io_u->xfer_buf, io_u->xfer_buflen, flags);
	187	}
	188
	189	static int fio_netio_recv(struct io_u *io_u)
	190	{
	191	int flags = MSG_WAITALL;
	192
	193	return recv(io_u->file->fd, io_u->xfer_buf, io_u->xfer_buflen, flags);
	194	}
	195
	196	static int fio_netio_queue(struct thread_data td, struct io_u io_u)
	197	{
	198	struct netio_data *nd = td->io_ops->data;
	199	int ret;
	200
7101d9c2 JA	201	fio_ro_check(td, io_u);
7101d9c2 JA	202
9cce02e8 JA	203	if (io_u->ddir == DDIR_WRITE) {
	204	if (nd->use_splice)
	205	ret = fio_netio_splice_out(td, io_u);
	206	else
	207	ret = fio_netio_send(td, io_u);
d4f12dd0	208	} else if (io_u->ddir == DDIR_READ) {
9cce02e8 JA	209	if (nd->use_splice)
	210	ret = fio_netio_splice_in(td, io_u);
	211	else
	212	ret = fio_netio_recv(io_u);
d4f12dd0	213	} else
7a6499da	214	ret = 0; /* must be a SYNC */
ed92ac0c	215
cec6b55d	216	if (ret != (int) io_u->xfer_buflen) {
22819ec2	217	if (ret >= 0) {
cec6b55d JA	218	io_u->resid = io_u->xfer_buflen - ret;
cec6b55d JA	219	io_u->error = 0;
36167d82	220	return FIO_Q_COMPLETED;
ed92ac0c JA	221	} else
	222	io_u->error = errno;
	223	}
	224
36167d82	225	if (io_u->error)
e1161c32	226	td_verror(td, io_u->error, "xfer");
ed92ac0c	227
36167d82	228	return FIO_Q_COMPLETED;
ed92ac0c JA	229	}
ed92ac0c JA	230
b5af8293	231	static int fio_netio_connect(struct thread_data td, struct fio_file f)
ed92ac0c	232	{
b5af8293	233	struct netio_data *nd = td->io_ops->data;
ed92ac0c	234
b5af8293 JA	235	f->fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	236	if (f->fd < 0) {
	237	td_verror(td, errno, "socket");
	238	return 1;
ed92ac0c JA	239	}
ed92ac0c JA	240
b5af8293 JA	241	if (connect(f->fd, (struct sockaddr *) &nd->addr, sizeof(nd->addr)) < 0) {
	242	td_verror(td, errno, "connect");
	243	return 1;
ed92ac0c JA	244	}
	245
	246	return 0;
ed92ac0c JA	247	}
ed92ac0c JA	248
b5af8293	249	static int fio_netio_accept(struct thread_data td, struct fio_file f)
5fdd124a	250	{
b5af8293 JA	251	struct netio_data *nd = td->io_ops->data;
b5af8293 JA	252	socklen_t socklen = sizeof(nd->addr);
5fdd124a	253	struct pollfd pfd;
b5af8293	254	int ret;
5fdd124a	255
6d86144d	256	log_info("fio: waiting for connection\n");
5fdd124a JA	257
	258	/*
	259	* Accept loop. poll for incoming events, accept them. Repeat until we
	260	* have all connections.
	261	*/
b5af8293 JA	262	while (!td->terminate) {
b5af8293 JA	263	pfd.fd = nd->listenfd;
5fdd124a JA	264	pfd.events = POLLIN;
	265
	266	ret = poll(&pfd, 1, -1);
ad830ed7	267	printf("got ret %d\n", ret);
5fdd124a JA	268	if (ret < 0) {
	269	if (errno == EINTR)
	270	continue;
	271
e1161c32	272	td_verror(td, errno, "poll");
5fdd124a JA	273	break;
	274	} else if (!ret)
	275	continue;
	276
0c09442b JA	277	/*
	278	* should be impossible
	279	*/
	280	if (!(pfd.revents & POLLIN))
	281	continue;
	282
b5af8293 JA	283	f->fd = accept(nd->listenfd, (struct sockaddr *) &nd->addr, &socklen);
	284	if (f->fd < 0) {
	285	td_verror(td, errno, "accept");
	286	return 1;
	287	}
	288	break;
	289	}
5fdd124a	290
b5af8293 JA	291	return 0;
	292	}
	293
b5af8293 JA	294	static int fio_netio_open_file(struct thread_data td, struct fio_file f)
	295	{
	296	if (td_read(td))
	297	return fio_netio_accept(td, f);
	298	else
	299	return fio_netio_connect(td, f);
	300	}
	301
	302	static int fio_netio_setup_connect(struct thread_data td, const char host,
	303	unsigned short port)
	304	{
	305	struct netio_data *nd = td->io_ops->data;
	306
	307	nd->addr.sin_family = AF_INET;
	308	nd->addr.sin_port = htons(port);
	309
	310	if (inet_aton(host, &nd->addr.sin_addr) != 1) {
	311	struct hostent *hent;
	312
	313	hent = gethostbyname(host);
	314	if (!hent) {
	315	td_verror(td, errno, "gethostbyname");
	316	return 1;
5fdd124a	317	}
b5af8293 JA	318
b5af8293 JA	319	memcpy(&nd->addr.sin_addr, hent->h_addr, 4);
5fdd124a JA	320	}
	321
	322	return 0;
	323	}
	324
b5af8293	325	static int fio_netio_setup_listen(struct thread_data *td, short port)
ed92ac0c	326	{
b5af8293	327	struct netio_data *nd = td->io_ops->data;
5fdd124a	328	int fd, opt;
ed92ac0c	329
6bedbfaf	330	fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
ed92ac0c	331	if (fd < 0) {
e1161c32	332	td_verror(td, errno, "socket");
ed92ac0c JA	333	return 1;
	334	}
	335
	336	opt = 1;
	337	if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) < 0) {
e1161c32	338	td_verror(td, errno, "setsockopt");
ed92ac0c JA	339	return 1;
ed92ac0c JA	340	}
6bedbfaf JA	341	#ifdef SO_REUSEPORT
6bedbfaf JA	342	if (setsockopt(fd, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt)) < 0) {
e1161c32	343	td_verror(td, errno, "setsockopt");
6bedbfaf JA	344	return 1;
	345	}
	346	#endif
ed92ac0c	347
b5af8293 JA	348	nd->addr.sin_family = AF_INET;
	349	nd->addr.sin_addr.s_addr = htonl(INADDR_ANY);
	350	nd->addr.sin_port = htons(port);
ed92ac0c	351
b5af8293	352	if (bind(fd, (struct sockaddr *) &nd->addr, sizeof(nd->addr)) < 0) {
e1161c32	353	td_verror(td, errno, "bind");
ed92ac0c JA	354	return 1;
	355	}
	356	if (listen(fd, 1) < 0) {
e1161c32	357	td_verror(td, errno, "listen");
ed92ac0c JA	358	return 1;
	359	}
	360
b5af8293 JA	361	nd->listenfd = fd;
b5af8293 JA	362	return 0;
ed92ac0c JA	363	}
ed92ac0c JA	364
9bec88e1	365	static int fio_netio_init(struct thread_data *td)
ed92ac0c	366	{
b5af8293	367	struct netio_data *nd = td->io_ops->data;
e01547d2	368	unsigned short port;
b5af8293	369	char host[64], buf[128];
ed92ac0c	370	char *sep;
af52b345	371	int ret;
ed92ac0c	372
413dd459	373	if (td_rw(td)) {
ed92ac0c JA	374	log_err("fio: network connections must be read OR write\n");
	375	return 1;
	376	}
16d55aae JA	377	if (td_random(td)) {
	378	log_err("fio: network IO can't be random\n");
	379	return 1;
	380	}
ed92ac0c	381
2dc1bbeb	382	strcpy(buf, td->o.filename);
ed92ac0c	383
9f9214f2	384	sep = strchr(buf, '/');
ed92ac0c	385	if (!sep) {
2dc1bbeb	386	log_err("fio: bad network host/port <<%s>>\n", td->o.filename);
ed92ac0c JA	387	return 1;
	388	}
	389
	390	*sep = '\0';
	391	sep++;
	392	strcpy(host, buf);
e01547d2	393	port = atoi(sep);
ed92ac0c	394
413dd459	395	if (td_read(td)) {
b5af8293	396	nd->send_to_net = 0;
ed92ac0c JA	397	ret = fio_netio_setup_listen(td, port);
ed92ac0c JA	398	} else {
b5af8293	399	nd->send_to_net = 1;
ed92ac0c JA	400	ret = fio_netio_setup_connect(td, host, port);
	401	}
	402
7bb48f84	403	return ret;
ed92ac0c JA	404	}
ed92ac0c JA	405
b5af8293	406	static void fio_netio_cleanup(struct thread_data *td)
9bec88e1	407	{
b5af8293 JA	408	struct netio_data *nd = td->io_ops->data;
	409
	410	if (nd) {
64b24cd8 JA	411	if (nd->listenfd != -1)
	412	close(nd->listenfd);
	413	if (nd->pipes[0] != -1)
	414	close(nd->pipes[0]);
	415	if (nd->pipes[1] != -1)
	416	close(nd->pipes[1]);
	417
b5af8293 JA	418	free(nd);
	419	td->io_ops->data = NULL;
	420	}
	421	}
	422
	423	static int fio_netio_setup(struct thread_data *td)
	424	{
7bb48f84	425	struct netio_data *nd;
7bb48f84 JA	426
	427	if (!td->io_ops->data) {
	428	nd = malloc(sizeof(*nd));;
	429
	430	memset(nd, 0, sizeof(*nd));
	431	nd->listenfd = -1;
64b24cd8	432	nd->pipes[0] = nd->pipes[1] = -1;
7bb48f84	433	td->io_ops->data = nd;
7bb48f84	434	}
b5af8293	435
9bec88e1 JA	436	return 0;
	437	}
	438
9cce02e8 JA	439	static int fio_netio_setup_splice(struct thread_data *td)
	440	{
	441	struct netio_data *nd;
	442
	443	fio_netio_setup(td);
	444
	445	nd = td->io_ops->data;
	446	if (nd) {
	447	if (pipe(nd->pipes) < 0)
	448	return 1;
	449
	450	nd->use_splice = 1;
	451	return 0;
	452	}
	453
	454	return 1;
	455	}
	456
	457	static struct ioengine_ops ioengine_rw = {
ed92ac0c JA	458	.name = "net",
ed92ac0c JA	459	.version = FIO_IOOPS_VERSION,
ed92ac0c JA	460	.prep = fio_netio_prep,
ed92ac0c JA	461	.queue = fio_netio_queue,
ed92ac0c	462	.setup = fio_netio_setup,
9bec88e1	463	.init = fio_netio_init,
b5af8293 JA	464	.cleanup = fio_netio_cleanup,
	465	.open_file = fio_netio_open_file,
	466	.close_file = generic_close_file,
ad830ed7 JA	467	.flags = FIO_SYNCIO \| FIO_DISKLESSIO \| FIO_UNIDIR \|
ad830ed7 JA	468	FIO_SIGQUIT,
ed92ac0c JA	469	};
ed92ac0c JA	470
9cce02e8 JA	471	static struct ioengine_ops ioengine_splice = {
	472	.name = "netsplice",
	473	.version = FIO_IOOPS_VERSION,
	474	.prep = fio_netio_prep,
	475	.queue = fio_netio_queue,
	476	.setup = fio_netio_setup_splice,
	477	.init = fio_netio_init,
	478	.cleanup = fio_netio_cleanup,
	479	.open_file = fio_netio_open_file,
	480	.close_file = generic_close_file,
ad830ed7 JA	481	.flags = FIO_SYNCIO \| FIO_DISKLESSIO \| FIO_UNIDIR \|
ad830ed7 JA	482	FIO_SIGQUIT,
9cce02e8 JA	483	};
9cce02e8 JA	484
ed92ac0c JA	485	static void fio_init fio_netio_register(void)
ed92ac0c JA	486	{
9cce02e8 JA	487	register_ioengine(&ioengine_rw);
9cce02e8 JA	488	register_ioengine(&ioengine_splice);
ed92ac0c JA	489	}
	490
	491	static void fio_exit fio_netio_unregister(void)
	492	{
9cce02e8 JA	493	unregister_ioengine(&ioengine_rw);
9cce02e8 JA	494	unregister_ioengine(&ioengine_splice);
ed92ac0c	495	}