Home
last modified time | relevance | path

Searched defs:reactor (Results 1 – 25 of 51) sorted by relevance

123

/external/grpc-grpc/include/grpcpp/impl/
Dserver_callback_handlers.h62 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
196 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor()
219 ServerReactor* reactor() override { in reactor() function
278 ServerReadReactor<RequestType>* reactor = nullptr; in RunHandler() local
378 void SetupReactor(ServerReadReactor<RequestType>* reactor) { in SetupReactor()
418 ServerReactor* reactor() override { in reactor() function
472 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 …]
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/
Dserver_callback_handlers.h61 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
193 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor()
216 ServerReactor* reactor() override { in reactor() function
275 ServerReadReactor<RequestType>* reactor = nullptr; in RunHandler() local
373 void SetupReactor(ServerReadReactor<RequestType>* reactor) { in SetupReactor()
413 ServerReactor* reactor() override { in reactor() function
467 ServerWriteReactor<ResponseType>* reactor = nullptr; in RunHandler() local
598 void SetupReactor(ServerWriteReactor<ResponseType>* reactor) { in SetupReactor()
638 ServerReactor* reactor() override { in reactor() function
691 ServerBidiReactor<RequestType, ResponseType>* reactor = nullptr; in RunHandler() local
[all …]
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/
Dserver_callback_handlers.h61 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
193 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor()
216 ServerReactor* reactor() override { in reactor() function
275 ServerReadReactor<RequestType>* reactor = nullptr; in RunHandler() local
373 void SetupReactor(ServerReadReactor<RequestType>* reactor) { in SetupReactor()
413 ServerReactor* reactor() override { in reactor() function
467 ServerWriteReactor<ResponseType>* reactor = nullptr; in RunHandler() local
598 void SetupReactor(ServerWriteReactor<ResponseType>* reactor) { in SetupReactor()
638 ServerReactor* reactor() override { in reactor() function
691 ServerBidiReactor<RequestType, ResponseType>* reactor = nullptr; in RunHandler() local
[all …]
/external/grpc-grpc/test/cpp/naming/utils/
Ddns_resolver.py21 import twisted.internet.reactor as reactor namespace
63 def BeginQuery(reactor, qname): argument
/external/grpc-grpc/include/grpcpp/support/
Dclient_callback.h163 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor()
178 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor()
199 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor()
444 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor()
583 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl()
641 auto* reactor = reactor_; in MaybeFinish() local
705 ClientBidiReactor<Request, Response>* reactor) { in Create()
803 ClientReadReactor<Response>* reactor) in ClientCallbackReaderImpl()
816 auto* reactor = reactor_; in MaybeFinish() local
867 ClientReadReactor<Response>* reactor) { in Create()
[all …]
Dserver_callback.h110 void MaybeCallOnCancel(ServerReactor* reactor) { in MaybeCallOnCancel()
210 void BindReactor(Reactor* reactor) { in BindReactor()
224 void BindReactor(ServerReadReactor<Request>* reactor) { in BindReactor()
241 void BindReactor(ServerWriteReactor<Response>* reactor) { in BindReactor()
259 void BindReactor(ServerBidiReactor<Request, Response>* reactor) { in BindReactor()
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/support/
Dclient_callback.h171 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor()
186 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor()
207 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor()
452 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor()
591 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl()
649 auto* reactor = reactor_; in MaybeFinish() local
711 ClientBidiReactor<Request, Response>* reactor) { in Create()
809 ClientReadReactor<Response>* reactor) in ClientCallbackReaderImpl()
822 auto* reactor = reactor_; in MaybeFinish() local
871 ClientReadReactor<Response>* reactor) { in Create()
[all …]
Dserver_callback.h107 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()
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/support/
Dclient_callback.h171 void BindReactor(ClientBidiReactor<Request, Response>* reactor) { in BindReactor()
186 void BindReactor(ClientReadReactor<Response>* reactor) { in BindReactor()
207 void BindReactor(ClientWriteReactor<Request>* reactor) { in BindReactor()
452 inline void ClientCallbackUnary::BindReactor(ClientUnaryReactor* reactor) { in BindReactor()
591 ClientBidiReactor<Request, Response>* reactor) in ClientCallbackReaderWriterImpl()
649 auto* reactor = reactor_; in MaybeFinish() local
711 ClientBidiReactor<Request, Response>* reactor) { in Create()
809 ClientReadReactor<Response>* reactor) in ClientCallbackReaderImpl()
822 auto* reactor = reactor_; in MaybeFinish() local
871 ClientReadReactor<Response>* reactor) { in Create()
[all …]
Dserver_callback.h107 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()
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/
Dgeneric_stub.h106 ResponseType* response, ClientUnaryReactor* reactor) { in PrepareUnaryCall()
116 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall()
138 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCallInternal()
/external/grpc-grpc/include/grpcpp/generic/
Dgeneric_stub.h106 ResponseType* response, ClientUnaryReactor* reactor) { in PrepareUnaryCall()
116 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall()
138 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCallInternal()
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/generic/
Dgeneric_stub.h106 ResponseType* response, ClientUnaryReactor* reactor) { in PrepareUnaryCall()
116 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall()
138 ClientUnaryReactor* reactor) { in PrepareUnaryCallInternal()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCallInternal()
/external/grpc-grpc/examples/cpp/multiplex/
Dmultiplex_server.cc60 ServerUnaryReactor* reactor = context->DefaultReactor(); in SayHello() local
77 ServerUnaryReactor* reactor = context->DefaultReactor(); in GetFeature() local
/external/grpc-grpc/test/core/memory_usage/
Dcallback_server.cc54 auto* reactor = context->DefaultReactor(); in UnaryCall() local
64 auto* reactor = context->DefaultReactor(); in GetBeforeSnapshot() local
/external/grpc-grpc/examples/cpp/deadline/
Dserver.cc86 ServerUnaryReactor* reactor = context->DefaultReactor(); in SayHello() local
99 ServerUnaryReactor* reactor = context->DefaultReactor(); in SayHello() local
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_callback.cc56 void ServerCallbackCall::CallOnCancel(ServerReactor* reactor) { in CallOnCancel()
67 ServerReactor* reactor; in CallOnCancel() member
/external/parameter-framework/asio-1.10.6/include/asio/detail/
Dreactor_fwd.hpp21 typedef class epoll_reactor reactor; typedef
/external/grpc-grpc/test/cpp/interop/
Dpre_stop_hook_server.cc149 auto reactor = context->DefaultReactor(); in Hook() local
159 auto reactor = context->DefaultReactor(); in SetReturnStatus() local
172 auto reactor = context->DefaultReactor(); in ClearReturnStatus() local
/external/sdv/vsomeip/third_party/boost/asio/include/boost/asio/detail/
Dreactor_fwd.hpp25 typedef class null_reactor reactor; typedef
/external/grpc-grpc/src/cpp/server/
Dserver_callback.cc31 void ServerCallbackCall::CallOnCancel(ServerReactor* reactor) { in CallOnCancel()
/external/grpc-grpc/include/grpcpp/test/
Ddefault_reactor_test_peer.h44 ServerUnaryReactor* reactor() const { in reactor() function
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/test/
Ddefault_reactor_test_peer.h44 ServerUnaryReactor* reactor() const { in reactor() function
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/test/
Ddefault_reactor_test_peer.h44 ServerUnaryReactor* reactor() const { in reactor() function
/external/grpc-grpc/test/cpp/end2end/
Dmock_test.cc169 auto* reactor = context->DefaultReactor(); in Echo() local
202 auto* reactor = service_.Echo(&ctx, &req, &resp); in TEST_F() local
224 auto* reactor = service_.Echo(&ctx, &req, &resp); in TEST_F() local
236 auto* reactor = service_.Echo(&ctx, &req, &resp); in TEST_F() local

123