// the corresponding connected module since otherwise the connectors cannot be connected anywhere
// and will be unusable.
-BOOST_AUTO_UNIT_TEST(connector)
+SENF_AUTO_UNIT_TEST(connector)
{
// It doesn't matter, which type of connectors we use here since they are all based on
// Connector.
BOOST_CHECK_EQUAL( & target.input.peer(), & source.output );
}
-BOOST_AUTO_UNIT_TEST(passiveConnector)
+SENF_AUTO_UNIT_TEST(passiveConnector)
{
debug::ActiveSource source;
debug::PassiveSink target;
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; }
}
-BOOST_AUTO_UNIT_TEST(activeConnector)
+SENF_AUTO_UNIT_TEST(activeConnector)
{
debug::ActiveSource source;
debug::PassiveSink target;
BOOST_CHECK_EQUAL( & source.output.peer(), & target.input );
}
-BOOST_AUTO_UNIT_TEST(inputConnector)
+SENF_AUTO_UNIT_TEST(inputConnector)
{
debug::ActiveSource source;
debug::PassiveSink target;
// 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() );
}
-BOOST_AUTO_UNIT_TEST(outputConnector)
+SENF_AUTO_UNIT_TEST(outputConnector)
{
debug::ActiveSource source;
debug::PassiveSink target;
};
}
-BOOST_AUTO_UNIT_TEST(passiveInput)
+SENF_AUTO_UNIT_TEST(passiveInput)
{
debug::ActiveSource source;
PassiveInputTest target;
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 );
BOOST_CHECK( ! target.input.throttled() );
}
-BOOST_AUTO_UNIT_TEST(passiveOutput)
+SENF_AUTO_UNIT_TEST(passiveOutput)
{
debug::PassiveSource source;
debug::ActiveSink target;
source.submit(p);
BOOST_CHECK( target.request() == p );
-
+
// connect() is tested indirectly via ppi::connect
}
-BOOST_AUTO_UNIT_TEST(activeInput)
+SENF_AUTO_UNIT_TEST(activeInput)
{
debug::PassiveSource source;
debug::ActiveSink target;
BOOST_CHECK( target.request() == p );
}
-BOOST_AUTO_UNIT_TEST(activeOutput)
+SENF_AUTO_UNIT_TEST(activeOutput)
{
debug::ActiveSource source;
debug::PassiveSink target;
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() );
}
};
}
-BOOST_AUTO_UNIT_TEST(typedInput)
+SENF_AUTO_UNIT_TEST(typedInput)
{
debug::ActiveSource source;
TypedPassiveInput<> target;
senf::Packet p (senf::DataPacket::create());
source.submit(p);
+
+ BOOST_CHECK( true );
}
-BOOST_AUTO_UNIT_TEST(tyepdOutput)
+SENF_AUTO_UNIT_TEST(tyepdOutput)
{
TypedPassiveOutput<> source;
debug::ActiveSink target;
ppi::connect(source,target);
ppi::init();
-
- (void) target.request();
+
+ senf::IGNORE( target.request() );
+
+ BOOST_CHECK( true );
}
-BOOST_AUTO_UNIT_TEST(connectorTest)
+SENF_AUTO_UNIT_TEST(connectorTest)
{
{
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) );
}
}
-BOOST_AUTO_UNIT_TEST(delayedConnect)
+SENF_AUTO_UNIT_TEST(delayedConnect)
{
{
debug::PassiveSource source;
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 );
}
}
-BOOST_AUTO_UNIT_TEST(disconnect)
+SENF_AUTO_UNIT_TEST(disconnect)
{
{
debug::PassiveSource source;
source.submit(p);
BOOST_CHECK( target.input );
-
+
target.input.disconnect();
ppi::init();
-
+
BOOST_CHECK( ! target.input );
}
{