Changeset 182 for drsdaq

Timestamp:

03/12/10 15:53:20 (15 years ago)

Author:

ogrimm

Message:

Updates to DIM integration

Location:

drsdaq

Files:

• DAQReadout.cc (modified) (22 diffs)
• DAQReadout.h (modified) (7 diffs)
• DRS/DRS.cc (modified) (12 diffs)
• HVFeedback.cc (modified) (5 diffs)
• HVFeedback.h (modified) (2 diffs)
• History.txt (modified) (1 diff)
• Makefile (modified) (1 diff)
• SlowData.cc (deleted)
• SlowData.h (deleted)
• drsdaq.cpp (modified) (4 diffs)

drsdaq/DAQReadout.cc

@@ -10 +10 @@
 
 #include "DAQReadout.h"
-#include "SlowData.h"
-
-#define TMPNAME "/tmp/__tmp__drsdaq__"  // ..for log file truncation
 
 static const char* daq_state_str[] = {"active", "stopped"};
@@ -63 +60 @@
 //
  
-DAQReadout::DAQReadout(const char *Configfile) {
+DAQReadout::DAQReadout() :EvidenceServer(SERVER_NAME) {
    
   time(&StartTime);  // Start time of DAQ
@@ -78 +75 @@
   LastBoard          = -1;
   CmdFromSocket      = false;
-  ConfigOK           = true;
-  
-  // Read configuration file (if any item missing, program will be terminated in main() routine)
-  FILE *File;
-  if ((File = fopen(Configfile,"r")) == NULL) {
-    printf("Error: Could not open drsdaq configuration file '%s'\n", Configfile);
-    ConfigOK = false;
-    return;
-  }
-  else {
-    printf("Reading drsdaq configuration file %s\n", Configfile);
-    ConfigOK &= ReadCard("LogFile",             fLogFile,           's', File);
-    ConfigOK &= ReadCard("SlowDataPath",        fSlowDataPath,      's', File);
-    ConfigOK &= ReadCard("MaxLogLines",        &fMaxLogLines,       'U', File);
-    ConfigOK &= ReadCard("RawDataPath",         fRawDataPath,       's', File);
-    ConfigOK &= ReadCard("CalibDataPath",       fCalibDataPath,     's', File);
-    ConfigOK &= ReadCard("FirstSample",        &fFirstSample,       'I', File);
-    ConfigOK &= ReadCard("Samples",            &fSamples,           'U', File);
-    ConfigOK &= ReadCard("MinDiskSpaceMB",     &fMinDiskSpaceMB,    'U', File);
-    ConfigOK &= ReadCard("MaxFileSizeMB",      &fMaxFileSizeMB,     'I', File);
-    ConfigOK &= ReadCard("CCPort",             &fCCPort,            'I', File);
-    ConfigOK &= ReadCard("HVFeedbackConfig",    fHVFeedbackConfig,  's', File);
-    ConfigOK &= ReadCard("DefaultFrequency",   &fDefaultFrequency , 'd', File);
-    fclose(File);
-    if (!ConfigOK) return;
-  }
+  
+  // Get configuration data
+  fRawDataPath = GetConfig("RawDataPath");
+  fCalibDataPath = GetConfig("CalibDataPath");
+  fFirstSample = atoi(GetConfig("FirstSample"));
+  fSamples = atoi(GetConfig("Samples"));
+  fMinDiskSpaceMB = atoi(GetConfig("MinDiskSpaceMB"));
+  fMaxFileSizeMB = atoi(GetConfig("MaxFileSizeMB"));
+  fCCPort = atoi(GetConfig("CCPort"));
+  fDefaultFrequency = atof(GetConfig("DefaultFrequency"));
+
   if (fFirstSample < 0 || fFirstSample > kNumberOfBins || fSamples > kNumberOfBins) {
     PrintMessage("Warning: Sample range in configuration beyond limits, setting to full range\n");
@@ -109 +91 @@
     fSamples = kNumberOfBins;
   }
-  
-  // Open log file and log configuration
-  if ((Logfile = fopen(fLogFile, "a")) == NULL) printf("Warning: Could not open log file '%s'\n", fLogFile);
-  PrintMessage(MsgToLog,"********** Logging started **********\n");
-  PrintConfig(MsgToLog);
-
+  snprintf(CalibInfoFilename,sizeof(CalibInfoFilename), "%s/CalibInfo", fCalibDataPath);
+  
   // Allocate headers and initialise to zero
   RHeader = new RunHeader;
@@ -120 +98 @@
   EHeader = new EventHeader;
   memset(EHeader, 0, sizeof(EventHeader));
-  
+
   // Scan for DRS boards
-  DRSFreq = new float [GetNumberOfBoards()];
-  ACalib = new bool [GetNumberOfBoards()];
-  ACalibTemp = new double [GetNumberOfBoards()];
-  TCalib = new bool [GetNumberOfBoards()];
-
-  if (GetNumberOfBoards() == 0) PrintMessage("No DRS boards found - check VME crate and configuration file!\n");
-
-  for (int i=0; i<GetNumberOfBoards(); i++) {
-    NumBoards++;
+  NumBoards = GetNumberOfBoards();
+  DRSFreq = new float [NumBoards];
+  ACalib = new bool [NumBoards];
+  ACalibTemp = new double [NumBoards];
+  TCalib = new bool [NumBoards];
+
+  if (NumBoards == 0) PrintMessage("No DRS boards found - check VME crate and configuration file!\n");
+
+  for (int i=0; i<NumBoards; i++) {
     LastBoard++;
     GetBoard(i)->Init();
@@ -138 +116 @@
     TCalib[i] = false;      
   }
-  BStruct  = new BoardStructure [NumBoards == 0 ? 1:GetNumberOfBoards()];
-  memset(BStruct, 0, sizeof(BoardStructure)*(NumBoards == 0 ? 1:GetNumberOfBoards()));
+  BStruct  = new BoardStructure [NumBoards == 0 ? 1:NumBoards];
+  memset(BStruct, 0, sizeof(BoardStructure)*(NumBoards == 0 ? 1:NumBoards));
 
   WaveForm = new short [NumBoards == 0 ? 1:NumBoards][kNumberOfChipsMax][kNumberOfChannelsMax][kNumberOfBins];
@@ -145 +123 @@
   
   // Create instance of HV feedback (must be called after CMC board detection)
-  HVFB    = new HVFeedback(this, fHVFeedbackConfig);
-  
-  // Create instance of slow data class for DAQ
-  SlowDataClass = new SlowData("DAQ", fSlowDataPath);
-  if(SlowDataClass->ErrorCode != 0) {
-   PrintMessage("Warning: Could not open DAQ slowdata file (%s)\n", strerror(SlowDataClass->ErrorCode));
-  }
-  SlowDataClass->NewEntry("Runinfo-Info", "Run information written after completion or termination of run (Status can be OK or Error): Runnumber Status Runtype Events Files Description ");
+  HVFB    = new HVFeedback(this);  
 }
 
@@ -160 +131 @@
 
 DAQReadout::~DAQReadout() {
-  delete SlowDataClass;
+
   delete RHeader;     delete EHeader;
   delete HVFB;        delete[] ACalibTemp;
@@ -166 +137 @@
   delete[] DRSFreq;   delete[] BStruct;
   delete[] WaveForm;  delete[] TriggerCell;
-  
-  if(Logfile) {
-    if(!fclose(Logfile)) printf("Closing logfile\n");
-    else perror("Error closing logfile");
-  }
 }
 
@@ -514 +480 @@
     }
 
-    PrintMessage("Creating amplitude calibration of board %d (serial #%04d)\n", i, GetBoard(i)->GetBoardSerialNumber());
-    
+    PrintMessage("Creating amplitude calibration of board %d (serial #%04d)\n  Note: No input signals should be connected\n", i, GetBoard(i)->GetBoardSerialNumber());
+                
     GetBoard(i)->EnableTcal(0);
     GetBoard(i)->SelectClockSource(0);
@@ -545 +511 @@
     ACalib[i] = true;
     ACalibTemp[i] = GetBoard(i)->GetTemperature();
+        
   } // Loop over boards
   PrintMessage("Amplitude calibration finished\n");
