AntennaControl.h

Go to the documentation of this file.

#ifndef SZA_ANTENNA_CONTROL_ANTENNACONTROL_H
#define SZA_ANTENNA_CONTROL_ANTENNACONTROL_H

#include <string>
#include <sys/socket.h>

// Shared control code includes

#include "carma/szautil/Directives.h"
#include "carma/szautil/GenericTask.h"
#include "carma/szautil/Logger.h"
#include "carma/szautil/LogMsgHandler.h"
#include "carma/szautil/NetCommHandler.h"
#include "carma/szautil/TcpClient.h"

#include "carma/antenna/sza/antenna/control/AntennaControlMsg.h"
#include "carma/antenna/sza/antenna/control/AntNetCmdForwarder.h"
#include "carma/antenna/sza/antenna/control/SzaTask.h"

namespace sza {
  namespace antenna {
    namespace corba {
      class AntennaCorba;
    }
  }
}

namespace sza {
  namespace antenna {
    namespace control {

      class AntennaMaster;

      class AntennaControl :
        public SzaTask,
        public sza::util::GenericTask<AntennaControlMsg> {
        
        public:
        
        AntennaControl(AntennaMaster* parent);
        
        virtual ~AntennaControl();
        
        SzaShare* getShare();

        AntennaMaster* parent() {
          return parent_;
        }

      private:

        friend class AntennaMaster;

        friend class sza::antenna::corba::AntennaCorba;

        static AntennaControl* control_;

        sza::antenna::corba::AntennaCorba* antennaCorba_;

        AntennaMaster* parent_;

        AntNetCmdForwarder* forwarder_;

        sza::util::NetCommHandler netCommHandler_;
        
        sza::util::TcpClient client_;

        sza::util::LogMsgHandler logMsgHandler_;

        //------------------------------------------------------------
        // Declare startup functions for threads managed by this class.
        //------------------------------------------------------------
        
        static THREAD_START(startAntennaCorba);
        
        //------------------------------------------------------------
        // Declare cleanup handlers for threads managed by this class.
        //------------------------------------------------------------
        
        static THREAD_CLEAN(cleanAntennaCorba);

        bool connect();

        bool isConnected(); 

        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(AntennaControlMsg* msg);

        void packNetMsg(AntennaControlMsg* msg);

        void sendGreeting();

        static NET_READ_HANDLER(netCmdReadHandler);
        
        static NET_SEND_HANDLER(netMsgReadHandler);

        static NET_SEND_HANDLER(netMsgSentHandler);
        
        static NET_ERROR_HANDLER(netErrorHandler);
        
        void sendAntennaIdMsg();

        void parseGreetingMsg(sza::util::NetMsg* msg);

        void writeCarmaSeqNo(AntennaControlMsg* msg);

        void writeCarmaMonitorPoints();

      }; // End class AntennaControl

    }; // End namespace control
  }; // End namespace antenna
}; // End namespace sza

#endif // End #ifndef