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

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

Merge "binderRpcTest: oneway stress test" am: 49a09dcf 

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

Change-Id: I54cba2cb2094b96c55b76571ee130ad3a3029fe0
parents c1e856b2 49a09dcf

libs/binder/tests/binderRpcTest.cpp

+24 −3
Original line number Diff line number Diff line
@@ -80,11 +80,10 @@ public: 
    sp<RpcConnection> connection;



    Status sendString(const std::string& str) override {

        std::cout << "Child received string: " << str << std::endl;

        (void)str;

        return Status::ok();

    }

    Status doubleString(const std::string& str, std::string* strstr) override {

        std::cout << "Child received string to double: " << str << std::endl;

        *strstr = str + str;

        return Status::ok();

    }
@@ -749,7 +748,7 @@ TEST_P(BinderRpc, ThreadingStressTest) { 
        threads.push_back(std::thread([&] {

            for (size_t j = 0; j < kNumCalls; j++) {

                sp<IBinder> out;

                proc.rootIface->repeatBinder(proc.rootBinder, &out);

                EXPECT_OK(proc.rootIface->repeatBinder(proc.rootBinder, &out));

                EXPECT_EQ(proc.rootBinder, out);

            }

        }));
@@ -758,6 +757,28 @@ TEST_P(BinderRpc, ThreadingStressTest) { 
    for (auto& t : threads) t.join();

}



TEST_P(BinderRpc, OnewayStressTest) {

    constexpr size_t kNumClientThreads = 10;

    constexpr size_t kNumServerThreads = 10;

    constexpr size_t kNumCalls = 100;



    auto proc = createRpcTestSocketServerProcess(kNumServerThreads);



    std::vector<std::thread> threads;

    for (size_t i = 0; i < kNumClientThreads; i++) {

        threads.push_back(std::thread([&] {

            for (size_t j = 0; j < kNumCalls; j++) {

                EXPECT_OK(proc.rootIface->sendString("a"));

            }



            // check threads are not stuck

            EXPECT_OK(proc.rootIface->sleepMs(250));

        }));

    }



    for (auto& t : threads) t.join();

}



TEST_P(BinderRpc, OnewayCallDoesNotWait) {

    constexpr size_t kReallyLongTimeMs = 100;

    constexpr size_t kSleepMs = kReallyLongTimeMs * 5;