Control.h

#ifndef CONTROL_H
#define CONTROL_H

#include <list>
#include <vector>

// Shared control code includes

#include "gcp/control/code/unix/libunix_src/specific/rtcnetcoms.h"

// SZA antenna code includes

#include "gcp/util/common/FdSet.h"
#include "gcp/util/common/GenericTask.h"
#include "gcp/util/common/Logger.h"
#include "gcp/util/common/LogMsgHandler.h"
#include "gcp/util/common/NetCommHandler.h"
#include "gcp/util/common/TcpClient.h"

#include "gcp/grabber/common/ControlMsg.h"
#include "gcp/grabber/common/GrabberNetCmdForwarder.h"

#define CONTROL_TASK_FWD_FN(fn) void (fn)(ControlMsg* msg)

namespace gcp {
  namespace grabber {
    
    class Master;
    
    class Control : 
      public gcp::util::GenericTask<ControlMsg> {
      
      public:
      
      ~Control();
      
      //------------------------------------------------------------
      // Task message forwarding methods
      //------------------------------------------------------------
      
      CONTROL_TASK_FWD_FN(forwardControlMsg);
      
      private:
      
      GrabberNetCmdForwarder* forwarder_;
      
      friend class Master;
      
      static Control* control_;
      
      gcp::util::NetCommHandler netCommHandler_;
      
      Master* parent_;
      
      gcp::util::TcpClient client_;
      
      std::string host_;        
      
      bool connected_;     
      
      gcp::util::LogMsgHandler logMsgHandler_;

      Control(Master* master);
      
      bool isConnected(); 
      
      bool connect();    
      
      void disconnect(); 
      
      void connectControl(bool reEnable);
      
      void disconnectControl();
      
      void serviceMsgQ();
      
      void sendControlConnectedMsg(bool connected);
      
      static LOG_HANDLER_FN(sendLogMsg);
      
      static LOG_HANDLER_FN(sendErrMsg);
      
      static void sendNetMsg(std::string& logStr, bool isErr);

      void processMsg(ControlMsg* taskMsg);
      
      void packNetMsg(ControlMsg* msg);
      
      static NET_READ_HANDLER(netCmdReadHandler);
      
      static NET_SEND_HANDLER(netMsgSentHandler);
      
      static NET_ERROR_HANDLER(netErrorHandler);
      
    }; // End class Control
    
  }; // End namespace grabber
}; // End namespace gcp


#endif // End #ifndef