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

Commit e18a412e authored by Treehugger Robot's avatar Treehugger Robot Committed by Automerger Merge Worker
Browse files

Merge "binderRpcTest: fix OnewayStressTest flake" am: beb91bd2 am:... 

Merge "binderRpcTest: fix OnewayStressTest flake" am: beb91bd2 am: 38f736ac am: bb2a825c am: fd265846

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

Change-Id: Ia6dc4a804f0d63dbf03282be1c1d17cb1abb3602
parents c50b4e89 fd265846

libs/binder/tests/binderRpcTest.cpp

+11 −10
Original line number Original line Diff line number Diff line
@@ -1036,6 +1036,14 @@ TEST_P(BinderRpc, ThreadingStressTest) { 
    for (auto& t : threads) t.join();

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

}

}





static void saturateThreadPool(size_t threadCount, const sp<IBinderRpcTest>& iface) {

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

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

        threads.push_back(std::thread([&] { EXPECT_OK(iface->sleepMs(500)); }));

    }

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

}



TEST_P(BinderRpc, OnewayStressTest) {

TEST_P(BinderRpc, OnewayStressTest) {

    constexpr size_t kNumClientThreads = 10;

    constexpr size_t kNumClientThreads = 10;

    constexpr size_t kNumServerThreads = 10;

    constexpr size_t kNumServerThreads = 10;
@@ -1049,13 +1057,12 @@ TEST_P(BinderRpc, OnewayStressTest) { 
            for (size_t j = 0; j < kNumCalls; j++) {

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

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

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

            }

            }



            // check threads are not stuck

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

        }));

        }));

    }

    }





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

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



    saturateThreadPool(kNumServerThreads, proc.rootIface);

}

}





TEST_P(BinderRpc, OnewayCallDoesNotWait) {

TEST_P(BinderRpc, OnewayCallDoesNotWait) {
@@ -1098,13 +1105,7 @@ TEST_P(BinderRpc, OnewayCallQueueing) { 




    EXPECT_GT(epochMsAfter, epochMsBefore + kSleepMs * kNumSleeps);

    EXPECT_GT(epochMsAfter, epochMsBefore + kSleepMs * kNumSleeps);





    // pending oneway transactions hold ref, make sure we read data on all

    saturateThreadPool(1 + kNumExtraServerThreads, proc.rootIface);

    // sockets

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

    for (size_t i = 0; i < 1 + kNumExtraServerThreads; i++) {

        threads.push_back(std::thread([&] { EXPECT_OK(proc.rootIface->sleepMs(250)); }));

    }

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

}

}





TEST_P(BinderRpc, OnewayCallExhaustion) {

TEST_P(BinderRpc, OnewayCallExhaustion) {