WxControl.h

Go to the documentation of this file.

#ifndef GCP_ASSEMBLER_WXCONTROL_H
#define GCP_ASSEMBLER_WXCONTROL_H

#include <string>
#include <list>

#include "gcp/mediator/specific/WxControlMsg.h"

#include "gcp/util/common/Angle.h"
#include "gcp/util/common/Date.h"
#include "gcp/util/common/GenericTask.h"
#include "gcp/util/common/Percent.h"
#include "gcp/util/common/Pressure.h"
#include "gcp/util/common/Speed.h"
#include "gcp/util/common/Temperature.h"
#include "gcp/util/common/TcpClient.h"
#include "gcp/util/common/TimeVal.h"

namespace gcp {
  
  namespace util {
    class MonitorPoint;
    class MonitorPointManager;
  }
  
namespace mediator {
    
    class Control;
    class WxClientCbass;
    
    class WxControl :
      public gcp::util::GenericTask<WxControlMsg> {
      
      public:
      

      struct WxData {
    gcp::util::Temperature airTemperature_;
    gcp::util::Speed       windSpeed_;
    gcp::util::Angle       windDirection_;
    gcp::util::Pressure    pressure_;
    gcp::util::Percent     relativeHumidity_;
    gcp::util::Date        sampleTime_;
      };

      WxControl(Control* parent);
      
      virtual ~WxControl();
      
      void incrementPending();
      void decrementPending();
      
      void writeVals(WxData& data);
      
      private:
      
      friend class Control;
      friend class SptWxClient;
      
      Control* parent_;
      
      unsigned pending_;
      
      gcp::util::TimeVal timer_;
      struct timeval* timeOut_;
      
      WxClientCbass* wx_;
      
      gcp::util::MonitorPointManager* monitor_;
 
      gcp::util::MonitorPoint* monUtc_;
      gcp::util::MonitorPoint* monAirTemp_;
      gcp::util::MonitorPoint* monRelHum_;
      gcp::util::MonitorPoint* monWindSpeed_;
      gcp::util::MonitorPoint* monWindDir_;
      gcp::util::MonitorPoint* monPressure_;
      
      WxData data_;

      void enableTimeOut(bool enable);
      
      void initiateReadValuesCommSequence();
      
      void serviceMsgQ();
      
      void processMsg(WxControlMsg* msg);

      void distributeWeatherData(WxData& data);
      
    }; // End class WxControl
    
} // End namespace mediator
} // End namespace gcp



#endif // End #ifndef GCP_ASSEMBLER_WXCONTROL_H