| /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/skqp/src/compute/skc/platforms/cl_12/ |
| D | extent_cl_12_unified.c | 121 cl_command_queue const cq, in skc_extent_phrw_pdrw_map_size()
136 cl_command_queue const cq, in skc_extent_phrw_pdrw_map()
145 cl_command_queue const cq, in skc_extent_phrw_pdrw_unmap()
185 cl_command_queue const cq, in skc_extent_phrN_pdwN_map_size()
200 cl_command_queue const cq, in skc_extent_phrN_pdwN_map()
209 cl_command_queue const cq, in skc_extent_phrN_pdwN_unmap()
249 cl_command_queue const cq, in skc_extent_phwN_pdrN_map_size()
264 cl_command_queue const cq, in skc_extent_phwN_pdrN_map()
273 cl_command_queue const cq, in skc_extent_phwN_pdrN_unmap()
|
| D | cq_pool_cl.c | 51 cl_command_queue cq; in skc_runtime_cl_12_create_cq() local
141 cl_command_queue cq) in skc_cq_pool_write()
186 cl_command_queue cq = pool->cq[pool->reads++ % pool->size]; in skc_cq_pool_read() local
203 cl_command_queue cq) in skc_runtime_release_cq_in_order()
|
| D | runtime_cl_12.c | 36 skc_block_pool_create(struct skc_runtime * const runtime, cl_command_queue cq) in skc_block_pool_create()
163 cl_command_queue cq = skc_runtime_acquire_cq_in_order(runtime); in skc_runtime_cl_12_create() local
251 cl_command_queue cq = skc_runtime_acquire_cq_in_order(runtime); in skc_runtime_cl_12_debug() local
|
| D | extent_cl_12.c | 83 cl_command_queue const cq, in skc_extent_tdrw_zero()
124 cl_command_queue const cq, in skc_extent_phr_pdrw_read()
141 cl_command_queue const cq, in skc_extent_phr_pdrw_zero()
188 cl_command_queue const cq, in skc_extent_thr_tdrw_read()
205 cl_command_queue const cq, in skc_extent_thr_tdrw_zero()
253 cl_command_queue const cq, in skc_extent_phw1g_tdrNs_snap_alloc()
338 cl_command_queue const cq, in skc_extent_phrwg_tdrNs_snap_alloc()
|
| /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.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()
|
| D | channel_cc.cc | 104 CompletionQueue* cq) { in CreateCall()
178 CompletionQueue* cq, void* tag) { in NotifyOnStateChangeImpl()
186 CompletionQueue cq; in WaitForStateChangeImpl() local
201 void TakeCQ(CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
|
| /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/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/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
|
| D | cq_verifier_native.cc | 29 grpc_completion_queue* cq; member
34 cq_verifier* cq_verifier_create(grpc_completion_queue* cq) { in cq_verifier_create()
|
| /external/grpc-grpc/include/grpcpp/ |
| D | alarm.h | 52 Alarm(CompletionQueue* cq, const T& deadline, void* tag) : Alarm() { in Alarm()
61 void Set(CompletionQueue* cq, const T& deadline, void* tag) { in Set()
|
| /external/grpc-grpc/test/core/bad_client/tests/ |
| D | server_registered_method.cc | 43 static void verifier_succeeds(grpc_server* server, grpc_completion_queue* cq, in verifier_succeeds()
69 static void verifier_fails(grpc_server* server, grpc_completion_queue* cq, in verifier_fails()
|