X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketSink.cti;h=b7482eb13f55e528213344e6f3c95fdf6dea8e76;hb=f2f5d59e83863f3b513950173baee1b6da2aee3c;hp=1ae129be8e5ba9837b59d16a6109b67e159b3678;hpb=a1a6c76a214ad1935032826713cabaf9ac57bf07;p=senf.git diff --git a/PPI/SocketSink.cti b/PPI/SocketSink.cti index 1ae129b..b7482eb 100644 --- a/PPI/SocketSink.cti +++ b/PPI/SocketSink.cti @@ -39,6 +39,20 @@ 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 @@ -55,10 +69,20 @@ prefix_ typename Writer::Handle & senf::ppi::module::PassiveSocketSink:: } template -prefix_ void senf::ppi::module::PassiveSocketSink::replaceHandle(Handle handle) +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_