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 df603f7..5545a8a 100644
--- a/client.c
+++ b/client.c
@@ -36,6 +36,7 @@
.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 @@
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 caeb432..9668afa 100644
--- a/client.h
+++ b/client.h
@@ -83,6 +83,7 @@
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 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 c78d3af..f6f8eb1 100644
--- a/gfio.c
+++ b/gfio.c
@@ -1464,6 +1464,7 @@
.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,
};