Home
last modified time | relevance | path

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

1234

/dports/devel/grpc/grpc-1.42.0/src/core/lib/surface/
H A 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; argument
82 void (*done)(void* done_arg, grpc_cq_completion* storage),
83 void* done_arg, grpc_cq_completion* storage,
H A Dcompletion_queue.cc230 bool Push(grpc_cq_completion* c);
231 grpc_cq_completion* Pop();
287 grpc_cq_completion completed_head;
288 grpc_cq_completion* completed_tail;
482 grpc_cq_completion* CqEventQueue::Pop() { in Pop()
483 grpc_cq_completion* c = nullptr; in Pop()
898 grpc_cq_completion* stolen_completion;
999 grpc_cq_completion* c = cqd->queue.Pop();
1173 grpc_cq_completion* c;
1204 grpc_cq_completion* c;
[all …]
H A Dchannel_ping.cc34 grpc_cq_completion completion_storage;
36 static void ping_destroy(void* arg, grpc_cq_completion* /*storage*/) { in ping_destroy() argument
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/surface/
H A 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,
H A Dcompletion_queue.cc230 bool Push(grpc_cq_completion* c);
231 grpc_cq_completion* Pop();
287 grpc_cq_completion completed_head;
288 grpc_cq_completion* completed_tail;
461 grpc_cq_completion* storage = in grpc_completion_queue_thread_local_cache_flush()
492 grpc_cq_completion* CqEventQueue::Pop() { in Pop()
493 grpc_cq_completion* c = nullptr; in Pop()
911 grpc_cq_completion* stolen_completion;
1181 grpc_cq_completion* c;
1212 grpc_cq_completion* c;
[all …]
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/surface/
H A 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; argument
81 void (*done)(void* done_arg, grpc_cq_completion* storage),
82 void* done_arg, grpc_cq_completion* storage,
H A Dcompletion_queue.cc231 bool Push(grpc_cq_completion* c);
232 grpc_cq_completion* Pop();
288 grpc_cq_completion completed_head;
289 grpc_cq_completion* completed_tail;
458 grpc_cq_completion* storage = in grpc_completion_queue_thread_local_cache_flush()
489 grpc_cq_completion* CqEventQueue::Pop() { in Pop()
490 grpc_cq_completion* c = nullptr; in Pop()
907 grpc_cq_completion* stolen_completion;
1177 grpc_cq_completion* c;
1208 grpc_cq_completion* c;
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/surface/
H A 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,
H A Dcompletion_queue.cc228 bool Push(grpc_cq_completion* c);
229 grpc_cq_completion* Pop();
273 grpc_cq_completion completed_head;
274 grpc_cq_completion* completed_tail;
439 grpc_cq_completion* storage = in grpc_completion_queue_thread_local_cache_flush()
469 grpc_cq_completion* CqEventQueue::Pop() { in Pop()
470 grpc_cq_completion* c = nullptr; in Pop()
884 grpc_cq_completion* stolen_completion;
1161 grpc_cq_completion* c;
1192 grpc_cq_completion* c;
[all …]
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/surface/
H A 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; argument
82 void (*done)(void* done_arg, grpc_cq_completion* storage),
83 void* done_arg, grpc_cq_completion* storage,
H A Dcompletion_queue.cc230 bool Push(grpc_cq_completion* c);
231 grpc_cq_completion* Pop();
287 grpc_cq_completion completed_head;
288 grpc_cq_completion* completed_tail;
482 grpc_cq_completion* CqEventQueue::Pop() { in Pop()
483 grpc_cq_completion* c = nullptr; in Pop()
898 grpc_cq_completion* stolen_completion;
999 grpc_cq_completion* c = cqd->queue.Pop();
1173 grpc_cq_completion* c;
1204 grpc_cq_completion* c;
[all …]
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/surface/
H A 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
82 void (*done)(void* done_arg, grpc_cq_completion* storage),
83 void* done_arg, grpc_cq_completion* storage,
H A Dcompletion_queue.cc230 bool Push(grpc_cq_completion* c);
231 grpc_cq_completion* Pop();
287 grpc_cq_completion completed_head;
288 grpc_cq_completion* completed_tail;
482 grpc_cq_completion* CqEventQueue::Pop() { in Pop()
483 grpc_cq_completion* c = nullptr; in Pop()
898 grpc_cq_completion* stolen_completion;
999 grpc_cq_completion* c = cqd->queue.Pop();
1173 grpc_cq_completion* c;
1204 grpc_cq_completion* c;
[all …]
/dports/devel/grpc134/grpc-1.34.1/test/cpp/microbenchmarks/
H A Dbm_cq.cc70 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()
230 grpc_cq_completion completion; in BM_Callback_CQ_Pass1Core()
275 grpc_cq_completion* completion = new grpc_cq_completion; in BM_Callback_CQ_Pass1CoreHeapCompletion()
H A Dbm_cq_multiple_threads.cc65 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()
/dports/devel/grpc/grpc-1.42.0/test/cpp/microbenchmarks/
H A Dbm_cq.cc71 grpc_cq_completion* /*completion*/) {} in DoneWithCompletionOnStack() argument
74 grpc_cq_completion* completion) { in DoneWithCompletionOnHeap()
90 grpc_cq_completion completion; in BM_Pass1Cpp()
111 grpc_cq_completion completion; in BM_Pass1Core()
130 grpc_cq_completion completion; in BM_Pluck1Core()
231 grpc_cq_completion completion; in BM_Callback_CQ_Pass1Core()
276 grpc_cq_completion* completion = new grpc_cq_completion; in BM_Callback_CQ_Pass1CoreHeapCompletion()
H A Dbm_cq_multiple_threads.cc67 static void cq_done_cb(void* /*done_arg*/, grpc_cq_completion* cq_completion) { in cq_done_cb()
87 static_cast<grpc_cq_completion*>(gpr_malloc(sizeof(grpc_cq_completion)))); in pollset_work()
/dports/devel/grpc130/grpc-1.30.2/test/cpp/microbenchmarks/
H A Dbm_cq.cc69 grpc_cq_completion* /*completion*/) {} in DoneWithCompletionOnStack() argument
83 grpc_cq_completion completion; in BM_Pass1Cpp()
104 grpc_cq_completion completion; in BM_Pass1Core()
123 grpc_cq_completion completion; in BM_Pluck1Core()
212 grpc_cq_completion completion; in BM_Callback_CQ_Pass1Core()
H A Dbm_cq_multiple_threads.cc64 static void cq_done_cb(void* /*done_arg*/, grpc_cq_completion* cq_completion) { in cq_done_cb()
84 static_cast<grpc_cq_completion*>(gpr_malloc(sizeof(grpc_cq_completion)))); in pollset_work()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/cpp/microbenchmarks/
H A Dbm_cq.cc69 grpc_cq_completion* completion) {} in DoneWithCompletionOnStack()
81 grpc_cq_completion completion; in BM_Pass1Cpp()
102 grpc_cq_completion completion; in BM_Pass1Core()
121 grpc_cq_completion completion; in BM_Pluck1Core()
208 grpc_cq_completion completion; in BM_Callback_CQ_Pass1Core()
H A 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()
/dports/devel/grpc130/grpc-1.30.2/test/core/surface/
H A Dcompletion_queue_threading_test.cc64 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()
/dports/devel/grpc/grpc-1.42.0/test/core/surface/
H A Dcompletion_queue_threading_test.cc63 grpc_cq_completion* /*c*/) {} in do_nothing_end_completion() argument
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()
/dports/devel/grpc134/grpc-1.34.1/test/core/surface/
H A Dcompletion_queue_threading_test.cc64 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()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/surface/
H A 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()

1234