X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketReader.test.cc;h=dcd410d957ea7f5b3521ce2d636adac2c0e56923;hb=81447258e6ecc9b5d9434fa5a7d382684179c7ab;hp=b17d6bc1c74bd70fd6585b6e43370628e40dd5c7;hpb=914af680a37d303da51e3877972ca9bd68d6190b;p=senf.git diff --git a/PPI/SocketReader.test.cc b/PPI/SocketReader.test.cc index b17d6bc..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(100000, &timeout); + senf::Scheduler::instance().timeout( + senf::ClockService::now() + senf::ClockService::milliseconds(100), &timeout); senf::ppi::run(); BOOST_REQUIRE( ! sink.empty() );