client: make ETA interval poll period configurage in fio_client_ops

Signed-off-by: Jens Axboe <axboe@kernel.dk>

diff --git a/client.c b/client.c
index df603f7e22ab11f6aacab53d2e08446aadeb2782..5545a8a90a9982f87af5ca73515daaf848a5c1b1 100644 (file)
--- a/client.c
+++ b/client.c
@@ -36,6 +36,7 @@ struct client_ops fio_client_ops = {
        .stop           = handle_stop,
        .eta            = display_thread_status,
        .probe          = handle_probe,
+       .eta_msec       = FIO_CLIENT_DEF_ETA_MSEC,
 };
 
 static struct timeval eta_tv;
@@ -1163,7 +1164,7 @@ int fio_handle_clients(struct client_ops *ops)
                        struct timeval tv;
 
                        gettimeofday(&tv, NULL);
-                       if (mtime_since(&eta_tv, &tv) >= 900) {
+                       if (mtime_since(&eta_tv, &tv) >= ops->eta_msec) {
                                request_client_etas(ops);
                                memcpy(&eta_tv, &tv, sizeof(tv));
 

diff --git a/client.h b/client.h
index caeb432a1bc4fb9bf4f95311e1f505afdcea2921..9668afa8dfc8a4a5e05fd465d3cd1f142dbc5564 100644 (file)
--- a/client.h
+++ b/client.h
@@ -83,6 +83,7 @@ struct client_ops {
        client_add_job_op add_job;
        client_timed_out timed_out;
        client_stop_op stop;
+       unsigned int eta_msec;
        int stay_connected;
 };
 
@@ -118,5 +119,7 @@ extern void fio_clients_terminate(void);
 extern struct fio_client *fio_get_client(struct fio_client *);
 extern void fio_put_client(struct fio_client *);
 
+#define FIO_CLIENT_DEF_ETA_MSEC                900
+
 #endif
 

diff --git a/gfio.c b/gfio.c
index c78d3af10ba7261084fdae7124d50751c99556ac..f6f8eb1d771559edd32ea0aafc4c89321d318b4c 100644 (file)
--- a/gfio.c
+++ b/gfio.c
@@ -1464,6 +1464,7 @@ struct client_ops gfio_client_ops = {
        .add_job                = gfio_add_job_op,
        .timed_out              = gfio_client_timed_out,
        .stop                   = gfio_client_stop,
+       .eta_msec               = FIO_CLIENT_DEF_ETA_MSEC,
        .stay_connected         = 1,
 };