| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | server_callback_handlers.h | 60 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
198 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor()
221 ServerReactor* reactor() override { in reactor() function
281 ServerReadReactor<RequestType>* reactor = nullptr; in RunHandler() local
379 void SetupReactor(ServerReadReactor<RequestType>* reactor) { in SetupReactor()
416 ServerReactor* reactor() override { in reactor() function
471 ServerWriteReactor<ResponseType>* reactor = nullptr; in RunHandler() local
605 void SetupReactor(ServerWriteReactor<ResponseType>* reactor) { in SetupReactor()
645 ServerReactor* reactor() override { in reactor() function
698 ServerBidiReactor<RequestType, ResponseType>* reactor = nullptr; in RunHandler() local
[all …]
|
| D | client_callback_impl.h | 153 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor()
168 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor()
189 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor()
441 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor()
578 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl()
632 auto* reactor = reactor_; in MaybeFinish() local
694 ClientBidiReactor<Request, Response>* reactor) { in Create()
790 ClientReadReactor<Response>* reactor) in ClientCallbackReaderImpl()
803 auto* reactor = reactor_; in MaybeFinish() local
853 ClientReadReactor<Response>* reactor) { in Create()
[all …]
|
| D | client_callback.h | 158 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor()
173 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor()
194 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor()
446 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor()
584 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl()
641 auto* reactor = reactor_; in MaybeFinish() local
703 ClientBidiReactor<Request, Response>* reactor) { in Create()
800 ClientReadReactor<Response>* reactor) in ClientCallbackReaderImpl()
813 auto* reactor = reactor_; in MaybeFinish() local
862 ClientReadReactor<Response>* reactor) { in Create()
[all …]
|
| D | server_callback_impl.h | 106 void MaybeCallOnCancel(ServerReactor* reactor) { in MaybeCallOnCancel()
201 void BindReactor(Reactor* reactor) { in BindReactor()
215 void BindReactor(ServerReadReactor<Request>* reactor) { in BindReactor()
232 void BindReactor(ServerWriteReactor<Response>* reactor) { in BindReactor()
250 void BindReactor(ServerBidiReactor<Request, Response>* reactor) { in BindReactor()
|
| D | server_callback.h | 106 void MaybeCallOnCancel(ServerReactor* reactor) { in MaybeCallOnCancel()
201 void BindReactor(Reactor* reactor) { in BindReactor()
215 void BindReactor(ServerReadReactor<Request>* reactor) { in BindReactor()
232 void BindReactor(ServerWriteReactor<Response>* reactor) { in BindReactor()
250 void BindReactor(ServerBidiReactor<Request, Response>* reactor) { in BindReactor()
|
| D | server_context_impl.h | 488 ::grpc_impl::internal::ServerReactor* reactor() override { in reactor() function
|
| D | server_context.h | 516 ::grpc::internal::ServerReactor* reactor() override { return reactor_; } in reactor() function
|
| /third_party/grpc/test/cpp/naming/utils/ |
| D | dns_resolver.py | 22 import twisted.internet.reactor as reactor namespace
54 def BeginQuery(reactor, qname): argument
|
| /third_party/grpc/include/grpcpp/generic/ |
| D | generic_stub.h | 102 ClientUnaryReactor* reactor) { in PrepareUnaryCall()
111 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall()
138 ClientUnaryReactor* reactor) { in PrepareUnaryCall()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall()
178 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal()
188 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCallInternal()
|
| /third_party/grpc/src/cpp/server/ |
| D | server_callback.cc | 53 void ServerCallbackCall::CallOnCancel(ServerReactor* reactor) { in CallOnCancel()
64 ServerReactor* reactor; in CallOnCancel() member
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | reactor_fwd.hpp | 25 typedef class null_reactor reactor; typedef
|
| /third_party/boost/boost/asio/detail/ |
| D | reactor_fwd.hpp | 25 typedef class null_reactor reactor; typedef
|
| /third_party/grpc/include/grpcpp/test/ |
| D | default_reactor_test_peer.h | 44 ::grpc::experimental::ServerUnaryReactor* reactor() const { in reactor() function
|
| /third_party/grpc/src/cpp/client/ |
| D | client_callback.cc | 33 ClientReactor* const reactor; in InternalScheduleOnDone() member
|
| /third_party/grpc/test/cpp/end2end/ |
| D | mock_test.cc | 176 auto* reactor = context->DefaultReactor(); in Echo() local
209 auto* reactor = service_.Echo(&ctx, &req, &resp); in TEST_F() local
229 auto* reactor = service_.Echo(&ctx, &req, &resp); in TEST_F() local
241 auto* reactor = service_.Echo(&ctx, &req, &resp); in TEST_F() local
|
| D | message_allocator_end2end_test.cc | 71 auto* reactor = context->DefaultReactor(); in Echo() local
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_callback.cc | 39 auto* reactor = context->DefaultReactor(); in UnaryCall() local
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | callback_test_service.cc | 59 auto* reactor = context->DefaultReactor(); in Echo() local
|