Blinker

@@ -9,7 +9,9 @@

       purposes.

       It accepts all incoming operator connections and prints events received

       to standard output.

-      It also replies with a sound play request to the key events 7 and 9.

+      It also replies with a sound play request on connection and in

+      response to the key events <code>7</code> and <code>9</code>.

+      Key event <code>#</code> closes the connection.

     </p>

     <h2>Configuration</h2>

     <p>

@@ -6,6 +6,7 @@

 #include <iostream>

 #include <string>

+#include "CallMgr.h"

 #include "Directory.h"

 #include "File.h"

 #include "Mgrs.h"

@@ -15,6 +16,8 @@

 #include "OpMgr.h"

 #include "OpPrinter.h"

 #include "OpReqIf.h"

+#include "Time.h"

+#include "TimeCallee.h"

 namespace Blinker {

@@ -52,6 +55,16 @@ void OpPrinter::updateConfig()

   // nothing to do here for this module

 }

+/// callback when requested time reached

+void OpPrinter::timeCall()

+{

+  while (!m_sendPlay.empty()) {

+    OpConns::iterator it = m_sendPlay.begin();

+    (*it)->sendPlay("opprinter");

+    m_sendPlay.erase(it);

+  }

+}

+

 /**

  * @brief check if accepting new operator connction is possible

  * @param[in] name operator interface name

@@ -74,6 +87,8 @@ void OpPrinter::newOpConn(const std::string &name, OpConn *pConn)

 {

   m_opConns.insert(pConn);

   std::cout << "new connection " << pConn << std::endl;

+  m_sendPlay.insert(pConn); // schedule sending play command

+  m_mgrs.m_callMgr.requestTimeCall(this, Time::now());

   (void)name; // unused

 }

@@ -90,6 +105,12 @@ void OpPrinter::opConnRecvKey(OpConn *pConn, char key)

   switch (key) {

     case '7': pConn->sendPlay("ueber_7_bruecken"); break;

     case '9': pConn->sendPlay("99_luftballons"); break;

+    case '#':

+      std::cout << "closing connection " << pConn << std::endl;

+      pConn->close();

+      m_opConns.erase(pConn);

+      m_sendPlay.erase(pConn); // could be in there, better be on safe side

+      break;

   }

 }

@@ -115,6 +136,7 @@ void OpPrinter::opConnClose(OpConn *pConn)

 {

   std::cout << "connection " << pConn << " closed" << std::endl;

   m_opConns.erase(pConn);

+  m_sendPlay.erase(pConn); // could be in there, better be on safe side

 }

 } // namespace Blinker

@@ -16,11 +16,12 @@

 #include "OpConn.h"

 #include "OpConnIf.h"

 #include "OpReqIf.h"

+#include "TimeCallee.h"

 namespace Blinker {

 /// a operator connection printer

-class OpPrinter: public Module, public OpReqIf

+class OpPrinter: public Module, public OpReqIf, public TimeCallee

 {

 public:

   /// type for set of open operator connections

@@ -49,6 +50,9 @@ public:

   /// check for update of configuration

   virtual void updateConfig();

+  /// callback when requested time reached

+  virtual void timeCall();

+

   /**

    * @brief check if accepting new operator connction is possible

    * @param[in] name operator interface name

@@ -89,6 +93,7 @@ public:

 protected:

   OpConns m_opConns;  ///< open operator connections

+  OpConns m_sendPlay; ///< connections to send play request on

 }; // class OpPrinter

 } // namespace Blinker