Blinker

@@ -28,13 +28,22 @@ OpPrinter::OpPrinter(const std::string &name, Mgrs &mgrs,

                      const Directory &dirBase):

   Module(name, mgrs, dirBase)

 {

+  // open operator connection interface

   m_mgrs.m_opMgr.open(m_name, this);

 }

 /// virtual destructor

 OpPrinter::~OpPrinter()

 {

+  // close operator connection interface

   m_mgrs.m_opMgr.close(m_name);

+

+  // close open operator connections

+  while (!m_opConns.empty()) {

+    OpConns::iterator itOpConn = m_opConns.begin();

+    (*itOpConn)->close();

+    m_opConns.erase(itOpConn);

+  }

 }

 /// check for update of configuration

@@ -61,6 +70,7 @@ bool OpPrinter::acceptNewOpConn(const std::string &name)

  */

 void OpPrinter::newOpConn(const std::string &name, OpConn *pConn)

 {

+  m_opConns.insert(pConn);

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

   (void)name; // unused

 }

@@ -100,6 +110,7 @@ void OpPrinter::opConnRecvPlay(OpConn *pConn, const std::string &sound)

 void OpPrinter::opConnClose(OpConn *pConn)

 {

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

+  m_opConns.erase(pConn);

 }

 } // namespace Blinker

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

 #ifndef BLINKER_OPPRINTER_H

 #define BLINKER_OPPRINTER_H

+#include <set>

 #include <string>

 #include "Directory.h"

@@ -21,6 +22,10 @@ namespace Blinker {

 /// a operator connection printer

 class OpPrinter: public Module, public OpReqIf

 {

+public:

+  /// type for set of open operator connections

+  typedef std::set<OpConn *> OpConns;

+

 public:

   /**

    * @brief constructor

@@ -77,6 +82,9 @@ public:

    * @param[in] pConn operator connection object

    */

   virtual void opConnClose(OpConn *pConn);

+

+protected:

+  OpConns m_opConns; ///< open operator connections

 }; // class OpPrinter

 } // namespace Blinker