Master.h

#ifndef SZA_TRANSLTOR_MASTER_H
#define SZA_TRANSLTOR_MASTER_H

#include <vector>

#include "gcp/util/common/Directives.h"
#include "gcp/util/common/GenericMasterTask.h"

#include "gcp/grabber/common/MasterMsg.h"

#define IMAGE_SIGNAL   SIGRTMIN+1
#define CONNECT_SIGNAL SIGRTMIN+2

#define CONNECT_SEC 2

#define MASTER_TASK_FWD_FN(fn) void (fn)(MasterMsg* msg)

namespace gcp {
  namespace grabber {
    
    class Control;
    class Scanner;
    
    class Master : 
    public gcp::util::GenericMasterTask<MasterMsg> { 
      
    public:
      
      //============================================================
      // Master public members & methods
      //============================================================
      
      Master(std::string ctlHost, std::string imHost, 
         bool simulate, unsigned channel);
      
      ~Master();
      
      std::string ctlHost();
      std::string imHost();
      
      MASTER_TASK_FWD_FN(forwardMasterMsg);
      
      MASTER_TASK_FWD_FN(forwardScannerMsg);
      
      MASTER_TASK_FWD_FN(forwardControlMsg);
      
      unsigned channel() {
    return channel_;
      }

    private:
      
      //============================================================
      // Master private members & methods
      //============================================================
      
      static Master* master_;
      
      Control* control_;
      Scanner* scanner_;
      
      // The control host to connect to.

      std::string ctlHost_;

      // The host to send images to

      std::string imHost_;
      
      bool simulate_;
      
      inline bool simulate() {
    return simulate_;
      }
      
      unsigned channel_;

      //------------------------------------------------------------
      // Thread management methods
      //------------------------------------------------------------
      
      static THREAD_START(startControl);  
      
      static THREAD_CLEAN(cleanControl);  
      
      static THREAD_START(startScanner);  
      
      static THREAD_CLEAN(cleanScanner);  
      
      static THREAD_START(startSignal);  
      
      static THREAD_CLEAN(cleanSignal);  
      
      //------------------------------------------------------------
      // Message processing
      
      void processMsg(MasterMsg* msg);
      
      //------------------------------------------------------------
      // Static functions which will be passed to the
      // Signal class as callbacks on receipt of signals.
      //------------------------------------------------------------
      
      static SIGNALTASK_HANDLER_FN(sendShutDownMsg);
      
      static SIGNALTASK_HANDLER_FN(sendConnectControlMsg);
      
      static SIGNALTASK_HANDLER_FN(sendConnectScannerMsg);
      
      void sendControlConnectedMsg(bool connected);
      
      void sendScannerConnectedMsg(bool connected);
      
      void installSignals();
      
      void installTimers();
      
    }; // End class Master
    
  }; // End namespace grabber
}; // End namespace gcp


#endif // End #ifndef