X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketReader.test.cc;h=dcd410d957ea7f5b3521ce2d636adac2c0e56923;hb=81447258e6ecc9b5d9434fa5a7d382684179c7ab;hp=8a28946b21eab6c2be9fc470e70fa887e90b6ea5;hpb=9e64a6d6a4840325f74502ba959ebd56fbb8441c;p=senf.git diff --git a/PPI/SocketReader.test.cc b/PPI/SocketReader.test.cc index 8a28946..dcd410d 100644 --- a/PPI/SocketReader.test.cc +++ b/PPI/SocketReader.test.cc @@ -28,8 +28,8 @@ // Custom includes #include -#include "Socket/Protocols/INet/UDPSocketHandle.hh" -#include "Scheduler/Scheduler.hh" +#include "../Socket/Protocols/INet/UDPSocketHandle.hh" +#include "../Scheduler/Scheduler.hh" #include "SocketReader.hh" #include "DebugModules.hh" #include "Setup.hh" @@ -57,14 +57,15 @@ BOOST_AUTO_UNIT_TEST(socketReader) inputSocket.bind(senf::INet4SocketAddress("localhost:44344")); inputSocket.blocking(false); module::ActiveSocketReader<> udpReader(inputSocket); - debug::PassivePacketSink sink; + debug::PassiveSink sink; ppi::connect(udpReader, sink); std::string data ("TEST"); senf::UDPv4ClientSocketHandle outputSocket; outputSocket.writeto(senf::INet4SocketAddress("localhost:44344"),data); - senf::Scheduler::instance().timeout(100, &timeout); + senf::Scheduler::instance().timeout( + senf::ClockService::now() + senf::ClockService::milliseconds(100), &timeout); senf::ppi::run(); BOOST_REQUIRE( ! sink.empty() );