]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - ITS/ITSSPDPHYSda.cxx
Update HFE v2 analyses
[u/mrichter/AliRoot.git] / ITS / ITSSPDPHYSda.cxx
index 3d4b8bf53bb5a790d0b0ee1cae8cc763ddee669c..7654da9fb0a7b30b968fc991b83489ed613fdb81 100644 (file)
@@ -35,21 +35,24 @@ extern "C" {
 #include "AliLog.h"
 #include <iostream>
 #include <fstream>
-//#include <time.h>
+#include <time.h>
 #include <TROOT.h>
 #include <TPluginManager.h>
 #include <TObjArray.h>
 #include <TObjString.h>
 #include <TString.h>
+#include <cstdlib>
 
 
 int main(int argc, char **argv) {
   if (argc<2) {
-    printf("Wrong number of arguments\n");
+    printf("SPD DA ERROR: Wrong number of arguments\n");
     return -1;
   }
 
-  // directory structure, hard coded
+  UInt_t nrErrors = 0;
+
+  // directory structure, hard coded                              //   FOR OFFLINE VERSION:
   char *saveDirDead          = "./calibResults/Dead";             // may NOT delete content
   char *saveDirDeadToFXS     = "./calibResults/DeadToFXS";        //     may delete content
   char *saveDirDeadRef       = "./calibResults/DeadReference";    //     may delete content
@@ -58,7 +61,17 @@ int main(int argc, char **argv) {
   char *saveDirNoisyRef      = "./calibResults/NoisyReference";   //     may delete content
   char *saveDirIdsToFXS      = "./calibResults/IdsToFXS";         //     may delete content
   char *configFilesDir       = "./configFiles";                   //     may delete content
-  // make sure the directory structure is put up correctly:
+  // clean up and make sure the directory structure is put up correctly:
+#ifndef SPD_DA_OFF
+  system("rm ./calibResults -rf >& /dev/null");
+  system("rm ./ITS -rf >& /dev/null");
+#else
+  system("rm ./calibResults/DeadToFXS -rf >& /dev/null");
+  system("rm ./calibResults/DeadReference -rf >& /dev/null");
+  system("rm ./calibResults/NoisyToFXS -rf >& /dev/null");
+  system("rm ./calibResults/NoisyReference -rf >& /dev/null");
+  system("rm ./calibResults/IdsToFXS -rf >& /dev/null");
+#endif
   system("mkdir ./calibResults >& /dev/null");
   system("mkdir ./calibResults/Dead >& /dev/null");
   system("mkdir ./calibResults/DeadToFXS >& /dev/null");
@@ -68,6 +81,11 @@ int main(int argc, char **argv) {
   system("mkdir ./calibResults/NoisyReference >& /dev/null");
   system("mkdir ./calibResults/IdsToFXS >& /dev/null");
   system("mkdir ./configFiles >& /dev/null");
+#ifndef SPD_DA_OFF
+  system("mkdir ./ITS >& /dev/null");
+  system("mkdir ./ITS/Calib >& /dev/null");
+  system("mkdir ./ITS/Calib/SPDNoisy >& /dev/null");
+#endif
   // parameters config file
   TString paramsFileName = Form("%s/physics_params.txt",configFilesDir);
 
@@ -80,9 +98,9 @@ int main(int argc, char **argv) {
                                        "TStreamerInfo()");
 
   // turn off annoying warning messages
-  new AliLog;
-  AliLog::Instance()->SetGlobalDebugLevel(-20);
-
+  // NB: Should not be handled here
+  AliLog* logger = AliLog::GetRootLogger();
+  logger->SetGlobalDebugLevel(-20);
 
   // ********* STEP 0: Get configuration files from db (if there are any) , then read parameters*********
   UInt_t nrTuningParams = 0;
@@ -95,14 +113,16 @@ int main(int argc, char **argv) {
   TString idp = "spd_physics_params";
   par_status=daqDA_DB_getFile(idp.Data(),paramsFileName.Data());
   if (par_status) {
-    printf("Failed to get config file %s: status=%d. Using default tuning parameters.\n",idp.Data(),par_status);
+    printf("SPD DA: Failed to get config file %s: status=%d. Using default tuning parameters.\n",idp.Data(),par_status);
+    TString rmCmd = Form("rm -f %s",paramsFileName.Data());
+    system(rmCmd.Data());
   }
 #endif
   if (par_status==0) {
     ifstream paramsFile;
     paramsFile.open(paramsFileName.Data(), ifstream::in);
     if (paramsFile.fail()) {
-      printf("No config file (%s) present. Using default tuning parameters.\n",paramsFileName.Data());
+      printf("SPD DA: No config file (%s) present. Using default tuning parameters.\n",paramsFileName.Data());
     }
     else {
       while(1) {
@@ -130,10 +150,41 @@ int main(int argc, char **argv) {
 
   // create calibration handler (needed already at step 1 in order to fill which eq,hs,chips are active
   AliITSOnlineCalibrationSPDhandler* handler = new AliITSOnlineCalibrationSPDhandler();
+
   // Read silent=dead+inactive info from previous calibrations
+#ifndef SPD_DA_OFF
+  for (UInt_t eq=0; eq<20; eq++) {
+    Int_t getPreviousDead_status = 0;
+    TString idpd = Form("spd_previous_dead_%d",eq);
+    TString fileName = Form("%s/SPD_Dead_%d.root",saveDirDead,eq);
+    getPreviousDead_status = daqDA_DB_getFile(idpd.Data(),fileName.Data());
+    //        printf("daqDA_DB_getFile(%s,%s)\n",idpd.Data(),fileName.Data());
+    if (getPreviousDead_status) {
+      printf("SPD DA: Failed to get dead file %s: status=%d. Dead search will start from zero for this eq.\n",idpd.Data(),getPreviousDead_status);
+      TString rmCmd = Form("rm -f %s",fileName.Data());
+      system(rmCmd.Data());
+    }
+  }
+#endif
   handler->SetFileLocation(saveDirDead);
   handler->ReadSilentFromFiles();
-  printf("Nr dead pixels before: %d\n",handler->GetNrDead());
+  printf("SPD DA: Number of single dead pixels from previous runs: %d\n",handler->GetNrDead());
+
+  // Read hit-maps from previous runs
+#ifndef SPD_DA_OFF
+  for (UInt_t eq=0; eq<20; eq++) {
+    Int_t getPreviousHitmap_status = 0;
+    TString idph = Form("spd_previous_hitmap_%d",eq);
+    TString fileName = Form("%s/SPDphys_dead_run_0_0_eq_%d.root",saveDirDeadRefTmp,eq);
+    getPreviousHitmap_status = daqDA_DB_getFile(idph.Data(),fileName.Data());
+    //    printf("daqDA_DB_getFile(%s,%s)\n",idph.Data(),fileName.Data());
+    if (getPreviousHitmap_status) {
+      printf("SPD DA: Failed to get previous hitmap file %s: status=%d. Dead search will start with empty hitmap for this eq.\n",idph.Data(),getPreviousHitmap_status);
+      TString rmCmd = Form("rm -f %s",fileName.Data());
+      system(rmCmd.Data());
+    }
+  }
+#endif
 
 
 
@@ -142,7 +193,7 @@ int main(int argc, char **argv) {
 
 #ifndef SPD_DA_OFF
   if (getenv("DATE_RUN_NUMBER")==0) {
-    printf("DATE_RUN_NUMBER not properly set.\n");
+    printf("SPD DA ERROR: DATE_RUN_NUMBER not properly set.\n");
     return -1;
   }
   int runNr = atoi(getenv("DATE_RUN_NUMBER"));
@@ -161,6 +212,8 @@ int main(int argc, char **argv) {
   }
 
 
+  UInt_t eventNr=0;
+
   // loop over run segments in case of offline mode
 #ifdef SPD_DA_OFF
   for (int segNr=startSeg; segNr<argc; segNr++) {
@@ -175,13 +228,13 @@ int main(int argc, char **argv) {
     status=monitorSetDataSource( argv[segNr] );
 #endif
     if (status!=0) {
-      printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
+      printf("SPD DA ERROR: monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
       return -1;
     }
     /* declare monitoring program */
     status=monitorDeclareMp("ITS_SPD_PHYS");
     if (status!=0) {
-      printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
+      printf("SPD DA ERROR: monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
       return -1;
     }
     /* define wait event timeout - 1s max */
@@ -189,8 +242,6 @@ int main(int argc, char **argv) {
     monitorSetNoWaitNetworkTimeout(1000);
 
 
-    UInt_t eventNr=0;
-
     /* main loop (infinite) */
     for(;;) {
 
@@ -205,12 +256,12 @@ int main(int argc, char **argv) {
       /* get next event (blocking call until timeout) */
       status=monitorGetEventDynamic((void **)&event);
       if (status==MON_ERR_EOF) {
-       printf ("End of File detected\n");
+       printf ("SPD DA: End of File detected\n");
        break; /* end of monitoring file has been reached */
       }
 
       if (status!=0) {
-       printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
+       printf("SPD DA: monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
        break;
       }
 
@@ -232,7 +283,7 @@ int main(int argc, char **argv) {
          Int_t eq = reader->GetDDLID();
          // check that this hs is active in handler object
          if (!(handler->IsActiveEq(eq))) {
-           printf("Info: Found Eq (%d) , previously inactive\n",eq);
+           printf("SPD DA: Found Eq (%d) , previously inactive\n",eq);
            handler->ActivateEq(eq);
          }
          if (eq>=0 && eq<20) {
@@ -247,13 +298,13 @@ int main(int argc, char **argv) {
            UInt_t hs = str->GetHalfStaveNr();
            // check that this hs is active in handler object
            if (!(handler->IsActiveHS(eq,hs))) {
-             printf("Info: Found HS (%d,%d) , previously inactive\n",eq,hs);
+             printf("SPD DA: Found HS (%d,%d) , previously inactive\n",eq,hs);
              handler->ActivateHS(eq,hs);
            }
            UInt_t chip = str->GetChipAddr();
            // check that this chip is active in handler object
            if (!(handler->IsActiveChip(eq,hs,chip))) {
-             printf("Info: Found Chip (%d,%d,%d) , previously inactive\n",eq,hs,chip);
+             printf("SPD DA: Found Chip (%d,%d,%d) , previously inactive\n",eq,hs,chip);
              handler->ActivateChip(eq,hs,chip);
            }
            physObj[eq]->IncrementHits(hs,chip,str->GetChipCol(),str->GetChipRow());
@@ -319,33 +370,25 @@ int main(int argc, char **argv) {
     
 
 #ifdef SPD_DA_OFF
-    printf("progress: %d\n",(unsigned int)( ((Float_t)(segNr-startSeg+1))/(argc-startSeg)*50 ));
+    printf("SPD DA: progress: %d\n",(unsigned int)( ((Float_t)(segNr-startSeg+1))/(argc-startSeg)*50 ));
   }
 #endif
-  
+
   // clean up phys objects (also saves them)
   for (UInt_t eq=0; eq<20; eq++) {
     if (physObj[eq]!=NULL) delete physObj[eq];
   }
 
+  printf("SPD DA: %d events collected for this run.\n",eventNr);
 
 
 
 
   // ********* STEP 2: Analyze phys container files. ************************************************
 
-  //  time_t timeStamp = time(NULL);
+  time_t timeStamp = time(NULL);
   //  printf("*** Start step2 , %d\n",time(NULL) - timeStamp);
 
-  // clear noisyToFXS dir:
-  TString command;
-  command = Form("cd %s; rm -f *",saveDirNoisyToFXS);
-  system(command.Data());
-  // clear deadToFXS dir:
-  command = Form("cd %s; rm -f *",saveDirDeadToFXS);
-  system(command.Data());
-
-
   UInt_t firstRunNrDead = runNr;
 
 
@@ -364,8 +407,7 @@ int main(int argc, char **argv) {
     // check data in container
     if (noisyAnalyzer->GetEqNr() != eq) {
       if (noisyAnalyzer->GetEqNr() != 999) {
-       printf("Error: Mismatching EqId in Container data and filename (%d!=%d). Skipping.\n",
-              noisyAnalyzer->GetEqNr(),eq);
+       printf("SPD DA ERROR: Mismatching EqId in Container data and filename (%d!=%d). Skipping eq.\n",noisyAnalyzer->GetEqNr(),eq);
       }
       delete noisyAnalyzer;
       continue;
@@ -379,7 +421,7 @@ int main(int argc, char **argv) {
       noisyAnalyzer->SetParam(((TObjString*)paramNames.At(i))->GetString().Data(),((TObjString*)paramVals.At(i))->GetString().Data());
     }
 
-    printf("SPD phys STEP 2: Noisy search for eq %d\n",eq);  
+    printf("SPD DA: SPD phys STEP 2: Noisy search for eq %d\n",eq);  
 
     // search for noisy pixels:
     nrEnoughStatNoisy += noisyAnalyzer->ProcessNoisyPixels();
@@ -409,19 +451,31 @@ int main(int argc, char **argv) {
     delete noisyAnalyzer;
 
 #ifndef SPD_DA_OFF
-    daqDA_progressReport((unsigned int)((eq+1)*2.5));
+    //    daqDA_progressReport((unsigned int)((eq+1)*2.5));
+    printf("SPD DA: progress: %d , %ld\n",(unsigned int)(50+(eq+1)*2.5), time(NULL) - timeStamp);
 #else
-    printf("progress: %d\n",(unsigned int)(50+(eq+1)*1.25));
+    //    printf("SPD DA: progress: %d\n",(unsigned int)(50+(eq+1)*1.25));
+    printf("SPD DA: progress: %d , %ld\n",(unsigned int)(50+(eq+1)*1.25), time(NULL) - timeStamp);
 #endif
   }
   // *** *** *** end loop over equipments (eq_id)
 
-  printf("Noisy search finished. %d noisy pixels found. %d chips had enough statistics.\n",
+  printf("SPD DA: Noisy search finished. %d noisy pixels found. %d chips had enough statistics.\n",
         handler->GetNrNoisy(),nrEnoughStatNoisy);
   handler->SetFileLocation(saveDirNoisyToFXS);
-  handler->WriteNoisyToFiles();
-
-
+  UInt_t nrNoisyFilesProduced = handler->WriteNoisyToFiles();
+#ifndef SPD_DA_OFF
+  // save noisy to local OCDB
+  handler->WriteNoisyToDB(runNr,9999999,".");
+  // store local OCDB file in daq Det DB
+  TString ocdb_fileName = Form("./ITS/Calib/SPDNoisy/Run%d_9999999_v0_s0.root",runNr);
+  TString idod = "spd_noisy_ocdb";
+  Int_t ocdb_store_status = daqDA_DB_storeFile(ocdb_fileName.Data(),idod.Data());
+  //    printf("daqDA_DB_storeFile(%s,%s)\n",ocdb_fileName.Data(),idod.Data());
+  if (ocdb_store_status) {
+    printf("SPD DA ERROR: Failed to store noisy ocdb file %s in daqDetDB: status=%d.\n",idod.Data(),ocdb_store_status);
+  }
+#endif
 
 
 
@@ -444,8 +498,7 @@ int main(int argc, char **argv) {
     // check data in container
     if (deadAnalyzer->GetEqNr() != eq) {
       if (deadAnalyzer->GetEqNr() != 999) {
-       printf("Error: Mismatching EqId in Dead Container data and filename (%d!=%d). Skipping.\n",
-              deadAnalyzer->GetEqNr(),eq);
+       printf("SPD DA ERROR: Mismatching EqId in Dead Container data and filename (%d!=%d). Skipping eq.\n",deadAnalyzer->GetEqNr(),eq);
       }
       delete deadAnalyzer;
       nrDeadChips+=60; // since this eq is inactive...
@@ -460,7 +513,8 @@ int main(int argc, char **argv) {
       deadAnalyzer->SetParam(((TObjString*)paramNames.At(i))->GetString().Data(),((TObjString*)paramVals.At(i))->GetString().Data());
     }
 
-    printf("SPD phys STEP 2: Dead search for eq %d\n",eq);  
+    UInt_t nrEventsCollected = physObj->GetNrEvents();
+    printf("SPD DA: SPD phys STEP 2: Dead search for eq %d (%d events)\n",eq,nrEventsCollected);  
 
     // search for dead pixels:
     nrEnoughStatChips += deadAnalyzer->ProcessDeadPixels();
@@ -471,102 +525,144 @@ int main(int argc, char **argv) {
 
 
 #ifndef SPD_DA_OFF
-    daqDA_progressReport((unsigned int)(50+(eq+1)*2.5));
+    //    daqDA_progressReport((unsigned int)(50+(eq+1)*2.5));
+    printf("SPD DA: progress: %d , %ld\n",(unsigned int)(50+(eq+1)*2.5), time(NULL) - timeStamp);
 #else
-    printf("progress: %d\n",(unsigned int)(75+(eq+1)*1.25));
+    //    printf("SPD DA: progress: %d\n",(unsigned int)(75+(eq+1)*1.25));
+    printf("SPD DA: progress: %d , %ld\n",(unsigned int)(75+(eq+1)*1.25), time(NULL) - timeStamp);
 #endif
   }
-  // *** *** *** end loop over equipments (eq_id)
+  // *** *** *** end loop over equipments (eq)
 
 
 
   
-  printf("Dead search finished.\n");
-  printf("%d single dead pixels , %d dead or inactive pixels in total.\n",handler->GetNrDead(),handler->GetNrSilent());
-  printf("%d chips had enough statistics. %d chips are dead. %d chips are inefficient.\n",nrEnoughStatChips,nrDeadChips,nrInefficientChips);
+  printf("SPD DA: Dead search finished.\n");
+  printf("SPD DA: %d single dead pixels , %d dead or inactive pixels in total.\n",handler->GetNrDead(),handler->GetNrSilent());
+  printf("SPD DA: %d chips had enough statistics. %d chips are dead. %d chips are inefficient.\n",nrEnoughStatChips,nrDeadChips,nrInefficientChips);
   handler->SetFileLocation(saveDirDead);
   handler->WriteSilentToFilesAlways();
   handler->SetFileLocation(saveDirDeadToFXS);
   handler->WriteSilentToFilesAlways();
 
 
-  printf("Opening id list file\n");
+  //  printf("SPD DA: Opening id list file\n");
+  printf("SPD DA: Opening id list file , %ld\n",time(NULL) - timeStamp);
   TString idsFXSFileName = Form("%s/FXSids_run_%d.txt",saveDirIdsToFXS,runNr);
   ofstream idsFXSfile;
   idsFXSfile.open(idsFXSFileName.Data());
 
 
+  // store dead+inactive pixels in DB, used as starting point for later runs
+#ifndef SPD_DA_OFF
+  printf("store previous dead in DB , %ld\n",time(NULL) - timeStamp);
+  for (UInt_t eq=0; eq<20; eq++) {
+    Int_t storePreviousDead_status = 0;
+    TString idpd = Form("spd_previous_dead_%d",eq);
+    TString fileName = Form("%s/SPD_Dead_%d.root",saveDirDead,eq);
+    storePreviousDead_status = daqDA_DB_storeFile(fileName.Data(),idpd.Data());
+    //    printf("daqDA_DB_storeFile(%s,%s)\n",fileName.Data(),idpd.Data());
+    if (storePreviousDead_status) {
+      printf("SPD DA ERROR: Failed to store dead file %s in daqDetDB: status=%d.\n",idpd.Data(),storePreviousDead_status);
+    }
+  }
+#endif
+
+
   // send (dead) reference data for this run to FXS - only if there is no chip in category "needsMoreStat"
-  if (nrEnoughStatChips+nrDeadChips+nrInefficientChips == 1200) {
-    printf("Dead calibration is complete.\n");    // calibration is complete
-    printf("Preparing dead reference data\n");
+  if (nrEnoughStatChips>0 && nrEnoughStatChips+nrDeadChips+nrInefficientChips == 1200) {
+    printf("SPD DA: Dead calibration is complete.\n");
+    printf("SPD DA: Preparing dead reference data\n");
     // send reference data for dead pixels to FXS
     TString tarFiles = "";
     for (UInt_t eq=0; eq<20; eq++) {
       if (eqActiveDead[eq]) {
-       printf("Preparing dead pixels for eq %d\n",eq);
+       printf("SPD DA: Preparing dead pixels for eq %d\n",eq);
        // move file to ref dir
        TString fileName = Form("%s/SPDphys_dead_run_0_0_eq_%d.root",saveDirDeadRefTmp,eq);
        TString newFileName = Form("%s/SPDphys_dead_run_%d_%d_eq_%d.root",saveDirDeadRef,firstRunNrDead,runNr,eq);
        TString command = Form("mv -f %s %s",fileName.Data(),newFileName.Data());
        system(command.Data());
-
        tarFiles.Append(Form("SPDphys_dead_run_%d_%d_eq_%d.root ",firstRunNrDead,runNr,eq));
+       // create empty hitmap file to send to DB later
+       AliITSOnlineSPDphys* physObj = new AliITSOnlineSPDphys(fileName.Data());
+       physObj->SetEqNr(eq);
+       delete physObj;
       }
     }
-    TString send_command = Form("cd %s; tar -cf ref_phys_dead.tar %s",saveDirDeadRef,tarFiles.Data());
-    system(send_command.Data());
-    TString fileName = Form("%s/ref_phys_dead.tar",saveDirDeadRef);
-    TString id = "SPD_ref_phys_dead";
+    if  (tarFiles.Length() > 0) {   // make sure there are some files to send
+      TString send_command = Form("cd %s; tar -cf ref_phys_dead.tar %s",saveDirDeadRef,tarFiles.Data());
+      system(send_command.Data());
+      TString fileName = Form("%s/ref_phys_dead.tar",saveDirDeadRef);
+      TString id = "SPD_ref_phys_dead";
 #ifndef SPD_DA_OFF
-    status = daqDA_FES_storeFile(fileName.Data(),id.Data());
-    if (status!=0) {
-      printf("Failed to export file %s , status %d\n",fileName.Data(),status);
-      return -1;
-    }
+      status = daqDA_FES_storeFile(fileName.Data(),id.Data());
+      if (status!=0) {
+       printf("SPD DA ERROR: Failed to export file %s , status %d\n",fileName.Data(),status);
+       nrErrors++;
+      }
 #endif
-    idsFXSfile << Form("%s\n",id.Data());
+      idsFXSfile << Form("%s\n",id.Data());
+    }
   }
 
+  // store hitmaps (maybe empty) in DB, used as starting point for later runs:
+#ifndef SPD_DA_OFF
+  printf("store previous hitmaps in DB , %ld\n",time(NULL) - timeStamp);
+  for (UInt_t eq=0; eq<20; eq++) {
+    Int_t storePreviousHitmap_status = 0;
+    TString idph = Form("spd_previous_hitmap_%d",eq);
+    TString fileName = Form("%s/SPDphys_dead_run_0_0_eq_%d.root",saveDirDeadRefTmp,eq);
+    storePreviousHitmap_status = daqDA_DB_storeFile(fileName.Data(),idph.Data());
+    //    printf("daqDA_DB_storeFile(%s,%s)\n",fileName.Data(),idph.Data());
+    if (storePreviousHitmap_status) {
+      printf("SPD DA ERROR: Failed to store hitmap file %s in daqDetDB: status=%d.\n",idph.Data(),storePreviousHitmap_status);
+    }
+  }
+#endif
+
 
 
   // send (noisy) reference data for this run to FXS
-  printf("Preparing noisy reference data\n");
+  //  printf("SPD DA: Preparing physics reference data for this run\n");
+  printf("SPD DA: Preparing physics reference data for this run , %ld\n",time(NULL) - timeStamp);
   TString tarFiles = "";
   for (UInt_t eq=0; eq<20; eq++) {
     if (eqActiveNoisy[eq]) {
       tarFiles.Append(Form("SPDphys_run_%d_eq_%d.root ",runNr,eq));
     }
   }
-  TString send_command = Form("cd %s; tar -cf ref_phys.tar %s",saveDirNoisyRef,tarFiles.Data());
-  system(send_command.Data());
-  TString fileName = Form("%s/ref_phys.tar",saveDirNoisyRef);
-  TString id = "SPD_ref_phys";
+  if  (tarFiles.Length() > 0) {   // make sure there are any files to send
+    TString send_command = Form("cd %s; tar -cf ref_phys.tar %s",saveDirNoisyRef,tarFiles.Data());
+    system(send_command.Data());
+    TString fileName = Form("%s/ref_phys.tar",saveDirNoisyRef);
+    TString id = "SPD_ref_phys";
 #ifndef SPD_DA_OFF
-  status = daqDA_FES_storeFile(fileName.Data(),id.Data());
-  if (status!=0) {
-    printf("Failed to export file %s , status %d\n",fileName.Data(),status);
-    return -1;
-  }
+    status = daqDA_FES_storeFile(fileName.Data(),id.Data());
+    if (status!=0) {
+      printf("SPD DA ERROR: Failed to export file %s , status %d\n",fileName.Data(),status);
+      nrErrors++;
+    }
 #endif
-  idsFXSfile << Form("%s\n",id.Data());
-
+    idsFXSfile << Form("%s\n",id.Data());
+  }
 
 
 
   // send dead pixels to FXS
-  printf("Preparing dead files\n");
+  //  printf("SPD DA: Preparing dead files for FXS\n");
+  printf("SPD DA: Preparing dead files for FXS , %ld\n",time(NULL) - timeStamp);
   // send a tared file of all the dead files
-  send_command = Form("cd %s; tar -cf dead_phys.tar *",saveDirDeadToFXS);
+  TString send_command = Form("cd %s; tar -cf dead_phys.tar *",saveDirDeadToFXS);
   //  printf("\n\n%s\n\n",command.Data());
   system(send_command.Data());
-  fileName = Form("%s/dead_phys.tar",saveDirDeadToFXS);
-  id = "SPD_phys_dead";
+  TString fileName = Form("%s/dead_phys.tar",saveDirDeadToFXS);
+  TString id = "SPD_phys_dead";
 #ifndef SPD_DA_OFF
   Int_t send_status = daqDA_FES_storeFile(fileName.Data(),id.Data());
   if (send_status!=0) {
-    printf("Failed to export file %s , status %d\n",fileName.Data(),send_status);
-    return -1;
+    printf("SPD DA ERROR: Failed to export file %s , status %d\n",fileName.Data(),send_status);
+    nrErrors++;
   }
 #endif
   idsFXSfile << Form("%s\n",id.Data());
@@ -574,8 +670,9 @@ int main(int argc, char **argv) {
 
 
   // send noisy pixels to FXS
-  if (handler->GetNrNoisy()>0) { // there must be at least one file created
-    printf("Preparing noisy files\n");
+  if (nrNoisyFilesProduced > 0) {   // make sure there is at least one file created
+    //    printf("SPD DA: Preparing noisy files for FXS\n");
+    printf("SPD DA: Preparing noisy files for FXS , %ld\n",time(NULL) - timeStamp);
     // send a tared file of all the noisy files
     TString command = Form("cd %s; tar -cf noisy_phys.tar *",saveDirNoisyToFXS);
     //    printf("\n\n%s\n\n",command.Data());
@@ -585,8 +682,8 @@ int main(int argc, char **argv) {
 #ifndef SPD_DA_OFF
     status = daqDA_FES_storeFile(fileName.Data(),id.Data());
     if (status!=0) {
-      printf("Failed to export file %s , status %d\n",fileName.Data(),status);
-      return -1;
+      printf("SPD DA ERROR: Failed to export file %s , status %d\n",fileName.Data(),status);
+      nrErrors++;
     }
 #endif
     idsFXSfile << Form("%s\n",id.Data());
@@ -600,8 +697,8 @@ int main(int argc, char **argv) {
 #ifndef SPD_DA_OFF
   status = daqDA_FES_storeFile(idsFXSFileName.Data(),id.Data());
   if (status!=0) {
-    printf("Failed to export file %s , status %d\n",idsFXSFileName.Data(),status);
-    return -1;
+    printf("SPD DA ERROR: Failed to export file %s , status %d\n",idsFXSFileName.Data(),status);
+    nrErrors++;
   }
 #endif
 
@@ -610,8 +707,10 @@ int main(int argc, char **argv) {
 
   delete handler;
 
-  //  printf("*** End step2 , %d\n",time(NULL) - timeStamp);
+  printf("SPD DA: End of all operations, %d errors, %ld\n", nrErrors, time(NULL) - timeStamp);
 
+  if (nrErrors>0) return -1;
 
   return 0;
+
 }