X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketSink.cti;h=b7482eb13f55e528213344e6f3c95fdf6dea8e76;hb=f2f5d59e83863f3b513950173baee1b6da2aee3c;hp=fd4fda8328f2f732ef67ae8528548b7e1a8e6630;hpb=f73fa16ed5abdce272ac77f8b8b9ef2b9922c266;p=senf.git diff --git a/PPI/SocketSink.cti b/PPI/SocketSink.cti index fd4fda8..b7482eb 100644 --- a/PPI/SocketSink.cti +++ b/PPI/SocketSink.cti @@ -1,8 +1,8 @@ // $Id$ // -// Copyright (C) 2007 -// Fraunhofer Institute for Open Communication Systems (FOKUS) -// Competence Center NETwork research (NET), St. Augustin, GERMANY +// 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,23 +31,58 @@ ///////////////////////////////cti.p/////////////////////////////////////// /////////////////////////////////////////////////////////////////////////// -// senf::ppi::module::ActiveSocketSink +// senf::ppi::module::ActiveSocketSink -template -prefix_ Sink & senf::ppi::module::ActiveSocketSink::sink() +template +prefix_ Writer & senf::ppi::module::ActiveSocketSink::writer() { return writer_; } +template +prefix_ typename senf::ppi::module::ActiveSocketSink::Handle +senf::ppi::module::ActiveSocketSink::handle() +{ + return handle_; +} + +template +prefix_ void senf::ppi::module::ActiveSocketSink::handle(Handle handle) +{ + handle_ = handle; + event_.set(handle_, IOEvent::Write); +} + /////////////////////////////////////////////////////////////////////////// -// senf::ppi::module::PassiveSocketSink +// senf::ppi::module::PassiveSocketSink -template -prefix_ Sink & senf::ppi::module::PassiveSocketSink::sink() +template +prefix_ Writer & senf::ppi::module::PassiveSocketSink::writer() { return writer_; } +template +prefix_ typename Writer::Handle & senf::ppi::module::PassiveSocketSink::handle() +{ + return handle_; +} + +template +prefix_ void senf::ppi::module::PassiveSocketSink::handle(Handle handle) +{ + handle_ = handle; + checkThrottle(); +} + +#ifndef DOXYGEN +template +prefix_ void senf::ppi::module::PassiveSocketSink::replaceHandle(Handle newHandle) +{ + handle(newHandle); +} +#endif + ///////////////////////////////cti.e/////////////////////////////////////// #undef prefix_