| /frameworks/native/libs/binder/ |
| D | RpcServer.cpp | 51 RpcServer::RpcServer(std::unique_ptr<RpcTransportCtx> ctx) : mCtx(std::move(ctx)) {} in RpcServer() function in android::RpcServer
52 RpcServer::~RpcServer() { in ~RpcServer()
57 sp<RpcServer> RpcServer::make(std::unique_ptr<RpcTransportCtxFactory> rpcTransportCtxFactory) { in make()
63 return sp<RpcServer>::make(std::move(ctx)); in make()
66 status_t RpcServer::setupUnixDomainSocketBootstrapServer(unique_fd bootstrapFd) { in setupUnixDomainSocketBootstrapServer()
67 return setupExternalServer(std::move(bootstrapFd), &RpcServer::recvmsgSocketConnection); in setupUnixDomainSocketBootstrapServer()
70 status_t RpcServer::setupUnixDomainServer(const char* path) { in setupUnixDomainServer()
74 status_t RpcServer::setupVsockServer(unsigned int bindCid, unsigned int port) { in setupVsockServer()
78 status_t RpcServer::setupInetServer(const char* address, unsigned int port, in setupInetServer()
117 void RpcServer::setMaxThreads(size_t threads) { in setMaxThreads()
[all …]
|
| D | libbinder_rpc_unstable.cpp | 33 using android::RpcServer;
85 auto server = RpcServer::make(); in ARpcServer_newVsock()
115 auto server = RpcServer::make(); in ARpcServer_newBoundSocket()
131 auto server = RpcServer::make(); in ARpcServer_newUnixDomainBootstrap()
148 auto server = RpcServer::make(); in ARpcServer_newInet()
162 auto server = handleToStrongPointer<RpcServer>(handle); in ARpcServer_setSupportedFileDescriptorTransportModes()
171 handleToStrongPointer<RpcServer>(handle)->setMaxThreads(threads); in ARpcServer_setMaxThreads()
175 handleToStrongPointer<RpcServer>(handle)->start(); in ARpcServer_start()
179 handleToStrongPointer<RpcServer>(handle)->join(); in ARpcServer_join()
183 return handleToStrongPointer<RpcServer>(handle)->shutdown(); in ARpcServer_shutdown()
[all …]
|
| D | servicedispatcher.cpp | 38 using android::RpcServer;
90 auto rpcServer = RpcServer::make(); in Dispatch()
215 auto rpcServer = RpcServer::make(); in wrapServiceManager()
|
| D | Binder.cpp | 230 RpcServerLink(const sp<RpcServer>& rpcServer, const sp<IBinder>& keepAliveBinder, in RpcServerLink()
254 sp<RpcServer> mRpcServer;
694 auto rpcServer = RpcServer::make(); in setRpcClientDebug()
|
| D | RpcSession.cpp | 470 sp<RpcServer> RpcSession::server() { in server()
471 RpcServer* unsafeServer = mForServer.unsafe_get(); in server()
472 sp<RpcServer> server = mForServer.promote(); in server()
784 bool RpcSession::setForServer(const wp<RpcServer>& server, const wp<EventListener>& eventListener, in setForServer()
|
| D | Android.bp | 235 "RpcServer.cpp",
|
| D | RpcState.cpp | 1018 sp<RpcServer> server = session->server(); in processTransactInternal()
|
| /frameworks/native/libs/binder/rust/rpcbinder/src/server/ |
| D | android.rs | 31 pub struct RpcServer;
37 unsafe impl Send for RpcServer {} implementation
39 unsafe impl Sync for RpcServer {} implementation
41 impl RpcServer { implementation
47 pub fn new_vsock(mut service: SpIBinder, cid: u32, port: u32) -> Result<RpcServer, Error> { in new_vsock() argument
65 ) -> Result<RpcServer, Error> { in new_bound_socket() argument
86 ) -> Result<RpcServer, Error> { in new_unix_domain_bootstrap() argument
102 pub fn new_inet(mut service: SpIBinder, address: &str, port: u32) -> Result<RpcServer, Error> { in new_inet() argument
123 unsafe fn checked_from_ptr(ptr: *mut ARpcServer) -> Result<RpcServer, Error> { in checked_from_ptr() argument
129 Ok(unsafe { RpcServer::from_ptr(ptr) }) in checked_from_ptr()
|
| D | trusty.rs | 26 pub struct RpcServer { struct
32 unsafe impl Send for RpcServer {} implementation
34 unsafe impl Sync for RpcServer {} implementation
36 impl Drop for RpcServer { implementation
46 impl RpcServer { impl
48 pub fn new(service: SpIBinder) -> RpcServer { in new() argument
57 pub fn new_per_session<F: PerSessionCallback>(f: F) -> RpcServer { in new_per_session() argument
66 RpcServer { inner } in new_per_session()
118 impl UnbufferedService for RpcServer { implementation
|
| /frameworks/native/libs/binder/include/binder/ |
| D | RpcServer.h | 49 class RpcServer final : public virtual RefBase, private RpcSession::EventListener {
51 LIBBINDER_EXPORTED static sp<RpcServer> make(
246 LIBBINDER_EXPORTED ~RpcServer();
250 friend sp<RpcServer>;
251 explicit RpcServer(std::unique_ptr<RpcTransportCtx> ctx);
258 std::function<status_t(const RpcServer&, RpcTransportFd*)>&& acceptFn);
262 sp<RpcServer>&& server, RpcTransportFd clientFd,
265 static status_t acceptSocketConnection(const RpcServer& server, RpcTransportFd* out);
266 static status_t recvmsgSocketConnection(const RpcServer& server, RpcTransportFd* out);
291 std::function<status_t(const RpcServer& server, RpcTransportFd* out)> mAcceptFn;
|
| D | RpcSession.h | 33 class RpcServer; variable
218 LIBBINDER_EXPORTED sp<RpcServer> server();
225 friend RpcServer; variable
301 [[nodiscard]] bool setForServer(const wp<RpcServer>& server,
363 wp<RpcServer> mForServer; // maybe null, for client sessions
|
| /frameworks/native/libs/binder/trusty/rust/binder_rpc_server_bindgen/cpp/ |
| D | ARpcServerTrusty.cpp | 23 using android::RpcServer;
31 sp<RpcServer> mRpcServer;
34 ARpcServerTrusty(sp<RpcServer> rpcServer) : mRpcServer(std::move(rpcServer)) {} in ARpcServerTrusty()
|
| /frameworks/native/libs/binder/trusty/include/binder/ |
| D | RpcServerTrusty.h | 94 static sp<RpcServer> makeRpcServer(std::unique_ptr<RpcTransportCtx> ctx) { in makeRpcServer()
95 auto rpcServer = sp<RpcServer>::make(std::move(ctx)); in makeRpcServer()
125 static int handleConnectInternal(RpcServer* rpcServer, handle_t chan, const uuid* peer,
137 sp<RpcServer> mRpcServer;
|
| /frameworks/native/libs/binder/trusty/ |
| D | RpcServerTrusty.cpp | 103 int RpcServerTrusty::handleConnectInternal(RpcServer* rpcServer, handle_t chan, const uuid* peer, in handleConnectInternal()
139 std::array<uint8_t, RpcServer::kRpcAddressSize> addr; in handleConnectInternal()
142 RpcServer::establishConnection(sp<RpcServer>::fromExisting(rpcServer), std::move(transportFd), in handleConnectInternal()
|
| D | rules.mk | 39 $(LIBBINDER_DIR)/RpcServer.cpp \
|
| /frameworks/native/libs/binder/tests/unit_fuzzers/ |
| D | BpBinderFuzz.cpp | 41 sp<RpcServer> server = RpcServer::make(); in LLVMFuzzerTestOneInput()
|
| /frameworks/native/libs/binder/tests/ |
| D | binderRpcTestService.cpp | 25 wp<RpcServer> server;
40 sp<RpcServer> strongServer = server.promote(); in scheduleShutdown()
121 sp<RpcServer> server = RpcServer::make(newTlsFactory(rpcSecurity, certVerifier)); in main()
|
| D | binderRpcBenchmark.cpp | 53 using android::RpcServer;
304 void forkRpcServer(const char* addr, const sp<RpcServer>& server) { in forkRpcServer()
349 forkRpcServer(addr.c_str(), RpcServer::make(RpcTransportCtxFactoryRaw::make())); in main()
355 forkRpcServer(tlsAddr.c_str(), RpcServer::make(makeFactoryTls())); in main()
|
| D | binderAllocationLimits.cpp | 142 using android::RpcServer;
231 auto server = RpcServer::make(); in TEST()
|
| D | binderRpcTest.cpp | 1317 using SetFn = std::function<void(RpcServer*, sp<IBinder>)>; in TEST_P()
1319 return isStrong ? SetFn(&RpcServer::setRootObject) : SetFn(&RpcServer::setRootObjectWeak); in TEST_P()
1323 auto server = RpcServer::make(newTlsFactory(rpcSecurity)); in TEST_P()
1389 auto rpcServer = RpcServer::make(); in TEST()
1430 auto server = RpcServer::make(newTlsFactory(std::get<0>(GetParam()))); in TEST_P()
1446 auto server = RpcServer::make(newTlsFactory(std::get<0>(GetParam()))); in TEST_P()
1495 auto rpcServer = RpcServer::make(newTlsFactory(rpcSecurity)); in setUp()
|
| D | binderLibTest.cpp | 1604 auto rpcServer = RpcServer::make(); in CreateSocket()
|
| /frameworks/native/libs/binder/rust/rpcbinder/src/ |
| D | lib.rs | 22 pub use server::RpcServer;
|
| /frameworks/native/libs/binder/trusty/rust/binder_rpc_test/service/ |
| D | main.rs | 24 use rpcbinder::RpcServer;
209 wrap_service!(TestRpcServer(RpcServer: UnbufferedService));
222 TestRpcServer::new(RpcServer::new_per_session(move |_uuid| Some(service.as_binder()))); in main()
|
| /frameworks/native/libs/binder/tests/rpc_fuzzer/ |
| D | main.cpp | 125 sp<RpcServer> server = RpcServer::make(makeTransportCtxFactory(&provider)); in LLVMFuzzerTestOneInput()
|