Lines Matching refs:eta
45 .eta = display_thread_status,
209 static int fio_client_dec_jobs_eta(struct client_eta *eta, client_eta_op eta_fn)
211 if (!--eta->pending) {
212 eta_fn(&eta->eta);
213 free(eta);
253 fio_client_dec_jobs_eta(client->eta_in_flight, client->ops->eta);
1253 struct client_eta *eta = (struct client_eta *) (uintptr_t) cmd->tag;
1255 dprint(FD_NET, "client: got eta tag %p, %d\n", eta, eta->pending);
1257 assert(client->eta_in_flight == eta);
1266 fio_client_sum_jobs_eta(&eta->eta, je);
1267 fio_client_dec_jobs_eta(eta, client->ops->eta);
1809 struct client_eta *eta;
1812 dprint(FD_NET, "client: request eta (%d)\n", nr_clients);
1814 eta = calloc(1, sizeof(*eta) + __THREAD_RUNSTR_SZ(REAL_MAX_JOBS));
1815 eta->pending = nr_clients;
1829 client->eta_in_flight = eta;
1831 (uintptr_t) eta, &client->cmd_list);
1835 if (!fio_client_dec_jobs_eta(eta, ops->eta))
1839 dprint(FD_NET, "client: requested eta tag %p\n", eta);
1858 fio_client_dec_jobs_eta(client->eta_in_flight, client->ops->eta);
