Home
last modified time | relevance | path

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

123

/aosp_15_r20/packages/modules/Bluetooth/system/osi/test/
Dreactor_test.cc15 reactor_t* reactor = (reactor_t*)ptr; in reactor_thread() local
24 static void spawn_reactor_thread(reactor_t* reactor) { in spawn_reactor_thread()
32 reactor_t* reactor = reactor_new(); in TEST_F() local
40 reactor_t* reactor = reactor_new(); in TEST_F() local
47 reactor_t* reactor = reactor_new(); in TEST_F() local
56 reactor_t* reactor = reactor_new(); in TEST_F() local
70 reactor_t* reactor; member
81 reactor_t* reactor = reactor_new(); in TEST_F() local
97 reactor_t* reactor = reactor_new(); in TEST_F() local
/aosp_15_r20/external/rust/android-crates-io/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 …]
/aosp_15_r20/external/grpc-grpc/include/grpcpp/impl/
H A 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 …]
/aosp_15_r20/external/rust/android-crates-io/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 …]
/aosp_15_r20/external/rust/android-crates-io/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()
/aosp_15_r20/external/grpc-grpc/include/grpcpp/support/
H A 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 …]
H A 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()
/aosp_15_r20/external/rust/android-crates-io/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()
/aosp_15_r20/packages/modules/Bluetooth/system/osi/src/
Dreactor.cc55 reactor_t* reactor; // the reactor instance this object is registered with. member
110 void reactor_free(reactor_t* reactor) { in reactor_free()
122 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start()
127 reactor_status_t reactor_run_once(reactor_t* reactor) { in reactor_run_once()
132 void reactor_stop(reactor_t* reactor) { in reactor_stop()
138 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context, in reactor_register()
202 reactor_t* reactor = obj->reactor; in reactor_unregister() local
235 static reactor_status_t run_reactor(reactor_t* reactor, int iterations) { in run_reactor()
/aosp_15_r20/external/grpc-grpc/include/grpcpp/generic/
H A 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()
/aosp_15_r20/external/rust/android-crates-io/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()
/aosp_15_r20/external/rust/android-crates-io/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()
/aosp_15_r20/packages/modules/Bluetooth/system/test/stub/
Dosi.cc173 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context, in reactor_register()
179 reactor_status_t reactor_run_once(reactor_t* reactor) { in reactor_run_once()
183 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start()
191 void reactor_free(reactor_t* reactor) { inc_func_call_count(__func__); } in reactor_free()
192 void reactor_stop(reactor_t* reactor) { inc_func_call_count(__func__); } in reactor_stop()
305 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, fixed_queue_cb ready_cb, in fixed_queue_register_dequeue()
460 void socket_register(socket_t* socket, reactor_t* reactor, void* context, socket_cb read_cb, in socket_register()
/aosp_15_r20/external/grpc-grpc/test/cpp/end2end/
H A 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
H A Dresource_quota_end2end_stress_test.cc130 EchoClientUnaryReactor reactor(&ctx, stub.get(), payload_, &status); in MakeGrpcCall() local
238 EchoClientUnaryReactor reactor(&ctx, stubs[i].get(), payload_, &status); in TestExceedingConnectionQuota() local
/aosp_15_r20/external/grpc-grpc/test/cpp/interop/
H A 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
/aosp_15_r20/external/grpc-grpc/test/cpp/naming/utils/
H A Ddns_resolver.py21 import twisted.internet.reactor as reactor namespace
63 def BeginQuery(reactor, qname): argument
/aosp_15_r20/external/grpc-grpc/examples/cpp/multiplex/
H A Dmultiplex_server.cc60 ServerUnaryReactor* reactor = context->DefaultReactor(); in SayHello() local
77 ServerUnaryReactor* reactor = context->DefaultReactor(); in GetFeature() local
/aosp_15_r20/external/grpc-grpc/test/core/memory_usage/
H A Dcallback_server.cc54 auto* reactor = context->DefaultReactor(); in UnaryCall() local
64 auto* reactor = context->DefaultReactor(); in GetBeforeSnapshot() local
/aosp_15_r20/external/grpc-grpc/examples/cpp/deadline/
H A Dserver.cc86 ServerUnaryReactor* reactor = context->DefaultReactor(); in SayHello() local
99 ServerUnaryReactor* reactor = context->DefaultReactor(); in SayHello() local
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_callback.cc56 void ServerCallbackCall::CallOnCancel(ServerReactor* reactor) { in CallOnCancel()
67 ServerReactor* reactor; in CallOnCancel() member
/aosp_15_r20/packages/modules/Bluetooth/system/gd/os/
Dqueue.h202 Reactor* reactor = nullptr; in UnregisterEnqueue() local
233 Reactor* reactor = nullptr; in UnregisterDequeue() local
/aosp_15_r20/external/parameter-framework/asio-1.10.6/include/asio/detail/
H A Dreactor_fwd.hpp21 typedef class epoll_reactor reactor; typedef

123