/dports/devel/grpc/grpc-1.42.0/src/core/lib/surface/ |
H A D | completion_queue.h | 39 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 D | completion_queue.cc | 230 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 D | channel_ping.cc | 34 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 D | completion_queue.h | 39 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 D | completion_queue.cc | 230 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 D | completion_queue.h | 39 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 D | completion_queue.cc | 231 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 D | completion_queue.h | 38 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 D | completion_queue.cc | 228 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 D | completion_queue.h | 39 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 D | completion_queue.cc | 230 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 D | completion_queue.h | 39 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 D | completion_queue.cc | 230 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 D | bm_cq.cc | 70 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 D | bm_cq_multiple_threads.cc | 65 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 D | bm_cq.cc | 71 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 D | bm_cq_multiple_threads.cc | 67 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 D | bm_cq.cc | 69 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 D | bm_cq_multiple_threads.cc | 64 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 D | bm_cq.cc | 69 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 D | bm_cq_multiple_threads.cc | 63 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 D | completion_queue_threading_test.cc | 64 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 D | completion_queue_threading_test.cc | 63 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 D | completion_queue_threading_test.cc | 64 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 D | completion_queue_threading_test.cc | 63 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()
|