// Custom includes
#include <deque>
-#include "Utils/SafeBool.hh"
-#include "Packets/Packets.hh"
+#include "../Utils/SafeBool.hh"
+#include "../Packets/Packets.hh"
#include "Module.hh"
#include "ActiveFeeder.hh"
-#include "Utils/Logger.hh"
+#include "../Utils/Logger.hh"
//#include "DebugModules.mpp"
///////////////////////////////hh.p////////////////////////////////////////
connector::PassiveOutput output;
PassiveSource();
+
+ void throttle(); ///< Throttle output connector
+ void unthrottle(); ///< Unthrottle output connector
void submit(Packet packet); ///< Enqueue packet
typedef Queue::const_iterator iterator;
connector::PassiveInput input;
-
+
PassiveSink();
+ void throttle(); ///< Throttle input connection
+ void unthrottle(); ///< Unthrottle input connection
+
bool empty(); ///< \c true, if queue is empty
size_type size(); ///< number of packets in the queue
iterator begin(); ///< begin iterator of packets in the queue