| /external/grpc-grpc/test/cpp/common/ |
| D | alarm_test.cc | 35 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/ |
| D | completion_queue_cc.cc | 35 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/common/ |
| D | completion_queue_cc.cc | 35 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue() function in grpc::CompletionQueue
40 void CompletionQueue::Shutdown() { in Shutdown()
51 CompletionQueue::NextStatus CompletionQueue::AsyncNextInternal( in AsyncNextInternal()
73 CompletionQueue::CompletionQueueTLSCache::CompletionQueueTLSCache( in CompletionQueueTLSCache()
74 CompletionQueue* cq) in CompletionQueueTLSCache()
79 CompletionQueue::CompletionQueueTLSCache::~CompletionQueueTLSCache() { in ~CompletionQueueTLSCache()
83 bool CompletionQueue::CompletionQueueTLSCache::Flush(void** tag, bool* ok) { in Flush()
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | compiler_test_mock_golden | 17 …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));
|
| D | compiler_test_golden | 42 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/test/cpp/qps/ |
| D | client_async.cc | 53 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/flatbuffers/tests/ |
| D | monster_test.grpc.fb.h | 21 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/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | call.h | 25 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_;
|
| D | server_interface.h | 38 class CompletionQueue; variable
196 ::grpc::CompletionQueue* call_cq,
210 ::grpc::CompletionQueue* const call_cq_;
226 ::grpc::CompletionQueue* call_cq,
256 ::grpc::CompletionQueue* call_cq, in NoPayloadAsyncRequest()
274 ::grpc::CompletionQueue* call_cq, in PayloadAsyncRequest()
330 ::grpc::CompletionQueue* call_cq,
344 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
355 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
365 ::grpc::CompletionQueue* call_cq, in RequestAsyncGenericCall()
[all …]
|
| D | completion_queue.h | 102 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_;
426 class ServerCompletionQueue : public CompletionQueue {
444 : CompletionQueue(grpc_completion_queue_attributes{ in ServerCompletionQueue()
|
| D | intercepted_channel.h | 25 class CompletionQueue; variable
50 ::grpc::CompletionQueue* cq) override { in CreateCall()
63 ::grpc::CompletionQueue* cq, in NotifyOnStateChangeImpl()
72 ::grpc::CompletionQueue* CallbackCQ() override { in CallbackCQ()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | call.h | 25 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_;
|
| D | server_interface.h | 38 class CompletionQueue; variable
196 ::grpc::CompletionQueue* call_cq,
210 ::grpc::CompletionQueue* const call_cq_;
226 ::grpc::CompletionQueue* call_cq,
256 ::grpc::CompletionQueue* call_cq, in NoPayloadAsyncRequest()
274 ::grpc::CompletionQueue* call_cq, in PayloadAsyncRequest()
330 ::grpc::CompletionQueue* call_cq,
344 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
355 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall()
365 ::grpc::CompletionQueue* call_cq, in RequestAsyncGenericCall()
[all …]
|
| D | completion_queue.h | 102 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_;
426 class ServerCompletionQueue : public CompletionQueue {
444 : CompletionQueue(grpc_completion_queue_attributes{ in ServerCompletionQueue()
|
| D | intercepted_channel.h | 25 class CompletionQueue; variable
50 ::grpc::CompletionQueue* cq) override { in CreateCall()
63 ::grpc::CompletionQueue* cq, in NotifyOnStateChangeImpl()
72 ::grpc::CompletionQueue* CallbackCQ() override { in CallbackCQ()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 151 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()
|
| D | completion_queue.h | 64 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/tensorflow/tensorflow/core/tpu/kernels/ |
| D | tpu_compilation_cache_grpc.h | 79 ::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/rust/crates/grpcio-sys/grpc/src/cpp/client/ |
| D | channel_cc.cc | 106 ::grpc::CompletionQueue* cq, size_t interceptor_pos) { in CreateCallInternal()
152 CompletionQueue* cq) { in CreateCall()
191 ::grpc::CompletionQueue* cq, void* tag) { in NotifyOnStateChangeImpl()
199 ::grpc::CompletionQueue cq; in WaitForStateChangeImpl()
221 void TakeCQ(::grpc::CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
232 ::grpc::CompletionQueue* cq_ = nullptr;
236 ::grpc::CompletionQueue* Channel::CallbackCQ() { in CallbackCQ()
242 callback_cq_ = new ::grpc::CompletionQueue(grpc_completion_queue_attributes{ in CallbackCQ()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 134 ::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/ |
| D | channel_cc.cc | 104 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/grpc-grpc/include/grpcpp/generic/ |
| D | generic_stub.h | 31 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,
|
| /external/grpc-grpc/include/grpcpp/ |
| D | channel.h | 70 CompletionQueue* cq) override;
76 gpr_timespec deadline, CompletionQueue* cq,
81 CompletionQueue* CallbackCQ() override;
93 CompletionQueue* callback_cq_ = nullptr;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | channel.h | 90 ::grpc::CompletionQueue* cq) override;
97 ::grpc::CompletionQueue* cq, void* tag) override;
101 ::grpc::CompletionQueue* CallbackCQ() override;
105 ::grpc::CompletionQueue* cq, size_t interceptor_pos) override;
117 ::grpc::CompletionQueue* callback_cq_ = nullptr;
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | channel.h | 90 ::grpc::CompletionQueue* cq) override;
97 ::grpc::CompletionQueue* cq, void* tag) override;
101 ::grpc::CompletionQueue* CallbackCQ() override;
105 ::grpc::CompletionQueue* cq, size_t interceptor_pos) override;
117 ::grpc::CompletionQueue* callback_cq_ = nullptr;
|