senf::DatagramFramingPolicy >::policy > Handle;
///< Handle type supported by this reader
- Packet 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.
explicit ActiveSocketSource(Reader reader); ///< Create non-connected reader
/**< The reader will be disabled until a socket is set
\pre Requires \a Reader to be copy constructible */
- explicit ActiveSocketSource(Handle handle); ///< Create new reader for the given handle
+ explicit ActiveSocketSource(Handle const & handle);
+ ///< Create new reader for the given handle
/**< Data will be read from \a handle and be parsed by \a
Reader.
\pre Requires \a Reader to be default constructible
\param[in] handle Handle to read data from */
- ActiveSocketSource(Handle handle, Reader reader);
+ ActiveSocketSource(Handle const & handle, Reader reader);
///< Create new reader for the given handle
/**< Data will be read from \a handle and be parsed by \a
Reader.
Reader & reader(); ///< Access Reader helper
Handle handle(); ///< Access handle
- void handle(Handle handle); ///< Set handle
+ void handle(Handle const & handle);
+ ///< Set handle
/**< Assigning an empty or in-valid() handle will disable
the module until a new, valid handle is assigned. */
-
private:
+ Handle handle_;
+ IOEvent event_;
+ Reader reader_;
+
void read();
+ };
+
+
+ template <class Reader=DgramReader<> >
+ class ActiveBurstSocketSource
+ : public Module
+ {
+ SENF_PPI_MODULE(ActiveBurstSocketSource);
+
+ public:
+ typedef typename Reader::Handle Handle; ///< Handle type requested by the reader
+
+ connector::ActiveOutput<typename Reader::PacketType> output;
+ ///< Output connector to which the data received is written
+
+ ActiveBurstSocketSource(unsigned max_burst);
+ explicit ActiveBurstSocketSource(Reader reader, unsigned max_burst);
+ explicit ActiveBurstSocketSource(Handle const & handle, unsigned max_burst);
+ ActiveBurstSocketSource(Handle const & handle, Reader reader, unsigned max_burst);
+
+ Reader & reader(); ///< Access Reader helper
+ Handle handle(); ///< Access handle
+ void handle(Handle const & handle);
+ ///< Set handle
+ /**< Assigning an empty or in-valid() handle will disable
+ the module until a new, valid handle is assigned. */
+
+ unsigned maxBurst() const;
+ void maxBurst(unsigned max_burst);
+ private:
Handle handle_;
IOEvent event_;
Reader reader_;
+ unsigned maxBurst_;
+
+ void read();
};
}}}