// 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
/** \file
- \brief SocketWriter.test unit tests */
+ \brief SocketSink.test unit tests */
-//#include "SocketWriter.test.hh"
-//#include "SocketWriter.test.ih"
+//#include "SocketSink.test.hh"
+//#include "SocketSink.test.ih"
// Custom includes
#include "../Socket/Protocols/INet/UDPSocketHandle.hh"
#include "../Socket/Protocols/INet/ConnectedUDPSocketHandle.hh"
-#include "SocketReader.hh"
+#include "SocketSource.hh"
#include "DebugModules.hh"
-#include "SocketWriter.hh"
+#include "SocketSink.hh"
#include "Setup.hh"
#include <boost/test/auto_unit_test.hpp>
}
}
-BOOST_AUTO_UNIT_TEST(passiveSocketWriter)
+BOOST_AUTO_UNIT_TEST(passiveSocketSink)
{
senf::ConnectedUDPv4ClientSocketHandle outputSocket (
senf::INet4SocketAddress("localhost:44344"));
- module::PassiveSocketWriter<> udpWriter(outputSocket);
+ module::PassiveSocketSink<> udpSink(outputSocket);
debug::ActiveSource source;
- ppi::connect(source, udpWriter);
+ ppi::connect(source, udpSink);
std::string data ("TEST");
senf::Packet p (senf::DataPacket::create(data));
BOOST_CHECK_EQUAL( data, input );
}
-BOOST_AUTO_UNIT_TEST(activeSocketWriter)
+BOOST_AUTO_UNIT_TEST(activeSocketSink)
{
senf::ConnectedUDPv4ClientSocketHandle outputSocket (
senf::INet4SocketAddress("localhost:44344"));
- module::ActiveSocketWriter<> udpWriter(outputSocket);
+ module::ActiveSocketSink<> udpSink(outputSocket);
debug::PassiveSource source;
- ppi::connect(source, udpWriter);
+ ppi::connect(source, udpSink);
std::string data ("TEST");
senf::Packet p (senf::DataPacket::create(data));