/** \file
\brief DebugModules public header */
-#ifndef HH_DebugModules_
-#define HH_DebugModules_ 1
+#ifndef HH_SENF_PPI_DebugModules_
+#define HH_SENF_PPI_DebugModules_ 1
// Custom includes
#include <deque>
#include "../Utils/safe_bool.hh"
#include "../Packets/Packets.hh"
-#include "Module.hh"
+#include "MonitorModule.hh"
#include "ActiveFeeder.hh"
#include "../Utils/Logger/SenfLog.hh"
ActiveSource();
- void submit(Packet packet); ///< Submit packet
+ void submit(Packet const & packet); ///< Submit packet
/**< \pre boolean_test() is \c true */
bool boolean_test() const; ///< \c true if \a output is not throttled
void throttle(); ///< Throttle output connector
void unthrottle(); ///< Unthrottle output connector
- void submit(Packet packet); ///< Enqueue packet
+ void submit(Packet const & packet); ///< Enqueue packet
bool empty(); ///< \c true if queue is empty
size_type size(); ///< Number of packets in queue
template < class Stream = log::Debug,
class Area = log::DefaultArea,
class Level = log::VERBOSE >
- class LogSink
- : public module::Module
+ class Logger
+ : public MonitorModule<>
{
- SENF_PPI_MODULE(LogSink);
+ SENF_PPI_MODULE(Logger);
public:
-
- connector::PassiveInput<> input;
-
- LogSink();
+ Logger();
+ explicit Logger(std::string label);
private:
- void request();
+ virtual void v_handlePacket(Packet const & packet);
+
+ std::string label_;
};
}}}}