MUON + CheckCompiler

[u/mrichter/AliRoot.git] / FMD / FMDBaseda.cxx

diff --git a/FMD/FMDBaseda.cxx b/FMD/FMDBaseda.cxx
index c8e069b9ce2270cfe544253af85b398250bc69de..c472c85497d342372d31e1a35e8060c3f0b8cd70 100644 (file)
--- a/FMD/FMDBaseda.cxx
+++ b/FMD/FMDBaseda.cxx
@@ -11,17 +11,33 @@
   Output Files:            conditions.csv
   Trigger types used:      PHYSICS_EVENT
 */
+#include <cstdlib>
+#include <Riostream.h>
+#include "monitor.h"
+#include "event.h"
+#include <AliLog.h>
 #include <TSystem.h>
-#include <AliCDBManager.h>
+#include <TString.h>
 #include <AliFMDParameters.h>
 #include <AliRawReader.h>
 #include <TStopwatch.h>
 #include <AliFMDBaseDA.h>
 #include <AliRawReaderDate.h>
+#include <AliRawReaderRoot.h>
+#include "daqDA.h"
 #include "TROOT.h"
 #include "TPluginManager.h"
 
-
+void
+usage(std::ostream& o, const char* progname)
+{
+  o << "Usage: " << progname << " FILE [OPTIONS]\n\n"
+    << "Options:\n"
+    << "\t-h,--help         Show this help\n"
+    << "\t-d,--diagnostics  Create diagnostics\n"
+    << "\t-D,--debug LEVEL  Set the debug level\n"
+    << std::endl;
+}
 
 int main(int argc, char **argv) 
 {
@@ -36,29 +52,118 @@ int main(int argc, char **argv)
 #endif
   
   
-  Char_t* fileName = argv[1];
-  
+  const Char_t* tableSOD[]  = {"ALL", "no", "SOD", "all", NULL, NULL};
+
   Bool_t old = kTRUE;
-  
-  AliCDBManager* cdb = AliCDBManager::Instance();
-  cdb->SetRun(0);
-  cdb->SetDefaultStorage("");
-  
+  monitorDeclareTable(const_cast<char**>(tableSOD));
+
   AliFMDParameters::Instance()->Init(kFALSE,0);
-  AliFMDParameters::Instance()->UseRcuTrailer(!old);
-  AliFMDParameters::Instance()->UseCompleteHeader(!old);
-  
-  AliRawReader *reader = new AliRawReaderDate(fileName);
-  TStopwatch timer;
-  timer.Start();
-  AliFMDBaseDA baseDA;
-  
-  baseDA.Run(reader);
-  
-  timer.Stop();
-  timer.Print();
+  AliFMDParameters::Instance()->UseCompleteHeader(old);
+  struct eventHeaderStruct *event;
+  int status;
 
+  Int_t  debugLevel = 0;
+  Bool_t badOption  = false;
+  char*  source     = 0;
+  for (int i = 1; i < argc; i++) { 
+    if (argv[i][0] == '-') { // Options 
+      if (argv[i][1] == '-') { // Long option 
+       TString arg(&(argv[i][2])); 
+       if      (arg.EqualTo("help")) { usage(std::cout, argv[0]); return 0; }
+       if      (arg.EqualTo("diagnostics")) { }
+       else if (arg.EqualTo("debug")) debugLevel = atoi(argv[++i]); 
+       else                             badOption = true;
+      }
+      else { // Short option 
+       switch (argv[i][1]) { 
+       case 'h': usage(std::cout, argv[0]); return 0; 
+       case 'd': break; 
+       case 'D': debugLevel = atoi(argv[++i]); break;
+       default:  badOption = true;
+       }
+      }
+      if (badOption) { 
+       std::cerr << argv[0] << ": Unknown option " << argv[i] 
+                 << std::endl;
+       return 1;
+      }
+    }
+    else { 
+      if (!source) source     = argv[i];
+      else         debugLevel = atoi(argv[i]);
+    }
+  }
+  if (!source) { 
+    printf("%s: No data source specified\n", argv[0]);
+    return -1;
+  }
+  status=monitorSetDataSource(source);
+  if (status!=0) {
+    printf("monitorSetDataSource() failed for %s: %s\n",
+          source, monitorDecodeError(status));
+    return -1;
+  }
   
+  AliLog::SetModuleDebugLevel("FMD", debugLevel);
+  /* declare monitoring program */
+  status=monitorDeclareMp( __FILE__ );
+  if (status!=0) {
+    printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
+    return -1;
+  }
   
-  
+  monitorSetNowait();
+  monitorSetNoWaitNetworkTimeout(1000);
+
+  AliRawReader *reader = 0;
+  AliFMDBaseDA baseDA;
+  Int_t  retval = 0;
+  Int_t iev = 0;
+  Bool_t SODread = kFALSE;
+  while(!SODread && iev<1000) {
+    
+    /* check shutdown condition */
+    if (daqDA_checkShutdown()) {break;}
+    
+    /* get next event (blocking call until timeout) */
+    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("monitorGetEventDynamic() failed : %s\n",
+            monitorDecodeError(status));
+      break;
+    }
+    
+    /* retry if got no event */
+    if (event==NULL) {
+      continue;
+    }
+    
+    iev++; 
+    
+    switch (event->eventType){
+      
+    case START_OF_DATA:
+      reader = new AliRawReaderDate((void*)event);
+      baseDA.Run(reader);
+      SODread = kTRUE;
+      retval = 
+       daqDA_FES_storeFile("conditions.csv", 
+                           AliFMDParameters::Instance()->GetConditionsShuttleID());
+      if (retval != 0) std::cerr << "Base DA failed" << std::endl;
+      
+      break;
+    
+    default:
+      break;
+    
+    }
+  }
+ 
+   
+  return retval;
 }