| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_remote_worker.h | 25 class CompletionQueue;
33 ::grpc::CompletionQueue* completion_queue,
|
| grpc_master_service_impl.h | 132 ::grpc::CompletionQueue* new_call_cq,
140 ::grpc::CompletionQueue* new_call_cq,
148 ::grpc::CompletionQueue* new_call_cq,
156 ::grpc::CompletionQueue* new_call_cq,
164 ::grpc::CompletionQueue* new_call_cq,
172 ::grpc::CompletionQueue* new_call_cq,
180 ::grpc::CompletionQueue* new_call_cq,
188 ::grpc::CompletionQueue* new_call_cq,
196 ::grpc::CompletionQueue* new_call_cq,
204 ::grpc::CompletionQueue* new_call_cq
[all...] |
| /external/grpc-grpc/src/cpp/common/ |
| completion_queue_cc.cc | 31 // 'CompletionQueue' constructor can safely call GrpcLibraryCodegen(false) here
35 CompletionQueue::CompletionQueue(grpc_completion_queue* take)
40 void CompletionQueue::Shutdown() {
45 void CompletionQueue::CompleteAvalanching() {
53 CompletionQueue::NextStatus CompletionQueue::AsyncNextInternal(
74 CompletionQueue::CompletionQueueTLSCache::CompletionQueueTLSCache(
75 CompletionQueue* cq)
80 CompletionQueue::CompletionQueueTLSCache::~CompletionQueueTLSCache()
[all...] |
| /external/grpc-grpc/test/cpp/common/ |
| alarm_test.cc | 35 CompletionQueue cq;
42 const CompletionQueue::NextStatus status =
45 EXPECT_EQ(status, CompletionQueue::GOT_EVENT);
111 CompletionQueue cq;
115 CompletionQueue::NextStatus status;
129 EXPECT_EQ(status, CompletionQueue::GOT_EVENT);
135 CompletionQueue cq;
141 const CompletionQueue::NextStatus status =
144 EXPECT_EQ(status, CompletionQueue::GOT_EVENT);
150 CompletionQueue cq
[all...] |
| /external/grpc-grpc/include/grpcpp/ |
| channel.h | 70 CompletionQueue* cq) override;
76 gpr_timespec deadline, CompletionQueue* cq,
81 CompletionQueue* CallbackCQ() override;
93 CompletionQueue* callback_cq_ = nullptr;
|
| alarm.h | 52 Alarm(CompletionQueue* cq, const T& deadline, void* tag) : Alarm() {
61 void Set(CompletionQueue* cq, const T& deadline, void* tag) {
106 void SetInternal(CompletionQueue* cq, gpr_timespec deadline, void* tag);
|
| /external/grpc-grpc/include/grpcpp/generic/ |
| generic_stub.h | 31 class CompletionQueue;
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/src/cpp/server/ |
| async_generic_service.cc | 27 CompletionQueue* call_cq, ServerCompletionQueue* notification_cq,
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| _server_test.py | 26 server_call_completion_queue = cygrpc.CompletionQueue()
27 server_shutdown_completion_queue = cygrpc.CompletionQueue()
|
| /external/grpc-grpc/src/cpp/client/ |
| generic_stub.cc | 30 const grpc::string& method, CompletionQueue* cq, bool start, void* tag) {
43 ClientContext* context, const grpc::string& method, CompletionQueue* cq,
50 ClientContext* context, const grpc::string& method, CompletionQueue* cq) {
57 const ByteBuffer& request, CompletionQueue* cq) {
|
| channel_cc.cc | 104 CompletionQueue* cq) {
178 CompletionQueue* cq, void* tag) {
186 CompletionQueue cq;
201 void TakeCQ(CompletionQueue* cq) { cq_ = cq; }
212 CompletionQueue* cq_ = nullptr;
216 CompletionQueue* Channel::CallbackCQ() {
222 callback_cq_ = new CompletionQueue(grpc_completion_queue_attributes{
|
| /external/grpc-grpc/test/cpp/codegen/ |
| codegen_test_full.cc | 29 grpc::CompletionQueue cq;
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| channel_interface.h | 29 class CompletionQueue;
68 CompletionQueue* cq, void* tag) {
113 CompletionQueue* cq) = 0;
119 CompletionQueue* cq, void* tag) = 0;
131 virtual CompletionQueue* CallbackCQ() { return nullptr; }
|
| completion_queue.h | 64 class CompletionQueue;
95 class CompletionQueue : private GrpcLibraryCodegen {
99 CompletionQueue()
100 : CompletionQueue(grpc_completion_queue_attributes{
107 explicit CompletionQueue(grpc_completion_queue* take);
110 ~CompletionQueue() {
183 /// See documentation for CompletionQueue::Next for explanation of ok
237 /// Private constructor of CompletionQueue only visible to friend classes
238 CompletionQueue(const grpc_completion_queue_attributes& attributes) {
286 CompletionQueueTLSCache(CompletionQueue* cq)
[all...] |
| server_interface.h | 151 CompletionQueue* call_cq, void* tag,
161 CompletionQueue* const call_cq_;
171 CompletionQueue* call_cq, void* tag);
185 CompletionQueue* call_cq,
200 CompletionQueue* call_cq,
246 CompletionQueue* const call_cq_;
257 CompletionQueue* call_cq,
271 CompletionQueue* call_cq,
283 CompletionQueue* call_cq,
292 CompletionQueue* call_cq
[all...] |
| service_type.h | 31 class CompletionQueue;
94 CompletionQueue* call_cq,
105 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq,
114 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq,
122 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq,
|
| async_generic_service.h | 71 CompletionQueue* call_cq,
|
| /external/grpc-grpc/test/cpp/qps/ |
| client_async.cc | 53 virtual void StartNewClone(CompletionQueue* cq) = 0;
59 virtual void Start(CompletionQueue* cq, const ClientConfig& config) = 0;
72 CompletionQueue*)>
85 void Start(CompletionQueue* cq, const ClientConfig& config) override {
111 void StartNewClone(CompletionQueue* cq) override {
121 CompletionQueue* cq_;
131 CompletionQueue*)>
138 void StartInternal(CompletionQueue* cq) {
174 cli_cqs_.emplace_back(new CompletionQueue);
295 std::vector<std::unique_ptr<CompletionQueue>> cli_cqs_
[all...] |
| /external/tensorflow/tensorflow/contrib/bigtable/kernels/test_kernels/ |
| 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/flatbuffers/tests/ |
| monster_test.grpc.fb.h | 21 class CompletionQueue;
39 std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< flatbuffers::grpc::Message<Stat>>> AsyncStore(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) {
42 std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< flatbuffers::grpc::Message<Stat>>> PrepareAsyncStore(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) {
48 std::unique_ptr< ::grpc::ClientAsyncReaderInterface< flatbuffers::grpc::Message<Monster>>> AsyncRetrieve(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* tag) {
51 std::unique_ptr< ::grpc::ClientAsyncReaderInterface< flatbuffers::grpc::Message<Monster>>> PrepareAsyncRetrieve(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) {
57 std::unique_ptr< ::grpc::ClientAsyncWriterInterface< flatbuffers::grpc::Message<Monster>>> AsyncGetMaxHitPoint(::grpc::ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* tag) {
60 std::unique_ptr< ::grpc::ClientAsyncWriterInterface< flatbuffers::grpc::Message<Monster>>> PrepareAsyncGetMaxHitPoint(::grpc::ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) {
66 std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< flatbuffers::grpc::Message<Monster>, flatbuffers::grpc::Message<Stat>>> AsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
69 std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< flatbuffers::grpc::Message<Monster>, flatbuffers::grpc::Message<Stat>>> PrepareAsyncGetMinMaxHitPoints(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
73 virtual ::grpc::ClientAsyncResponseReaderInterface< flatbuffers::grpc::Message<Stat>>* AsyncStoreRaw(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) = 0
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| grpc_eager_client.cc | 33 ::grpc::CompletionQueue* cq)
58 ::grpc::CompletionQueue* cq_;
123 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; }
126 ::grpc::CompletionQueue completion_queue_;
|
| grpc_eager_service.h | 114 ::grpc::CompletionQueue* new_call_cq,
122 ::grpc::CompletionQueue* new_call_cq,
130 ::grpc::CompletionQueue* new_call_cq,
138 ::grpc::CompletionQueue* new_call_cq,
146 ::grpc::CompletionQueue* new_call_cq,
154 ::grpc::CompletionQueue* new_call_cq,
162 ::grpc::CompletionQueue* new_call_cq,
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| greeter_async_client.cc | 31 using grpc::CompletionQueue;
58 CompletionQueue cq;
|
| greeter_async_client2.cc | 32 using grpc::CompletionQueue;
118 CompletionQueue cq_;
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| server.pxd.pxi | 25 cdef CompletionQueue backup_shutdown_queue
30 cdef _c_shutdown(self, CompletionQueue queue, tag)
|
