X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketReader.hh;h=723daef1181bba621bc065f0dcbfe511f4dd3262;hb=81ffa1c459b96dd44472bcef37e1e373934ee138;hp=4d0c626072cdeb4c438ae44bd0785570e191d60d;hpb=145f6a7d0f3a6aaa77b3625351c952d24cb0b8a1;p=senf.git diff --git a/PPI/SocketReader.hh b/PPI/SocketReader.hh index 4d0c626..723daef 100644 --- a/PPI/SocketReader.hh +++ b/PPI/SocketReader.hh @@ -25,10 +25,14 @@ #define HH_SocketReader_ 1 // Custom includes -#include "Packets/Packet.hh" -#include "Packets/DataPacket.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 "Connector.hh" +#include "Connectors.hh" +#include "IOEvent.hh" //#include "SocketReader.mpp" ///////////////////////////////hh.p//////////////////////////////////////// @@ -49,10 +53,10 @@ namespace ppi { public: typedef senf::ClientSocketHandle< senf::MakeSocketPolicy< senf::ReadablePolicy, - senf::DatagramFramingPolicy > > Handle; + senf::DatagramFramingPolicy >::policy > Handle; ///< Handle type supported by this reader - Packet::ptr operator()(Handle handle); + Packet operator()(Handle handle); ///< Read packet from \a handle /**< Read a datagram from \a handle and interpret is as packet of type \c Packet. @@ -95,13 +99,20 @@ namespace module { /**< Data will be read from \a handle and be parsed by \a Reader. \param[in] handle Handle to read data from */ + + private: + void read(); + + Handle handle_; + IOEvent event_; + Reader reader_; }; }}} ///////////////////////////////hh.e//////////////////////////////////////// //#include "SocketReader.cci" -//#include "SocketReader.ct" +#include "SocketReader.ct" //#include "SocketReader.cti" #endif