Searched refs:gpr_mpscq_push (Results 1 – 6 of 6) sorted by relevance
| /external/grpc-grpc/src/core/lib/gpr/ |
| D | mpscq.cc | 36 bool gpr_mpscq_push(gpr_mpscq* q, gpr_mpscq_node* n) { in gpr_mpscq_push() function
73 gpr_mpscq_push(q, &q->stub); in gpr_mpscq_pop_and_check_end()
96 return gpr_mpscq_push(&q->queue, n); in gpr_locked_mpscq_push()
|
| D | mpscq.h | 54 bool gpr_mpscq_push(gpr_mpscq* q, gpr_mpscq_node* n);
|
| /external/grpc-grpc/test/core/gpr/ |
| D | mpscq_test.cc | 50 gpr_mpscq_push(&q, &new_node(i, nullptr)->node); in test_serial()
72 gpr_mpscq_push(a->q, &new_node(i, &a->ctr)->node); in test_thread()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | call_combiner.cc | 95 gpr_mpscq_push(&call_combiner->queue, in grpc_call_combiner_start()
|
| D | combiner.cc | 186 gpr_mpscq_push(&lock->queue, &cl->next_data.atm_next); in combiner_exec()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 429 gpr_mpscq_push(&q->queue, reinterpret_cast<gpr_mpscq_node*>(c)); in cq_event_queue_push()
|