Home
last modified time | relevance | path

Searched refs:grpc_experimental_completion_queue_functor (Results 1 – 25 of 29) sorted by relevance

12

/external/grpc-grpc/include/grpcpp/impl/codegen/
Dcallback_common.h53 : public grpc_experimental_completion_queue_functor {
90 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
110 : public grpc_experimental_completion_queue_functor {
143 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
/external/rust/crates/grpcio-sys/grpc/include/grpc/impl/codegen/
Dgrpc_types.h743 typedef struct grpc_experimental_completion_queue_functor { struct
748 void (*functor_run)(struct grpc_experimental_completion_queue_functor*, int); argument
756 struct grpc_experimental_completion_queue_functor* internal_next; argument
757 } grpc_experimental_completion_queue_functor; typedef
777 grpc_experimental_completion_queue_functor* cq_shutdown_cb;
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/codegen/
Dgrpc_types.h743 typedef struct grpc_experimental_completion_queue_functor { struct
748 void (*functor_run)(struct grpc_experimental_completion_queue_functor*, int); argument
756 struct grpc_experimental_completion_queue_functor* internal_next; argument
757 } grpc_experimental_completion_queue_functor; typedef
777 grpc_experimental_completion_queue_functor* cq_shutdown_cb;
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dcallback_common.h70 : public grpc_experimental_completion_queue_functor {
111 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
138 : public grpc_experimental_completion_queue_functor {
201 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dcallback_common.h70 : public grpc_experimental_completion_queue_functor {
111 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
138 : public grpc_experimental_completion_queue_functor {
201 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
Dcompletion_queue.h443 grpc_experimental_completion_queue_functor* shutdown_cb) in ServerCompletionQueue()
/external/grpc-grpc/include/grpc/impl/codegen/
Dgrpc_types.h668 typedef struct grpc_experimental_completion_queue_functor { struct
673 void (*functor_run)(struct grpc_experimental_completion_queue_functor*, int); argument
674 } grpc_experimental_completion_queue_functor; typedef
694 grpc_experimental_completion_queue_functor* cq_shutdown_cb;
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/
Dthreadpool.h46 virtual void Add(grpc_experimental_completion_queue_functor* closure) = 0;
123 void Add(grpc_experimental_completion_queue_functor* closure) override;
Dthreadpool.cc45 static_cast<grpc_experimental_completion_queue_functor*>(elem); in Run()
123 void ThreadPool::Add(grpc_experimental_completion_queue_functor* closure) { in Add()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dexec_ctx.h352 static void Enqueue(grpc_experimental_completion_queue_functor* functor, in Enqueue()
378 grpc_experimental_completion_queue_functor* head_{nullptr};
379 grpc_experimental_completion_queue_functor* tail_{nullptr};
/external/grpc-grpc/test/core/end2end/
Dinproc_callback_test.cc40 class CQDeletingCallback : public grpc_experimental_completion_queue_functor {
46 static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { in Run()
57 grpc_experimental_completion_queue_functor* NewDeletingCallback(F f) { in NewDeletingCallback()
61 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
69 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
182 static grpc_experimental_completion_queue_functor* tag(intptr_t t) { in tag()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcompletion_queue.cc201 grpc_experimental_completion_queue_functor* shutdown_callback);
314 grpc_experimental_completion_queue_functor* shutdown_callback) in cq_callback_data()
335 grpc_experimental_completion_queue_functor* shutdown_callback;
401 void* data, grpc_experimental_completion_queue_functor* shutdown_callback);
403 void* data, grpc_experimental_completion_queue_functor* shutdown_callback);
405 void* data, grpc_experimental_completion_queue_functor* shutdown_callback);
516 grpc_experimental_completion_queue_functor* shutdown_callback) { in grpc_completion_queue_create_internal()
553 grpc_experimental_completion_queue_functor* /*shutdown_callback*/) { in cq_init_next() argument
564 grpc_experimental_completion_queue_functor* /*shutdown_callback*/) { in cq_init_pluck() argument
574 void* data, grpc_experimental_completion_queue_functor* shutdown_callback) { in cq_init_callback()
[all …]
Dcompletion_queue_factory.cc75 grpc_experimental_completion_queue_functor* shutdown_callback, in grpc_completion_queue_create_for_callback()
Dcompletion_queue.h95 grpc_experimental_completion_queue_functor* shutdown_callback);
Dserver.h52 grpc_experimental_completion_queue_functor* tag;
62 grpc_experimental_completion_queue_functor* tag;
/external/grpc-grpc/test/core/surface/
Dcompletion_queue_test.cc372 class ShutdownCallback : public grpc_experimental_completion_queue_functor { in test_callback()
378 static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { in test_callback()
398 class TagCallback : public grpc_experimental_completion_queue_functor { in test_callback()
404 static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { in test_callback()
/external/grpc-grpc/src/core/lib/surface/
Dcompletion_queue.cc188 grpc_experimental_completion_queue_functor* shutdown_callback);
271 grpc_experimental_completion_queue_functor* shutdown_callback;
338 void* data, grpc_experimental_completion_queue_functor* shutdown_callback);
340 void* data, grpc_experimental_completion_queue_functor* shutdown_callback);
342 void* data, grpc_experimental_completion_queue_functor* shutdown_callback);
466 grpc_experimental_completion_queue_functor* shutdown_callback) { in grpc_completion_queue_create_internal()
502 void* data, grpc_experimental_completion_queue_functor* shutdown_callback) { in cq_init_next()
518 void* data, grpc_experimental_completion_queue_functor* shutdown_callback) { in cq_init_pluck()
536 void* data, grpc_experimental_completion_queue_functor* shutdown_callback) { in cq_init_callback()
863 auto* functor = static_cast<grpc_experimental_completion_queue_functor*>(tag);
Dcompletion_queue_factory.cc75 grpc_experimental_completion_queue_functor* shutdown_callback, in grpc_completion_queue_create_for_callback()
Dcompletion_queue.h92 grpc_experimental_completion_queue_functor* shutdown_callback);
/external/grpc-grpc/src/cpp/client/
Dchannel_cc.cc196 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
205 static void Run(grpc_experimental_completion_queue_functor* cb, int) { in Run()
/external/rust/crates/grpcio-sys/grpc/src/cpp/client/
Dchannel_cc.cc209 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
225 static void Run(grpc_experimental_completion_queue_functor* cb, int) { in Run()
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_cc.cc265 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
281 static void Run(grpc_experimental_completion_queue_functor* cb, int) { in Run()
593 class CallbackCallTag : public grpc_experimental_completion_queue_functor {
616 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
/external/grpc-grpc/include/grpc/
Dgrpc.h114 grpc_experimental_completion_queue_functor* shutdown_callback,
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/
Dgrpc.h118 grpc_experimental_completion_queue_functor* shutdown_callback,
/external/rust/crates/grpcio-sys/grpc/include/grpc/
Dgrpc.h118 grpc_experimental_completion_queue_functor* shutdown_callback,

12