AntennaControl.h

#ifndef GCP_ANTENNA_CONTROL_ANTENNACONTROL_H
#define GCP_ANTENNA_CONTROL_ANTENNACONTROL_H

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

// Shared control code includes

#include "gcp/util/specific/Directives.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/antenna/control/specific/AntennaControlMsg.h"
#include "gcp/antenna/control/specific/AntNetCmdForwarder.h"
#include "gcp/antenna/control/specific/FrameSender.h"
#include "gcp/antenna/control/specific/SpecificTask.h"

#define ANTENNACONTROL_TASK_FWD_FN(fn) void (fn)(AntennaControlMsg* msg)

namespace gcp {
  namespace antenna {
    namespace control {

      class AntennaMaster;
      class AntennaGpib;
      class LnaBiasMonitor;
      class AdcMonitor;
      class DlpTempSensors;

      class AntennaControl :
    public SpecificTask,
    public gcp::util::GenericTask<AntennaControlMsg> {
    
    public:
    
      AntennaControl(AntennaMaster* parent, bool simGpib, bool simDlp, bool simLna, bool simAdc);
    
    virtual ~AntennaControl();
    
    FrameSender* getSender();

    SpecificShare* getShare();

    void sendGpibConnectedMsg(bool connected);

      private:

    friend class AntennaMaster;

    static AntennaControl* control_;

    AntennaMaster* parent_;

    // The task that will be used to communicate with GPIB devices

    AntennaGpib* gpibTask_;


    // The task that will be used to communicate with LNA power supply

    LnaBiasMonitor* lnaTask_;


    // The task that will be used to communicate with the ADC labjack

    AdcMonitor* adcTask_;

    AntNetCmdForwarder* forwarder_;

    DlpTempSensors* dlp_;

    gcp::util::NetCommHandler netCommHandler_;
    
    gcp::util::TcpClient client_;

    FrameSender sender_;

    gcp::util::LogMsgHandler logMsgHandler_;
    
    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(gcp::util::NetMsg* msg);

    //------------------------------------------------------------
    // Thread management functions.
    //------------------------------------------------------------

    static THREAD_START(startGpib);
    
    //------------------------------------------------------------
    // Thread cleanup handlers methods
    
    static THREAD_CLEAN(cleanGpib);
    
    //------------------------------------------------------------
    // Ping routines for the (pingable) subsystem threads

    static THREAD_PING(pingGpib);

    ANTENNACONTROL_TASK_FWD_FN(forwardGpibMsg);

      }; // End class AntennaControl
      
    } // End namespace control
  } // End namespace antenna
} // End namespace gcp

#endif // End #ifndef