Home
last modified time | relevance | path

Searched refs:grpc_cq_completion (Results 1 – 23 of 23) sorted by relevance

/external/grpc-grpc/src/core/lib/surface/
Dcompletion_queue.h38 typedef struct grpc_cq_completion { struct
45 void (*done)(void* done_arg, struct grpc_cq_completion* c); argument
49 } grpc_cq_completion; argument
79 void (*done)(void* done_arg, grpc_cq_completion* storage),
80 void* done_arg, grpc_cq_completion* storage);
Dcompletion_queue.cc193 void (*done)(void* done_arg, grpc_cq_completion* storage),
194 void* done_arg, grpc_cq_completion* storage);
234 grpc_cq_completion completed_head;
235 grpc_cq_completion* completed_tail;
315 grpc_cq_completion* storage),
316 void* done_arg, grpc_cq_completion* storage);
321 grpc_cq_completion* storage),
322 void* done_arg, grpc_cq_completion* storage);
327 grpc_cq_completion* storage),
328 void* done_arg, grpc_cq_completion* storage);
[all …]
Dchannel_ping.cc35 grpc_cq_completion completion_storage;
38 static void ping_destroy(void* arg, grpc_cq_completion* storage) { in ping_destroy()
Dserver.cc72 grpc_cq_completion completion;
112 grpc_cq_completion completion;
444 static void done_request_event(void* req, grpc_cq_completion* c) { in done_request_event()
638 static void done_shutdown_event(void* server, grpc_cq_completion* completion) { in done_shutdown_event()
1189 void done_published_shutdown(void* done_arg, grpc_cq_completion* storage) { in done_published_shutdown()
1239 static_cast<grpc_cq_completion*>( in grpc_server_shutdown_and_notify()
1240 gpr_malloc(sizeof(grpc_cq_completion)))); in grpc_server_shutdown_and_notify()
Dcall.cc85 grpc_cq_completion cq_completion;
1115 grpc_cq_completion* storage) { in finish_batch_completion()
1470 static void free_no_op_completion(void* p, grpc_cq_completion* completion) { in free_no_op_completion()
1495 static_cast<grpc_cq_completion*>( in call_start_batch()
1496 gpr_malloc(sizeof(grpc_cq_completion)))); in call_start_batch()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcompletion_queue.h39 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,
Dcompletion_queue.cc206 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 …]
Dchannel_ping.cc35 grpc_cq_completion completion_storage;
37 static void ping_destroy(void* arg, grpc_cq_completion* /*storage*/) { in ping_destroy() argument
Dserver.h331 grpc_cq_completion completion;
337 grpc_cq_completion* /*completion*/) { in DoneShutdownEvent() argument
341 static void DoneRequestEvent(void* req, grpc_cq_completion* completion);
Dcall.cc95 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()
Dserver.cc100 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()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_cq.cc71 grpc_cq_completion* completion) {} in DoneWithCompletionOnStack()
83 grpc_cq_completion completion; in BM_Pass1Cpp()
104 grpc_cq_completion completion; in BM_Pass1Core()
123 grpc_cq_completion completion; in BM_Pluck1Core()
Dbm_cq_multiple_threads.cc63 static void cq_done_cb(void* done_arg, grpc_cq_completion* cq_completion) { in cq_done_cb()
82 static_cast<grpc_cq_completion*>(gpr_malloc(sizeof(grpc_cq_completion)))); in pollset_work()
/external/grpc-grpc/test/core/surface/
Dcompletion_queue_threading_test.cc63 static void do_nothing_end_completion(void* arg, grpc_cq_completion* c) {} in do_nothing_end_completion()
80 grpc_cq_completion completions[GPR_ARRAY_SIZE(tags)]; in test_too_many_plucks()
139 static void free_completion(void* arg, grpc_cq_completion* completion) { in free_completion()
165 static_cast<grpc_cq_completion*>( in producer_thread()
166 gpr_malloc(sizeof(grpc_cq_completion)))); in producer_thread()
Dcompletion_queue_test.cc131 static void do_nothing_end_completion(void* arg, grpc_cq_completion* c) {} in do_nothing_end_completion()
136 grpc_cq_completion completion; in test_cq_end_op()
169 grpc_cq_completion completion; in test_cq_tls_cache_full()
285 grpc_cq_completion completions[GPR_ARRAY_SIZE(tags)]; in test_pluck()
363 grpc_cq_completion completions[GPR_ARRAY_SIZE(tags)]; in test_callback()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc74 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()
/external/grpc-grpc/src/cpp/common/
Dalarm.cc67 [](void* arg, grpc_cq_completion* completion) {}, in Set()
109 grpc_cq_completion completion_;
/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dalarm.cc69 [](void* /*arg*/, grpc_cq_completion* /*completion*/) {}, arg, in Set() argument
121 grpc_cq_completion completion_;
/external/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/
Dalts_shared_resource.h39 grpc_cq_completion storage;
Dalts_tsi_handshaker.cc399 [](void* /*done_arg*/, grpc_cq_completion* /*storage*/) {}, nullptr, in on_handshaker_service_resp_recv_dedicated() argument
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc73 grpc_cq_completion completion_storage;
92 static void finished_completion(void* pw, grpc_cq_completion* ignored) { in finished_completion()
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_cc.cc196 [](void* /*arg*/, grpc_cq_completion* completion) { delete completion; }, in ContinueFinalizeResultAfterInterception()
197 nullptr, new grpc_cq_completion()); in ContinueFinalizeResultAfterInterception()
/external/grpc-grpc/doc/
Depoll-polling-engine.md26 …e thread that performs the work finally queues a completion event `grpc_cq_completion` on the appr…