X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketReader.test.cc;h=dcd410d957ea7f5b3521ce2d636adac2c0e56923;hb=e84dd6c52a07fc9e283cbd72c7616f3523920387;hp=1d58e1c77e30046866f052830b73d0fca7e55873;hpb=48bbf27e9e89d6eba4754fba65d70a15b115ac8b;p=senf.git

diff --git a/PPI/SocketReader.test.cc b/PPI/SocketReader.test.cc
index 1d58e1c..dcd410d 100644
--- a/PPI/SocketReader.test.cc
+++ b/PPI/SocketReader.test.cc
@@ -28,8 +28,8 @@
 
 // Custom includes
 #include <algorithm>
-#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;
-    ppi::connect(udpReader.output, sink.input);
+    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(1000, &timeout);
+    senf::Scheduler::instance().timeout(
+        senf::ClockService::now() + senf::ClockService::milliseconds(100), &timeout);
     senf::ppi::run();
 
     BOOST_REQUIRE( ! sink.empty() );