X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FSocketSink.hh;h=ab689904593a7d8db14ecd00d71171708e310968;hb=ff4249b4a9c23236b2e56dcd593c91a5c58f7b75;hp=ee944ddf8ba9c46106bc00bf7fd3109a9b1688f9;hpb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;p=senf.git diff --git a/senf/PPI/SocketSink.hh b/senf/PPI/SocketSink.hh index ee944dd..ab68990 100644 --- a/senf/PPI/SocketSink.hh +++ b/senf/PPI/SocketSink.hh @@ -27,15 +27,15 @@ #define HH_SENF_PPI_SocketSink_ 1 // Custom includes -#include "../Packets/Packets.hh" -#include "../Socket/ClientSocketHandle.hh" -#include "../Socket/SocketPolicy.hh" -#include "../Socket/ReadWritePolicy.hh" -#include "../Socket/FramingPolicy.hh" -#include "../Socket/CommunicationPolicy.hh" +#include +#include +#include +#include +#include +#include #include "Module.hh" #include "Connectors.hh" -#include "../Socket/Protocols/INet/INetAddressing.hh" +#include #include "IOEvent.hh" //#include "SocketSink.mpp" @@ -58,7 +58,7 @@ namespace ppi { ///< Handle type supported by this writer typedef Packet PacketType; - void operator()(Handle handle, Packet const & packet); + bool operator()(Handle handle, Packet const & packet); ///< Write \a packet to \a handle /**< Write the complete \a packet as a datagram to \a handle. @@ -87,7 +87,7 @@ namespace ppi { typename Handle::Address target() const; ///< Get current target address void target(typename Handle::Address const & target); ///< Set target address - void operator()(Handle handle, Packet const & packet); ///< Write \a packet to \a handle + bool operator()(Handle handle, Packet const & packet); ///< Write \a packet to \a handle /**< Write the complete \a packet as a datagram to \a handle. \param[in] handle Handle to write data to @@ -113,7 +113,7 @@ namespace ppi { void destination(senf::INet4SocketAddress & dest); senf::INet4SocketAddress destination(); - void operator()(Handle handle, Packet const & packet); + bool operator()(Handle handle, Packet const & packet); ///< Write \a packet to \a handle /**< Write the complete \a packet as a datagram to \a handle. @@ -142,7 +142,7 @@ namespace ppi { void destination(senf::INet6SocketAddress & dest); senf::INet6SocketAddress destination(); - void operator()(Handle handle, Packet const & packet); + bool operator()(Handle handle, Packet const & packet); ///< Write \a packet to \a handle /**< Write the complete \a packet as a datagram to \a handle. @@ -184,7 +184,7 @@ namespace module { SomeWriter(); // EITHER default constructible OR SomeWriter(SomeWriter const & other); // copy constructible - void operator()(Handle handle, Packet packet); // insertion function + bool operator()(Handle handle, Packet packet); // insertion function }; \endcode Whenever a packet is received for sending, the \a Writer's \c operator() is called. @@ -241,10 +241,10 @@ namespace module { able to handle complete datagrams. This output module will write data to a FileHandle object using a given \a Writer. This - output module is passive. This implies, that the output handle may not block. This also - implies, that data will probably get lost if written to fast for the underlying transport - mechanism. Either this is desired (like for a UDP socket) or some additional bandwidth - shaping needs to be used. + output module is passive. This implies, that the output handle may not block. This + also implies, that data will probably get lost if written to fast for the underlying + transport mechanism. Either this is desired (like for a UDP socket) or some additional + bandwidth shaping needs to be used. The default \a Writer is senf::ppi::ConnectedDgramWriter which will write out the complete packet to the file handle. @@ -260,7 +260,7 @@ namespace module { SomeWriter(); // EITHER default constructible SomeWriter(SomeWriter const & other); // OR copy constructible - void operator()(Handle handle, Packet packet); // insertion function + bool operator()(Handle handle, Packet packet); // insertion function }; \endcode Whenever a packet is received for sending, the \a Writer's \c operator() is called. @@ -302,7 +302,7 @@ namespace module { Handle & handle(); ///< Access handle void handle(Handle handle); ///< Set handle /**< Assigning an empty or in-valid() handle will disable - the module until a new. valid handle is assigned. */ + the module until a new valid handle is assigned. */ #ifndef DOXYGEN void replaceHandle(Handle newHandle); @@ -325,7 +325,7 @@ namespace module { #include "SocketSink.cti" #endif - + // Local Variables: // mode: c++ // fill-column: 100