diff options
| -rw-r--r-- | libs/binder/RpcSession.cpp | 4 | ||||
| -rw-r--r-- | libs/binder/include/binder/RpcSession.h | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/libs/binder/RpcSession.cpp b/libs/binder/RpcSession.cpp index 0471705ede..3e83c99a29 100644 --- a/libs/binder/RpcSession.cpp +++ b/libs/binder/RpcSession.cpp @@ -93,7 +93,7 @@ sp<IBinder> RpcSession::getRootObject() { return state()->getRootObject(connection.fd(), sp<RpcSession>::fromExisting(this)); } -status_t RpcSession::getMaxThreads(size_t* maxThreads) { +status_t RpcSession::getRemoteMaxThreads(size_t* maxThreads) { ExclusiveConnection connection(sp<RpcSession>::fromExisting(this), ConnectionUse::CLIENT); return state()->getMaxThreads(connection.fd(), sp<RpcSession>::fromExisting(this), maxThreads); } @@ -201,7 +201,7 @@ bool RpcSession::setupSocketClient(const RpcSocketAddress& addr) { // instead of all at once. // TODO(b/186470974): first risk of blocking size_t numThreadsAvailable; - if (status_t status = getMaxThreads(&numThreadsAvailable); status != OK) { + if (status_t status = getRemoteMaxThreads(&numThreadsAvailable); status != OK) { ALOGE("Could not get max threads after initial session to %s: %s", addr.toString().c_str(), statusToString(status).c_str()); return false; diff --git a/libs/binder/include/binder/RpcSession.h b/libs/binder/include/binder/RpcSession.h index 0b77787e96..1657167066 100644 --- a/libs/binder/include/binder/RpcSession.h +++ b/libs/binder/include/binder/RpcSession.h @@ -81,7 +81,7 @@ public: * Query the other side of the session for the maximum number of threads * it supports (maximum number of concurrent non-nested synchronous transactions) */ - status_t getMaxThreads(size_t* maxThreads); + status_t getRemoteMaxThreads(size_t* maxThreads); [[nodiscard]] status_t transact(const RpcAddress& address, uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags); |