generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-04-02 17:50:53 +02:00
Code Issues Projects Releases Wiki Activity

fix(ci): PollSetTest::testPollNoServer()

Browse Source
This commit is contained in:
Aleksandar Fabijanic 2023-10-21 19:35:47 +02:00
parent c0f7257ccd
commit de04b9eac7
1 changed files with 25 additions and 4 deletions

29
Net/testsuite/src/PollSetTest.cpp

@ -347,7 +347,14 @@ void PollSetTest::testPollNoServer()
assertTrue(0 != (s.second & PollSet::POLL_ERROR)); assertTrue(0 != (s.second & PollSet::POLL_ERROR));
signalled += static_cast<int>(sm.size()); signalled += static_cast<int>(sm.size());
if (sw.elapsedSeconds() > 10) fail(); sm.clear();
int secs = sw.elapsedSeconds();
if (secs > 10)
{
fail(Poco::format("testPollNoServer() timed out after %ds, "
"sockets signalled=%d (expected 2)",
secs, signalled), __LINE__);
}
} while (signalled < 2); } while (signalled < 2);
assertTrue(signalled == 2); assertTrue(signalled == 2);
@ -379,20 +386,34 @@ void PollSetTest::testPollClosedServer()
// echoServer is blocked waiting for data, send some // echoServer is blocked waiting for data, send some
assertTrue (len == ss1.sendBytes(str.data(), len)); assertTrue (len == ss1.sendBytes(str.data(), len));
// the stop flag should kick in, wait for it ... // the stop flag should kick in, wait for it ...
while (!echoServer1.done()) Thread::sleep(10); Stopwatch sw; sw.start();
while (!echoServer1.done())
{
Thread::sleep(10);
int secs = sw.elapsedSeconds();
if (secs > 10)
{
fail(Poco::format("testPollClosedServer() timed out "
"waiting on server after %ds", secs), __LINE__);
}
}
echoServer2.stop(); echoServer2.stop();
assertTrue (len == ss2.sendBytes(str.data(), len)); assertTrue (len == ss2.sendBytes(str.data(), len));
while (!echoServer2.done()) Thread::sleep(10); while (!echoServer2.done()) Thread::sleep(10);
int signalled = 0; int signalled = 0;
Stopwatch sw; sw.start(); sw.restart();
do do
{ {
signalled += static_cast<int>(ps.poll(Timespan(1000000)).size()); signalled += static_cast<int>(ps.poll(Timespan(1000000)).size());
int secs = sw.elapsedSeconds(); int secs = sw.elapsedSeconds();
if (secs > 10) if (secs > 10)
fail(Poco::format("timed out after %ds, sockets signalled=%z (expected 2)", secs, signalled), __LINE__); {
fail(Poco::format("testPollClosedServer() timed out waiting on "
"signalled sockets after %ds, sockets signalled=%d (expected 2)",
secs, signalled), __LINE__);
}
} while (signalled < 2); } while (signalled < 2);
assertTrue(signalled == 2); assertTrue(signalled == 2);