ngcdcsEXPDRV.hpp

Go to the documentation of this file.

#ifndef ngcdcsEXPDRV_H
#define ngcdcsEXPDRV_H
 
 
#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif
 
#include <stdlib.h>
#include <stdio.h>
#include <stdarg.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
 
#include <ngc/core/ngcbOBJ.hpp>
#include <ngc/core/ngcbPARAM.hpp>
#include <ngc/core/ngcdcsFINFO.hpp>

class ngcdcsEXPDRV: public ngcbOBJ
{
public:
  char name[64];

  int state;

  int acqId;

  unsigned int expId;

  ngcbPARAM_LIST setupList;

  ngcbPARAM_LIST *paramList;

  ngcbFITS fits;

  explicit ngcdcsEXPDRV(const ngcb_fb_t &fb) : fb_(fb) {Init_();}

  virtual ~ngcdcsEXPDRV() {
    if (fb_.automatic && (fb_.chan != NULL))
      {
      fclose(fb_.chan); fb_.chan = NULL;
      }
  }

  int Initialized() {return (initialized_);}

  FILE *FeedBackStream() {return (fb_.chan);}

  int ImgProcessor() {return (imgProcessor_ || (state > 0));}

  virtual int Configure(ngcbPARAM_LIST *cfg) {USE(cfg); return (ngcbSUCCESS);}

  void GetCfg(ngcbPARAM_LIST *cfg) {cfg->Clear(); CfgStatus(cfg);}

  int Active() {return (active_);}

  int NewSetup() {return ((setupList.First() != NULL));}

  void Init() {state = 0; expId = 0; FeedBack("\n<INIT!>\n");}

  int Next() {
    int result;
    setupList.Clear();
    delay_ = 0;
    active_ = 1;
    ErrMsg()[0] = '\0';
    result = Exec();
    if (result == ngcbFAILURE) state = -1;
    return (result);
  }

  void Terminate(int status=0) {
    setupList.Clear();
    if (Active())
      {
      Exit(status);
      active_ = 0;
      if (status == ngcbABORTED) FeedBack("\n<ABORTED!>\n");
      else if (status == ngcbFAILURE) FeedBack("\n<FAILURE!>\n");
      else FeedBack("\n<SUCCESS!>\n");
      }
  }
  
  int Delay() {return (delay_);}

  virtual int Process(void *buffer, ngcdcs_finfo_t *finfo) {
    USE(buffer); USE(finfo);
    return (ngcbSUCCESS);
  }

  virtual int MergeFits(ngcbFITS *hdr) {USE(hdr); return (ngcbSUCCESS);}
 
protected: 
  void Initialized(int flag) {
    if (flag) initialized_ = 1;
    else initialized_ = 0;
  }

  void ImgProcessorOn() {imgProcessor_ = 1;}

  void Delay(int ms) {delay_ = ms;}

  int Status(const char *paramName, char *value) {
    if (paramList != NULL)
      {
      /*
       * Check global list first
       */
      if (paramList->ValString(paramName, value) == ngcbSUCCESS)
    {
    return (ngcbSUCCESS);
    }
      }
 
    if (services != NULL)
      {
      /*
       * An external hook is defined - check if this
       * resolves our parameter.
       */
      if (services->ParamLookup(paramName, value))
    {
    return (ngcbSUCCESS);
    }
      }
    
    /*
     * Parameter is unknown within this scope
     */
    sprintf(ErrMsg(), "unknown parameter");
    return (ngcbFAILURE);
  }

  virtual int Exec() {return (ngcbSUCCESS);}

  virtual void Exit(int status) {USE(status);}

  virtual void CfgStatus(ngcbPARAM_LIST *cfg) {USE(cfg);}

  void SendFeedBack(const char *msg) {
    if (fb_.chan != NULL)
      {
      if ((verboseLevel <= 0) || (fb_.chan != stdout))
    {
    if (fprintf(fb_.chan, "%s", msg) < 0)
      {
      if (fb_.automatic) fclose(fb_.chan); 
      fb_.chan = NULL; // don't use anymore
      }
    if (fflush(fb_.chan) != 0)
      {
      if (fb_.automatic) fclose(fb_.chan); 
      fb_.chan = NULL; // don't use anymore
      }
    }
      }
 
    if ((strcmp(msg, "\n<ABORTED!>\n") == 0) ||
    (strcmp(msg, "\n<FAILURE!>\n") == 0) ||
    (strcmp(msg, "\n<SUCCESS!>\n") == 0))
      {
      return;
      }
    else
      {
      Verbose("ngcdcsEXPDRV: %s", msg);
      }
  }
 
private:
  int initialized_;

  int delay_;

  int active_;

  ngcb_fb_t fb_;

  int imgProcessor_;

  void Init_() {
    initialized_ = 0;
 
    if ((fb_.chan == NULL) && fb_.automatic)
      {
      fb_.chan = ngcbDebugOpen(static_cast<char *>(NULL));
      }
    
    delay_ = 0;
    state = 0;  
    acqId = 0;
    expId = 0;
    paramList = NULL;
    name[0] = '\0';
    active_ = 0;
    imgProcessor_ = 0;
    initialized_ = 1;
  }
};
 
#endif