| /external/grpc-grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 363 #define DATA_FROM_CQ(cq) ((void*)(cq + 1)) argument
364 #define POLLSET_FROM_CQ(cq) \ argument
369 #define GRPC_SURFACE_TRACE_RETURNED_EVENT(cq, event) \ argument
384 void grpc_completion_queue_thread_local_cache_init(grpc_completion_queue* cq) { in grpc_completion_queue_thread_local_cache_init()
391 int grpc_completion_queue_thread_local_cache_flush(grpc_completion_queue* cq, in grpc_completion_queue_thread_local_cache_flush()
469 grpc_completion_queue* cq; in grpc_completion_queue_create_internal() local
547 grpc_cq_completion_type grpc_get_cq_completion_type(grpc_completion_queue* cq) { in grpc_get_cq_completion_type()
551 int grpc_get_cq_poll_num(grpc_completion_queue* cq) { in grpc_get_cq_poll_num()
560 void grpc_cq_internal_ref(grpc_completion_queue* cq, const char* reason,
575 grpc_completion_queue* cq = static_cast<grpc_completion_queue*>(arg); local
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 426 #define DATA_FROM_CQ(cq) ((void*)((cq) + 1)) argument
427 #define POLLSET_FROM_CQ(cq) \ argument
432 #define GRPC_SURFACE_TRACE_RETURNED_EVENT(cq, event) \ argument
449 void grpc_completion_queue_thread_local_cache_init(grpc_completion_queue* cq) { in grpc_completion_queue_thread_local_cache_init()
457 int grpc_completion_queue_thread_local_cache_flush(grpc_completion_queue* cq, in grpc_completion_queue_thread_local_cache_flush()
519 grpc_completion_queue* cq; in grpc_completion_queue_create_internal() local
583 grpc_cq_completion_type grpc_get_cq_completion_type(grpc_completion_queue* cq) { in grpc_get_cq_completion_type()
587 int grpc_get_cq_poll_num(grpc_completion_queue* cq) { in grpc_get_cq_poll_num()
596 void grpc_cq_internal_ref(grpc_completion_queue* cq, const char* reason,
608 grpc_completion_queue* cq = static_cast<grpc_completion_queue*>(arg); local
[all …]
|
| D | completion_queue.h | 58 #define GRPC_CQ_INTERNAL_REF(cq, reason) \ argument
60 #define GRPC_CQ_INTERNAL_UNREF(cq, reason) \ argument
65 #define GRPC_CQ_INTERNAL_REF(cq, reason) grpc_cq_internal_ref(cq) argument
66 #define GRPC_CQ_INTERNAL_UNREF(cq, reason) grpc_cq_internal_unref(cq) argument
|
| /external/flatbuffers/tests/ |
| D | monster_test.grpc.fb.cc | 42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStoreRaw()
46 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStoreRaw()
54 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieveRaw()
58 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieveRaw()
66 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPointRaw()
70 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPointRaw()
78 …ub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPointsRaw()
82 …b::PrepareAsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPointsRaw()
|
| D | monster_test_generated.grpc.fb.cc | 41 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStoreRaw()
45 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStoreRaw()
53 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieveRaw()
57 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieveRaw()
65 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPointRaw()
69 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPointRaw()
77 …ub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPointsRaw()
81 …b::PrepareAsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPointsRaw()
|
| D | monster_test_generated.grpc.fb.h | 39 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
48 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …tat>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
89 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
92 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
[all …]
|
| D | monster_test.grpc.fb.h | 39 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
48 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …tat>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
89 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
92 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
[all …]
|
| /external/flatbuffers/tests/monster_test_suffix/ext_only/ |
| D | monster_test.grpc.fb.cc | 42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStoreRaw()
46 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStoreRaw()
54 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieveRaw()
58 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieveRaw()
66 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPointRaw()
70 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPointRaw()
78 …ub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPointsRaw()
82 …b::PrepareAsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPointsRaw()
|
| D | monster_test.grpc.fb.h | 39 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
48 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …tat>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
89 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
92 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
[all …]
|
| /external/flatbuffers/tests/monster_test_suffix/filesuffix_only/ |
| D | monster_test.grpc.fb.cc | 42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStoreRaw()
46 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStoreRaw()
54 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieveRaw()
58 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieveRaw()
66 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPointRaw()
70 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPointRaw()
78 …ub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPointsRaw()
82 …b::PrepareAsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPointsRaw()
|
| D | monster_test.grpc.fb.h | 39 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
48 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …tat>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
89 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
92 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
[all …]
|
| /external/flatbuffers/tests/monster_test_suffix/ |
| D | monster_test.grpc.fb.cc | 42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStoreRaw()
46 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStoreRaw()
54 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieveRaw()
58 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieveRaw()
66 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPointRaw()
70 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPointRaw()
78 …ub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPointsRaw()
82 …b::PrepareAsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPointsRaw()
|
| D | monster_test.grpc.fb.h | 39 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
42 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
48 …ext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* … in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …tContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* … in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …tat>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* … in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
89 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in AsyncStore()
92 …ontext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncStore()
[all …]
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 40 CompletionQueue cq; in BM_CreateDestroyCpp() local
52 CompletionQueue cq(core_cq); in BM_CreateDestroyCpp2() local
80 CompletionQueue cq; in BM_Pass1Cpp() local
101 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in BM_Pass1Core() local
120 grpc_completion_queue* cq = grpc_completion_queue_create_for_pluck(nullptr); in BM_Pluck1Core() local
139 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in BM_EmptyCore() local
|
| /external/grpc-grpc/src/cpp/client/ |
| D | generic_stub.cc | 30 const grpc::string& method, CompletionQueue* cq, bool start, void* tag) { in CallInternal()
43 ClientContext* context, const grpc::string& method, CompletionQueue* cq, in Call()
50 ClientContext* context, const grpc::string& method, CompletionQueue* cq) { in PrepareCall()
57 const ByteBuffer& request, CompletionQueue* cq) { in PrepareUnaryCall()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | call.h | 43 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq) in Call()
49 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
57 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
70 ::grpc::CompletionQueue* cq() const { return cq_; } in cq() function
|
| D | delegating_channel.h | 48 ::grpc::CompletionQueue* cq) final { in CreateCall()
63 ::grpc::CompletionQueue* cq, in NotifyOnStateChangeImpl()
76 ::grpc::CompletionQueue* cq, in CreateCallInternal()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | call.h | 43 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq) in Call()
49 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
57 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
70 ::grpc::CompletionQueue* cq() const { return cq_; } in cq() function
|
| D | delegating_channel.h | 48 ::grpc::CompletionQueue* cq) final { in CreateCall()
63 ::grpc::CompletionQueue* cq, in NotifyOnStateChangeImpl()
76 ::grpc::CompletionQueue* cq, in CreateCallInternal()
|
| /external/grpc-grpc/test/cpp/common/ |
| D | alarm_test.cc | 35 CompletionQueue cq; in TEST() local
111 CompletionQueue cq; in TEST() local
135 CompletionQueue cq; in TEST() local
150 CompletionQueue cq; in TEST() local
165 CompletionQueue cq; in TEST() local
183 CompletionQueue cq; in TEST() local
201 CompletionQueue cq; in TEST() local
217 CompletionQueue cq; in TEST() local
233 CompletionQueue cq; in TEST() local
270 CompletionQueue cq; in TEST() local
[all …]
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_async.cc | 85 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
111 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
138 void StartInternal(CompletionQueue* cq) { in StartInternal()
186 auto* cq = cli_cqs_[t].get(); in AsyncClient() local
195 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in ~AsyncClient() local
206 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in GetPollCount() local
235 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in DestroyMultithreading() local
323 const SimpleRequest& request, CompletionQueue* cq) { in PrepareReq()
357 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
426 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 33 Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq); in HandleCall()
52 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall()
116 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall()
179 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall()
242 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall()
309 public Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall()
|
| /external/grpc-grpc/test/core/surface/ |
| D | num_external_connectivity_watchers_test.cc | 40 grpc_completion_queue* cq) { in channel_idle_start_watch()
52 grpc_completion_queue* cq) { in channel_idle_poll_for_timeout()
76 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in run_timeouts_test() local
130 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in run_channel_shutdown_before_timeout_test() local
|
| /external/tensorflow/tensorflow/core/tpu/kernels/ |
| D | tpu_compilation_cache_grpc.h | 79 ::grpc::CompletionQueue* cq) { in AsyncGetTpuProgram()
87 ::grpc::CompletionQueue* cq) { in PrepareAsyncGetTpuProgram()
112 ::grpc::CompletionQueue* cq) { in AsyncGetTpuProgram()
119 ::grpc::CompletionQueue* cq) { in PrepareAsyncGetTpuProgram()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | h2_ssl_session_reuse_test.cc | 48 grpc_server* server_create(grpc_completion_queue* cq, char* server_addr) { in server_create()
94 void do_round_trip(grpc_completion_queue* cq, grpc_server* server, in do_round_trip()
208 void drain_cq(grpc_completion_queue* cq) { in drain_cq()
221 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in TEST() local
|