return fd;
}
-static int fio_client_connect(struct fio_client *client)
+int fio_client_connect(struct fio_client *client)
{
int fd;
return 0;
}
+void fio_client_terminate(struct fio_client *client)
+{
+ fio_net_send_simple_cmd(client->fd, FIO_NET_CMD_QUIT, 0, NULL);
+}
+
void fio_clients_terminate(void)
{
struct flist_head *entry;
flist_for_each(entry, &client_list) {
client = flist_entry(entry, struct fio_client, list);
-
- fio_net_send_simple_cmd(client->fd, FIO_NET_CMD_QUIT, 0, NULL);
+ fio_client_terminate(client);
}
}
client->eta_in_flight = NULL;
flist_del_init(&client->eta_list);
+ if (client->ops->jobs_eta)
+ client->ops->jobs_eta(client, je);
+
fio_client_sum_jobs_eta(&eta->eta, je);
fio_client_dec_jobs_eta(eta, client->ops->eta);
}