X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketSource.ct;fp=PPI%2FSocketReader.ct;h=f38f045c5b307fce6b2956a831d53a4661564feb;hb=a479735a65e334af538b895f182f8efd36a541c5;hp=f4a0152c3a5264da9fca0a9c6416428c284b81c6;hpb=fa368bbbcb79a9aad8daf7cb25a9adee8270d1b8;p=senf.git diff --git a/PPI/SocketReader.ct b/PPI/SocketSource.ct similarity index 78% rename from PPI/SocketReader.ct rename to PPI/SocketSource.ct index f4a0152..f38f045 100644 --- a/PPI/SocketReader.ct +++ b/PPI/SocketSource.ct @@ -21,9 +21,9 @@ // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. /** \file - \brief SocketReader non-inline template implementation */ + \brief SocketSource non-inline template implementation */ -//#include "SocketReader.ih" +//#include "SocketSource.ih" // Custom includes @@ -31,10 +31,10 @@ ///////////////////////////////ct.p//////////////////////////////////////// /////////////////////////////////////////////////////////////////////////// -// senf::ppi::PacketReader +// senf::ppi::PacketSource template -prefix_ Packet senf::ppi::PacketReader::operator()(Handle handle) +prefix_ Packet senf::ppi::PacketSource::operator()(Handle handle) { Packet packet (Packet::create(Packet::noinit)); handle.read(packet.data(),0u); @@ -42,22 +42,22 @@ prefix_ Packet senf::ppi::PacketReader::operator()(Handle handle) } /////////////////////////////////////////////////////////////////////////// -// senf::ppi::module::ActiveSocketReader +// senf::ppi::module::ActiveSocketSource -template -prefix_ senf::ppi::module::ActiveSocketReader:: -ActiveSocketReader(Handle handle) +template +prefix_ senf::ppi::module::ActiveSocketSource:: +ActiveSocketSource(Handle handle) : handle_(handle), event_(handle_, IOEvent::Read), reader_() { - registerEvent( event_, &ActiveSocketReader::read ); + registerEvent( event_, &ActiveSocketSource::read ); route(event_, output); } //////////////////////////////////////// // private members -template -prefix_ void senf::ppi::module::ActiveSocketReader::read() +template +prefix_ void senf::ppi::module::ActiveSocketSource::read() { output(reader_(handle_)); }