ngcdcsRTD.hpp

Go to the documentation of this file.

#ifndef ngcdcsRTD_H
#define ngcdcsRTD_H
 
 
#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif
 
#include <ngc/core/ngcbSHM.hpp>

#define ngcdcsRTD_MAX_ACQ 24

struct ngcdcs_rtdacq_t {
  char host[64];
  
  int dataPort;

  int nx;
  
  int ny;
  
  ngcdcs_rtdacq_t() {
    memset(host, 0, sizeof(host));
    dataPort = 0; nx = 0; ny = 0;
  }
};

struct ngcdcs_rtdshm_t {
  ngcdcs_rtdacq_t acq[ngcdcsRTD_MAX_ACQ];
};

class ngcdcsRTD: public ngcbSHMDB
{
public:
  explicit ngcdcsRTD(const char *s, ngcdcs_rtdshm_t *initVal = NULL)
    : ngcbSHMDB("ngcdcsrtd", s, initVal, sizeof(ngcdcs_rtdshm_t)) {
    shm_ = static_cast<ngcdcs_rtdshm_t *>(shmBuf);
    server_ = (initVal != NULL);
  }

  virtual ~ngcdcsRTD() {
    shm_ = NULL;
  }

  void Cfg(int idx, const ngcdcs_rtdacq_t &acq) {
    if (server_ && (CheckIdx_(idx) == 0))
      {
      if (Lock() != -1)
    {
    memcpy(&shm_->acq[idx], &acq, sizeof(ngcdcs_rtdacq_t));
    Unlock();
    }
      }
  }

  int GetCfg(int idx, ngcdcs_rtdacq_t *acq) {
    if (CheckIdx_(idx) != 0) return (-1);
    else if (Lock() != 0) return (-1);
    else 
      {
      memcpy(acq, &shm_->acq[idx], sizeof(ngcdcs_rtdacq_t));
      Unlock();
      }
    return (0);
  }
 
protected: 
 
private:
  ngcdcs_rtdshm_t *shm_;

  int server_;

  int CheckIdx_(int idx) {
    if ((idx < 0) || (idx >= ngcdcsRTD_MAX_ACQ))
      {
      strcpy(ErrMsg(), "invalid acquisition module index");
      return (-1);
      }
    else
      {
      return (0);
      }
  }
};
 
#endif