target.input.throttle();
BOOST_CHECK( target.input.throttled() );
BOOST_CHECK( target.input.nativeThrottled() );
-
+
target.input.unthrottle();
BOOST_CHECK( ! target.input.throttled() );
BOOST_CHECK( ! target.input.nativeThrottled() );
}
namespace {
-
+
bool called = false;
-
+
void handler() { called = true; }
}
// peek() is implicitly tested within the Active/PassiveSink implementation
BOOST_CHECK_EQUAL ( & target.input.peer(), & source.output );
-
+
BOOST_CHECK( target.input.begin() == target.input.end() );
BOOST_CHECK_EQUAL( target.input.queueSize(), 0u );
BOOST_CHECK( target.input.empty() );
ppi::init();
BOOST_CHECK_EQUAL( & target.input.peer(), & source.output );
-
+
target.input.throttle();
senf::Packet p (senf::DataPacket::create());
source.submit(p);
-
+
BOOST_CHECK_EQUAL( target.counter, 0u );
BOOST_CHECK( target.input );
BOOST_CHECK_EQUAL( target.input.queueSize(), 1u );
target.input.unthrottle();
BOOST_CHECK( target.input );
BOOST_CHECK_EQUAL( target.counter, 1u );
-
+
BOOST_CHECK( target.input() == p );
BOOST_CHECK( ! target.input );
-
+
source.submit(p);
-
+
BOOST_CHECK_EQUAL( target.counter, 2u );
BOOST_CHECK( target.input.throttled() );
BOOST_CHECK( target.input() == p );
source.submit(p);
BOOST_CHECK( target.request() == p );
-
+
// connect() is tested indirectly via ppi::connect
}
ppi::connect(source,target);
ppi::init();
-
+
BOOST_CHECK_EQUAL( & source.output.peer(), & target.input );
BOOST_CHECK( source.output );
target.input.throttle();
}
void request() {
- (void) input();
- (void) input.read();
+ senf::IGNORE( input() );
+ senf::IGNORE( input.read() );
}
};
senf::Packet p (senf::DataPacket::create());
source.submit(p);
-
+
BOOST_CHECK( true );
}
ppi::connect(source,target);
ppi::init();
-
- (void) target.request();
-
+
+ senf::IGNORE( target.request() );
+
BOOST_CHECK( true );
}
{
TypedPassiveInput<> input;
TypedActiveOutput<MyPacket> output;
- BOOST_CHECK_THROW( ppi::connect(output, input),
+ BOOST_CHECK_THROW( ppi::connect(output, input),
ppi::connector::IncompatibleConnectorsException );
}
{
TypedPassiveInput<MyPacket> input;
TypedActiveOutput<> output;
- BOOST_CHECK_THROW( ppi::connect(output, input),
+ BOOST_CHECK_THROW( ppi::connect(output, input),
ppi::connector::IncompatibleConnectorsException );
}
{
TypedActiveOutput<> output;
SENF_CHECK_NO_THROW( ppi::connect(output, input) );
}
- {
+ {
TypedPassiveInput<> input;
debug::ActiveSource output;
SENF_CHECK_NO_THROW( ppi::connect(output, input) );
ppi::connect(source, target);
ppi::init();
-
+
BOOST_CHECK( source.output );
senf::Packet p (senf::DataPacket::create());
source.submit(p);
- BOOST_CHECK( target.front() == p );
+ BOOST_CHECK( target.front() == p );
BOOST_CHECK_EQUAL( target.size(), 1u );
}
ppi::connect(source, target);
ppi::init();
-
+
BOOST_CHECK( ! source.output );
target.unthrottle();
BOOST_CHECK( source.output );
source.submit(p);
BOOST_CHECK( target.input );
-
+
target.input.disconnect();
ppi::init();
-
+
BOOST_CHECK( ! target.input );
}
{