+  
+  // Write short calibration information
+  time_t Time = time(NULL);
+  FILE *InfoFile = fopen(CalibInfoFilename, "w");
+  if (InfoFile != NULL) {
+        fprintf(InfoFile, "# Calibration information as of %s\n", ctime(&Time));
+        for (int i=0; i<GetNumberOfBoards(); i++) {
+          fprintf(InfoFile, "%d %d %.1f %d %.2f\n", GetBoard(i)->GetBoardSerialNumber(), ACalib[i], ACalibTemp[i], TCalib[i], DRSFreq[i]);
+        }
+        fclose(InfoFile);
+  }
+  else PrintMessage("Could not write calibration information to file '%s'\n", CalibInfoFilename);
+
 }
 
@@ -554 +534 @@
   if (!IsDRSFreqSet()) {
     PrintMessage("Set sampling frequency for all boards first\n");
+    return;
+  }
+  if (!ReadCalibration()) {
+    PrintMessage("Amplitude calibration has to be done first\n");
     return;
   }
@@ -562 +546 @@
       continue;
     }
-    if (!ACalib[i]) {
-      PrintMessage("Amplitude calibration of board %d has to be done first, skipping this board\n", i);
-      continue;
-    }
-    PrintMessage("Creating time calibration of board %d (serial #%04d)\n", i, GetBoard(i)->GetBoardSerialNumber());
+    PrintMessage("Creating time calibration of board %d (serial #%04d)\n  Note: No input signals should be connected\n", i, GetBoard(i)->GetBoardSerialNumber());
     
     GetBoard(i)->SetFrequency(DRSFreq[i], true);
