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

Commit fbbcccc7 authored by Steven Moreland's avatar Steven Moreland Committed by Automerger Merge Worker
Browse files

Merge "RpcServer: expose server fd" am: e81f29d2 

Original change: https://android-review.googlesource.com/c/platform/frameworks/native/+/1705663

Change-Id: I9ef5da6927f7c590e9a6a3d1b84f4a12264826db
parents 08cb54f4 e81f29d2

libs/binder/RpcServer.cpp

+18 −0
Original line number Original line Diff line number Diff line
@@ -272,8 +272,26 @@ void RpcServer::onSessionTerminating(const sp<RpcSession>& session) { 
}

}





bool RpcServer::hasServer() {

bool RpcServer::hasServer() {

    LOG_ALWAYS_FATAL_IF(!mAgreedExperimental, "no!");

    std::lock_guard<std::mutex> _l(mLock);

    std::lock_guard<std::mutex> _l(mLock);

    return mServer.ok();

    return mServer.ok();

}

}





unique_fd RpcServer::releaseServer() {

    LOG_ALWAYS_FATAL_IF(!mAgreedExperimental, "no!");

    std::lock_guard<std::mutex> _l(mLock);

    return std::move(mServer);

}



bool RpcServer::setupExternalServer(base::unique_fd serverFd) {

    LOG_ALWAYS_FATAL_IF(!mAgreedExperimental, "no!");

    std::lock_guard<std::mutex> _l(mLock);

    if (mServer.ok()) {

        ALOGE("Each RpcServer can only have one server.");

        return false;

    }

    mServer = std::move(serverFd);

    return true;

}



} // namespace android
 
} // namespace android

libs/binder/include/binder/RpcServer.h

+11 −0
Original line number Original line Diff line number Diff line
@@ -79,6 +79,17 @@ public: 
     */

     */

    [[nodiscard]] bool hasServer();

    [[nodiscard]] bool hasServer();





    /**

     * If hasServer(), return the server FD. Otherwise return invalid FD.

     */

    [[nodiscard]] base::unique_fd releaseServer();



    /**

     * Set up server using an external FD previously set up by releaseServer().

     * Return false if there's already a server.

     */

    bool setupExternalServer(base::unique_fd serverFd);



    void iUnderstandThisCodeIsExperimentalAndIWillNotUseItInProduction();

    void iUnderstandThisCodeIsExperimentalAndIWillNotUseItInProduction();





    /**

    /**

libs/binder/tests/binderRpcTest.cpp

+13 −0
Original line number Original line Diff line number Diff line
@@ -50,6 +50,19 @@ TEST(BinderRpcParcel, EntireParcelFormatted) { 
    EXPECT_DEATH(p.markForBinder(sp<BBinder>::make()), "");

    EXPECT_DEATH(p.markForBinder(sp<BBinder>::make()), "");

}

}





TEST(BinderRpc, SetExternalServer) {

    base::unique_fd sink(TEMP_FAILURE_RETRY(open("/dev/null", O_RDWR)));

    int sinkFd = sink.get();

    auto server = RpcServer::make();

    server->iUnderstandThisCodeIsExperimentalAndIWillNotUseItInProduction();

    ASSERT_FALSE(server->hasServer());

    ASSERT_TRUE(server->setupExternalServer(std::move(sink)));

    ASSERT_TRUE(server->hasServer());

    base::unique_fd retrieved = server->releaseServer();

    ASSERT_FALSE(server->hasServer());

    ASSERT_EQ(sinkFd, retrieved.get());

}



using android::binder::Status;

using android::binder::Status;





#define EXPECT_OK(status)                 \

#define EXPECT_OK(status)                 \