| /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;
|