X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketReader.hh;h=5d2691303d4a977a1c5e2370ec7d30d0cb7d1dac;hb=81447258e6ecc9b5d9434fa5a7d382684179c7ab;hp=723daef1181bba621bc065f0dcbfe511f4dd3262;hpb=81ffa1c459b96dd44472bcef37e1e373934ee138;p=senf.git diff --git a/PPI/SocketReader.hh b/PPI/SocketReader.hh index 723daef..5d26913 100644 --- a/PPI/SocketReader.hh +++ b/PPI/SocketReader.hh @@ -25,11 +25,11 @@ #define HH_SocketReader_ 1 // Custom includes -#include "Packets/Packets.hh" -#include "Socket/ClientSocketHandle.hh" -#include "Socket/SocketPolicy.hh" -#include "Socket/ReadWritePolicy.hh" -#include "Socket/FramingPolicy.hh" +#include "../Packets/Packets.hh" +#include "../Socket/ClientSocketHandle.hh" +#include "../Socket/SocketPolicy.hh" +#include "../Socket/ReadWritePolicy.hh" +#include "../Socket/FramingPolicy.hh" #include "Module.hh" #include "Connectors.hh" #include "IOEvent.hh" @@ -74,22 +74,35 @@ namespace module { /** \brief Input module reading data from an arbitrary FileHandle This input module will read data from a FileHandle object and parse the data according to - the \a Reader. - - The \a Reader must fulfill the following interface: + the \a Reader. The default reader is senf::ppi::PacketReader <> which reads the data into a + senf::DataPacket. To parse the data according to some other packet type, pass that packet + type to senf::ppi::PacketReader: + \code + senf::ppi::module::ActiveSocketReader< senf::ppi::PacketReader > reader; + \endcode + declares a \a reader module reading senf::EthrtnetPacket's. + + A \a Reader must fulfill the following interface: \code - class SomeReader - { - public: - typedef unspecified_type Handle; // type of handle requested - SomeReader(); // default constructible - Packet::ptr operator()(Handle handle); // extraction function - }; + class SomeReader + { + public: + typedef unspecified_type Handle; // type of handle requested + SomeReader(); // default constructible + Packet operator()(Handle handle); // extraction function + }; \endcode + Whenever the FileHandle object is ready for reading, the \a Reader's \c operator() is called + to read a packet. + + \ingroup io_modules */ template > - class ActiveSocketReader : public Module + class ActiveSocketReader + : public Module { + SENF_PPI_MODULE(ActiveSocketReader); + public: typedef typename Reader::Handle Handle; ///< Handle type requested by the reader