@@ -586 +566 @@
       GetBoard(i)->GetTime(Chip, Time[Chip], true, false);
         }
-    
-    if (asprintf(&Filename, "TCalib_%d_%.2fGHz.txt", GetBoard(i)->GetBoardSerialNumber(), DRSFreq[i]) == -1) {
+
+        // Write calibration data to file
+    if (asprintf(&Filename, "%s/TCalib_%d_%.2fGHz.txt", fCalibDataPath, GetBoard(i)->GetBoardSerialNumber(), DRSFreq[i]) == -1) {
       PrintMessage("Error: asprintf() failed, cannot generate filename (%s)\n", strerror(errno));
       return; 
@@ -827 +808 @@
     GetBoard(i)->TransferWaves(GetBoard(i)->GetNumberOfChannels()*GetBoard(i)->GetNumberOfChips()); 
 
-    for (int j=0; j<GetBoard(i)->GetNumberOfChannels(); j++) {
-      for (int k=0; k<GetBoard(i)->GetNumberOfChips(); k++) {
-        GetBoard(i)->GetWave(k, j, WaveForm[i][k][j], true, GetBoard(i)->GetTriggerCell(k));
-        TriggerCell[i][k] = GetBoard(i)->GetTriggerCell(k);
+    for (int k=0; k<GetBoard(i)->GetNumberOfChips(); k++) {
+          TriggerCell[i][k] = GetBoard(i)->GetTriggerCell(k);
+
+          for (int j=0; j<GetBoard(i)->GetNumberOfChannels(); j++) {
+        GetBoard(i)->GetWave(k, j, WaveForm[i][k][j], true, TriggerCell[i][k]);
       }
     }
@@ -836 +818 @@
 }
 
-// Read calibration file
+// Read calibration data
 bool DAQReadout::ReadCalibration() {
 
+  static char Buffer[MAX_COM_SIZE];
+  int Serial, Calib;
+  float Temp, Freq;
+
   for (int i=FirstBoard; i<=LastBoard; i++) {
-    if (!TCalib[i]) PrintMessage("Warning: No time calibration for board %d\n", i);
-    
     if (GetBoard(i)->GetDRSType() == 4) {
-      if (ACalib[i] == false) return false;
+      if (ACalib[i] == false) {
+            // Check calibration info file if EEPROM data on DRS board still valild
+                FILE *CalibInfo = fopen(CalibInfoFilename, "r");
+                if (CalibInfo == NULL) return false;
+                fgets(Buffer, sizeof(Buffer), CalibInfo); // skip first two lines
+                fgets(Buffer, sizeof(Buffer), CalibInfo);
+
+                while (fgets(Buffer, sizeof(Buffer), CalibInfo) != NULL) {
+                  if (sscanf(Buffer, "%d %d %f %*d %f", &Serial, &Calib, &Temp, &Freq) != 4) {
+                        fclose(CalibInfo);
+                        return false;
+                  }
+
+                  if (Serial==GetBoard(i)->GetBoardSerialNumber() && int(Freq*100)==int(DRSFreq[i]*100) && Calib==1) {
+                        ACalib[i] = true;
+                        ACalibTemp[i] = Temp;
+                        break;
+                  }
+                }
+                fclose(CalibInfo);
+          }
     }
     else {
@@ -855 +859 @@
       }
     }
+        if (fabs(ACalibTemp[i]-GetBoard(i)->GetTemperature())>2) PrintMessage("Warning: Large difference to calibration temperature for board %d\n", i);
   } // Loop over boards
   return true;
@@ -1127 +1132 @@
 // Print configuration to target
 void DAQReadout::PrintConfig(int Target) {
-  PrintMessage(Target, "LogFile: %s\tMaxLogLines: %u\tRawDataPath: %s\n"
+  PrintMessage(Target, "RawDataPath: %s\n"
                "DefaultFrequency: %.2f\tFirstSample: %d\tSamples: %u\n"
                "MinDiskSpaceMB: %u\tMaxFileSizeMB: %d\tCCPort: %d\n"
-               "CalibDataPath: %s\n"
-               "SlowDataPath: %s\tHVFeedbackConfig: %s\n",
-    fLogFile,fMaxLogLines,fRawDataPath,fDefaultFrequency,fFirstSample,fSamples,fMinDiskSpaceMB,
-    fMaxFileSizeMB,fCCPort,fCalibDataPath,fSlowDataPath,fHVFeedbackConfig);
+                           "CalibDataPath: %s\n",
+    fRawDataPath,fDefaultFrequency,fFirstSample,fSamples,fMinDiskSpaceMB,
+    fMaxFileSizeMB,fCCPort,fCalibDataPath);
 }
 
@@ -1160 +1164 @@
   va_list ArgumentPointer;
   va_start(ArgumentPointer, Format);
-  if(CmdFromSocket) DoPrintMessage(Format, ArgumentPointer, MsgToSocket|MsgToLog);
-  else DoPrintMessage(Format, ArgumentPointer, MsgToConsole|MsgToLog);
+  if(CmdFromSocket) DoPrintMessage(Format, ArgumentPointer, MsgToSocket);
+  else DoPrintMessage(Format, ArgumentPointer, MsgToConsole);
   va_end(ArgumentPointer);
 }
@@ -1179 +1183 @@
     if(strlen(Textbuffer)>0 && Textbuffer[strlen(Textbuffer)-1]=='\n') {
       printf("\r%s%s", Textbuffer, Prompt);   // New prompt
-      fflush(stdout);
     }
     else printf("%s", Textbuffer);
-  }
-  // Print to log file
-  if((Target & MsgToLog) && Logfile!=NULL) {
-    time_t Time;
-    strftime(Textbuffer+strlen(Textbuffer)+1,MAX_COM_SIZE-strlen(Textbuffer)-1, "%d/%m/%y %X", localtime(&(Time=time(NULL))));
-    fprintf(Logfile, "%s: %s", Textbuffer+strlen(Textbuffer)+1, Textbuffer);
-    fflush(Logfile);
+        fflush(stdout);
+  }
+  // Send to log
+  if(Target & MsgToLog) {
+    char *Buf;
+    if (asprintf(&Buf, "%s %s", SERVER_NAME, Textbuffer) != -1) { 
+      DimClient::sendCommandNB("DColl/Log", Buf);
+      free(Buf);
+    }
+    else DimClient::sendCommandNB("DColl/Log", SERVER_NAME" asprintf() failed"); 
   }
   // Print to socket
@@ -1233 +1239 @@
 }
 
