| /third_party/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()
51 CompletionQueue cq; in TEST()
60 const CompletionQueue::NextStatus status = in TEST()
63 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
74 CompletionQueue cq; in TEST()
79 const CompletionQueue::NextStatus status = in TEST()
82 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
149 CompletionQueue cq; in TEST()
[all …]
|
| /third_party/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()
|
| /third_party/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 | 67 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) {
70 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) {
81 …ClientContext* context, ::grpc::testing::Response* response, ::grpc::CompletionQueue* cq, void* ta…
84 …::grpc::ClientContext* context, ::grpc::testing::Response* response, ::grpc::CompletionQueue* cq) {
92 …ntContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq, void* ta…
95 …pc::ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) {
103 …ng::Response>> AsyncMethodA4(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta…
106 …ing::Response>> PrepareAsyncMethodA4(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
160 …:ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) = 0;
161 …:ClientContext* context, const ::grpc::testing::Request& request, ::grpc::CompletionQueue* cq) = 0;
[all …]
|
| /third_party/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 …]
|
| /third_party/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
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 …]
|
| D | completion_queue_impl.h | 103 class CompletionQueue : private ::grpc::GrpcLibraryCodegen {
107 CompletionQueue() in CompletionQueue() function
108 : CompletionQueue(grpc_completion_queue_attributes{ in CompletionQueue()
115 explicit CompletionQueue(grpc_completion_queue* take);
118 ~CompletionQueue() { in ~CompletionQueue()
247 CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
303 CompletionQueueTLSCache(CompletionQueue* cq);
308 CompletionQueue* cq_;
424 class ServerCompletionQueue : public CompletionQueue {
442 : 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()
|
| 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 | delegating_channel.h | 48 ::grpc::CompletionQueue* cq) final { in CreateCall()
63 ::grpc::CompletionQueue* cq, in NotifyOnStateChangeImpl()
76 ::grpc::CompletionQueue* cq, in CreateCallInternal()
82 ::grpc::CompletionQueue* CallbackCQ() final { in CallbackCQ()
|
| D | channel_interface.h | 55 class CompletionQueue; variable
82 ::grpc::CompletionQueue* cq, void* tag) { in NotifyOnStateChange()
135 ::grpc::CompletionQueue* cq) = 0;
141 ::grpc::CompletionQueue* cq,
155 ::grpc::CompletionQueue* /*cq*/, size_t /*interceptor_pos*/) { in CreateCallInternal() argument
167 virtual ::grpc::CompletionQueue* CallbackCQ() { return nullptr; } in CallbackCQ()
|
| D | service_type.h | 31 class CompletionQueue; variable
129 ::grpc::CompletionQueue* call_cq, in RequestAsyncUnary()
142 ::grpc::CompletionQueue* call_cq, in RequestAsyncClientStreaming()
152 ::grpc::CompletionQueue* call_cq, in RequestAsyncServerStreaming()
161 ::grpc::CompletionQueue* call_cq, in RequestAsyncBidiStreaming()
|
| /third_party/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()
|
| /third_party/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;
|
| D | channel_impl.h | 92 ::grpc_impl::CompletionQueue* cq) override;
99 ::grpc_impl::CompletionQueue* cq,
104 ::grpc_impl::CompletionQueue* CallbackCQ() override;
108 ::grpc_impl::ClientContext* context, ::grpc_impl::CompletionQueue* cq,
121 ::grpc_impl::CompletionQueue* callback_cq_ = nullptr;
|
| D | alarm_impl.h | 51 Alarm(::grpc::CompletionQueue* cq, const T& deadline, void* tag) : Alarm() { in Alarm()
60 void Set(::grpc::CompletionQueue* cq, const T& deadline, void* tag) { in Set()
116 void SetInternal(::grpc::CompletionQueue* cq, gpr_timespec deadline,
|
| D | alarm.h | 51 Alarm(::grpc::CompletionQueue* cq, const T& deadline, void* tag) : Alarm() { in Alarm()
60 void Set(::grpc::CompletionQueue* cq, const T& deadline, void* tag) { in Set()
116 void SetInternal(::grpc::CompletionQueue* cq, gpr_timespec deadline,
|
| /third_party/grpc/test/cpp/end2end/ |
| D | interceptors_util.h | 226 int Next(CompletionQueue* cq, bool ignore_ok) { in Next()
235 CompletionQueue::NextStatus DoOnceThenAsyncNext( in DoOnceThenAsyncNext()
236 CompletionQueue* cq, void** got_tag, bool* ok, T deadline, in DoOnceThenAsyncNext()
248 void Verify(CompletionQueue* cq) { Verify(cq, false); } in Verify()
252 void Verify(CompletionQueue* cq, bool ignore_ok) { in Verify()
262 void Verify(CompletionQueue* cq, in Verify()
269 CompletionQueue::TIMEOUT); in Verify()
275 CompletionQueue::GOT_EVENT); in Verify()
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 119 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in BaseAsyncRequest()
202 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RegisteredAsyncRequest()
224 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in GenericAsyncRequest()
277 void TakeCQ(CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
288 CompletionQueue* cq_ = nullptr;
507 grpc::CompletionQueue cq_;
546 grpc::CompletionQueue* cq, in CallbackRequest()
566 CallbackRequest(Server* server, grpc::CompletionQueue* cq, in CallbackRequest()
727 grpc::CompletionQueue* const cq_;
772 SyncRequestThreadManager(Server* server, grpc::CompletionQueue* server_cq, in SyncRequestThreadManager()
[all …]
|
| /third_party/grpc/include/grpcpp/generic/ |
| D | generic_stub.h | 34 class CompletionQueue; variable
55 ::grpc::CompletionQueue* cq) { in PrepareCall()
65 const RequestType& request, ::grpc::CompletionQueue* cq) { in PrepareUnaryCall()
82 ::grpc::CompletionQueue* cq, void* tag) { in Call()
198 const std::string& method, ::grpc::CompletionQueue* cq, in CallInternal()
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _server_test.py | 26 server_call_completion_queue = cygrpc.CompletionQueue()
27 server_shutdown_completion_queue = cygrpc.CompletionQueue()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | server.pyx.pxi | 33 self, CompletionQueue call_queue not None,
34 CompletionQueue server_queue not None, tag):
50 self, CompletionQueue queue not None):
69 self.backup_shutdown_queue = CompletionQueue(shutdown_cq=True)
95 cdef _c_shutdown(self, CompletionQueue queue, tag):
104 def shutdown(self, CompletionQueue queue not None, tag):
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_client.cc | 35 using grpc::CompletionQueue;
62 CompletionQueue cq; in SayHello()
|
| D | greeter_async_client2.cc | 36 using grpc::CompletionQueue;
122 CompletionQueue cq_;
|