Switch to the new raw reader (Julian, Raphaelle)
[u/mrichter/AliRoot.git] / TRD / TRDHALFCHAMBERSTATUSda.cxx
index 25e90faaa450456665029c85ee5908aa7109b3ae..7526de012fd0fb9e485ae898eeffeacaa500aae1 100644 (file)
@@ -31,13 +31,15 @@ extern "C" {
 #include <TStopwatch.h>
 #include "TROOT.h"
 #include "TPluginManager.h"
+#include "TSystem.h"
 //
 // AliRoot includes
 //
 #include "AliRawReader.h"
 #include "AliRawReaderDate.h"
-#include "AliTRDrawFastStream.h"
-#include "AliTRDrawStreamBase.h"
+//#include "AliTRDrawFastStream.h"
+//#include "AliTRDrawStreamBase.h"
+#include "AliLog.h"
 //#include "AliCDBManager.h"
 
 //
@@ -51,7 +53,7 @@ extern "C" {
 #include "AliTRDCalibChamberStatus.h"
 
 //functios, implementation below
-//void SendToAmoreDB(TObject *o, unsigned long32 runNb);
+void SendToAmoreDB(TObject *o, unsigned long32 runNb);
 
 /* Main routine
       Arguments: list of DATE raw data files
@@ -71,22 +73,31 @@ int main(int argc, char **argv) {
   /* log start of process */
   printf("TRD DA HALFCHAMBERSTATUS started\n");  
 
-
-  /* check that we got some arguments = list of files */
-  if (argc<2) {
+  if (argc!=2) {
     printf("Wrong number of arguments\n");
     return -1;
   }
 
 
-  /* copy locally a file from daq detector config db */
-  //status=daqDA_DB_getFile("myconfig","./myconfig.txt");
-  //if (status) {
-  //  printf("Failed to get config file : %d\n",status);
-  //  return -1;
-  //}
-  /* and possibly use it */
-  
+  /* define data source : this is argument 1 */  
+  status=monitorSetDataSource( argv[1] );
+  if (status!=0) {
+    printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
+    return -1;
+  }
+
+
+  /* declare monitoring program */
+  status=monitorDeclareMp( __FILE__ );
+  if (status!=0) {
+    printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
+    return -1;
+  }
+
+
+  /* define wait event timeout - 1s max */
+  monitorSetNowait();
+  monitorSetNoWaitNetworkTimeout(1000);
 
   /* init some counters */
   int nevents_total=0;
@@ -99,78 +110,80 @@ int main(int argc, char **argv) {
   // AliTRDCalibPadStatus object
   AliTRDCalibChamberStatus calipad = AliTRDCalibChamberStatus();
   calipad.Init();
-  //unsigned long32 runNb=0;      //run number
+    
+  unsigned long32 runNb=0;      //run number
 
   // setting
-  AliTRDrawFastStream::DisableSkipData();
-
-  /* read the data files */
-  int n;
-  for (n=1;n<argc;n++) {
-   
-    /* define data source : this is argument i */
-    printf("Processing file %s\n",argv[n]);
-    status=monitorSetDataSource( argv[n] );
+  //AliTRDrawFastStream::DisableSkipData();
+  AliLog::SetGlobalLogLevel(AliLog::kFatal); 
+
+  /* read the file  until EOF */
+  for(;;) {
+    struct eventHeaderStruct *event;
+    eventTypeType eventT;
+    
+    /* check shutdown condition */
+    if (daqDA_checkShutdown()) {break;}
+    
+    /* get next event */
+    status=monitorGetEventDynamic((void **)&event);
+    if (status==MON_ERR_EOF) {
+      printf("End of File detected\n");
+      break; /* end of monitoring file has been reached */
+    }
     if (status!=0) {
-      printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
-      return -1;
+      printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
+      break;
     }
-
-    /* read the file  until EOF */
-    for(;;) {
-      struct eventHeaderStruct *event;
-      eventTypeType eventT;
+    
+    /* retry if got no event */
+    if (event==NULL) {
+      continue;
+    }
+    
+    /* use event - here, just write event id to result file */
+    eventT=event->eventType;
+    
+    if(eventT==PHYSICS_EVENT){
       
-      /* get next event */
-      status=monitorGetEventDynamic((void **)&event);
-      if (status==MON_ERR_EOF) {
-       printf("End of File %d detected\n",n);
-       break; /* end of monitoring file has been reached */
-      }
-      if (status!=0) {
-        printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
-        break;
-      }
-
-      /* retry if got no event */
-      if (event==NULL) {
-        break;
-      }
-
-      /* use event - here, just write event id to result file */
-      eventT=event->eventType;
-
-      if(eventT==PHYSICS_EVENT){
-
-       AliRawReader *rawReader = new AliRawReaderDate((void*)event);
-       rawReader->Select("TRD");
-       
-       calipad.ProcessEvent((AliRawReader *) rawReader,nevents);
-       nevents++;
-       delete rawReader;
+      AliRawReader *rawReader = new AliRawReaderDate((void*)event);
+      rawReader->Select("TRD");
       
-      }
-
-      nevents_total++;
-
-      // get the run number
-      //runNb = event->eventRunNb;
-
-      /* free resources */
-      free(event);
+      calipad.ProcessEvent3((AliRawReader *) rawReader,nevents);
+      nevents++;
+      delete rawReader;
+      
+    }
+    
+    nevents_total++;
+    
+    // get the run number
+    runNb = event->eventRunNb;
+    
+    /* free resources */
+    free(event);
+    
+    /* exit when last event received, no need to wait for TERM signal */
+    if (eventT==END_OF_RUN) {
+      printf("EOR event detected\n");
+      break;
     }
   }
-
-
+  
+  Int_t neventused = calipad.GetNumberEventNotEmpty();
+  
   /* report progress */
-  printf("%d events processed and %d used\n",nevents_total,nevents);
-
+  printf("%d events processed and %d used\n",nevents_total,neventused);
+  
   /* write file in any case to see what happens in case of problems*/
   TFile *fileTRD = new TFile(RESULT_FILE,"recreate");
   calipad.AnalyseHisto();
   calipad.Write("calibchamberstatus");
   fileTRD->Close();   
+  
+
+  /* Send to amore */
+  SendToAmoreDB(&calipad,runNb);
      
   /* store the result file on FES */
   status=daqDA_FES_storeFile(RESULT_FILE,FILE_ID);
@@ -178,8 +191,34 @@ int main(int argc, char **argv) {
     printf("Failed to export file : %d\n",status);
     return -1;
   }
-
   
   return status;
 
 }
+void SendToAmoreDB(TObject *o, unsigned long32 runNb)
+{
+  //AMORE
+  const char *amoreDANameorig=gSystem->Getenv("AMORE_DA_NAME");
+  //cheet a little -- temporary solution (hopefully)
+  //
+  //currently amoreDA uses the environment variable AMORE_DA_NAME to create the mysql
+  //table in which the calib objects are stored. This table is dropped each time AmoreDA
+  //is initialised. This of course makes a problem if we would like to store different
+  //calibration entries in the AMORE DB. Therefore in each DA which writes to the AMORE DB
+  //the AMORE_DA_NAME env variable is overwritten.
+  
+  gSystem->Setenv("AMORE_DA_NAME","TRD-dataHALFCHAMBERSTATUS");
+  //
+  // end cheet
+  TDatime time;
+  TObjString info(Form("Run: %u; Date: %s",runNb,time.AsSQLString()));
+  
+  amore::da::AmoreDA amoreDA(amore::da::AmoreDA::kSender);
+  Int_t statusDA=0;
+  statusDA+=amoreDA.Send("DataHalfChamberStatus",o);
+  statusDA+=amoreDA.Send("Info",&info);
+  if ( statusDA!=0 )
+    printf("TRDQAda: Waring: Failed to write one of the calib objects to the AMORE database\n");
+  // reset env var
+  if (amoreDANameorig) gSystem->Setenv("AMORE_DA_NAME",amoreDANameorig);
+}
\ No newline at end of file