-// ReadCard function (original version by F. Goebel)
-// Data is read into an array if MaxNum is larger than 1
-bool ReadCard(const char *card_flag, void *store, char Type, FILE *File, unsigned int MaxNum) {
-  
-  char *card_name, *card_val, Buffer[MAX_COM_SIZE];
-  unsigned int Count=0;
-  
-  rewind(File);
-
-  while (fgets(Buffer, sizeof(Buffer), File) != NULL) {    // Read line by line
-    card_name = strtok(Buffer," \t\n");
-    
-     // Ignore empty lines, comments, and skip if card name does not match
-    if (card_name==NULL || card_name[0]=='#' || strcmp(card_name, card_flag)!=0) continue;
-
-    // Read numbers of given type (if MaxNum>1 read array)
-    while ((card_val=strtok(NULL," \t\n")) != NULL && Count++<MaxNum) {
-      switch (Type) {
-        case 'I': *(((int *&) store)++) = (int) strtol(card_val, NULL, 10);
-                  break;
-        case 'i': *(((short *&) store)++) = (short) strtol(card_val, NULL, 10);
-                  break;
-        case 'U': *(((unsigned int *&) store)++) = (unsigned int) strtoul(card_val, NULL, 10);
-                  break;
-        case 'u': *(((unsigned short *&) store)++) = (unsigned short) strtoul(card_val, NULL, 10);
-                  break;
-        case 'f': *(((float *&) store)++) = atof(card_val);
-                  break;
-        case 'd': *(((double *&) store)++) = atof(card_val);
-                  break;
-        case 's': sprintf((char *) store, "%s", card_val);
-                  break;
-        case 'c': *((char *) store) = card_val[0];
-                  break;
-        default:  fprintf(stderr,"Warning: Unknown type '%c' for reading of configuration file\n", Type);
-                  return false;
-      }
-    }
-    return true;  // Finished reading data for card name
-    
-  }
-  fprintf(stderr,"Warning: Configuration value %s not found\n", card_flag);
-  return false;
-}
-
 
 /********************************************************************\
@@ -1368 +1329 @@
 
   // Write run summary to slow data file
-  m->SlowDataClass->NewEntry("Runinfo");
-  m->SlowDataClass->AddToEntry("%d %s %s %d %d %s", m->RunNumber, WriteError?"Error":"OK", daq_runtype_str[m->daq_runtype], m->NumEvents, m->FileNumber, m->RHeader->Description);
-  if(m->SlowDataClass->ErrorCode != 0) {
-    m->PrintMessage("Error: Could not write DAQ slow data to file (%s), file closed\n", strerror(m->SlowDataClass->ErrorCode));
-  }
+  //m->SlowDataClass->NewEntry("Runinfo");
+  //m->SlowDataClass->AddToEntry("%d %s %s %d %d %s", m->RunNumber, WriteError?"Error":"OK", daq_runtype_str[m->daq_runtype], m->NumEvents, m->FileNumber, m->RHeader->Description);
 
   // Print run statistics

drsdaq/DAQReadout.h

@@ -14 +14 @@
 #include <sys/vfs.h>
 #include <signal.h>
+#include <sys/time.h>
 
 #include "RawDataCTX.h"
@@ -32 +33 @@
 enum runtype_enum {data, pedestal, reserved, test};
 
-class DAQReadout : public DRS, public DRSCallback {
+class DAQReadout : public DRS, public DRSCallback, public EvidenceServer {
     time_t StartTime;
 
@@ -39 +40 @@
 
     unsigned int CmdNumber;
-    FILE *Logfile;    
     void PrintUsage();
         
@@ -52 +52 @@
     int Rawfile;
     class HVFeedback* HVFB;
-    class SlowData *SlowDataClass; 
 
     // Configuration data
-    char fLogFile[MAX_PATH];
-    char fSlowDataPath[MAX_PATH];
-    char fCalibDataPath[MAX_PATH];
-    unsigned int fMaxLogLines;
-    char fRawDataPath[MAX_PATH];
+    char *fCalibDataPath;
+    char *fRawDataPath;
     int fMinDiskSpaceMB;   // Minimum required disk space in MBytes
     int fMaxFileSizeMB;    // Maximum File size in Bytes 
@@ -65 +61 @@
     unsigned int fSamples;
     int fCCPort;
-    char fHVFeedbackConfig[MAX_PATH];
     double fDefaultFrequency;
     
@@ -92 +87 @@
     char FileName[MAX_PATH];
     char Prompt[MAX_COM_SIZE];
-    bool ConfigOK;
+    char CalibInfoFilename[MAX_PATH];
        
     // Public functions
-    DAQReadout(const char*);
+    DAQReadout();
     ~DAQReadout();
 
@@ -149 +144 @@
 int ParseInput(char*, const char *Param[]);
 int CheckDisk(char*);
-bool ReadCard(const char *, void *, char, FILE *, unsigned int=1);
 
 #endif

drsdaq/DRS/DRS.cc

@@ -183 +183 @@
 #endif
       /* check all VME slave slots */
