generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-01-20 09:08:29 +01:00
Code Issues Projects Releases Wiki Activity

fix(SocketProactor): test

Browse Source
This commit is contained in:
Alex Fabijanic 2021-09-03 15:10:09 +02:00
parent fef9d34e29
commit da70f91796
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
Net/testsuite/src/SocketProactorTest.cpp
View File

@ -215,7 +215,8 @@ void SocketProactorTest::testSocketProactorStartStop()
proactor.stop(); proactor.stop();
}; };
proactor.addReceiveFrom(s, buf, sa, onRecvCompletion); proactor.addReceiveFrom(s, buf, sa, onRecvCompletion);
proactor.run();
while (!received) proactor.poll();
assertTrue (sent); assertTrue (sent);
assertTrue (sendPassed); assertTrue (sendPassed);
@ -241,7 +242,7 @@ void SocketProactorTest::testSocketProactorStartStop()
SocketAddress("127.0.0.1", echoServer.port()), SocketAddress("127.0.0.1", echoServer.port()),
onSendCompletion); onSendCompletion);
proactor.addReceiveFrom(s, buf, sa, onRecvCompletion); proactor.addReceiveFrom(s, buf, sa, onRecvCompletion);
proactor.run(); while (!received) proactor.poll();
assertTrue(std::string(buf.begin(), buf.end()) == hello); assertTrue(std::string(buf.begin(), buf.end()) == hello);
assertTrue (sent); assertTrue (sent);