ppi::connect(source, sink);
ppi::init();
-
+
senf::PacketData::byte data[] = { 0x13u, 0x24u, 0x35u };
senf::Packet p (senf::DataPacket::create(data));
BOOST_CHECK( ! sink.input.throttled() );
BOOST_CHECK_EQUAL( sink.size(), 1u );
BOOST_CHECK( ! sink.empty() );
- BOOST_CHECK_EQUAL(
+ BOOST_CHECK_EQUAL(
debug::PassiveSink::size_type(std::distance(sink.begin(),sink.end())),
sink.size() );
BOOST_CHECK( *sink.begin() == p );
senf::Packet p (senf::DataPacket::create(data));
source.submit(p);
-
+
BOOST_CHECK_EQUAL( source.size(), 1u );
BOOST_CHECK_EQUAL( sink.request(), p );
BOOST_CHECK_EQUAL( source.size(), 0u );
senf::PacketData::byte data[] = { 0x13u, 0x24u, 0x35u };
source.submit( senf::DataPacket::create(data) );
senf::ppi::run();
-
+
BOOST_CHECK( ! logTarget.str().empty() );
}