Searched refs:rpcTransport (Results 1 – 3 of 3) sorted by relevance
| /frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 258 std::unique_ptr<RpcTransport> rpcTransport; member
284 PreJoinSetupResult preJoinSetup(std::unique_ptr<RpcTransport> rpcTransport);
298 [[nodiscard]] status_t addIncomingConnection(std::unique_ptr<RpcTransport> rpcTransport);
299 [[nodiscard]] status_t addOutgoingConnection(std::unique_ptr<RpcTransport> rpcTransport,
306 std::unique_ptr<RpcTransport> rpcTransport);
|
| /frameworks/native/libs/binder/ |
| D | RpcSession.cpp | 344 std::unique_ptr<RpcTransport> rpcTransport) { in preJoinSetup() argument
347 sp<RpcConnection> connection = assignIncomingConnectionToThisThread(std::move(rpcTransport)); in preJoinSetup()
723 status_t RpcSession::addIncomingConnection(std::unique_ptr<RpcTransport> rpcTransport) { in addIncomingConnection() argument
732 std::unique_ptr<RpcTransport> movedRpcTransport = std::move(rpcTransport); in addIncomingConnection()
764 status_t RpcSession::addOutgoingConnection(std::unique_ptr<RpcTransport> rpcTransport, bool init) { in addOutgoingConnection() argument
768 connection->rpcTransport = std::move(rpcTransport); in addOutgoingConnection()
805 std::unique_ptr<RpcTransport> rpcTransport) { in assignIncomingConnectionToThisThread() argument
823 session->rpcTransport = std::move(rpcTransport); in assignIncomingConnectionToThisThread()
995 if (connection->exclusiveTid != std::nullopt && !connection->rpcTransport->isWaiting()) { in hasActiveConnection()
|
| D | RpcState.cpp | 366 what, i + 1, niovs, connection->rpcTransport.get(), in rpcSend()
371 connection->rpcTransport->interruptableWriteFully(session->mShutdownTrigger.get(), in rpcSend()
376 connection->rpcTransport.get(), statusToString(status).c_str()); in rpcSend()
388 connection->rpcTransport->interruptableReadFully(session->mShutdownTrigger.get(), in rpcRec()
393 connection->rpcTransport.get(), statusToString(status).c_str()); in rpcRec()
400 what, i + 1, niovs, connection->rpcTransport.get(), in rpcRec()
631 connection->rpcTransport.get()); in transactAddress()
768 LOG_RPC_DETAIL("getAndExecuteCommand on RpcTransport %p", connection->rpcTransport.get()); in getAndExecuteCommand()
786 status_t status = connection->rpcTransport->pollRead(); in drainCommands()
|