added PassiveQueueingSocketSink

[senf.git] / senf / PPI / SocketSink.cti

diff --git a/senf/PPI/SocketSink.cti b/senf/PPI/SocketSink.cti
index 07dba5b..4e2ebf7 100644 (file)
--- a/senf/PPI/SocketSink.cti
+++ b/senf/PPI/SocketSink.cti
@@ -59,11 +59,12 @@ senf::ppi::TargetDgramWriter<HandleType>::target(typename Handle::Address const
 }
 
 template <class HandleType>
-prefix_ void senf::ppi::TargetDgramWriter<HandleType>::operator()(Handle handle,
+prefix_ bool senf::ppi::TargetDgramWriter<HandleType>::operator()(Handle handle,
                                                                   Packet const & packet)
 {
     if (target_)
-        handle.writeto(target_, packet.data());
+        return handle.writeto(target_, packet.data()) != packet.data().begin();
+    return false;
 }
 
 ///////////////////////////////////////////////////////////////////////////