Searched refs:nb_inflight_cops (Results 1 – 4 of 4) sorted by relevance
43 psd_qp_ctx->primary_worker.nb_inflight_cops, in schedule_enqueue()44 psd_qp_ctx->secondary_worker.nb_inflight_cops in schedule_enqueue()199 if (worker->nb_inflight_cops) { in schedule_dequeue()202 worker->nb_inflight_cops -= nb_deq_ops_pri; in schedule_dequeue()212 if (worker->nb_inflight_cops) { in schedule_dequeue()216 worker->nb_inflight_cops -= nb_deq_ops_sec; in schedule_dequeue()218 if (!worker->nb_inflight_cops) in schedule_dequeue()273 ps_qp_ctx->primary_worker.nb_inflight_cops = 0; in scheduler_start()278 ps_qp_ctx->secondary_worker.nb_inflight_cops = 0; in scheduler_start()303 if (ps_qp_ctx->primary_worker.nb_inflight_cops + in scheduler_stop()[all …]
34 worker->nb_inflight_cops += processed_ops; in failover_worker_enqueue()88 if (worker->nb_inflight_cops) { in schedule_dequeue()91 worker->nb_inflight_cops -= nb_deq_ops; in schedule_dequeue()101 if (worker->nb_inflight_cops) { in schedule_dequeue()104 worker->nb_inflight_cops -= nb_deq_ops2; in schedule_dequeue()
37 worker->nb_inflight_cops += processed_ops; in schedule_enqueue()71 if (unlikely(rr_qp_ctx->workers[last_worker_idx].nb_inflight_cops in schedule_dequeue()81 } while (rr_qp_ctx->workers[last_worker_idx].nb_inflight_cops in schedule_dequeue()95 worker->nb_inflight_cops -= nb_deq_ops; in schedule_dequeue()
24 uint32_t nb_inflight_cops; member