X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketSink.ct;h=e578fd07ae614fa5fee0714d05f03cc58d7d6e7d;hb=92f8630b75f3ef50e73c48cde58645dcd1534e27;hp=ba7fffccec3dc97c4619c3552d84a602c427ff57;hpb=a479735a65e334af538b895f182f8efd36a541c5;p=senf.git diff --git a/PPI/SocketSink.ct b/PPI/SocketSink.ct index ba7fffc..e578fd0 100644 --- a/PPI/SocketSink.ct +++ b/PPI/SocketSink.ct @@ -1,8 +1,8 @@ // $Id$ // -// Copyright (C) 2007 -// Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS) -// Kompetenzzentrum fuer Satelitenkommunikation (SatCom) +// Copyright (C) 2007 +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY // Stefan Bund // // This program is free software; you can redistribute it and/or modify @@ -31,41 +31,59 @@ ///////////////////////////////ct.p//////////////////////////////////////// /////////////////////////////////////////////////////////////////////////// -// senf::ppi::module::ActiveSocketSink +// senf::ppi::module::ActiveSocketSink -template -prefix_ senf::ppi::module::ActiveSocketSink::ActiveSocketSink(Handle handle) +template +prefix_ senf::ppi::module::ActiveSocketSink::ActiveSocketSink(Handle handle) : handle_(handle), event_(handle_, IOEvent::Write), writer_() { registerEvent( event_, &ActiveSocketSink::write ); route(input, event_); } +template +prefix_ senf::ppi::module::ActiveSocketSink::ActiveSocketSink(Handle handle, + Writer const & writer) + : handle_(handle), event_(handle_, IOEvent::Write), writer_(writer) +{ + registerEvent( event_, &ActiveSocketSink::write ); + route(input, event_); +} + //////////////////////////////////////// // private members -template -prefix_ void senf::ppi::module::ActiveSocketSink::write() +template +prefix_ void senf::ppi::module::ActiveSocketSink::write() { writer_(handle_,input()); } /////////////////////////////////////////////////////////////////////////// -// senf::ppi::module::PassiveSocketSink +// senf::ppi::module::PassiveSocketSink -template -prefix_ senf::ppi::module::PassiveSocketSink::PassiveSocketSink(Handle handle) +template +prefix_ senf::ppi::module::PassiveSocketSink::PassiveSocketSink(Handle handle) : handle_(handle), writer_() { noroute(input); input.onRequest(&PassiveSocketSink::write); } +template +prefix_ senf::ppi::module::PassiveSocketSink::PassiveSocketSink(Handle handle, + Writer const & writer) + : handle_(handle), writer_(writer) +{ + noroute(input); + input.onRequest(&PassiveSocketSink::write); +} + //////////////////////////////////////// // private members -template -prefix_ void senf::ppi::module::PassiveSocketSink::write() +template +prefix_ void senf::ppi::module::PassiveSocketSink::write() { writer_(handle_,input()); }