| /third_party/grpc/src/core/lib/surface/ |
| D | completion_queue.h | 39 typedef struct grpc_cq_completion { struct
47 void (*done)(void* done_arg, struct grpc_cq_completion* c); argument
51 } grpc_cq_completion; typedef
81 void (*done)(void* done_arg, grpc_cq_completion* storage),
82 void* done_arg, grpc_cq_completion* storage,
|
| D | completion_queue.cc | 206 void (*done)(void* done_arg, grpc_cq_completion* storage),
207 void* done_arg, grpc_cq_completion* storage, bool internal);
231 bool Push(grpc_cq_completion* c);
232 grpc_cq_completion* Pop();
288 grpc_cq_completion completed_head;
289 grpc_cq_completion* completed_tail;
380 void (*done)(void* done_arg, grpc_cq_completion* storage), void* done_arg,
381 grpc_cq_completion* storage, bool internal);
385 void (*done)(void* done_arg, grpc_cq_completion* storage), void* done_arg,
386 grpc_cq_completion* storage, bool internal);
[all …]
|
| D | channel_ping.cc | 35 grpc_cq_completion completion_storage;
37 static void ping_destroy(void* arg, grpc_cq_completion* /*storage*/) { in ping_destroy() argument
|
| D | server.h | 331 grpc_cq_completion completion;
337 grpc_cq_completion* /*completion*/) { in DoneShutdownEvent() argument
341 static void DoneRequestEvent(void* req, grpc_cq_completion* completion);
|
| D | call.cc | 95 grpc_cq_completion cq_completion;
1166 grpc_cq_completion* /*storage*/) { in finish_batch_completion() argument
1551 static void free_no_op_completion(void* /*p*/, grpc_cq_completion* completion) { in free_no_op_completion()
1576 static_cast<grpc_cq_completion*>( in call_start_batch()
1577 gpr_malloc(sizeof(grpc_cq_completion)))); in call_start_batch()
|
| D | server.cc | 100 grpc_cq_completion completion;
699 void Server::DoneRequestEvent(void* req, grpc_cq_completion* /*c*/) { in DoneRequestEvent() argument
774 void DonePublishedShutdown(void* /*done_arg*/, grpc_cq_completion* storage) { in DonePublishedShutdown()
804 new grpc_cq_completion); in ShutdownAndNotify()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 70 grpc_cq_completion* /*completion*/) {} in DoneWithCompletionOnStack() argument
73 grpc_cq_completion* completion) { in DoneWithCompletionOnHeap()
89 grpc_cq_completion completion; in BM_Pass1Cpp()
110 grpc_cq_completion completion; in BM_Pass1Core()
129 grpc_cq_completion completion; in BM_Pluck1Core()
225 grpc_cq_completion completion; in BM_Callback_CQ_Pass1Core()
270 grpc_cq_completion* completion = new grpc_cq_completion; in BM_Callback_CQ_Pass1CoreHeapCompletion()
|
| D | bm_cq_multiple_threads.cc | 65 static void cq_done_cb(void* /*done_arg*/, grpc_cq_completion* cq_completion) { in cq_done_cb()
85 static_cast<grpc_cq_completion*>(gpr_malloc(sizeof(grpc_cq_completion)))); in pollset_work()
|
| /third_party/grpc/test/core/surface/ |
| D | completion_queue_threading_test.cc | 64 grpc_cq_completion* /*c*/) {} in do_nothing_end_completion() argument
81 grpc_cq_completion completions[GPR_ARRAY_SIZE(tags)]; in test_too_many_plucks()
140 static void free_completion(void* /*arg*/, grpc_cq_completion* completion) { in free_completion()
166 static_cast<grpc_cq_completion*>( in producer_thread()
167 gpr_malloc(sizeof(grpc_cq_completion)))); in producer_thread()
|
| D | completion_queue_test.cc | 133 grpc_cq_completion* /*c*/) {} in do_nothing_end_completion() argument
138 grpc_cq_completion completion; in test_cq_end_op()
171 grpc_cq_completion completion; in test_cq_tls_cache_full()
287 grpc_cq_completion completions[GPR_ARRAY_SIZE(tags)]; in test_pluck()
365 grpc_cq_completion completions[GPR_ARRAY_SIZE(tags)]; in test_callback()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | channel_connectivity.cc | 74 grpc_cq_completion completion_storage;
93 static void finished_completion(void* pw, grpc_cq_completion* /*ignored*/) { in finished_completion() argument
118 grpc_cq_completion* end_op_completion_storage = nullptr; in partly_done()
|
| /third_party/grpc/src/cpp/common/ |
| D | alarm.cc | 69 [](void* /*arg*/, grpc_cq_completion* /*completion*/) {}, arg, in Set() argument
121 grpc_cq_completion completion_;
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_shared_resource.h | 39 grpc_cq_completion storage;
|
| D | alts_tsi_handshaker.cc | 399 [](void* /*done_arg*/, grpc_cq_completion* /*storage*/) {}, nullptr, in on_handshaker_service_resp_recv_dedicated() argument
|
| /third_party/grpc/ |
| D | libgrpc.map | 169 …mpletion_queue*, void*, grpc_error*, void (*)(void*, grpc_cq_completion*), void*, grpc_cq_completi…
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 196 [](void* /*arg*/, grpc_cq_completion* completion) { delete completion; }, in ContinueFinalizeResultAfterInterception()
197 nullptr, new grpc_cq_completion()); in ContinueFinalizeResultAfterInterception()
|
| /third_party/grpc/doc/core/ |
| D | epoll-polling-engine.md | 26 …e thread that performs the work finally queues a completion event `grpc_cq_completion` on the appr…
|