X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=client.c;h=5a6fc39ff8dac6f984e5bdfa2603a210ec9973b4;hp=4b77f6920f2236dd67ab03492e3056d694289587;hb=2b7d9d5bba54ea0252f36d851c90fa4679aa0392;hpb=28d3ab07f7c68afe9ad3b07bb9c288f3e94957da

diff --git a/client.c b/client.c
index 4b77f692..5a6fc39f 100644
--- a/client.c
+++ b/client.c
@@ -42,7 +42,7 @@ enum {
 
 static FLIST_HEAD(client_list);
 
-static int handle_client(struct fio_client *client, int one);
+static int handle_client(struct fio_client *client, int one, int block);
 
 static struct fio_client *find_client_by_fd(int fd)
 {
@@ -217,7 +217,7 @@ static void probe_client(struct fio_client *client)
 	dprint(FD_NET, "client: send probe\n");
 
 	fio_net_send_simple_cmd(client->fd, FIO_NET_CMD_PROBE, 0);
-	handle_client(client, 1);
+	handle_client(client, 1, 1);
 }
 
 static int send_client_cmd_line(struct fio_client *client)
@@ -479,14 +479,14 @@ static void handle_probe(struct fio_net_cmd *cmd)
 		probe->fio_minor, probe->fio_patch);
 }
 
-static int handle_client(struct fio_client *client, int one)
+static int handle_client(struct fio_client *client, int one, int block)
 {
 	struct fio_net_cmd *cmd;
 	int done = 0, did_cmd = 0;
 
 	dprint(FD_NET, "client: handle %s\n", client->hostname);
 
-	while ((cmd = fio_net_recv_cmd(client->fd, 1)) != NULL) {
+	while ((cmd = fio_net_recv_cmd(client->fd, block)) != NULL) {
 		did_cmd++;
 
 		dprint(FD_NET, "client: got cmd op %d from %s\n",
@@ -588,7 +588,7 @@ int fio_handle_clients(void)
 				log_err("fio: unknown client\n");
 				continue;
 			}
-			if (!handle_client(client, 0)) {
+			if (!handle_client(client, 0, 0)) {
 				log_info("client: host=%s disconnected\n",
 						client->hostname);
 				remove_client(client);