| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_threadpool.cc | 65 class AddAnotherFunctor : public grpc_experimental_completion_queue_functor {
77 static void Run(grpc_experimental_completion_queue_functor* cb, int /*ok*/) { in Run()
131 class SuicideFunctorForAdd : public grpc_experimental_completion_queue_functor {
140 static void Run(grpc_experimental_completion_queue_functor* cb, int /*ok*/) { in Run()
182 class AddSelfFunctor : public grpc_experimental_completion_queue_functor {
194 static void Run(grpc_experimental_completion_queue_functor* cb, int /*ok*/) { in Run()
262 : public grpc_experimental_completion_queue_functor {
273 static void Run(grpc_experimental_completion_queue_functor* cb, int /*ok*/) { in Run()
|
| D | bm_cq.cc | 165 class TagCallback : public grpc_experimental_completion_queue_functor {
172 static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { in Run()
185 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
192 static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { in Run()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| D | callback_common.pxd.pxi | 28 # functor: A grpc_experimental_completion_queue_functor represents the
36 grpc_experimental_completion_queue_functor functor
50 grpc_experimental_completion_queue_functor* functor,
53 cdef grpc_experimental_completion_queue_functor *c_functor(self)
|
| D | callback_common.pyx.pxi | 52 grpc_experimental_completion_queue_functor* functor,
63 cdef grpc_experimental_completion_queue_functor *c_functor(self):
|
| D | completion_queue.pyx.pxi | 166 <grpc_experimental_completion_queue_functor *>event.tag,
|
| /third_party/grpc/include/grpc/impl/codegen/ |
| D | grpc_types.h | 743 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;
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | callback_common.h | 70 : 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()
|
| D | completion_queue_impl.h | 441 grpc_experimental_completion_queue_functor* shutdown_cb) in ServerCompletionQueue()
|
| D | completion_queue.h | 443 grpc_experimental_completion_queue_functor* shutdown_cb) in ServerCompletionQueue()
|
| /third_party/grpc/test/core/iomgr/ |
| D | threadpool_test.cc | 47 class SimpleFunctorForAdd : public grpc_experimental_completion_queue_functor {
57 static void Run(struct grpc_experimental_completion_queue_functor* cb, in Run()
142 : public grpc_experimental_completion_queue_functor {
150 static void Run(struct grpc_experimental_completion_queue_functor* cb, in Run()
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | connectivity.cc | 37 grpc_experimental_completion_queue_functor functor;
40 grpc_experimental_completion_queue_functor* functor, int success)) { in CallbackContext()
178 grpc_experimental_completion_queue_functor* functor, int success) { in cb_watch_connectivity()
189 static void cb_shutdown(grpc_experimental_completion_queue_functor* functor, in cb_shutdown()
|
| /third_party/grpc/src/core/lib/iomgr/executor/ |
| D | threadpool.h | 46 virtual void Add(grpc_experimental_completion_queue_functor* closure) = 0;
123 void Add(grpc_experimental_completion_queue_functor* closure) override;
|
| D | threadpool.cc | 45 static_cast<grpc_experimental_completion_queue_functor*>(elem); in Run()
123 void ThreadPool::Add(grpc_experimental_completion_queue_functor* closure) { in Add()
|
| /third_party/grpc/test/core/end2end/ |
| D | inproc_callback_test.cc | 40 class CQDeletingCallback : public grpc_experimental_completion_queue_functor {
47 static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { in Run()
58 grpc_experimental_completion_queue_functor* NewDeletingCallback(F f) { in NewDeletingCallback()
62 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
74 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
187 static grpc_experimental_completion_queue_functor* tag(intptr_t t) { in tag()
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | exec_ctx.h | 352 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};
|
| /third_party/grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 201 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 …]
|
| D | completion_queue_factory.cc | 75 grpc_experimental_completion_queue_functor* shutdown_callback, in grpc_completion_queue_create_for_callback()
|
| D | completion_queue.h | 95 grpc_experimental_completion_queue_functor* shutdown_callback);
|
| D | server.h | 52 grpc_experimental_completion_queue_functor* tag;
62 grpc_experimental_completion_queue_functor* tag;
|
| /third_party/grpc/test/core/surface/ |
| D | completion_queue_test.cc | 381 class ShutdownCallback : public grpc_experimental_completion_queue_functor { in test_callback()
388 static void Run(grpc_experimental_completion_queue_functor* cb, int ok) { in test_callback()
416 class TagCallback : public grpc_experimental_completion_queue_functor { in test_callback()
424 static void Run(grpc_experimental_completion_queue_functor* cb, in test_callback()
|
| /third_party/grpc/src/cpp/client/ |
| D | channel_cc.cc | 209 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
225 static void Run(grpc_experimental_completion_queue_functor* cb, int) { in Run()
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 265 class ShutdownCallback : public grpc_experimental_completion_queue_functor {
281 static void Run(grpc_experimental_completion_queue_functor* cb, int) { in Run()
603 class CallbackCallTag : public grpc_experimental_completion_queue_functor {
626 static void StaticRun(grpc_experimental_completion_queue_functor* cb, in StaticRun()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | grpc.pxi | 45 ctypedef struct grpc_experimental_completion_queue_functor:
46 void (*functor_run)(grpc_experimental_completion_queue_functor*, int);
361 grpc_experimental_completion_queue_functor* shutdown_callback,
|
| /third_party/grpc/include/grpc/ |
| D | grpc.h | 118 grpc_experimental_completion_queue_functor* shutdown_callback,
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_grpc_imports.generated.h | 113 …ueue*(*grpc_completion_queue_create_for_callback_type)(grpc_experimental_completion_queue_functor*…
|