projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
posixaio engine: residual data count
[fio.git]
/
engines
/
net.c
diff --git
a/engines/net.c
b/engines/net.c
index 55b2128e8b3f8c1fdc26fea9a0c331762a81e7be..2381f7390ea3d0d9934599409ce6ddbadb4ab5b1 100644
(file)
--- a/
engines/net.c
+++ b/
engines/net.c
@@
-210,7
+210,7
@@
static int fio_netio_setup_listen(struct thread_data *td, unsigned short port)
return fio_netio_accept_connections(td, fd, &addr);
}
return fio_netio_accept_connections(td, fd, &addr);
}
-static int fio_netio_
setup
(struct thread_data *td)
+static int fio_netio_
init
(struct thread_data *td)
{
char host[64], buf[128];
unsigned short port;
{
char host[64], buf[128];
unsigned short port;
@@
-223,7
+223,7
@@
static int fio_netio_setup(struct thread_data *td)
return 1;
}
return 1;
}
- if (td
->iomix
) {
+ if (td
_rw(td)
) {
log_err("fio: network connections must be read OR write\n");
return 1;
}
log_err("fio: network connections must be read OR write\n");
return 1;
}
@@
-241,7
+241,7
@@
static int fio_netio_setup(struct thread_data *td)
strcpy(host, buf);
port = atoi(sep);
strcpy(host, buf);
port = atoi(sep);
- if (td
->ddir == DDIR_READ
) {
+ if (td
_read(td)
) {
send_to_net(td) = 0;
ret = fio_netio_setup_listen(td, port);
} else {
send_to_net(td) = 0;
ret = fio_netio_setup_listen(td, port);
} else {
@@
-260,6
+260,12
@@
static int fio_netio_setup(struct thread_data *td)
f->real_file_size = f->file_size;
}
f->real_file_size = f->file_size;
}
+ td->nr_open_files = td->nr_files;
+ return 0;
+}
+
+static int fio_netio_setup(struct thread_data fio_unused *td)
+{
return 0;
}
return 0;
}
@@
-269,7
+275,8
@@
static struct ioengine_ops ioengine = {
.prep = fio_netio_prep,
.queue = fio_netio_queue,
.setup = fio_netio_setup,
.prep = fio_netio_prep,
.queue = fio_netio_queue,
.setup = fio_netio_setup,
- .flags = FIO_SYNCIO | FIO_NETIO,
+ .init = fio_netio_init,
+ .flags = FIO_SYNCIO | FIO_DISKLESSIO | FIO_SELFOPEN,
};
static void fio_init fio_netio_register(void)
};
static void fio_init fio_netio_register(void)