/home/kopmann/git-mirror/fdhwlib/fdhwlib/FEdata/tsbackgroundloop.h

Go to the documentation of this file.

/***************************************************************************
                          tsbackgroundloop.h  -  description
                             -------------------
    begin                : Thu Oct 31 2002
    copyright            : (C) 2002 by Andreas Kopmann
    email                : kopmann@ipe.fzk.de
 ***************************************************************************/


#ifndef TSBACKGROUNDLOOP_H
#define TSBACKGROUNDLOOP_H

#include <cstdio>
#include <string>
#include <map>

#include <FEdata/tsdef.h>

#ifdef USE_MYSQL
#include <mysql/mysql.h>
#endif // of USE_MYSQL

#include <akutil/simpleserver.h>
#include <akutil/procDuration.h>

#define BGLOOP_PORT 5103
#define BGCMD_LEN 4000

class SimpleServer;
class procDuration;
class TsBackgroundBase;

class TsBackgroundLoop : public SimpleServer  {
public: 
  TsBackgroundLoop();
  ~TsBackgroundLoop();

  typedef enum {
      eDebug,           
      eInfo,            
      eWarning,         
      eError,           
      eCritical,        
      eSevere,          
      eFatal            
  } DBMessageSeverity;

  void readInifile(const char *inifile);

  void replaceTemplates();  
  
  int setParameter(char *file="bg_bayX.txt",float tSample=30,
                   int selTelescopes=0, int selStore=0, int selDisplay=0,
                   const char *runType = "test");

  void enablePixelRecording();
  
  void disablePixelRecording();

#ifdef USE_MYSQL

  int setDatabaseParameter(const char *server, 
         const char *user, const char *password,
         const char *database, const char *runtable,
         const char *sampletable, const char *errortable,
         const char *pixeltable=0);

  void enableDatabase();

  void disableDatabase();
#endif // of USE_MYSQL

  void setLocation(const char *name, int id);

  void getLocation(const char *name, int *id);
  
  void setSamplingTime(float tSample);

  float getSamplingTime();

  void setLogfile(FILE *flog);

  void setFilename(const char *file);

  const char *getFilename();

  void selectTelescopes(unsigned long selTelelescopes);

  unsigned long getTelescopes();

  void selectItems(unsigned long selStore);

  unsigned long getItems();  

  void selectDisplayItems(unsigned long selDisplay);

  unsigned long getDisplayItems();

  void setVarianceLimits(unsigned int limit);

  unsigned long getVarianceLimits();

  void setPixelStatus(int col, int row, bool enabled);

  bool getPixelStatus(int col, int row);

  void displayParameter();

  //int read_from_client(int client);

  int openFile();

  void setFDDASRunId(unsigned long runId);

  
#ifdef USE_MYSQL

  int openDatabase();

  int loadFromDatabase(TsBackgroundBase *bg);

  int saveSampleToDatabase(TsBackgroundBase *bg);

  int savePixelToDatabase(TsBackgroundBase *bg);
  
#endif // of USE_MYSQL

  void executeCmd(int client, short cmd, unsigned long *arg, short n);
  void executeCmd(int client, short cmd, unsigned int *arg, short n);

  void runReadout(FILE *fout, int eyeId=0);

  void displayRuns(FILE *fout, char *cmd=0);
   
  void displayHeader(TsBackgroundBase *bg, int select);
  
  void displaySummary(TsBackgroundBase *bg, int select);

  void setVarianceLevel(int low, int high);
  
  void displayError(const char *msg, int tel=0);

#ifdef USE_MYSQL

  void writeMessageToDatabase(const char *msg, 
                              DBMessageSeverity severity=eInfo, int tel=0);
#endif // USE_MYSQL

  void checkStatus(TsBackgroundBase *bg);

  void writeLogfileHeader();

  void writeLogfileFooter();

  void changeToDataDir(FILE *fout);
 
  void enableDaemonMode();
  
  void enableInteractiveMode();


private:
  int debug;

  std::string inifile;

  std::string filename;

  std::string filenameTmpl;

  std::string basedir;
  
  std::string basedirTmpl;
  
  int locationId;

  std::string location;

  int uniqueId;
  
  FILE *fout;

  FILE *bgFile;

  bool record;

  procDuration tRef;

  float tSample;

  int selStore;

  int selDisplay;

  int selTelescopes;

  int limitVar;

  unsigned long statSamples;

  unsigned long statOffset;

  unsigned long disabledPixel[20];

  unsigned long pixelStatus[20][24];

  unsigned long fddasRunId;

  std::string bgrunFile;
  
  std::string bgcalFile;

  int bgrunTSample;

  int bgcalTSample;

  bool runAsDaemon;
  
#ifdef USE_MYSQL

  bool recordDatabase;

  bool recordPixel;

  bool recordBroken;

  std::string dbServer;

  std::string dbUser;

  std::string dbPassword;

  std::string dbName;

  std::string dbNameTmpl;
  

  std::string dbRuntable;

  std::string dbSampletable;

  std::string dbPixeltable;

  std::string dbErrortable;

  unsigned long dbRunId;

  unsigned long dbSampleId;
  
  unsigned long nSamples;

  unsigned long nCmdsInFile;
  
  typedef struct {
  
    time_t       lastGPS;     // when message occurred last time
    unsigned int nOccur;      // number of occurrences
    unsigned int maxOccur;    // max. number of occurrences until we stay quiet
  
  } MsgInfo;
  
  std::map<std::string,MsgInfo> dbMessageMap;
  
  MYSQL *db;

  FILE *dbBackup;  

  void dbWrite(const char *cmd, const char *cmdBackup = 0);
    
  int compareFields(char *cmd, std::string *fields, int n);
  
#endif // of USE_MYSQL

  FILE *flog;

  std::string logfile;

  int runMode;

  std::string runType;

  int telActive[24];

  unsigned long lastDataSec[24];

  int hitrateOverflow[24];

  unsigned long lastSecondDiff[24];

  int varianceLevel[24];

  float varianceClosedShutter;

  float varianceOverflow;

  int lastVariance[24];

  int actualVariance[24];

  unsigned long lastTimeStamp;

  unsigned long actualTimeStamp;
  
  int thresholdLevel[24];

  int missingTel[24];

  int errorLevel[24];

  int errorGeneral;

  //int faultyPixelMask[24][20][22];

  unsigned long long lastDeadtime[24];

  int deadtimeActive[24];

  int tDatabase;
  
};

#endif