| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 34 class ServerCompletionQueue; variable
136 virtual void Start(ServerCompletionQueue** cqs, size_t num_cqs) = 0;
177 ServerCompletionQueue* notification_cq);
186 ServerCompletionQueue* notification_cq, void* tag) in NoPayloadAsyncRequest()
201 ServerCompletionQueue* notification_cq, void* tag, in PayloadAsyncRequest()
247 ServerCompletionQueue* const notification_cq_;
258 ServerCompletionQueue* notification_cq, void* tag,
272 ServerCompletionQueue* notification_cq, void* tag, in RequestAsyncCall()
284 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncCall()
293 ServerCompletionQueue* notification_cq, in RequestAsyncGenericCall()
|
| D | service_type.h | 34 class ServerCompletionQueue; variable
95 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncUnary()
106 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncClientStreaming()
115 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncServerStreaming()
123 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncBidiStreaming()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 40 class ServerCompletionQueue; variable
183 virtual void Start(::grpc::ServerCompletionQueue** cqs, size_t num_cqs) = 0;
199 ::grpc::ServerCompletionQueue* notification_cq, void* tag,
213 ::grpc::ServerCompletionQueue* const notification_cq_;
229 ::grpc::ServerCompletionQueue* notification_cq,
247 ::grpc::ServerCompletionQueue* notification_cq);
259 ::grpc::ServerCompletionQueue* notification_cq, in NoPayloadAsyncRequest()
277 ::grpc::ServerCompletionQueue* notification_cq, in PayloadAsyncRequest()
333 ::grpc::ServerCompletionQueue* notification_cq,
347 ::grpc::ServerCompletionQueue* notification_cq, in RequestAsyncCall()
[all …]
|
| D | service_type.h | 130 ::grpc::ServerCompletionQueue* notification_cq, in RequestAsyncUnary()
143 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncClientStreaming()
153 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncServerStreaming()
162 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncBidiStreaming()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | server_interface.h | 40 class ServerCompletionQueue; variable
183 virtual void Start(::grpc::ServerCompletionQueue** cqs, size_t num_cqs) = 0;
199 ::grpc::ServerCompletionQueue* notification_cq, void* tag,
213 ::grpc::ServerCompletionQueue* const notification_cq_;
229 ::grpc::ServerCompletionQueue* notification_cq,
247 ::grpc::ServerCompletionQueue* notification_cq);
259 ::grpc::ServerCompletionQueue* notification_cq, in NoPayloadAsyncRequest()
277 ::grpc::ServerCompletionQueue* notification_cq, in PayloadAsyncRequest()
333 ::grpc::ServerCompletionQueue* notification_cq,
347 ::grpc::ServerCompletionQueue* notification_cq, in RequestAsyncCall()
[all …]
|
| D | service_type.h | 130 ::grpc::ServerCompletionQueue* notification_cq, in RequestAsyncUnary()
143 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncClientStreaming()
153 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncServerStreaming()
162 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncBidiStreaming()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/health/ |
| D | default_health_check_service.h | 57 std::unique_ptr<ServerCompletionQueue> cq);
111 static void CreateAndStart(ServerCompletionQueue* cq,
117 CheckCallHandler(ServerCompletionQueue* cq,
134 ServerCompletionQueue* cq_;
154 static void CreateAndStart(ServerCompletionQueue* cq,
160 WatchCallHandler(ServerCompletionQueue* cq,
192 ServerCompletionQueue* cq_;
226 std::unique_ptr<ServerCompletionQueue> cq_;
245 std::unique_ptr<ServerCompletionQueue> cq);
|
| D | default_health_check_service.cc | 116 std::unique_ptr<ServerCompletionQueue> cq) { in GetHealthCheckService()
155 std::unique_ptr<ServerCompletionQueue> cq) in HealthCheckServiceImpl()
267 CreateAndStart(ServerCompletionQueue* cq, in CreateAndStart()
287 CheckCallHandler(ServerCompletionQueue* cq, in CheckCallHandler()
348 CreateAndStart(ServerCompletionQueue* cq, in CreateAndStart()
375 WatchCallHandler(ServerCompletionQueue* cq, in WatchCallHandler()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 135 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCreateSession()
143 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestExtendSession()
151 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestPartialRunSetup()
159 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestRunStep()
167 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCloseSession()
175 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestListDevices()
183 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestReset()
191 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestMakeCallable()
199 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestRunCallable()
207 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestReleaseCallable()
|
| D | grpc_call.h | 156 ::grpc::CompletionQueue*, ::grpc::ServerCompletionQueue*, void*);
209 ::grpc::ServerCompletionQueue* cq, in EnqueueRequest()
231 GrpcService* grpc_service, ::grpc::ServerCompletionQueue* cq, in EnqueueRequestForMethod()
413 ::grpc::CompletionQueue*, ::grpc::ServerCompletionQueue*, void*);
423 ::grpc::ServerCompletionQueue* cq, EnqueueFunction enqueue_function) in ServerBidirectionalStreamingCall()
476 ::grpc::ServerCompletionQueue* cq, in EnqueueRequest()
516 ::grpc::ServerCompletionQueue* cq_;
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.h | 43 std::unique_ptr<ServerCompletionQueue> cq);
100 static void CreateAndStart(ServerCompletionQueue* cq,
106 ReportLoadHandler(ServerCompletionQueue* cq,
148 ServerCompletionQueue* cq_;
182 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.h | 42 std::unique_ptr<ServerCompletionQueue> cq);
99 static void CreateAndStart(ServerCompletionQueue* cq,
105 ReportLoadHandler(ServerCompletionQueue* cq,
147 ServerCompletionQueue* cq_;
181 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 33 using grpc::ServerCompletionQueue;
75 CallData(Greeter::AsyncService* service, ServerCompletionQueue* cq) in CallData()
120 ServerCompletionQueue* cq_;
157 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_builder.cc | 71 std::unique_ptr<ServerCompletionQueue> ServerBuilder::AddCompletionQueue( in AddCompletionQueue()
73 ServerCompletionQueue* cq = new ServerCompletionQueue( in AddCompletionQueue()
76 return std::unique_ptr<ServerCompletionQueue>(cq); in AddCompletionQueue()
239 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>> in BuildAndStart()
241 std::vector<std::unique_ptr<ServerCompletionQueue>>>()); in BuildAndStart()
259 sync_server_cqs->emplace_back(new ServerCompletionQueue(polling_type)); in BuildAndStart()
|
| D | server_cc.cc | 104 UnimplementedAsyncRequest(Server* server, ServerCompletionQueue* cq) in UnimplementedAsyncRequest()
117 ServerCompletionQueue* const cq_;
390 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>> in Server()
555 void Server::Start(ServerCompletionQueue** cqs, size_t num_cqs) { in Start()
714 ServerCompletionQueue* notification_cq) { in IssueRequest()
725 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in GenericAsyncRequest()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_builder.cc | 71 std::unique_ptr<grpc::ServerCompletionQueue> ServerBuilder::AddCompletionQueue( in AddCompletionQueue()
73 grpc::ServerCompletionQueue* cq = new grpc::ServerCompletionQueue( in AddCompletionQueue()
78 return std::unique_ptr<grpc::ServerCompletionQueue>(cq); in AddCompletionQueue()
287 std::shared_ptr<std::vector<std::unique_ptr<grpc::ServerCompletionQueue>>> in BuildAndStart()
290 std::vector<std::unique_ptr<grpc::ServerCompletionQueue>>>()); in BuildAndStart()
323 new grpc::ServerCompletionQueue(GRPC_CQ_NEXT, polling_type, nullptr)); in BuildAndStart()
|
| D | server_cc.cc | 131 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in BaseAsyncRequest()
214 ServerCompletionQueue* notification_cq, void* tag, const char* name, in RegisteredAsyncRequest()
223 ServerCompletionQueue* notification_cq) { in IssueRequest()
236 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in GenericAsyncRequest()
312 grpc::ServerCompletionQueue* cq) in UnimplementedAsyncRequest()
859 std::shared_ptr<std::vector<std::unique_ptr<grpc::ServerCompletionQueue>>> in Server()
1123 void Server::Start(grpc::ServerCompletionQueue** cqs, size_t num_cqs) { in Start()
1130 grpc::ServerCompletionQueue* health_check_cq = nullptr; in Start()
1141 health_check_cq = new grpc::ServerCompletionQueue( in Start()
1147 std::unique_ptr<grpc::ServerCompletionQueue>(health_check_cq)); in Start()
|
| /external/grpc-grpc/include/grpcpp/ |
| D | server.h | 149 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
160 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
199 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
|
| D | server_builder.h | 43 class ServerCompletionQueue; variable
125 std::unique_ptr<ServerCompletionQueue> AddCompletionQueue(
285 std::vector<ServerCompletionQueue*> cqs_;
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 116 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
121 std::unique_ptr<ServerCompletionQueue> cq_;
245 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
255 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 56 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest() argument
60 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
64 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
68 ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
72 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
521 std::vector<std::unique_ptr<grpc::ServerCompletionQueue>> srv_cqs_;
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | server.h | 177 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
195 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
323 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
|
| D | server_builder.h | 45 class ServerCompletionQueue; variable
166 std::unique_ptr<grpc::ServerCompletionQueue> AddCompletionQueue(
394 std::vector<grpc::ServerCompletionQueue*> cqs_;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | server_builder.h | 45 class ServerCompletionQueue; variable
166 std::unique_ptr<grpc::ServerCompletionQueue> AddCompletionQueue(
394 std::vector<grpc::ServerCompletionQueue*> cqs_;
|
| D | server.h | 177 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
195 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
323 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
|