Home
last modified time | relevance | path

Searched refs:RpcSession (Results 1 – 25 of 37) sorted by relevance

12

/frameworks/native/libs/binder/
DRpcState.h69 [[nodiscard]] status_t readNewSessionResponse(const sp<RpcSession::RpcConnection>& connection,
70 const sp<RpcSession>& session, uint32_t* version);
71 [[nodiscard]] status_t sendConnectionInit(const sp<RpcSession::RpcConnection>& connection,
72 const sp<RpcSession>& session);
73 [[nodiscard]] status_t readConnectionInit(const sp<RpcSession::RpcConnection>& connection,
74 const sp<RpcSession>& session);
77 sp<IBinder> getRootObject(const sp<RpcSession::RpcConnection>& connection,
78 const sp<RpcSession>& session);
79 [[nodiscard]] status_t getMaxThreads(const sp<RpcSession::RpcConnection>& connection,
80 const sp<RpcSession>& session, size_t* maxThreadsOut);
[all …]
DRpcSession.cpp57 RpcSession::RpcSession(std::unique_ptr<RpcTransportCtx> ctx) : mCtx(std::move(ctx)) { in RpcSession() function in android::RpcSession
62 RpcSession::~RpcSession() { in ~RpcSession()
70 sp<RpcSession> RpcSession::make() { in make()
75 sp<RpcSession> RpcSession::make(std::unique_ptr<RpcTransportCtxFactory> rpcTransportCtxFactory) { in make()
78 return sp<RpcSession>::make(std::move(ctx)); in make()
81 void RpcSession::setMaxIncomingThreads(size_t threads) { in setMaxIncomingThreads()
88 size_t RpcSession::getMaxIncomingThreads() { in getMaxIncomingThreads()
93 void RpcSession::setMaxOutgoingConnections(size_t connections) { in setMaxOutgoingConnections()
100 size_t RpcSession::getMaxOutgoingThreads() { in getMaxOutgoingThreads()
105 bool RpcSession::setProtocolVersionInternal(uint32_t version, bool checkStarted) { in setProtocolVersionInternal()
[all …]
Dlibbinder_rpc_unstable.cpp34 using android::RpcSession;
67 RpcSession::FileDescriptorTransportMode toTransportMode( in toTransportMode()
71 return RpcSession::FileDescriptorTransportMode::NONE; in toTransportMode()
73 return RpcSession::FileDescriptorTransportMode::UNIX; in toTransportMode()
75 return RpcSession::FileDescriptorTransportMode::TRUSTY; in toTransportMode()
77 return RpcSession::FileDescriptorTransportMode::NONE; in toTransportMode()
163 std::vector<RpcSession::FileDescriptorTransportMode> modevec; in ARpcServer_setSupportedFileDescriptorTransportModes()
194 auto session = RpcSession::make(); in ARpcSession_new()
199 freeObjectHandle<RpcSession>(handle); in ARpcSession_free()
204 auto session = handleToStrongPointer<RpcSession>(handle); in ARpcSession_setupVsockClient()
[all …]
DRpcState.cpp58 static bool enableAncillaryFds(RpcSession::FileDescriptorTransportMode mode) { in enableAncillaryFds()
60 case RpcSession::FileDescriptorTransportMode::NONE: in enableAncillaryFds()
62 case RpcSession::FileDescriptorTransportMode::UNIX: in enableAncillaryFds()
63 case RpcSession::FileDescriptorTransportMode::TRUSTY: in enableAncillaryFds()
72 status_t RpcState::onBinderLeaving(const sp<RpcSession>& session, const sp<IBinder>& binder, in onBinderLeaving()
155 status_t RpcState::onBinderEntering(const sp<RpcSession>& session, uint64_t address, in onBinderEntering()
202 status_t RpcState::flushExcessBinderRefs(const sp<RpcSession>& session, uint64_t address, in flushExcessBinderRefs()
235 status_t RpcState::sendObituaries(const sp<RpcSession>& session) { in sendObituaries()
360 status_t RpcState::rpcSend(const sp<RpcSession::RpcConnection>& connection, in rpcSend()
361 const sp<RpcSession>& session, const char* what, iovec* iovs, int niovs, in rpcSend()
[all …]
DRpcTrusty.cpp28 sp<RpcSession> RpcTrustyConnectWithSessionInitializer( in RpcTrustyConnectWithSessionInitializer()
30 std::function<void(sp<RpcSession>&)> sessionInitializer) { in RpcTrustyConnectWithSessionInitializer()
31 auto session = RpcSession::make(RpcTransportCtxFactoryTipcAndroid::make()); in RpcTrustyConnectWithSessionInitializer()
DRpcServer.cpp137 const std::vector<RpcSession::FileDescriptorTransportMode>& modes) { in setSupportedFileDescriptorTransportModes()
139 for (RpcSession::FileDescriptorTransportMode mode : modes) { in setSupportedFileDescriptorTransportModes()
157 std::function<sp<IBinder>(wp<RpcSession> session, const void*, size_t)>&& makeObject) { in setPerSessionRootObject()
284 addrLen, RpcSession::join); in join()
355 std::vector<sp<RpcSession>> RpcServer::listSessions() { in listSessions()
357 std::vector<sp<RpcSession>> sessions; in listSessions()
373 std::function<void(sp<RpcSession>&&, RpcSession::PreJoinSetupResult&&)>&& joinFn) { in establishConnection() argument
450 sp<RpcSession> session; in establishConnection()
496 session = sp<RpcSession>::make(nullptr); in establishConnection()
505 static_cast<RpcSession::FileDescriptorTransportMode>( in establishConnection()
[all …]
/frameworks/native/libs/binder/include/binder/
DRpcServer.h49 class RpcServer final : public virtual RefBase, private RpcSession::EventListener {
154 const std::vector<RpcSession::FileDescriptorTransportMode>& modes);
182 std::function<sp<IBinder>(wp<RpcSession> session, const void*, size_t)>&& object);
238 LIBBINDER_EXPORTED std::vector<sp<RpcSession>> listSessions();
253 void onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) override;
264 std::function<void(sp<RpcSession>&&, RpcSession::PreJoinSetupResult&&)>&& joinFn);
275 static_cast<size_t>(RpcSession::FileDescriptorTransportMode::NONE));
285 std::function<sp<IBinder>(wp<RpcSession>, const void*, size_t)> mRootObjectFactory;
288 std::map<std::vector<uint8_t>, sp<RpcSession>> mSessions;
DRpcSession.h58 class RpcSession final : public virtual RefBase {
61 LIBBINDER_EXPORTED static sp<RpcSession> make();
66 LIBBINDER_EXPORTED static sp<RpcSession> make(
212 LIBBINDER_EXPORTED ~RpcSession();
224 friend sp<RpcSession>;
228 explicit RpcSession(std::unique_ptr<RpcTransportCtx> ctx);
241 virtual void onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) = 0;
247 void onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) override;
249 void waitForShutdown(RpcMutexUniqueLock& lock, const sp<RpcSession>& session);
286 static void join(sp<RpcSession>&& session, PreJoinSetupResult&& result);
[all …]
DBpBinder.h32 class RpcSession; variable
133 friend class ::android::RpcSession;
138 static sp<BpBinder> create(const sp<RpcSession>& session, uint64_t address) { in create()
147 const sp<RpcSession>& rpcSession() const { return mBinder->rpcSession(); } in rpcSession()
160 static sp<BpBinder> create(const sp<RpcSession>& session, uint64_t address);
166 sp<RpcSession> session;
173 const sp<RpcSession>& rpcSession() const;
/frameworks/native/libs/binder/rust/rpcbinder/src/
Dsession.rs31 pub struct RpcSession;
37 unsafe impl Send for RpcSession {} implementation
39 unsafe impl Sync for RpcSession {} implementation
41 impl RpcSession { impl
43 pub fn new() -> RpcSession { in new()
45 unsafe { RpcSession::from_ptr(binder_rpc_unstable_bindgen::ARpcSession_new()) } in new()
49 impl Default for RpcSession { implementation
Dlib.rs25 pub use session::{FileDescriptorTransportMode, RpcSession, RpcSessionRef};
/frameworks/native/libs/binder/trusty/include/binder/
DRpcServerTrusty.h65 const std::vector<RpcSession::FileDescriptorTransportMode>& modes) { in setSupportedFileDescriptorTransportModes()
71 std::function<sp<IBinder>(wp<RpcSession> session, const void*, size_t)>&& object) { in setPerSessionRootObject()
79 std::vector<sp<RpcSession>> listSessions() { return mRpcServer->listSessions(); } in listSessions()
116 sp<RpcSession> session;
117 sp<RpcSession::RpcConnection> connection;
/frameworks/native/libs/binder/include_trusty/binder/
DRpcTrusty.h25 sp<RpcSession> RpcTrustyConnectWithSessionInitializer(
27 std::function<void(sp<RpcSession>&)> sessionInitializer);
/frameworks/native/libs/binder/tests/
DbinderRpcTestService.cpp113 std::vector<RpcSession::FileDescriptorTransportMode> in main()
117 static_cast<RpcSession::FileDescriptorTransportMode>(mode)); in main()
173 server->setPerSessionRootObject([&](wp<RpcSession> session, const void* addrPtr, size_t len) { in main()
175 sp<RpcSession> spSession = session.promote(); in main()
DbinderRpcBenchmark.cpp54 using android::RpcSession;
142 static sp<RpcSession> gSession = RpcSession::make();
146 static sp<RpcSession> gSessionTls = RpcSession::make(makeFactoryTls());
314 void setupClient(const sp<RpcSession>& session, const char* addr) { in setupClient()
DbinderRpcTest.cpp176 sp<RpcSession>& session = info.session; in ~LinuxProcessSession()
182 wp<RpcSession> weakSession = session; in ~LinuxProcessSession()
189 sp<RpcSession> strongSession = weakSession.promote(); in ~LinuxProcessSession()
314 std::vector<sp<RpcSession>> sessions; in createRpcTestSocketServerProcessEtc()
327 sessions.emplace_back(RpcSession::make(std::move(factory))); in createRpcTestSocketServerProcessEtc()
582 .clientFileDescriptorTransportMode = RpcSession::FileDescriptorTransportMode::UNIX, in TEST_P()
584 {RpcSession::FileDescriptorTransportMode::UNIX}, in TEST_P()
685 wp<RpcSession> session = proc.proc->sessions.at(1).session; in TEST_P()
886 .clientFileDescriptorTransportMode = RpcSession::FileDescriptorTransportMode::NONE, in TEST_P()
888 {RpcSession::FileDescriptorTransportMode::UNIX}, in TEST_P()
[all …]
DbinderRpcTestCommon.h167 RpcSession::FileDescriptorTransportMode clientFileDescriptorTransportMode =
168 RpcSession::FileDescriptorTransportMode::NONE;
169 std::vector<RpcSession::FileDescriptorTransportMode>
171 RpcSession::FileDescriptorTransportMode::NONE};
DbinderRpcUniversalTests.cpp44 auto session = RpcSession::make(); in TEST()
53 auto session = RpcSession::make(); in TEST()
335 auto fileDescriptorTransportMode = RpcSession::FileDescriptorTransportMode::UNIX; in TEST_P()
338 fileDescriptorTransportMode = RpcSession::FileDescriptorTransportMode::NONE; in TEST_P()
DbinderAllocationLimits.cpp143 using android::RpcSession;
238 auto session = RpcSession::make(); in TEST()
DbinderRpcTestServiceTrusty.cpp93 [=](wp<RpcSession> /*session*/, const void* /*addrPtr*/, size_t /*len*/) { in main() argument
/frameworks/native/libs/binder/tests/unit_fuzzers/
DBpBinderFuzz.cpp51 sp<RpcSession> session = RpcSession::make(); in LLVMFuzzerTestOneInput()
/frameworks/native/libs/binder/trusty/rust/binder_rpc_server_bindgen/cpp/
DARpcServerTrusty.cpp25 using android::RpcSession;
57 [cb, cbArgSp](wp<RpcSession> /*session*/, const void* addrPtr, size_t len) { in ARpcServerTrusty_newPerSession() argument
/frameworks/native/libs/binder/trusty/
DRpcServerTrusty.cpp109 auto joinFn = [&](sp<RpcSession>&& session, RpcSession::PreJoinSetupResult&& result) { in handleConnectInternal()
Drules.mk40 $(LIBBINDER_DIR)/RpcSession.cpp \
/frameworks/native/libs/binder/trusty/rust/binder_rpc_test/
Dmain.rs23 use rpcbinder::RpcSession;
46 RpcSession::new().setup_trusty_client(port.as_c_str()).expect("Failed to create session") in get_service()

12