Searched refs:grpc_cq_begin_op (Results 1 – 11 of 11) sorted by relevance
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 86 GPR_ASSERT(grpc_cq_begin_op(c_cq, &dummy_tag)); in BM_Pass1Cpp()
106 GPR_ASSERT(grpc_cq_begin_op(cq, nullptr)); in BM_Pass1Core()
125 GPR_ASSERT(grpc_cq_begin_op(cq, nullptr)); in BM_Pluck1Core()
|
| D | bm_cq_multiple_threads.cc | 79 GPR_ASSERT(grpc_cq_begin_op(g_cq, tag)); in pollset_work()
|
| /external/grpc-grpc/test/core/surface/ |
| D | completion_queue_test.cc | 152 GPR_ASSERT(grpc_cq_begin_op(cc, tag)); in test_cq_end_op()
188 GPR_ASSERT(grpc_cq_begin_op(cc, tag)); in test_cq_tls_cache_full()
309 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_pluck()
321 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_pluck()
423 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_callback()
|
| D | completion_queue_threading_test.cc | 110 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_too_many_plucks()
153 GPR_ASSERT(grpc_cq_begin_op(opt->cc, (void*)(intptr_t)1)); in producer_thread()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | channel_ping.cc | 63 GPR_ASSERT(grpc_cq_begin_op(cq, tag)); in grpc_channel_ping()
|
| D | completion_queue.h | 74 bool grpc_cq_begin_op(grpc_completion_queue* cc, void* tag);
|
| D | server.cc | 1236 GPR_ASSERT(grpc_cq_begin_op(cq, tag)); in grpc_server_shutdown_and_notify()
1402 if (grpc_cq_begin_op(cq_for_notification, tag) == false) { in grpc_server_request_call()
1458 if (grpc_cq_begin_op(cq_for_notification, tag) == false) { in grpc_server_request_registered_call()
|
| D | call.cc | 1492 GPR_ASSERT(grpc_cq_begin_op(call->cq, notify_tag)); in call_start_batch()
1833 GPR_ASSERT(grpc_cq_begin_op(call->cq, notify_tag)); in call_start_batch()
|
| D | completion_queue.cc | 661 bool grpc_cq_begin_op(grpc_completion_queue* cq, void* tag) { function
|
| /external/grpc-grpc/src/cpp/common/ |
| D | alarm.cc | 59 GPR_ASSERT(grpc_cq_begin_op(cq_, this)); in Set()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | channel_connectivity.cc | 218 GPR_ASSERT(grpc_cq_begin_op(cq, tag)); in grpc_channel_watch_connectivity_state()
|