Home
last modified time | relevance | path

Searched refs:grpc_completion_queue_functor (Results 1 – 25 of 36) sorted by relevance

12

/aosp_15_r20/external/grpc-grpc/include/grpc/impl/
H A Dgrpc_types.h444 typedef struct grpc_completion_queue_functor { struct
449 void (*functor_run)(struct grpc_completion_queue_functor*, int); argument
457 struct grpc_completion_queue_functor* internal_next; argument
458 } grpc_completion_queue_functor; typedef
476 grpc_completion_queue_functor* cq_shutdown_cb;
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/
Dgrpc_types.h802 typedef struct grpc_completion_queue_functor { struct
807 void (*functor_run)(struct grpc_completion_queue_functor*, int); argument
815 struct grpc_completion_queue_functor* internal_next; argument
816 } grpc_completion_queue_functor; typedef
834 grpc_completion_queue_functor* cq_shutdown_cb;
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpc/impl/
Dgrpc_types.h802 typedef struct grpc_completion_queue_functor { struct
807 void (*functor_run)(struct grpc_completion_queue_functor*, int); argument
815 struct grpc_completion_queue_functor* internal_next; argument
816 } grpc_completion_queue_functor; typedef
834 grpc_completion_queue_functor* cq_shutdown_cb;
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/
H A Dcallback_common.pxd.pxi28 # functor: A grpc_completion_queue_functor represents the
36 grpc_completion_queue_functor functor
50 grpc_completion_queue_functor* functor,
53 cdef grpc_completion_queue_functor *c_functor(self)
H A Dcallback_common.pyx.pxi52 grpc_completion_queue_functor* functor,
63 cdef grpc_completion_queue_functor *c_functor(self):
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/support/
Dcallback_common.h70 class CallbackWithStatusTag : public grpc_completion_queue_functor {
111 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
136 class CallbackWithSuccessTag : public grpc_completion_queue_functor {
199 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
/aosp_15_r20/external/grpc-grpc/include/grpcpp/support/
H A Dcallback_common.h70 class CallbackWithStatusTag : public grpc_completion_queue_functor {
111 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
136 class CallbackWithSuccessTag : public grpc_completion_queue_functor {
199 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpcpp/support/
Dcallback_common.h70 class CallbackWithStatusTag : public grpc_completion_queue_functor {
111 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
136 class CallbackWithSuccessTag : public grpc_completion_queue_functor {
199 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
/aosp_15_r20/external/grpc-grpc/src/core/lib/surface/
H A Dcompletion_queue.cc213 void (*init)(void* data, grpc_completion_queue_functor* shutdown_callback);
325 explicit cq_callback_data(grpc_completion_queue_functor* shutdown_callback) in cq_callback_data()
346 grpc_completion_queue_functor* shutdown_callback;
416 grpc_completion_queue_functor* shutdown_callback);
418 grpc_completion_queue_functor* shutdown_callback);
420 grpc_completion_queue_functor* shutdown_callback);
515 grpc_completion_queue_functor* shutdown_callback) { in grpc_completion_queue_create_internal()
561 grpc_completion_queue_functor* /*shutdown_callback*/) { in cq_init_next() argument
571 void* data, grpc_completion_queue_functor* /*shutdown_callback*/) { in cq_init_pluck() argument
581 grpc_completion_queue_functor* shutdown_callback) { in cq_init_callback()
[all …]
H A Dcompletion_queue_factory.cc80 grpc_completion_queue_functor* shutdown_callback, void* reserved) { in grpc_completion_queue_create_for_callback()
H A Dcompletion_queue.h98 grpc_completion_queue_functor* shutdown_callback);
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcompletion_queue.cc210 void (*init)(void* data, grpc_completion_queue_functor* shutdown_callback);
322 explicit cq_callback_data(grpc_completion_queue_functor* shutdown_callback) in cq_callback_data()
343 grpc_completion_queue_functor* shutdown_callback;
413 grpc_completion_queue_functor* shutdown_callback);
415 grpc_completion_queue_functor* shutdown_callback);
417 grpc_completion_queue_functor* shutdown_callback);
512 grpc_completion_queue_functor* shutdown_callback) { in grpc_completion_queue_create_internal()
558 grpc_completion_queue_functor* /*shutdown_callback*/) { in cq_init_next() argument
568 void* data, grpc_completion_queue_functor* /*shutdown_callback*/) { in cq_init_pluck() argument
578 grpc_completion_queue_functor* shutdown_callback) { in cq_init_callback()
[all …]
Dcompletion_queue_factory.cc80 grpc_completion_queue_functor* shutdown_callback, void* reserved) { in grpc_completion_queue_create_for_callback()
Dcompletion_queue.h98 grpc_completion_queue_functor* shutdown_callback);
/aosp_15_r20/external/grpc-grpc/test/cpp/microbenchmarks/
H A Dbm_cq.cc154 class TagCallback : public grpc_completion_queue_functor {
161 static void Run(grpc_completion_queue_functor* cb, int ok) { in Run()
174 class ShutdownCallback : public grpc_completion_queue_functor {
181 static void Run(grpc_completion_queue_functor* cb, int ok) { in Run()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dexec_ctx.h308 static void Enqueue(grpc_completion_queue_functor* functor, int is_success) { in Enqueue()
327 grpc_completion_queue_functor* head_{nullptr};
328 grpc_completion_queue_functor* tail_{nullptr};
/aosp_15_r20/external/grpc-grpc/src/core/lib/iomgr/
H A Dexec_ctx.h335 static void Enqueue(grpc_completion_queue_functor* functor, int is_success) { in Enqueue()
354 grpc_completion_queue_functor* head_{nullptr};
355 grpc_completion_queue_functor* tail_{nullptr};
/aosp_15_r20/external/grpc-grpc/test/core/surface/
H A Dcompletion_queue_test.cc388 class ShutdownCallback : public grpc_completion_queue_functor { in TEST()
395 static void Run(grpc_completion_queue_functor* cb, int ok) { in TEST()
423 class TagCallback : public grpc_completion_queue_functor { in TEST()
431 static void Run(grpc_completion_queue_functor* cb, int ok) { in TEST()
/aosp_15_r20/external/grpc-grpc/src/cpp/client/
H A Dchannel_cc.cc215 class ShutdownCallback : public grpc_completion_queue_functor {
231 static void Run(grpc_completion_queue_functor* cb, int) { in Run()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/client/
Dchannel_cc.cc215 class ShutdownCallback : public grpc_completion_queue_functor {
231 static void Run(grpc_completion_queue_functor* cb, int) { in Run()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_cc.cc297 class ShutdownCallback : public grpc_completion_queue_functor {
313 static void Run(grpc_completion_queue_functor* cb, int) { in Run()
614 class CallbackCallTag : public grpc_completion_queue_functor {
637 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
/aosp_15_r20/external/grpc-grpc/src/cpp/server/
H A Dserver_cc.cc299 class ShutdownCallback : public grpc_completion_queue_functor {
315 static void Run(grpc_completion_queue_functor* cb, int) { in Run()
616 class CallbackCallTag : public grpc_completion_queue_functor {
639 static void StaticRun(grpc_completion_queue_functor* cb, int ok) { in StaticRun()
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
H A Dgrpc.pxi100 ctypedef struct grpc_completion_queue_functor:
101 void (*functor_run)(grpc_completion_queue_functor*, int);
417 grpc_completion_queue_functor* shutdown_callback,
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/common/
Dcompletion_queue_cc.cc93 static_cast<grpc_completion_queue_functor*>(ev.tag); in Ref()
/aosp_15_r20/external/grpc-grpc/src/cpp/common/
H A Dcompletion_queue_cc.cc93 static_cast<grpc_completion_queue_functor*>(ev.tag); in Ref()

12