Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 0ac025b8 authored by Treehugger Robot's avatar Treehugger Robot Committed by Gerrit Code Review
Browse files

Merge "libbinder: sess getMaxThreads->getRemoteMaxThreads"

parents 226376f9 1be91350

libs/binder/RpcSession.cpp

+2 −2
Original line number Diff line number Diff line
@@ -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;

libs/binder/include/binder/RpcSession.h

+1 −1
Original line number Diff line number Diff line
@@ -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);