// Custom includes
#define prefix_ inline
-///////////////////////////////cti.p///////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
-///////////////////////////////////////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
// senf::ppi::TargetDgramWriter<HandleType>
template <class HandleType>
}
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;
}
-///////////////////////////////////////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
// senf::ppi::module::ActiveSocketSink<Writer>
template <class Writer>
}
template <class Writer>
-prefix_ void senf::ppi::module::ActiveSocketSink<Writer>::handle(Handle handle)
+prefix_ void senf::ppi::module::ActiveSocketSink<Writer>::handle(Handle const & handle)
{
handle_ = handle;
event_.set(handle_, IOEvent::Write);
}
-///////////////////////////////////////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
// senf::ppi::module::PassiveSocketSink<Writer>
template <class Writer>
}
template <class Writer>
-prefix_ void senf::ppi::module::PassiveSocketSink<Writer>::handle(Handle handle)
+prefix_ void senf::ppi::module::PassiveSocketSink<Writer>::handle(Handle const & handle)
{
handle_ = handle;
checkThrottle();
}
#endif
-///////////////////////////////cti.e///////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
#undef prefix_
\f