Lines Matching refs:eta
43 .eta = display_thread_status,
200 fio_client_dec_jobs_eta(client->eta_in_flight, client->ops->eta); in remove_client()
1090 void fio_client_dec_jobs_eta(struct client_eta *eta, client_eta_op eta_fn) in fio_client_dec_jobs_eta() argument
1092 if (!--eta->pending) { in fio_client_dec_jobs_eta()
1093 eta_fn(&eta->eta); in fio_client_dec_jobs_eta()
1094 free(eta); in fio_client_dec_jobs_eta()
1149 struct client_eta *eta = (struct client_eta *) (uintptr_t) cmd->tag; in handle_eta() local
1151 dprint(FD_NET, "client: got eta tag %p, %d\n", eta, eta->pending); in handle_eta()
1153 assert(client->eta_in_flight == eta); in handle_eta()
1161 fio_client_sum_jobs_eta(&eta->eta, je); in handle_eta()
1162 fio_client_dec_jobs_eta(eta, client->ops->eta); in handle_eta()
1547 struct client_eta *eta; in request_client_etas() local
1552 eta = calloc(1, sizeof(*eta) + __THREAD_RUNSTR_SZ(REAL_MAX_JOBS)); in request_client_etas()
1553 eta->pending = nr_clients; in request_client_etas()
1567 client->eta_in_flight = eta; in request_client_etas()
1569 (uintptr_t) eta, &client->cmd_list); in request_client_etas()
1573 fio_client_dec_jobs_eta(eta, ops->eta); in request_client_etas()
1575 dprint(FD_NET, "client: requested eta tag %p\n", eta); in request_client_etas()