/frameworks/native/libs/binder/ |
D | RpcState.h | 65 [[nodiscard]] status_t readNewSessionResponse(const sp<RpcSession::RpcConnection>& connection, 66 const sp<RpcSession>& session, uint32_t* version); 67 [[nodiscard]] status_t sendConnectionInit(const sp<RpcSession::RpcConnection>& connection, 68 const sp<RpcSession>& session); 69 [[nodiscard]] status_t readConnectionInit(const sp<RpcSession::RpcConnection>& connection, 70 const sp<RpcSession>& session); 73 sp<IBinder> getRootObject(const sp<RpcSession::RpcConnection>& connection, 74 const sp<RpcSession>& session); 75 [[nodiscard]] status_t getMaxThreads(const sp<RpcSession::RpcConnection>& connection, 76 const sp<RpcSession>& session, size_t* maxThreadsOut); [all …]
|
D | RpcSession.cpp | 58 RpcSession::RpcSession(std::unique_ptr<RpcTransportCtx> ctx) : mCtx(std::move(ctx)) { in RpcSession() function in android::RpcSession 63 RpcSession::~RpcSession() { in ~RpcSession() 71 sp<RpcSession> RpcSession::make() { in make() 76 sp<RpcSession> RpcSession::make(std::unique_ptr<RpcTransportCtxFactory> rpcTransportCtxFactory) { in make() 79 return sp<RpcSession>::make(std::move(ctx)); in make() 82 void RpcSession::setMaxIncomingThreads(size_t threads) { in setMaxIncomingThreads() 91 size_t RpcSession::getMaxIncomingThreads() { in getMaxIncomingThreads() 96 void RpcSession::setMaxOutgoingThreads(size_t threads) { in setMaxOutgoingThreads() 105 size_t RpcSession::getMaxOutgoingThreads() { in getMaxOutgoingThreads() 110 bool RpcSession::setProtocolVersion(uint32_t version) { in setProtocolVersion() [all …]
|
D | RpcState.cpp | 55 status_t RpcState::onBinderLeaving(const sp<RpcSession>& session, const sp<IBinder>& binder, in onBinderLeaving() 138 status_t RpcState::onBinderEntering(const sp<RpcSession>& session, uint64_t address, in onBinderEntering() 185 status_t RpcState::flushExcessBinderRefs(const sp<RpcSession>& session, uint64_t address, in flushExcessBinderRefs() 312 status_t RpcState::rpcSend(const sp<RpcSession::RpcConnection>& connection, in rpcSend() 313 const sp<RpcSession>& session, const char* what, iovec* iovs, int niovs, in rpcSend() 334 status_t RpcState::rpcRec(const sp<RpcSession::RpcConnection>& connection, in rpcRec() 335 const sp<RpcSession>& session, const char* what, iovec* iovs, int niovs) { in rpcRec() 354 status_t RpcState::readNewSessionResponse(const sp<RpcSession::RpcConnection>& connection, in readNewSessionResponse() 355 const sp<RpcSession>& session, uint32_t* version) { in readNewSessionResponse() 366 status_t RpcState::sendConnectionInit(const sp<RpcSession::RpcConnection>& connection, in sendConnectionInit() [all …]
|
D | libbinder_rpc_unstable.cpp | 26 using android::RpcSession; 78 auto session = RpcSession::make(); in RpcClient() 88 auto session = RpcSession::make(); in RpcPreconnectedClient()
|
D | RpcServer.cpp | 254 std::vector<sp<RpcSession>> RpcServer::listSessions() { in listSessions() 256 std::vector<sp<RpcSession>> sessions; in listSessions() 345 sp<RpcSession> session; in establishConnection() 391 session = RpcSession::make(); in establishConnection() 441 RpcSession::join(std::move(session), std::move(setupResult)); in establishConnection() 481 void RpcServer::onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) { in onSessionAllIncomingThreadsEnded()
|
D | ServiceManagerHost.cpp | 161 auto rpcSession = RpcSession::make(); in getDeviceService()
|
D | BpBinder.cpp | 158 sp<BpBinder> BpBinder::create(const sp<RpcSession>& session, uint64_t address) { in create() 199 const sp<RpcSession>& BpBinder::rpcSession() const { in rpcSession()
|
D | Android.bp | 119 "RpcSession.cpp",
|
D | Parcel.cpp | 653 void Parcel::markForRpc(const sp<RpcSession>& session) { in markForRpc()
|
/frameworks/native/libs/binder/include/binder/ |
D | RpcSession.h | 47 class RpcSession final : public virtual RefBase { 52 static sp<RpcSession> make(); 57 static sp<RpcSession> make(std::unique_ptr<RpcTransportCtxFactory> rpcTransportCtxFactory); 172 ~RpcSession(); 184 friend sp<RpcSession>; 187 explicit RpcSession(std::unique_ptr<RpcTransportCtx> ctx); 194 virtual void onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) = 0; 200 void onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) override; 202 void waitForShutdown(std::unique_lock<std::mutex>& lock, const sp<RpcSession>& session); 238 static void join(sp<RpcSession>&& session, PreJoinSetupResult&& result); [all …]
|
D | BpBinder.h | 29 class RpcSession; variable 120 friend class ::android::RpcSession; 125 static sp<BpBinder> create(const sp<RpcSession>& session, uint64_t address) { in create() 134 const sp<RpcSession>& rpcSession() const { return mBinder->rpcSession(); } in rpcSession() 145 static sp<BpBinder> create(const sp<RpcSession>& session, uint64_t address); 151 sp<RpcSession> session; 158 const sp<RpcSession>& rpcSession() const;
|
D | RpcServer.h | 45 class RpcServer final : public virtual RefBase, private RpcSession::EventListener { 168 std::vector<sp<RpcSession>> listSessions(); 177 void onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) override; 196 std::map<std::vector<uint8_t>, sp<RpcSession>> mSessions;
|
D | Parcel.h | 54 class RpcSession; variable 119 void markForRpc(const sp<RpcSession>& session); 1271 sp<RpcSession> mSession;
|
/frameworks/native/libs/binder/tests/ |
D | binderRpcBenchmark.cpp | 54 using android::RpcSession; 104 static sp<RpcSession> gSession = RpcSession::make(); 107 static sp<RpcSession> gSessionTls = RpcSession::make(makeFactoryTls()); 215 void setupClient(const sp<RpcSession>& session, const char* addr) { in setupClient()
|
D | binderRpcTest.cpp | 122 auto session = RpcSession::make(); in TEST() 130 auto session = RpcSession::make(); in TEST() 378 sp<RpcSession> session; 393 sp<RpcSession>& session = info.session; in ~ProcessSession() 399 wp<RpcSession> weakSession = session; in ~ProcessSession() 592 std::vector<sp<RpcSession>> sessions; in createRpcTestSocketServerProcess() 595 sessions.emplace_back(RpcSession::make(newFactory(rpcSecurity, certVerifier))); in createRpcTestSocketServerProcess() 1394 sp<RpcSession> session = RpcSession::make(RpcTransportCtxFactoryRaw::make()); in testSupportVsockLoopback() 1531 auto rpcSession = RpcSession::make(); in TEST()
|
D | binderHostDeviceTest.cpp | 105 auto rpcSession = RpcSession::make(); in get()
|
D | binderRpcWireProtocolTest.cpp | 165 auto session = RpcSession::make(); in setParcelForRpc()
|
/frameworks/native/libs/binder/tests/unit_fuzzers/ |
D | BpBinderFuzz.cpp | 51 sp<RpcSession> session = RpcSession::make(); in LLVMFuzzerTestOneInput()
|
/frameworks/native/libs/binder/tests/parcel_fuzzer/ |
D | random_parcel.cpp | 45 auto session = RpcSession::make(RpcTransportCtxFactoryRaw::make()); in fillRandomParcel()
|
/frameworks/native/include/binder/ |
D | Parcel.h | 54 class RpcSession; variable 119 void markForRpc(const sp<RpcSession>& session); 1271 sp<RpcSession> mSession;
|