X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=client.c;h=097fcc57adfc763afdeb361d16d38dc77d9ad011;hb=f77d2676c36ec30cfb765b90505bdda7208c9796;hp=66ef38ca1e93dd761975b5773adc215cae4efa57;hpb=7f868316a7244cad23735e44e6ef66e5779c9660;p=fio.git

diff --git a/client.c b/client.c
index 66ef38ca..097fcc57 100644
--- a/client.c
+++ b/client.c
@@ -610,6 +610,9 @@ static void handle_eta(struct fio_client *client, struct fio_net_cmd *cmd)
 
 	dprint(FD_NET, "client: got eta tag %p, %d\n", eta, eta->pending);
 
+	assert(client->eta_in_flight == eta);
+
+	client->eta_in_flight = NULL;
 	flist_del_init(&client->eta_list);
 
 	convert_jobs_eta(je);
@@ -725,7 +728,9 @@ static void request_client_etas(void)
 			continue;
 		}
 
+		assert(!client->eta_in_flight);
 		flist_add_tail(&client->eta_list, &eta_list);
+		client->eta_in_flight = eta;
 		fio_net_send_simple_cmd(client->fd, FIO_NET_CMD_SEND_ETA,
 						(uint64_t) eta);
 	}