ngcdtt.hpp

Go to the documentation of this file.

#ifndef ngcdtt_H
#define ngcdtt_H
 
 
#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif
 
/* 
 * System Headers 
 */
#include <stdlib.h>
#include <stdio.h>
#include <sys/select.h>
#include <unistd.h>
 
/*
 * Local Headers 
 */
#include <ngc/core/ngcppInt.h>
#include <ngc/core/ngcbSocket.h>
#include <ngc/core/ngcdcsRTD.hpp>
#include <ngc/core/ngcdttPUBLISH.hpp>
#include <ngc/core/ngcdttIPC.hpp>

#define ngcdttMOD_ID "ngcdtt"

void ngcdttKillHandler(int sig);

void ngcdttBreakHandler(int sig);

void ngcdttExitHandler(int sig);

#define ngcdttSTATE_OFF     0                //< state OFF
#define ngcdttSTATE_ONLINE  1                //< state ONLINE

#define ngcdttMAX_CON 8

struct ngcdtt_dsup_t {
  char acqHost[64];

  int acqPort;

  char camera[128];
  
  int nxMax; 

  int nyMax;

  int numBuf;

  double freq;

  int win[4];            
  
  ngcdtt_dsup_t() {
    char *evar = getenv("NGCPP_DATA");
    if (evar != NULL) sscanf(evar, "%10d", &acqPort);
    else acqPort = 0; 
    
    evar = getenv("NGCPP_HOST");
    if (evar != NULL) str2str(acqHost, evar, 63);
    else
      {
      evar = getenv("HOSTNAME");
      if (evar != NULL) str2str(acqHost, evar, 63);
      else strcpy(acqHost, "localhost");
      }
 
    evar = getenv("RTD_CAMERA");
    if (evar != NULL) str2str(camera, evar, 63);
    else strcpy(camera, "NGC_CAM");
    
    nxMax = 2048; nyMax = 2048;
    win[0] = 1; win[1] = 1; win[2] = 0; win[3] = 0; 
    numBuf = 2;
    freq = 0.0;
  }
};

class ngcdtt {
public:
  int ignoreSignal;

  int cv32;

  int autoEnable;

  int nxMax;

  int nyMax;

  double frequency;

  int dcsMod;

  int interruptible;

  ngcdtt();                             

  explicit ngcdtt(ngcdttPUBLISH *display);                             

  virtual ~ngcdtt();                   

  virtual void InstallSignalHandlers();

  int ParseArguments(int argc, char **argv); 

  void PrintUsage(const char *argv0);

  int Configure(const char *arg, const char *value = NULL);

  void Service(const char *value);

  int ServicePort();

  void URI(const char *value);

  void Datastream(const char *value);

  void DCS(const char *value);

  void DefaultFrame(const char *value);

  void ConnectionId(int id);

  void ExecReply(int stat, const char *msg);

  int Initialize();

  void Abort(); 

  void StopMainLoop();

  int MainLoop();

  char *ErrMsg(); 

  void Verbose(const char *format, ...)
    __attribute__ ((format(printf, 2, 3)));
  
  void Log(const char *msg);

  void Verbose(int flag);

  void VerboseLevel(int level);

  void LogLevel(int level);

  int VerboseLevel();

  int LogLevel();

  void ExitSignal(int sig);
 
protected: 
  ngcdttPUBLISH *publisher;

  char acqHost[64];

  int acqPort;

  char camera[128];

  char dcsInst[64];
  
  char dcsHost[64];
  
  ngcdtt_dsup_t defaultSetup;          

  const char *Process();

  const char *Version();

  const char *Instance();

  void Shutdown();

  void DataService(const char *host, int port);

  int DataOpen(); 

  void DataClose();

  int CamOpen();

  void CamClose();
 
  int Connected();

  int Enabled();

  void Status(int flag);

  void Start();
  
  void Stop();
  
  void Invert();
  
  void Invert(int flag);
  
  int InvertStatus();

  int SelectFrame(const char *name);

  void CurrentFrame(char *name);

  int Window(int sx, int sy, int nx, int ny);

  int SX();

  int SY();

  int NX();

  int NY();

  void Retransmit();

  int Store();

  void Clear();

  int Subtract(int flag);

  int DS9(const char *cmd, char *reply, size_t max);

  virtual void Alarm(const char *msg);

  virtual int MsgInit(int *fd);
  
  virtual void MsgShutdown();

  virtual int MsgHandler(int fd);

  virtual void Logger(const char *msg);

  virtual int Select(fd_set *readMask, struct timeval *timeout);

  virtual void DbAttrState(int state);

  virtual void DbAttrFrames(int types);

  virtual void DbAttrConnected(int value);

  virtual void DbAttrEnabled(int value);

  virtual void DbAttrInvert(int value);

  virtual void DbAttrSelFrame(const char *name);

  virtual void DbAttrWin(int sx, int sy, int nx, int ny);

  virtual int DbGetCfg(const char *p, ngcdcs_rtdacq_t *acq);
  
private:
  void Init_();  

  char procName_[256];  

  char versionString_[256]; 

  char instance_[64]; 

  int aborted_; 

  int active_;                

  char erms_[256];  

  int test_;  

  int native_;

  int verboseLevel_; 

  int verboseLevelSaved_; 

  int logLevel_;  

  int logOnStdout_;

  int execHandle_; 

  int dcsPort_; 

  char thisHost_[64]; 

  char acqSrv_[256];

  int acqFd_;

  int connectionId_;

  int stopFd_[2];

  int tmode_;             
 
  char type_[64];

  int enabled_; 

  int connected_; 

  char ftype_[64]; 

  char selFrame_[64];

  ngcpp_req_t request_; 

  int oneShot_;      

  int rtiInvert_;                

  ngcdttFP fp_;

  int msgFd_; 

  uint64_t frameCounter_;
  
  void Display_(int idx); 

  void Scale_(ngcpp_frame_t *frame);

  void Invert_(void *array, ngcpp_hdr_t hdr);

  int TcpInit_();

  void TcpShutdown_(); 

  void CleanupCmd_(char *cmdLine, int *cmdLen);

  int TcpReadCmd_(int fd, char *cmdString, int maxLen);

  int TcpWriteReply_(int fd, const char *replyString, int success);

  int TcpHandleCmd_(int idx);

  void TcpSendMsg_(const char *cmd, const char *msg = NULL); 

  int TcpGetReply_(char *msg, size_t max = 0);
  
  void TcpReadRtdCmd_(int fd, char *cmd);

  void TcpHandleRtdCmd_(int fd);

  int SocketQuery_(int fd);

  int FdIsSet_(struct pollfd *fds, int n, int fd);

  char service_[64]; 

  ngcbSHMDB *tcpdb_;

  int srvCmdPort_; 

  int srvSocket_; 

  int clientSocket_[ngcdttMAX_CON]; 

  int rtdPid_; 

  int rtdPort_; 

  int rtdSocket_;                 

  int UpdateFrames_(int frames);
};
 
#endif