57 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()
123 bool RpcSession::setProtocolVersion(uint32_t version) {  in setProtocolVersion()
127 std::optional<uint32_t> RpcSession::getProtocolVersion() {  in getProtocolVersion()
132 void RpcSession::setFileDescriptorTransportMode(FileDescriptorTransportMode mode) {  in setFileDescriptorTransportMode()
139 RpcSession::FileDescriptorTransportMode RpcSession::getFileDescriptorTransportMode() {  in getFileDescriptorTransportMode()
143 status_t RpcSession::setupUnixDomainClient(const char* path) {  in setupUnixDomainClient()
147 status_t RpcSession::setupUnixDomainSocketBootstrapClient(unique_fd bootstrapFd) {  in setupUnixDomainSocketBootstrapClient()
175 status_t RpcSession::setupVsockClient(unsigned int cid, unsigned int port) {  in setupVsockClient()
179 status_t RpcSession::setupInetClient(const char* addr, unsigned int port) {  in setupInetClient()
190 status_t RpcSession::setupPreconnectedClient(unique_fd fd, std::function<unique_fd()>&& request) {  in setupPreconnectedClient()
205 status_t RpcSession::addNullDebuggingClient() {  in addNullDebuggingClient()
226 sp<IBinder> RpcSession::getRootObject() {  in getRootObject()
228     status_t status = ExclusiveConnection::find(sp<RpcSession>::fromExisting(this),  in getRootObject()
231     return state()->getRootObject(connection.get(), sp<RpcSession>::fromExisting(this));  in getRootObject()
234 status_t RpcSession::getRemoteMaxThreads(size_t* maxThreads) {  in getRemoteMaxThreads()
236     status_t status = ExclusiveConnection::find(sp<RpcSession>::fromExisting(this),  in getRemoteMaxThreads()
239     return state()->getMaxThreads(connection.get(), sp<RpcSession>::fromExisting(this), maxThreads);  in getRemoteMaxThreads()
242 bool RpcSession::shutdownAndWait(bool wait) {  in shutdownAndWait()
250         mShutdownListener->waitForShutdown(_l, sp<RpcSession>::fromExisting(this));  in shutdownAndWait()
257     if (status_t res = state()->sendObituaries(sp<RpcSession>::fromExisting(this)); res != OK) {  in shutdownAndWait()
267 status_t RpcSession::transact(const sp<IBinder>& binder, uint32_t code, const Parcel& data,  in transact()
271             ExclusiveConnection::find(sp<RpcSession>::fromExisting(this),  in transact()
277                              sp<RpcSession>::fromExisting(this), reply, flags);  in transact()
280 status_t RpcSession::sendDecStrong(const BpBinder* binder) {  in sendDecStrong()
285 status_t RpcSession::sendDecStrongToTarget(uint64_t address, size_t target) {  in sendDecStrongToTarget()
287     status_t status = ExclusiveConnection::find(sp<RpcSession>::fromExisting(this),  in sendDecStrongToTarget()
290     return state()->sendDecStrongToTarget(connection.get(), sp<RpcSession>::fromExisting(this),  in sendDecStrongToTarget()
294 status_t RpcSession::readId() {  in readId()
301     status_t status = ExclusiveConnection::find(sp<RpcSession>::fromExisting(this),  in readId()
305     status = state()->getSessionId(connection.get(), sp<RpcSession>::fromExisting(this), &mId);  in readId()
312 void RpcSession::WaitForShutdownListener::onSessionAllIncomingThreadsEnded(  in onSessionAllIncomingThreadsEnded()
313         const sp<RpcSession>& session) {  in onSessionAllIncomingThreadsEnded()
317 void RpcSession::WaitForShutdownListener::onSessionIncomingThreadEnded() {  in onSessionIncomingThreadEnded()
322 void RpcSession::WaitForShutdownListener::waitForShutdown(RpcMutexUniqueLock& lock,  in waitForShutdown()
323                                                           const sp<RpcSession>& session) {  in waitForShutdown()
334 void RpcSession::preJoinThreadOwnership(RpcMaybeThread thread) {  in preJoinThreadOwnership()
343 RpcSession::PreJoinSetupResult RpcSession::preJoinSetup(  in preJoinSetup()
355                 mRpcBinderState->readConnectionInit(connection, sp<RpcSession>::fromExisting(this));  in preJoinSetup()
426 void RpcSession::join(sp<RpcSession>&& session, PreJoinSetupResult&& setupResult) {  in join()
446     sp<RpcSession::EventListener> listener;  in join()
470 sp<RpcServer> RpcSession::server() {  in server()
479 status_t RpcSession::setupClient(const std::function<status_t(const std::vector<uint8_t>& sessionId,  in setupClient()
525         if (status_t status = ExclusiveConnection::find(sp<RpcSession>::fromExisting(this),  in setupClient()
533                                                     sp<RpcSession>::fromExisting(this), &version);  in setupClient()
583 status_t RpcSession::setupSocketClient(const RpcSocketAddress& addr) {  in setupSocketClient()
589 status_t RpcSession::setupOneSocketConnection(const RpcSocketAddress& addr,  in setupOneSocketConnection()
664 status_t RpcSession::initAndAddConnection(RpcTransportFd fd, const std::vector<uint8_t>& sessionId,  in initAndAddConnection()
723 status_t RpcSession::addIncomingConnection(std::unique_ptr<RpcTransport> rpcTransport) {  in addIncomingConnection()
728     sp<RpcSession> thiz = sp<RpcSession>::fromExisting(this);  in addIncomingConnection()
734         sp<RpcSession> session = thiz;  in addIncomingConnection()
745         RpcSession::join(std::move(session), std::move(setupResult));  in addIncomingConnection()
753 status_t RpcSession::initShutdownTrigger() {  in initShutdownTrigger()
764 status_t RpcSession::addOutgoingConnection(std::unique_ptr<RpcTransport> rpcTransport, bool init) {  in addOutgoingConnection()
776                 mRpcBinderState->sendConnectionInit(connection, sp<RpcSession>::fromExisting(this));  in addOutgoingConnection()
784 bool RpcSession::setForServer(const wp<RpcServer>& server, const wp<EventListener>& eventListener,  in setForServer()
804 sp<RpcSession::RpcConnection> RpcSession::assignIncomingConnectionToThisThread(  in assignIncomingConnectionToThisThread()
832 bool RpcSession::removeIncomingConnection(const sp<RpcConnection>& connection) {  in removeIncomingConnection()
842                 listener->onSessionAllIncomingThreadsEnded(sp<RpcSession>::fromExisting(this));  in removeIncomingConnection()
850 void RpcSession::clearConnectionTid(const sp<RpcConnection>& connection) {  in clearConnectionTid()
859 std::vector<uint8_t> RpcSession::getCertificate(RpcCertificateFormat format) {  in getCertificate()
863 status_t RpcSession::ExclusiveConnection::find(const sp<RpcSession>& session, ConnectionUse use,  in find()
957 void RpcSession::ExclusiveConnection::findConnection(uint64_t tid, sp<RpcConnection>* exclusive,  in findConnection()
984 RpcSession::ExclusiveConnection::~ExclusiveConnection() {  in ~ExclusiveConnection()
993 bool RpcSession::hasActiveConnection(const std::vector<sp<RpcConnection>>& connections) {  in hasActiveConnection()
1002 bool RpcSession::hasActiveRequests() {  in hasActiveRequests()