X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FSocketSink.cti;h=2b1138778fa8d6fbe06e14ec1caaf33a25dbaf18;hb=c505c034e5fdc932c02aa3dc3847a5551011d87e;hp=07dba5b124992c356842b7fdee025802aa8e7317;hpb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;p=senf.git diff --git a/senf/PPI/SocketSink.cti b/senf/PPI/SocketSink.cti index 07dba5b..2b11387 100644 --- a/senf/PPI/SocketSink.cti +++ b/senf/PPI/SocketSink.cti @@ -59,11 +59,12 @@ senf::ppi::TargetDgramWriter::target(typename Handle::Address const } template -prefix_ void senf::ppi::TargetDgramWriter::operator()(Handle handle, +prefix_ bool senf::ppi::TargetDgramWriter::operator()(Handle & handle, Packet const & packet) { if (target_) - handle.writeto(target_, packet.data()); + return handle.writeto(target_, packet.data()) != packet.data().begin(); + return false; } /////////////////////////////////////////////////////////////////////////// @@ -83,7 +84,7 @@ senf::ppi::module::ActiveSocketSink::handle() } template -prefix_ void senf::ppi::module::ActiveSocketSink::handle(Handle handle) +prefix_ void senf::ppi::module::ActiveSocketSink::handle(Handle const & handle) { handle_ = handle; event_.set(handle_, IOEvent::Write); @@ -105,7 +106,7 @@ prefix_ typename Writer::Handle & senf::ppi::module::PassiveSocketSink:: } template -prefix_ void senf::ppi::module::PassiveSocketSink::handle(Handle handle) +prefix_ void senf::ppi::module::PassiveSocketSink::handle(Handle const & handle) { handle_ = handle; checkThrottle();