Searched refs:grpc_cq_begin_op (Results 1 – 14 of 14) sorted by relevance
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 92 GPR_ASSERT(grpc_cq_begin_op(c_cq, &dummy_tag)); in BM_Pass1Cpp()
112 GPR_ASSERT(grpc_cq_begin_op(cq, nullptr)); in BM_Pass1Core()
131 GPR_ASSERT(grpc_cq_begin_op(cq, nullptr)); in BM_Pluck1Core()
226 GPR_ASSERT(grpc_cq_begin_op(cc, &tag_cb)); in BM_Callback_CQ_Pass1Core()
271 GPR_ASSERT(grpc_cq_begin_op(cc, &tag_cb)); in BM_Callback_CQ_Pass1CoreHeapCompletion()
|
| D | bm_cq_multiple_threads.cc | 82 GPR_ASSERT(grpc_cq_begin_op(g_cq, tag)); in pollset_work()
|
| /third_party/grpc/test/core/surface/ |
| D | completion_queue_test.cc | 154 GPR_ASSERT(grpc_cq_begin_op(cc, tag)); in test_cq_end_op()
190 GPR_ASSERT(grpc_cq_begin_op(cc, tag)); in test_cq_tls_cache_full()
311 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_pluck()
323 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_pluck()
449 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_callback()
|
| D | completion_queue_threading_test.cc | 111 GPR_ASSERT(grpc_cq_begin_op(cc, tags[i])); in test_too_many_plucks()
154 GPR_ASSERT(grpc_cq_begin_op(opt->cc, (void*)(intptr_t)1)); in producer_thread()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | channel_ping.cc | 62 GPR_ASSERT(grpc_cq_begin_op(cq, tag)); in grpc_channel_ping()
|
| D | completion_queue.h | 76 bool grpc_cq_begin_op(grpc_completion_queue* cq, void* tag);
|
| D | server.cc | 801 GPR_ASSERT(grpc_cq_begin_op(cq, tag)); in ShutdownAndNotify()
872 if (grpc_cq_begin_op(cq_for_notification, tag) == false) { in ValidateServerRequest()
|
| D | call.cc | 1573 GPR_ASSERT(grpc_cq_begin_op(call->cq, notify_tag)); in call_start_batch()
1925 GPR_ASSERT(grpc_cq_begin_op(call->cq, notify_tag)); in call_start_batch()
|
| D | completion_queue.cc | 674 bool grpc_cq_begin_op(grpc_completion_queue* cq, void* tag) { function
|
| /third_party/grpc/src/cpp/common/ |
| D | alarm.cc | 56 GPR_ASSERT(grpc_cq_begin_op(cq_, this)); in Set()
|
| /third_party/grpc/ |
| D | libgrpc.map | 164 "grpc_cq_begin_op(grpc_completion_queue*, void*)";
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | channel_connectivity.cc | 234 GPR_ASSERT(grpc_cq_begin_op(cq, tag)); in grpc_channel_watch_connectivity_state()
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker.cc | 446 GPR_ASSERT(grpc_cq_begin_op(grpc_alts_get_shared_resource_dedicated()->cq, in alts_tsi_handshaker_continue_handshaker_next()
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 193 grpc_cq_begin_op(notification_cq_->cq(), this); in ContinueFinalizeResultAfterInterception()
|