-      for (index = 2; index <= 10; index++) {      
+      for (index = 2; index <= 9; index++) {      
 #ifdef CT_VME 
         MasterMap.vmebus_address        = GEVPC_BASE_ADDR + index * GEVPC_WINSIZE; // VME board base address
-        MasterMapVME(&MasterMapping[index]);
+        if (MasterMapVME(&MasterMapping[index]) != VME_SUCCESS) continue;
 #endif
       
@@ -4857 +4857 @@
 
    // use following lines to save calibration into an ASCII file
-#if 1
+#if 0
    FILE *fh;
 
@@ -6907 +6907 @@
   if ((ErrorCode = VME_Open()) != VME_SUCCESS) {
     VME_ErrorString(ErrorCode,ErrorString); 
-    printf("Error: %s\n",ErrorString);
+    printf("VME_Open()  %s\n",ErrorString);
   }  
   return ErrorCode;
@@ -6917 +6917 @@
   if (ErrorCode = VME_MasterMap(&MasterMap, MMap)) {
     VME_ErrorString(ErrorCode,ErrorString); 
-    printf("Error: %s\n",ErrorString);
+    printf("VME_MasterMap()  %s\n",ErrorString);
   }
   return(ErrorCode);
@@ -6927 +6927 @@
   if (ErrorCode = VME_MasterUnmap(MMap)) {
     VME_ErrorString(ErrorCode,ErrorString); 
-    printf("Error: %s\n",ErrorString);
+    printf("VME_MasterUnmap()  %s\n",ErrorString);
   }  
   return(ErrorCode);  
@@ -6937 +6937 @@
   if ((ErrorCode = VME_Close()) != VME_SUCCESS) {    
     VME_ErrorString(ErrorCode,ErrorString);
-    printf("Error: %s\n",ErrorString);
+    printf("VME_Close()  %s\n",ErrorString);
   }
   return ErrorCode;
@@ -6947 +6947 @@
   if ((ErrorCode = CMEM_Open()) != CMEM_RCC_SUCCESS) {
     VME_ErrorString(ErrorCode,ErrorString); 
-    printf("Error: %s\n",ErrorString);
+    printf("CMEM_Open()  %s\n",ErrorString);
   }
   return ErrorCode;
@@ -6957 +6957 @@
   if ((ErrorCode = CMEM_Close()) != CMEM_RCC_SUCCESS) {  
     VME_ErrorString(ErrorCode,ErrorString);
-    printf("Error: %s\n",ErrorString);
+    printf("CMEM_Close  %s\n",ErrorString);
   }
   return ErrorCode;
@@ -6966 +6966 @@
   if ((ErrorCode = CMEM_SegmentAllocate(SegSize, "DMA_BUFFER", CMEM_SegIdentifier)) != CMEM_RCC_SUCCESS) {
     VME_ErrorString(ErrorCode,ErrorString); 
-    printf("Error: %s\n",ErrorString);
+    printf("CMEM_SegmentAllocate()  %s\n",ErrorString);
   }
   return ErrorCode;
@@ -6976 +6976 @@
   if ((ErrorCode = CMEM_SegmentPhysicalAddress(CMEM_SegIdentifier, PCIAddress)) != CMEM_RCC_SUCCESS) {
     VME_ErrorString(ErrorCode,ErrorString);
-    printf("Error: %s\n",ErrorString);
+    printf("CMEM_SegmentPhysicalAddress()  %s\n",ErrorString);
   }
   return ErrorCode;
@@ -6986 +6986 @@
   if ((ErrorCode = CMEM_SegmentVirtualAddress(CMEM_SegIdentifier, VirtualAddress)) != CMEM_RCC_SUCCESS) {
     VME_ErrorString(ErrorCode,ErrorString);
-    printf("Error: %s\n",ErrorString);
+    printf("CMEM_SegmentVirtualAddress()  %s\n",ErrorString);
   }
   return ErrorCode;
@@ -6996 +6996 @@
   if ((ErrorCode = CMEM_SegmentFree(CMEM_SegIdentifier)) != CMEM_RCC_SUCCESS) {
     VME_ErrorString(ErrorCode,ErrorString); 
-    printf("Error: %s\n",ErrorString);
+    printf("CMEM_SegmentFree()  %s\n",ErrorString);
   }  
   return ErrorCode;

drsdaq/HVFeedback.cc

@@ -25 +25 @@
 // Constructor: Initialise feedback 
 //
-HVFeedback::HVFeedback(DAQReadout* DAQClass, char* Configfile):
-                        EvidenceServer(SERVER_NAME){
+HVFeedback::HVFeedback(DAQReadout* DAQClass){//:
+                        //EvidenceServer(SERVER_NAME){
 
   m = DAQClass;
 
-  fNumberOfChannels = m->fNumberOfChannels;
-  fNumberOfChips = m->fNumberOfChips;  
+  fNumberOfChannels = m->GetBoard(0)->GetNumberOfChannels();
+  fNumberOfChips = m->GetBoard(0)->GetNumberOfChips();  
 
   PixMap = new PixelMap(PIXMAP_LOCATION, false);
@@ -45 +45 @@
   DIMSigma   = new float [m->NumBoards][kNumberOfChipsMax][kNumberOfChannelsMax]();
 
-  // Read configuration file
-  FILE *File;
-  if ((File = fopen(Configfile,"r")) == NULL) {
-    printf("Error: Could not open feedback configuration file '%s'\n", Configfile);
-  }
-  else {
-    printf("Reading feedback configuration file %s\n", Configfile);
-    ReadCard("TrigBoard",           &fLedTrigBoard,      'I', File);
-    ReadCard("TrigChannel",         &fLedTrigChannel,    'I', File);
-    ReadCard("TrigChip",            &fLedTrigChip,       'I', File);
-    ReadCard("TrigSample",          &fLedTrigSample,     'I', File);
-    ReadCard("TrigThreshold",       &fLedTrigThreshold,  'f', File);
-    ReadCard("SignalSample",        &fLedSignalSample,   'I', File);
-    ReadCard("BaselineSample",      &fLedBaselineSample, 'I', File);
-    ReadCard("IntHalfWidth",        &fIntHalfWidth,      'U', File);
-    ReadCard("DefaultNumAverage",   &fDefaultNumAverage, 'I', File);
-    ReadCard("DefaultResponse",      Response,           'f', File, m->NumBoards*fNumberOfChips*fNumberOfChannels);
-    ReadCard("DefaultTarget",        Target,             'f', File, m->NumBoards*fNumberOfChips*fNumberOfChannels);
-    // Add also initial gain to configuration parameters
-    fclose(File);
-  }
+  // Get configuration data
+  fLedTrigBoard = atoi(m->GetConfig("TrigBoard"));
+  fLedTrigChannel = atoi(m->GetConfig("TrigChannel"));
+  fLedTrigChip = atoi(m->GetConfig("TrigChip"));
+  fLedTrigSample = atoi(m->GetConfig("TrigSample"));
+  fLedTrigThreshold = atoi(m->GetConfig("TrigThreshold"));
+  fLedSignalSample = atoi(m->GetConfig("SignalSample"));
+  fLedBaselineSample = atoi(m->GetConfig("BaselineSample"));
+  fIntHalfWidth = atoi(m->GetConfig("IntHalfWidth"));
+  fDefaultNumAverage = atoi(m->GetConfig("DefaultNumAverage"));
+
+  char *Token = strtok(m->GetConfig("DefaultResponse"), " \t");
+  for (int i=0; i<m->NumBoards*fNumberOfChips*fNumberOfChannels; i++) {
+        if (Token == NULL) break;
+    *(&Response[0][0][0]+i) = (float) atof(Token);
+        Token = strtok(NULL, " \t");
+  }
+  Token = strtok(m->GetConfig("DefaultTarget"), " \t");
+  for (int i=0; i<m->NumBoards*fNumberOfChips*fNumberOfChannels; i++) {
+        if (Token == NULL) break;
+    *(&Target[0][0][0]+i) = (float) atof(Token);
+        Token = strtok(NULL, " \t");
+  }
+
   PrintConfig(MsgToLog);
 
@@ -76 +79 @@
 
   // Initial state
-  Gain = 0.2;
+  Gain = atoi(m->GetConfig("DefaultGain"));
   SetFBMode(FB_Off);
   SetNumAverages(fDefaultNumAverage);
@@ -94 +97 @@
 
   delete[] Average;     delete[] Response;
+  delete[] DIMAverage;          delete[] DIMSigma;
+  delete[] Sigma;
   delete[] Target;      delete[] Buffer;
   delete PixMap;
@@ -256 +261 @@
   else {
     FBMode = Mode;
-        if (Mode != FB_ResponseFirst) State(INFO, "%s", FBState_Description[FBMode]);
-        else State(INFO, "%s (voltage difference %.3f)", FBState_Description[FBMode], DiffVoltage);
+        if (Mode != FB_ResponseFirst) m->State(m->INFO, "%s", FBState_Description[FBMode]);
+        else m->State(m->INFO, "%s (voltage difference %.3f)", FBState_Description[FBMode], DiffVoltage);
     ClearAverages();
   }

drsdaq/HVFeedback.h

@@ -13 +13 @@
 #include "DAQReadout.h"
 
-#define kNumberOfChipsMax 2
-#define kNumberOfChannelsMax 10
-
 enum FBState {FB_Off, FB_Active, FB_Targets, FB_ResponseFirst, FB_ResponseSecond};
 
-class HVFeedback: public EvidenceServer {
+class HVFeedback: public DimServer {//EvidenceServer {
 
     class DAQReadout *m;
@@ -60 +57 @@
     
   public:
-    HVFeedback(class DAQReadout*, char*);
+    HVFeedback(class DAQReadout*);
     ~HVFeedback();
 

drsdaq/History.txt

@@ -59 +59 @@
 9/3/2010        Feedback now depended on DIM for communication with bias server.
                         Started migration to DRS4 (last tested revision as daqct3 for DRS2 is 161). DRS class will not run anymore with DRS2 FPGA firmware.
-                        
+11/3/2010       Removed SlowData class.                 
+12/3/2010       Removed local configuration and logging.

drsdaq/Makefile

@@ -10 +10 @@
 CC      = g++           # Compiler to use
 
-SOURCES = HVFeedback.cc DAQReadout.cc RawDataCTX.cc SlowData.cc ../pixelmap/Pixel.cc ../pixelmap/PixelMap.cc DRS/DRS.cc DRS/mxml.c DRS/strlcpy.c drsdaq.cpp ../Evidence/Evidence.cc 
+SOURCES = HVFeedback.cc DAQReadout.cc RawDataCTX.cc ../pixelmap/Pixel.cc ../pixelmap/PixelMap.cc DRS/DRS.cc DRS/mxml.c DRS/strlcpy.c drsdaq.cpp ../Evidence/Evidence.cc 
 OBJECTS = $(addsuffix .o, $(basename $(SOURCES)))
 INCDIRS   = -I. -IDRS -I../pixelmap -I../Evidence -I$(DIMDIR)/dim

drsdaq/drsdaq.cpp

@@ -30 +30 @@
 void SignalHandler(int);
 void CrashHandler(int);
+void ExitFunction();
 
 // ================
@@ -84 +85 @@
   signal(SIGINT, &CrashHandler);
   signal(SIGHUP, &CrashHandler);
-    
+  atexit(&ExitFunction);
+
   // Construct main instance and create mutex for thread synchronization
-  DAQReadout dreadout(argc==3 ? argv[2] : DEFAULT_CONFIG);
+  DAQReadout dreadout;
   if (pthread_mutex_init(&dreadout.control_mutex, NULL) != 0) {
     perror("pthread_mutex_init failed");
@@ -92 +94 @@
   }
 
-  if (dreadout.ConfigOK) { // Normal program execution only if configuration was complete
-    // Create threads
-    if (pthread_mutex_init(&dreadout.control_mutex, NULL) != 0) {
-      perror("pthread_mutex_init failed");
-      throw;
-    }
-    if ((pthread_create(&thread_ConsoleCommand, NULL, (void * (*)(void *)) ConsoleCommand,(void *) &dreadout)) != 0) {
-      perror("pthread_create failed with console thread");
-      throw;
-    }
-    if ((pthread_create(&thread_CCCommand, NULL, (void * (*)(void *)) CCCommand,(void *) &dreadout)) != 0) {
-      perror("pthread_create failed with socket thread");
-      dreadout.SocketThread = NULL;
-    }
-    else dreadout.SocketThread = &thread_CCCommand;  // Thread should be accessible for sending signals  
-
-    // Wait for threads to quit
-    pthread_join(thread_ConsoleCommand, NULL);
-    if(dreadout.SocketThread != NULL) pthread_join(thread_CCCommand, NULL);
-  }
-  else printf("Error: Configuration parameter missing in %s, terminating.\n", argc==3 ? argv[2] : DEFAULT_CONFIG);
+  // Create threads
+  if (pthread_mutex_init(&dreadout.control_mutex, NULL) != 0) {
+    perror("pthread_mutex_init failed");
+    throw;
+  }
+  if ((pthread_create(&thread_ConsoleCommand, NULL, (void * (*)(void *)) ConsoleCommand,(void *) &dreadout)) != 0) {
+    perror("pthread_create failed with console thread");
+    throw;
+  }
+  if ((pthread_create(&thread_CCCommand, NULL, (void * (*)(void *)) CCCommand,(void *) &dreadout)) != 0) {
+    perror("pthread_create failed with socket thread");
+    dreadout.SocketThread = NULL;
+  }
+  else dreadout.SocketThread = &thread_CCCommand;  // Thread should be accessible for sending signals  
+
+  // Wait for threads to quit
+  pthread_join(thread_ConsoleCommand, NULL);
+  if(dreadout.SocketThread != NULL) pthread_join(thread_CCCommand, NULL);
   
   // Destruct mutex and main instance
@@ -282 +281 @@
   return;
 }
+
+// This function will be implicitly called by exit()
+void ExitFunction() {
+  remove(LOCKFILE);
+  return;          
+}