X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FSocketSource.test.cc;h=0b207c423f58be101dbaa260b61f6abaf0d9b5ea;hb=9bf675b08d624cfac113a1a90dcfbd9503872b1d;hp=c8947a1ecc5638048d796c0bcad56fd1a6ef7e71;hpb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;p=senf.git diff --git a/senf/PPI/SocketSource.test.cc b/senf/PPI/SocketSource.test.cc index c8947a1..0b207c4 100644 --- a/senf/PPI/SocketSource.test.cc +++ b/senf/PPI/SocketSource.test.cc @@ -28,13 +28,13 @@ // Custom includes #include -#include "../Socket/Protocols/INet/UDPSocketHandle.hh" -#include "../Scheduler/Scheduler.hh" +#include +#include #include "SocketSource.hh" #include "DebugModules.hh" #include "Setup.hh" -#include "../Utils/auto_unit_test.hh" +#include #include #define prefix_ @@ -47,12 +47,31 @@ namespace { void timeout() { senf::scheduler::terminate(); } + + int base_pid = 0; + + unsigned port(unsigned i) + { + if (! base_pid) + base_pid = ::getpid(); + return 23456u + (((base_pid^(base_pid>>8)^(base_pid>>16)^(base_pid>>24))&0xff)<<2) + i; + } + + std::string localhost4str(unsigned i) + { + return (boost::format("localhost:%d") % port(i)).str(); + } + + std::string localhost6str(unsigned i) + { + return (boost::format("[::1]:%d") % port(i)).str(); + } } -BOOST_AUTO_UNIT_TEST(socketSource) +SENF_AUTO_UNIT_TEST(socketSource) { senf::UDPv4ClientSocketHandle inputSocket; - inputSocket.bind(senf::INet4SocketAddress("localhost:44344")); + inputSocket.bind(senf::INet4SocketAddress(localhost4str(0))); inputSocket.blocking(false); module::ActiveSocketSource<> udpSource(inputSocket); debug::PassiveSink sink; @@ -61,7 +80,7 @@ BOOST_AUTO_UNIT_TEST(socketSource) std::string data ("TEST"); senf::UDPv4ClientSocketHandle outputSocket; - outputSocket.writeto(senf::INet4SocketAddress("localhost:44344"),data); + outputSocket.writeto(senf::INet4SocketAddress(localhost4str(0)),data); senf::scheduler::TimerEvent timer ( "socketSource test timer", &timeout, senf::ClockService::now() + senf::ClockService::milliseconds(100));