#include <boost/test/test_tools.hpp>
#define prefix_
-///////////////////////////////cc.p////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
namespace ppi = senf::ppi;
namespace module = ppi::module;
namespace debug = module::debug;
SENF_AUTO_UNIT_TEST(passiveQueueingSocketSink)
{
- senf::ConnectedUDPv4ClientSocketHandle os(senf::noinit);
+ senf::ConnectedUDPv4ClientSocketHandle os (senf::noinit);
senf::ConnectedUDPv4ClientSocketHandle outputSocket (
senf::INet4SocketAddress( localhost4str(0)));
source.submit(p);
BOOST_CHECK_EQUAL( udpSink.qAlgorithm().size(), 1);
- for( int n = 0; n < 100; n++){
+ for( int n = 0; n < 100; n++) {
source.submit(p);
}
// queue default size is 64
udpSink.writer().throttled = false;
- runPPI( senf::ClockService::milliseconds(200));
+ runPPI( senf::ClockService::milliseconds(250));
- input = inputSocket.read();
- BOOST_CHECK_EQUAL( data, input );
+ inputSocket.blocking(false);
+ while (true) {
+ input = inputSocket.read();
+ if (input.empty()) break;
+ BOOST_CHECK_EQUAL( data, input );
+ }
+
+ runPPI( senf::ClockService::milliseconds(250));
BOOST_CHECK_EQUAL( udpSink.qAlgorithm().size(), 0);
}
-///////////////////////////////cc.e////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
#undef prefix_
\f