#include "Setup.hh"
#include "CloneSource.hh"
#include <senf/Scheduler/Scheduler.hh>
-#include <senf/Utils/membind.hh>
#include <senf/Utils/auto_unit_test.hh>
#include <boost/test/test_tools.hpp>
namespace scheduler = senf::scheduler;
namespace {
- void timeout() {
- scheduler::terminate();
- }
-
void run(senf::ClockService::clock_type t) {
- scheduler::TimerEvent timeoutTimer ("timeoutTimer", &timeout,
- senf::ClockService::now() + t);
+ scheduler::TimerEvent timeout(
+ "test-timeout", &scheduler::terminate, scheduler::now() + t);
ppi::run();
}
}
ppi::connect( source, feeder );
ppi::connect( feeder, sink );
- senf::ClockService::clock_type start (senf::ClockService::now());
+ senf::ClockService::clock_type start (senf::ClockService::now());
run( senf::ClockService::seconds(1));
- std::cerr << "\nActiveFeeder: "
+ std::cerr << "\nActiveFeeder: "
<< (sink.size()*1e9)/(senf::ClockService::now()-start)
<< " packets/s" << std::endl;
BOOST_CHECK( sink.size() > 0);