| /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/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/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/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 …]
|
| 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 …t* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* ta… in AsyncRetrieveRaw()
58 …ntContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) { in PrepareAsyncRetrieveRaw()
66 …ontext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMaxHitPointRaw()
70 …:ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMaxHitPointRaw()
78 …::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* ta… in AsyncGetMinMaxHitPointsRaw()
82 …b::PrepareAsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { in PrepareAsyncGetMinMaxHitPointsRaw()
|
| /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 …]
|
| D | channel_interface.h | 29 class CompletionQueue; variable
68 CompletionQueue* cq, void* tag) { in NotifyOnStateChange()
113 CompletionQueue* cq) = 0;
119 CompletionQueue* cq, void* tag) = 0;
131 virtual CompletionQueue* CallbackCQ() { return nullptr; } in CallbackCQ()
|
| D | service_type.h | 31 class CompletionQueue; variable
94 CompletionQueue* call_cq, in RequestAsyncUnary()
105 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RequestAsyncClientStreaming()
114 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RequestAsyncServerStreaming()
122 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RequestAsyncBidiStreaming()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 132 ::grpc::CompletionQueue* new_call_cq, in RequestCreateSession()
140 ::grpc::CompletionQueue* new_call_cq, in RequestExtendSession()
148 ::grpc::CompletionQueue* new_call_cq, in RequestPartialRunSetup()
156 ::grpc::CompletionQueue* new_call_cq, in RequestRunStep()
164 ::grpc::CompletionQueue* new_call_cq, in RequestCloseSession()
172 ::grpc::CompletionQueue* new_call_cq, in RequestListDevices()
180 ::grpc::CompletionQueue* new_call_cq, in RequestReset()
188 ::grpc::CompletionQueue* new_call_cq, in RequestMakeCallable()
196 ::grpc::CompletionQueue* new_call_cq, in RequestRunCallable()
204 ::grpc::CompletionQueue* new_call_cq, in RequestReleaseCallable()
|
| D | grpc_remote_worker.h | 25 class CompletionQueue; variable
33 ::grpc::CompletionQueue* completion_queue,
|
| /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()
|
| 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()
|
| /external/tensorflow/tensorflow/contrib/bigtable/kernels/test_kernels/ |
| D | bigtable_test_client.h | 54 grpc::CompletionQueue* cq) override;
75 grpc::CompletionQueue* cq) override;
82 ::grpc::CompletionQueue* cq, void* tag) override;
88 ::grpc::CompletionQueue* cq, void* tag) override;
95 grpc::CompletionQueue* cq) override;
101 grpc::CompletionQueue* cq, void* tag) override;
|
| /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/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service.h | 114 ::grpc::CompletionQueue* new_call_cq, in RequestCreateContext()
122 ::grpc::CompletionQueue* new_call_cq, in RequestEnqueue()
130 ::grpc::CompletionQueue* new_call_cq, in RequestWaitQueueDone()
138 ::grpc::CompletionQueue* new_call_cq, in RequestKeepAlive()
146 ::grpc::CompletionQueue* new_call_cq, in RequestCloseContext()
154 ::grpc::CompletionQueue* new_call_cq, in RequestRegisterFunction()
162 ::grpc::CompletionQueue* new_call_cq, in RequestSendTensor()
|
| D | grpc_eager_client.cc | 33 ::grpc::CompletionQueue* cq) in GrpcEagerClient()
58 ::grpc::CompletionQueue* cq_;
123 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue()
126 ::grpc::CompletionQueue completion_queue_;
|
| /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;
|
| 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()
106 void SetInternal(CompletionQueue* cq, gpr_timespec deadline, void* tag);
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 253 CompletionQueue cq_;
280 SyncRequestThreadManager(Server* server, CompletionQueue* server_cq, in SyncRequestThreadManager()
299 case CompletionQueue::TIMEOUT: in PollForWork()
301 case CompletionQueue::SHUTDOWN: in PollForWork()
303 case CompletionQueue::GOT_EVENT: in PollForWork()
379 CompletionQueue* server_cq_;
606 CompletionQueue shutdown_cq; in ShutdownInternal()
614 CompletionQueue::NextStatus status = in ShutdownInternal()
619 if (status == CompletionQueue::NextStatus::TIMEOUT) { in ShutdownInternal()
672 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in BaseAsyncRequest()
[all …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | server.pyx.pxi | 44 self, CompletionQueue call_queue not None,
45 CompletionQueue server_queue not None, tag):
61 self, CompletionQueue queue not None):
72 self.backup_shutdown_queue = CompletionQueue(shutdown_cq=True)
97 cdef _c_shutdown(self, CompletionQueue queue, tag):
106 def shutdown(self, CompletionQueue queue not None, tag):
|
| /external/grpc-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()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 40 CompletionQueue cq; in BM_CreateDestroyCpp()
52 CompletionQueue cq(core_cq); in BM_CreateDestroyCpp2()
80 CompletionQueue cq; in BM_Pass1Cpp()
|