diff options
| author | Håvard Pettersen <havardpe@yahooinc.com> | 2023-08-09 11:29:06 +0000 |
|---|---|---|
| committer | Håvard Pettersen <havardpe@yahooinc.com> | 2023-08-09 13:59:28 +0000 |
| commit | dd33e09806ef4649c79b72c5440221898fc1b4c1 (patch) | |
| tree | 9c856283e411d87db4ab6af69bdc912c4c531b61 /fnet/src/tests | |
| parent | 0f19048a0da9e582fc836697ed4f15d7801fdabe (diff) | |
more robust shutdown to avoid multi-close race
Diffstat (limited to 'fnet/src/tests')
| -rw-r--r-- | fnet/src/tests/sync_execute/sync_execute.cpp | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/fnet/src/tests/sync_execute/sync_execute.cpp b/fnet/src/tests/sync_execute/sync_execute.cpp index 5d2f4097ab4..0dd65b08874 100644 --- a/fnet/src/tests/sync_execute/sync_execute.cpp +++ b/fnet/src/tests/sync_execute/sync_execute.cpp @@ -17,6 +17,8 @@ TEST("sync execute") { DoIt exe2; DoIt exe3; DoIt exe4; + DoIt exe5; + DoIt exe6; FNET_Transport transport; ASSERT_TRUE(transport.execute(&exe1)); ASSERT_TRUE(transport.Start()); @@ -26,14 +28,16 @@ TEST("sync execute") { ASSERT_TRUE(exe2.gate.getCount() == 0u); ASSERT_TRUE(transport.execute(&exe3)); transport.ShutDown(false); - ASSERT_TRUE(!transport.execute(&exe4)); + uint32_t expect_cnt_4 = transport.execute(&exe4) ? 0 : 1; transport.sync(); transport.WaitFinished(); + ASSERT_TRUE(!transport.execute(&exe5)); transport.sync(); ASSERT_TRUE(exe1.gate.getCount() == 0u); ASSERT_TRUE(exe2.gate.getCount() == 0u); ASSERT_TRUE(exe3.gate.getCount() == 0u); - ASSERT_TRUE(exe4.gate.getCount() == 1u); + ASSERT_TRUE(exe4.gate.getCount() == expect_cnt_4); + ASSERT_TRUE(exe5.gate.getCount() == 1u); } TEST_MAIN() { TEST_RUN_ALL(); } |