Home
last modified time | relevance | path

Searched defs:cq (Results 1 – 25 of 209) sorted by relevance

123456789

/external/grpc-grpc/src/core/lib/surface/
Dcompletion_queue.cc363 #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 …]
Dchannel_ping.cc34 grpc_completion_queue* cq; member
48 void grpc_channel_ping(grpc_channel* channel, grpc_completion_queue* cq, in grpc_channel_ping()
/external/skqp/src/compute/skc/platforms/cl_12/
Dextent_cl_12_unified.c121 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()
Dcq_pool_cl.c51 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()
Druntime_cl_12.c36 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
Dextent_cl_12.c83 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/
Dmonster_test.grpc.fb.cc42 …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()
Dmonster_test.grpc.fb.h39 …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/src/cpp/client/
Dgeneric_stub.cc30 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()
Dchannel_cc.cc104 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/grpc-grpc/test/cpp/microbenchmarks/
Dbm_cq.cc40 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/test/cpp/common/
Dalarm_test.cc35 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/
Dclient_async.cc85 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/test/core/surface/
Dnum_external_connectivity_watchers_test.cc40 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/grpc-grpc/src/csharp/Grpc.Core/Internal/
DServerCallHandler.cs33 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()
DChannelSafeHandle.cs51 …feHandle parentCall, ContextPropagationFlags propagationMask, CompletionQueueSafeHandle cq, string… in CreateCall()
67 …ivityState(ChannelState lastObservedState, Timespec deadline, CompletionQueueSafeHandle cq, BatchC… in WatchConnectivityState()
/external/grpc-grpc/include/grpcpp/
Dalarm.h52 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/end2end/
Dcq_verifier_native.cc29 grpc_completion_queue* cq; member
34 cq_verifier* cq_verifier_create(grpc_completion_queue* cq) { in cq_verifier_create()
Dh2_ssl_session_reuse_test.cc48 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
Dcq_verifier_uv.cc39 grpc_completion_queue* cq; member
45 cq_verifier* cq_verifier_create(grpc_completion_queue* cq) { in cq_verifier_create()
/external/grpc-grpc/test/core/bad_client/tests/
Dserver_registered_method.cc43 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()
Dsimple_request.cc90 static void verifier(grpc_server* server, grpc_completion_queue* cq, in verifier()
116 static void failure_verifier(grpc_server* server, grpc_completion_queue* cq, in failure_verifier()
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_completion_queue.c33 grpc_completion_queue* cq; member
58 void grpc_rb_completion_queue_destroy(grpc_completion_queue* cq) { in grpc_rb_completion_queue_destroy()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_call.h209 ::grpc::ServerCompletionQueue* cq, in EnqueueRequest()
231 GrpcService* grpc_service, ::grpc::ServerCompletionQueue* cq, in EnqueueRequestForMethod()
423 ::grpc::ServerCompletionQueue* cq, EnqueueFunction enqueue_function) in ServerBidirectionalStreamingCall()
476 ::grpc::ServerCompletionQueue* cq, in EnqueueRequest()
/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc33 std::unique_ptr<ServerCompletionQueue> cq) in LoadReporterAsyncServiceImpl()
116 ServerCompletionQueue* cq, LoadReporterAsyncServiceImpl* service, in CreateAndStart()
139 ServerCompletionQueue* cq, LoadReporterAsyncServiceImpl* service, in ReportLoadHandler()

123456789