Home
last modified time | relevance | path

Searched refs:CompletionQueue (Results 1 – 25 of 138) sorted by relevance

123456

/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dcompletion_queue_cc.cc47 CompletionQueue* cq ABSL_GUARDED_BY(g_callback_alternative_mu);
51 CompletionQueue* Ref() { in Ref()
55 cq = new CompletionQueue; in Ref()
63 static_cast<CompletionQueue*>(arg)->cq(); in Ref()
128 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue() function in grpc::CompletionQueue
133 void CompletionQueue::Shutdown() { in Shutdown()
144 CompletionQueue::NextStatus CompletionQueue::AsyncNextInternal( in AsyncNextInternal()
166 CompletionQueue::CompletionQueueTLSCache::CompletionQueueTLSCache( in CompletionQueueTLSCache()
167 CompletionQueue* cq) in CompletionQueueTLSCache()
172 CompletionQueue::CompletionQueueTLSCache::~CompletionQueueTLSCache() { in ~CompletionQueueTLSCache()
[all …]
/external/grpc-grpc/test/cpp/common/
Dalarm_test.cc35 CompletionQueue cq; in TEST()
42 const CompletionQueue::NextStatus status = in TEST()
45 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
111 CompletionQueue cq; in TEST()
115 CompletionQueue::NextStatus status; in TEST()
129 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
135 CompletionQueue cq; in TEST()
141 const CompletionQueue::NextStatus status = in TEST()
144 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
150 CompletionQueue cq; in TEST()
[all …]
/external/grpc-grpc/src/cpp/common/
Dcompletion_queue_cc.cc35 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue() function in grpc::CompletionQueue
40 void CompletionQueue::Shutdown() { in Shutdown()
45 void CompletionQueue::CompleteAvalanching() { in CompleteAvalanching()
53 CompletionQueue::NextStatus CompletionQueue::AsyncNextInternal( in AsyncNextInternal()
74 CompletionQueue::CompletionQueueTLSCache::CompletionQueueTLSCache( in CompletionQueueTLSCache()
75 CompletionQueue* cq) in CompletionQueueTLSCache()
80 CompletionQueue::CompletionQueueTLSCache::~CompletionQueueTLSCache() { in ~CompletionQueueTLSCache()
84 bool CompletionQueue::CompletionQueueTLSCache::Flush(void** tag, bool* ok) { in Flush()
/external/rust/crates/grpcio-sys/grpc/src/cpp/client/
Dchannel_cc.cc60 CompletionQueue* callback_cq = callback_cq_.load(std::memory_order_relaxed); in ~Channel()
66 CompletionQueue::ReleaseCallbackAlternativeCQ(callback_cq); in ~Channel()
114 ::grpc::CompletionQueue* cq, size_t interceptor_pos) { in CreateCallInternal()
160 CompletionQueue* cq) { in CreateCall()
199 ::grpc::CompletionQueue* cq, void* tag) { in NotifyOnStateChangeImpl()
207 ::grpc::CompletionQueue cq; in WaitForStateChangeImpl()
229 void TakeCQ(::grpc::CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
240 ::grpc::CompletionQueue* cq_ = nullptr;
244 ::grpc::CompletionQueue* Channel::CallbackCQ() { in CallbackCQ()
247 CompletionQueue* callback_cq = callback_cq_.load(std::memory_order_acquire); in CallbackCQ()
[all …]
/external/flatbuffers/tests/monster_test_suffix/filesuffix_only/
Dmonster_test.grpc.fb.h21 class CompletionQueue; variable
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 …t* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* ta… in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …ontext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …t>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
73 …ext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) = 0;
[all …]
/external/flatbuffers/tests/
Dmonster_test_generated.grpc.fb.h21 class CompletionQueue; variable
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 …t* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* ta… in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …ontext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …t>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
73 …ext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) = 0;
[all …]
Dmonster_test.grpc.fb.h21 class CompletionQueue; variable
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 …t* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* ta… in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …ontext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …t>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
73 …ext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) = 0;
[all …]
/external/flatbuffers/tests/monster_test_suffix/ext_only/
Dmonster_test.grpc.fb.h21 class CompletionQueue; variable
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 …t* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* ta… in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …ontext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …t>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
73 …ext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) = 0;
[all …]
/external/flatbuffers/tests/monster_test_suffix/
Dmonster_test.grpc.fb.h21 class CompletionQueue; variable
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 …t* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* ta… in AsyncRetrieve()
51 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieve()
57 …ontext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMaxHitPoint()
60 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPoint()
66 …t>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMinMaxHitPoints()
69 …at>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPoints()
73 …ext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) = 0;
[all …]
/external/grpc-grpc/test/cpp/qps/
Dclient_async.cc53 virtual void StartNewClone(CompletionQueue* cq) = 0;
59 virtual void Start(CompletionQueue* cq, const ClientConfig& config) = 0;
72 CompletionQueue*)> in ClientRpcContextUnaryImpl()
85 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
111 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
121 CompletionQueue* cq_;
131 CompletionQueue*)>
138 void StartInternal(CompletionQueue* cq) { in StartInternal()
174 cli_cqs_.emplace_back(new CompletionQueue); in AsyncClient()
295 std::vector<std::unique_ptr<CompletionQueue>> cli_cqs_;
[all …]
/external/grpc-grpc/test/cpp/codegen/
Dcompiler_test_mock_golden17 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq));
18 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq));
20 …ClientContext* context, ::grpc::testing::Response* response, ::grpc::CompletionQueue* cq, void* ta…
21 …::grpc::ClientContext* context, ::grpc::testing::Response* response, ::grpc::CompletionQueue* cq));
23 …ntContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq, void* ta…
24 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq));
26 … ::grpc::testing::Response>*(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta…
27 …Request, ::grpc::testing::Response>*(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq));
33 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq));
34 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq));
Dcompiler_test_golden42 class CompletionQueue;
66 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) {
69 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) {
80 …ClientContext* context, ::grpc::testing::Response* response, ::grpc::CompletionQueue* cq, void* ta…
83 …::grpc::ClientContext* context, ::grpc::testing::Response* response, ::grpc::CompletionQueue* cq) {
91 …ntContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq, void* ta…
94 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) {
102 …ng::Response>> AsyncMethodA4(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta…
105 …ing::Response>> PrepareAsyncMethodA4(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
127 …:ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) = 0;
[all …]
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dserver_interface.h151 CompletionQueue* call_cq, void* tag,
161 CompletionQueue* const call_cq_;
171 CompletionQueue* call_cq, void* tag);
185 CompletionQueue* call_cq, in NoPayloadAsyncRequest()
200 CompletionQueue* call_cq, in PayloadAsyncRequest()
246 CompletionQueue* const call_cq_;
257 CompletionQueue* call_cq,
271 CompletionQueue* call_cq, in RequestAsyncCall()
283 CompletionQueue* call_cq, in RequestAsyncCall()
292 CompletionQueue* call_cq, in RequestAsyncGenericCall()
Dcompletion_queue.h64 class CompletionQueue; variable
95 class CompletionQueue : private GrpcLibraryCodegen {
99 CompletionQueue() in CompletionQueue() function
100 : CompletionQueue(grpc_completion_queue_attributes{ in CompletionQueue()
107 explicit CompletionQueue(grpc_completion_queue* take);
110 ~CompletionQueue() { in ~CompletionQueue()
238 CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
286 CompletionQueueTLSCache(CompletionQueue* cq);
291 CompletionQueue* cq_;
370 class ServerCompletionQueue : public CompletionQueue {
[all …]
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dcall.h25 class CompletionQueue; variable
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()
84 ::grpc::CompletionQueue* cq_;
Dcompletion_queue.h102 class CompletionQueue : private ::grpc::GrpcLibraryCodegen {
106 CompletionQueue() in CompletionQueue() function
107 : CompletionQueue(grpc_completion_queue_attributes{ in CompletionQueue()
114 explicit CompletionQueue(grpc_completion_queue* take);
117 ~CompletionQueue() override { in ~CompletionQueue()
246 explicit CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
304 explicit CompletionQueueTLSCache(CompletionQueue* cq);
309 CompletionQueue* cq_;
412 static CompletionQueue* CallbackAlternativeCQ();
413 static void ReleaseCallbackAlternativeCQ(CompletionQueue* cq);
[all …]
Dserver_interface.h38 class CompletionQueue; variable
198 ::grpc::CompletionQueue* call_cq,
212 ::grpc::CompletionQueue* const call_cq_;
228 ::grpc::CompletionQueue* call_cq,
258 ::grpc::CompletionQueue* call_cq, in NoPayloadAsyncRequest()
276 ::grpc::CompletionQueue* call_cq, in PayloadAsyncRequest()
332 ::grpc::CompletionQueue* call_cq,
346 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
357 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
367 ::grpc::CompletionQueue* call_cq, in RequestAsyncGenericCall()
[all …]
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dcall.h25 class CompletionQueue; variable
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()
84 ::grpc::CompletionQueue* cq_;
Dcompletion_queue.h102 class CompletionQueue : private ::grpc::GrpcLibraryCodegen {
106 CompletionQueue() in CompletionQueue() function
107 : CompletionQueue(grpc_completion_queue_attributes{ in CompletionQueue()
114 explicit CompletionQueue(grpc_completion_queue* take);
117 ~CompletionQueue() override { in ~CompletionQueue()
246 explicit CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
304 explicit CompletionQueueTLSCache(CompletionQueue* cq);
309 CompletionQueue* cq_;
412 static CompletionQueue* CallbackAlternativeCQ();
413 static void ReleaseCallbackAlternativeCQ(CompletionQueue* cq);
[all …]
Dserver_interface.h38 class CompletionQueue; variable
198 ::grpc::CompletionQueue* call_cq,
212 ::grpc::CompletionQueue* const call_cq_;
228 ::grpc::CompletionQueue* call_cq,
258 ::grpc::CompletionQueue* call_cq, in NoPayloadAsyncRequest()
276 ::grpc::CompletionQueue* call_cq, in PayloadAsyncRequest()
332 ::grpc::CompletionQueue* call_cq,
346 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
357 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
367 ::grpc::CompletionQueue* call_cq, in RequestAsyncGenericCall()
[all …]
/external/tensorflow/tensorflow/core/tpu/kernels/
Dtpu_compilation_cache_grpc.h79 ::grpc::CompletionQueue* cq) { in AsyncGetTpuProgram()
87 ::grpc::CompletionQueue* cq) { in PrepareAsyncGetTpuProgram()
97 ::grpc::CompletionQueue* cq) = 0;
101 ::grpc::CompletionQueue* cq) = 0;
112 ::grpc::CompletionQueue* cq) { in AsyncGetTpuProgram()
119 ::grpc::CompletionQueue* cq) { in PrepareAsyncGetTpuProgram()
128 ::grpc::CompletionQueue* cq) override;
132 ::grpc::CompletionQueue* cq) override;
169 ::grpc::CompletionQueue* new_call_cq, in RequestGetTpuProgram()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service_impl.h134 ::grpc::CompletionQueue* new_call_cq, in RequestCreateSession()
142 ::grpc::CompletionQueue* new_call_cq, in RequestExtendSession()
150 ::grpc::CompletionQueue* new_call_cq, in RequestPartialRunSetup()
158 ::grpc::CompletionQueue* new_call_cq, in RequestRunStep()
166 ::grpc::CompletionQueue* new_call_cq, in RequestCloseSession()
174 ::grpc::CompletionQueue* new_call_cq, in RequestListDevices()
182 ::grpc::CompletionQueue* new_call_cq, in RequestReset()
190 ::grpc::CompletionQueue* new_call_cq, in RequestMakeCallable()
198 ::grpc::CompletionQueue* new_call_cq, in RequestRunCallable()
206 ::grpc::CompletionQueue* new_call_cq, in RequestReleaseCallable()
/external/grpc-grpc/src/cpp/client/
Dchannel_cc.cc104 CompletionQueue* cq) { in CreateCall()
178 CompletionQueue* cq, void* tag) { in NotifyOnStateChangeImpl()
186 CompletionQueue cq; in WaitForStateChangeImpl()
201 void TakeCQ(CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
212 CompletionQueue* cq_ = nullptr;
216 CompletionQueue* Channel::CallbackCQ() { in CallbackCQ()
222 callback_cq_ = new CompletionQueue(grpc_completion_queue_attributes{ in CallbackCQ()
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_cc.cc130 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in BaseAsyncRequest()
213 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RegisteredAsyncRequest()
235 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in GenericAsyncRequest()
288 void TakeCQ(CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
299 CompletionQueue* cq_ = nullptr;
497 grpc::CompletionQueue cq_;
529 grpc::CompletionQueue* cq, in CallbackRequest()
549 CallbackRequest(Server* server, grpc::CompletionQueue* cq, in CallbackRequest()
711 grpc::CompletionQueue* const cq_;
757 SyncRequestThreadManager(Server* server, grpc::CompletionQueue* server_cq, in SyncRequestThreadManager()
[all …]
/external/grpc-grpc/include/grpcpp/generic/
Dgeneric_stub.h31 class CompletionQueue; variable
48 ClientContext* context, const grpc::string& method, CompletionQueue* cq);
56 const ByteBuffer& request, CompletionQueue* cq);
65 ClientContext* context, const grpc::string& method, CompletionQueue* cq,

123456