Home
last modified time | relevance | path

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

/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dserver_callback_handlers.h60 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
198 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor()
218 ServerReactor* reactor() override { in reactor() function
278 ServerReadReactor<RequestType>* reactor = nullptr; in RunHandler() local
376 void SetupReactor(ServerReadReactor<RequestType>* reactor) { in SetupReactor()
410 ServerReactor* reactor() override { in reactor() function
465 ServerWriteReactor<ResponseType>* reactor = nullptr; in RunHandler() local
599 void SetupReactor(ServerWriteReactor<ResponseType>* reactor) { in SetupReactor()
632 ServerReactor* reactor() override { in reactor() function
685 ServerBidiReactor<RequestType, ResponseType>* reactor = nullptr; in RunHandler() local
[all …]
Dclient_callback.h158 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 …]
Dserver_callback.h106 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()
Dserver_context.h508 ::grpc::internal::ServerReactor* reactor() override { return reactor_; } in reactor() function
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dserver_callback_handlers.h60 ServerUnaryReactor* reactor = nullptr; in RunHandler() local
198 void SetupReactor(ServerUnaryReactor* reactor) { in SetupReactor()
218 ServerReactor* reactor() override { in reactor() function
278 ServerReadReactor<RequestType>* reactor = nullptr; in RunHandler() local
376 void SetupReactor(ServerReadReactor<RequestType>* reactor) { in SetupReactor()
410 ServerReactor* reactor() override { in reactor() function
465 ServerWriteReactor<ResponseType>* reactor = nullptr; in RunHandler() local
599 void SetupReactor(ServerWriteReactor<ResponseType>* reactor) { in SetupReactor()
632 ServerReactor* reactor() override { in reactor() function
685 ServerBidiReactor<RequestType, ResponseType>* reactor = nullptr; in RunHandler() local
[all …]
Dclient_callback.h158 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 …]
Dserver_callback.h106 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()
Dserver_context.h508 ::grpc::internal::ServerReactor* reactor() override { return reactor_; } in reactor() function
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/generic/
Dgeneric_stub.h102 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()
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/
Dgeneric_stub.h102 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()
/external/grpc-grpc/test/cpp/naming/utils/
Ddns_resolver.py23 import twisted.internet.reactor as reactor namespace
41 def BeginQuery(reactor, qname): argument
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_callback.cc53 void ServerCallbackCall::CallOnCancel(ServerReactor* reactor) { in CallOnCancel()
64 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/rust/crates/grpcio-sys/grpc/include/grpcpp/test/
Ddefault_reactor_test_peer.h44 ::grpc::experimental::ServerUnaryReactor* reactor() const { in reactor() function
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/test/
Ddefault_reactor_test_peer.h44 ::grpc::experimental::ServerUnaryReactor* reactor() const { in reactor() function
/external/rust/crates/grpcio-sys/grpc/src/cpp/client/
Dclient_callback.cc33 ClientReactor* const reactor; in InternalScheduleOnDone() member