| 10 | #include <TSQLServer.h> | #include <TSQLServer.h> | 
| 11 | #include <TFile.h> | #include <TFile.h> | 
| 12 | #include <TSystem.h> | #include <TSystem.h> | 
| 13 |  | #include <TStopwatch.h> | 
| 14 |  | #include <TObjectTable.h> | 
| 15 |  | // | 
| 16 |  | #include <GLTables.h> | 
| 17 | // | // | 
| 18 | // Detector's package headers | // Detector's package headers | 
| 19 | // | // | 
| 38 | // | // | 
| 39 | void usage(){ | void usage(){ | 
| 40 | printf("\nUsage:\n"); | printf("\nUsage:\n"); | 
| 41 | printf("\n DarthVader [-v | --verbose] [-h | --help] [--version] -idRun ID_RUN [-processFile filename]\n"); | printf("\n DarthVader [ options ] -idRun ID_RUN [+-all] [+-detector [ detector options ] ] \n"); | 
| 42 | printf("\n            [-host host] [-user username] [-psw password] [+-all] [+-detector [ detector options ] ]\n"); | printf("\n Options are: \n\n"); | 
| 43 | printf("\n --version       print informations about compilation and exit\n"); | printf(" --version         print informations about compilation and exit\n"); | 
| 44 | printf("\n -h | --help     print this help and exit \n"); | printf(" -h || --help      print this help and exit \n"); | 
| 45 | printf("\n -v | --verbose  be verbose [default]\n"); | printf(" -v || --verbose   be verbose [default]\n"); | 
| 46 | printf("\n -s | --silent   print nothing on STDOUT\n"); | printf(" -s || --silent    print nothing on STDOUT\n"); | 
| 47 | printf("\n -c | --clean    remove file if exiting with errors\n"); | printf(" -c || --clean     remove file if exiting with errors\n"); | 
| 48 | printf("\n -idRun          ID_RUN: ID number of the run to be processed \n"); | printf(" -b || --benchmark perform and print a benchmark test\n"); | 
| 49 | printf("\n -processFile    output filename [default ID_RUN.Level2.root]\n"); | printf(" -auto || -AUTO    exclude from processing detector which are NOT in the acquisition [default]\n"); | 
| 50 | printf("\n -auto | -AUTO   exclude from processing detector which are NOT in the acquisition [default]\n"); | printf(" -zerofill         if a detector is not in the acquisition the routine is called anyway \n"); | 
| 51 | printf("\n -zerofill       if a detector is not in the acquisition the routine is called anyway \n"); | printf("                   but all detector's data will be marked as bad\n"); | 
| 52 | printf("\n                 but all detector's data will be marked as bad\n"); | printf(" -tedious          exit with error if a detector is not in the acquisition and \n"); | 
| 53 | printf("\n -tedious        exit with error if a detector is not in the acquisition and \n"); | printf("                   it has not been excluded from processing\n"); | 
| 54 | printf("\n                 it has not been excluded from processing\n"); | printf(" -host             name of the DB host [default = $PAM_DBHOST or mysql://localhost/pamelaprod]\n"); | 
| 55 | printf("\n -host           name for the host [default = $PAM_DBHOST or mysql://localhost/pamelaprod]\n"); | printf(" -user             username for the DB connection [default = $PAM_DBUSER or \"anonymous\"] \n"); | 
| 56 | printf("\n -user           username for the DB [default = $PAM_DBUSER or \"anonymous\"] \n"); | printf(" -psw              password for the DB connection [default = $PAM_DBPSW or \"\"]\n"); | 
| 57 | printf("\n -psw            password for the DB [default = $PAM_DBPSW or \"\"]\n"); | printf(" -idRun ID_RUN     ID number (from the DB) of the run to be processed \n"); | 
| 58 | printf("\n +all | +ALL     call all detectors software [default]\n"); | printf(" -processFile file output filename [default ID_RUN.Level2.root]\n"); | 
| 59 | printf("\n -all | -ALL     call nothing\n"); | printf(" +all || +ALL      call all detectors software [default]\n"); | 
| 60 | printf("\n +detector       process detector; detector can be: TOF,TRK,CAL,TRG,ORB,S4,ND,AC,RUN\n"); | printf(" -all || -ALL      call nothing\n"); | 
| 61 | printf("\n -detector       do not process detector (as above)\n"); | printf(" +detector         process detector; detector can be: TOF,TRK,CAL,TRG,ORB,S4,ND,AC,RUN\n"); | 
| 62 | printf("\n                 detector options must be included in square parenthesis with spaces, for example:\n"); | printf(" -detector         do not process detector (as above)\n"); | 
| 63 | printf("\n                 +CAL [ --verbose -g ] +TRK [ -v --level1 ] \n"); | printf("                   detector options must be included in square parenthesis with spaces, for example:\n"); | 
| 64 | printf("\nExamples: \n"); | printf("                   +CAL [ --verbose -g ] +TRK [ -v --level1 ] \n"); | 
| 65 | printf("\nStandard call: DarthVader -idRun 1085 \n"); | printf("\n Examples: \n"); | 
| 66 | printf("\nProcess only RunInfo and Tracker (be verbose for tracker): DarthVader -idRun 1085 -all +RUN +TRK [ --verbose ] \n"); | printf(" Standard call:\n            DarthVader -idRun 1085 \n"); | 
| 67 | printf("\nProcess all and be verbose for calorimeter: DarthVader -idRun 1085 +CAL [ --verbose ] \n\n"); | printf(" Process only RunInfo and Tracker (be verbose for tracker):\n            DarthVader -idRun 1085 -all +RUN +TRK [ --verbose ] \n"); | 
| 68 |  | printf(" Process all and be verbose for calorimeter:\n            DarthVader -idRun 1085 +CAL [ --verbose ] \n\n"); | 
| 69 | }; | }; | 
| 70 |  |  | 
| 71 | // | // | 
| 72 | // Here the main | // Here the main | 
| 73 | // | // | 
| 75 | // | // | 
| 76 | // Variables booking | // Variables booking | 
| 77 | // | // | 
| 78 |  | // | 
| 79 |  | // benchmarck variables | 
| 80 |  | // | 
| 81 |  | TStopwatch timer; | 
| 82 |  | TStopwatch dvtimer; | 
| 83 |  | dvtimer.Start(kTRUE); | 
| 84 |  | UInt_t nevents = 0; | 
| 85 |  | UInt_t nruns = 0; | 
| 86 |  | Double_t runtime = 0.; | 
| 87 |  | Double_t cruntime = 0.; | 
| 88 |  | Double_t trktime = 0.; | 
| 89 |  | Double_t ctrktime = 0.; | 
| 90 |  | Double_t caltime = 0.; | 
| 91 |  | Double_t ccaltime = 0.; | 
| 92 |  | Double_t toftime = 0.; | 
| 93 |  | Double_t ctoftime = 0.; | 
| 94 |  | Double_t trgtime = 0.; | 
| 95 |  | Double_t ctrgtime = 0.; | 
| 96 |  | Double_t actime = 0.; | 
| 97 |  | Double_t cactime = 0.; | 
| 98 |  | Double_t s4time = 0.; | 
| 99 |  | Double_t cs4time = 0.; | 
| 100 |  | Double_t ndtime = 0.; | 
| 101 |  | Double_t cndtime = 0.; | 
| 102 |  | Double_t orbtime = 0.; | 
| 103 |  | Double_t corbtime = 0.; | 
| 104 |  | Double_t dvtime = 0.; | 
| 105 |  | Double_t cdvtime = 0.; | 
| 106 |  | // | 
| 107 | TString message; | TString message; | 
| 108 | int nul = 0; | int nul = 0; | 
| 109 | Int_t error = 0; | Int_t error = 0; | 
| 119 | Int_t NDSGN = 0; | Int_t NDSGN = 0; | 
| 120 | Int_t DVSGN = 0; | Int_t DVSGN = 0; | 
| 121 | // | // | 
| 122 |  | UInt_t NQRUN = 0; | 
| 123 |  | UInt_t NQTRK = 0; | 
| 124 |  | UInt_t NQCAL = 0; | 
| 125 |  | UInt_t NQTOF = 0; | 
| 126 |  | UInt_t NQORB = 0; | 
| 127 |  | UInt_t NQTRG = 0; | 
| 128 |  | UInt_t NQAC = 0; | 
| 129 |  | UInt_t NQND = 0; | 
| 130 |  | UInt_t NQS4 = 0; | 
| 131 |  | UInt_t NQTOT = 0; | 
| 132 |  | // | 
| 133 | Bool_t autom = true; | Bool_t autom = true; | 
| 134 | Bool_t zerofill = false; | Bool_t zerofill = false; | 
| 135 | Bool_t tedious = false; | Bool_t tedious = false; | 
| 137 | Bool_t debug = false; | Bool_t debug = false; | 
| 138 | Bool_t beverbose = true; | Bool_t beverbose = true; | 
| 139 | Bool_t givenid = false; | Bool_t givenid = false; | 
| 140 |  | Bool_t bench = false; | 
| 141 | Bool_t CAL = true; | Bool_t CAL = true; | 
| 142 | Bool_t TRK = true; | Bool_t TRK = true; | 
| 143 | Bool_t TRG = true; | Bool_t TRG = true; | 
| 146 | Bool_t ND = true; | Bool_t ND = true; | 
| 147 | Bool_t AC = true; | Bool_t AC = true; | 
| 148 | Bool_t ORB = true; | Bool_t ORB = true; | 
| 149 | Bool_t RUN = true; | Bool_t RUN = true; | 
| 150 | // | // | 
| 151 | Int_t calargc = 0; | Int_t calargc = 0; | 
| 152 | char *calargv[50]; | char *calargv[50]; | 
| 178 | TString host = "mysql://localhost/pamelaprod"; | TString host = "mysql://localhost/pamelaprod"; | 
| 179 | TString user = "anonymous"; | TString user = "anonymous"; | 
| 180 | TString psw = ""; | TString psw = ""; | 
| 181 | // | // | 
| 182 | // | // | 
| 183 | const char *pamdbhost=gSystem->Getenv("PAM_DBHOST"); | const char *pamdbhost=gSystem->Getenv("PAM_DBHOST"); | 
| 184 | const char *pamdbuser=gSystem->Getenv("PAM_DBUSER"); | const char *pamdbuser=gSystem->Getenv("PAM_DBUSER"); | 
| 279 | debug = true; | debug = true; | 
| 280 | found = true; | found = true; | 
| 281 | }; | }; | 
| 282 |  | if ( !strcmp(inps[i],"-b") || !strcmp(inps[i],"--benchmark") ){ | 
| 283 |  | bench = true; | 
| 284 |  | found = true; | 
| 285 |  | }; | 
| 286 | if ( !strcmp(inps[i],"-auto") || !strcmp(inps[i],"-AUTO") ){ | if ( !strcmp(inps[i],"-auto") || !strcmp(inps[i],"-AUTO") ){ | 
| 287 | autom = true; | autom = true; | 
| 288 | tedious = false; | tedious = false; | 
| 560 | // Start: | // Start: | 
| 561 | // | // | 
| 562 | printf("\n Welcome to the PAMELA LEVEL2 flight software, version %s \n\n",version.Data()); | printf("\n Welcome to the PAMELA LEVEL2 flight software, version %s \n\n",version.Data()); | 
| 563 |  | if ( run )  printf("\n Processing run number %u \n\n",run); | 
| 564 | // | // | 
| 565 | // Connect to the DB | // Connect to the DB | 
| 566 | // | // | 
| 575 | // | // | 
| 576 | if ( debug ) printf("...connected! \n\n"); | if ( debug ) printf("...connected! \n\n"); | 
| 577 | // | // | 
| 578 |  | GL_TABLES *glt = new GL_TABLES(host,user,psw); | 
| 579 |  | // | 
| 580 |  | if ( debug ) printf("\n DB INFORMATIONS:\n SQL: %s Version: %s Host %s Port %i \n\n",dbc->GetDBMS(),dbc->ServerInfo(),dbc->GetHost(),dbc->GetPort()); | 
| 581 |  | // | 
| 582 | // Use UTC in the DB | // Use UTC in the DB | 
| 583 | // | // | 
| 584 | stringstream myquery; | stringstream myquery; | 
| 585 | myquery.str(""); | myquery.str(""); | 
| 586 | myquery << "SET time_zone='+0:00'"; | myquery << "SET time_zone='+0:00'"; | 
| 587 | dbc->Query(myquery.str().c_str()); | dbc->Query(myquery.str().c_str()); | 
| 588 |  | myquery.str(""); | 
| 589 |  | myquery << "SET wait_timeout=173000;"; | 
| 590 |  | dbc->Query(myquery.str().c_str()); | 
| 591 | // | // | 
| 592 | // | // | 
| 593 | // Create LEVEL2 filename and open it in update mode | // Create LEVEL2 filename and open it in update mode | 
| 604 | processFile = new TFile(filename.Data(),"UPDATE"); | processFile = new TFile(filename.Data(),"UPDATE"); | 
| 605 | if ( !processFile->IsOpen() ) throw -15; | if ( !processFile->IsOpen() ) throw -15; | 
| 606 | // | // | 
| 607 |  | Long64_t maxsize = 10000000000LL; | 
| 608 |  | TTree::SetMaxTreeSize(maxsize); | 
| 609 |  | processFile->SetCompressionLevel(1); | 
| 610 |  | // | 
| 611 |  | // | 
| 612 | // Run the core program, put any output error in the "error" variable | // Run the core program, put any output error in the "error" variable | 
| 613 | // | // | 
| 614 | printf("\n\n Pre-processing:\n\n"); | if ( debug ) printf("\n\n Pre-processing:\n\n"); | 
| 615 | // | // | 
| 616 |  | timer.Start(kTRUE); | 
| 617 | if ( RUN ) { | if ( RUN ) { | 
| 618 | printf(" Retrieve, if the case, the RUN informations from the DB...\n"); | glt->ResetCounters(); | 
| 619 |  | if ( debug ) printf(" Retrieve, if the case, the RUN informations from the DB...\n"); | 
| 620 | printf(" RunInfo called\n"); | printf(" RunInfo called\n"); | 
| 621 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start RunInfoCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start RunInfoCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | 
| 622 | RUNSGN = RunInfoCore(run,processFile,dbc,version,runargc,runargv); | RUNSGN = RunInfoCore(run,processFile,dbc,version,runargc,runargv); | 
| 623 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end RunInfoCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end RunInfoCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 624 | printf(" ...done\n"); | if ( debug ) printf(" ...done\n"); | 
| 625 |  | NQRUN = glt->GetNqueries(); | 
| 626 | }; | }; | 
| 627 |  | timer.Stop(); | 
| 628 |  | runtime = timer.RealTime(); | 
| 629 |  | cruntime = timer.CpuTime(); | 
| 630 | // | // | 
| 631 | // From the Run Infos extract acq_var_info to determine if detectors are in the acquisition or not | // From the Run Infos extract acq_var_info to determine if detectors are in the acquisition or not | 
| 632 | // | // | 
| 633 | printf(" Checking if requested detectors are in the acquisition\n"); | if ( debug ) printf(" Checking if requested detectors are in the acquisition\n"); | 
| 634 | ItoRunInfo *runinfo = new ItoRunInfo(processFile); | ItoRunInfo *runinfo = new ItoRunInfo(processFile); | 
| 635 | Int_t sgnl = runinfo->Read(run); | Int_t sgnl = runinfo->Read(run); | 
| 636 | if ( sgnl != 0 ) throw -17; | if ( sgnl != 0 ) throw -17; | 
| 637 | printf(" => ACQ_VAR_INFO = %i \n",runinfo->ACQ_VAR_INFO); | nevents = runinfo->GetEntries(); | 
| 638 |  | nruns = runinfo->GetNoRun(); | 
| 639 |  | if ( debug ) printf(" => ACQ_VAR_INFO = %i \n",runinfo->ACQ_VAR_INFO); | 
| 640 | if ( TRK && !(runinfo->ACQ_VAR_INFO & (1 << 4)) ){ | if ( TRK && !(runinfo->ACQ_VAR_INFO & (1 << 4)) ){ | 
| 641 | DVSGN += 1; | DVSGN += 1; | 
| 642 | if ( tedious ) throw -30; | if ( tedious ) throw -30; | 
| 643 | if ( autom ){ | if ( autom ){ | 
| 644 | TRK = 0; | TRK = 0; | 
| 645 | printf(" TRK excluded from processing \n"); | if ( debug ) printf(" TRK excluded from processing \n"); | 
| 646 | }; | }; | 
| 647 | if ( zerofill ) printf(" TRK is not in the acquisition! \n"); | if ( zerofill && debug ) printf(" TRK is not in the acquisition! \n"); | 
| 648 | }; | }; | 
| 649 | if ( TOF && !(runinfo->ACQ_VAR_INFO & (1 << 0)) ){ | if ( TOF && !(runinfo->ACQ_VAR_INFO & (1 << 0)) ){ | 
| 650 | DVSGN += 2; | DVSGN += 2; | 
| 651 | if ( tedious ) throw -31; | if ( tedious ) throw -31; | 
| 652 | if ( autom ){ | if ( autom ){ | 
| 653 | TOF = 0; | TOF = 0; | 
| 654 | printf(" TOF excluded from processing \n"); | if ( debug ) printf(" TOF excluded from processing \n"); | 
| 655 | }; | }; | 
| 656 | if ( zerofill ) printf(" TOF is not in the acquisition! \n"); | if ( zerofill && debug ) printf(" TOF is not in the acquisition! \n"); | 
| 657 | }; | }; | 
| 658 | if ( CAL && !(runinfo->ACQ_VAR_INFO & (1 << 3)) ){ | if ( CAL && !(runinfo->ACQ_VAR_INFO & (1 << 3)) ){ | 
| 659 | DVSGN += 4; | DVSGN += 4; | 
| 660 | if ( tedious ) throw -32; | if ( tedious ) throw -32; | 
| 661 | if ( autom ){ | if ( autom ){ | 
| 662 | CAL = 0; | CAL = 0; | 
| 663 | printf(" CAL excluded from processing \n"); | if ( debug ) printf(" CAL excluded from processing \n"); | 
| 664 | }; | }; | 
| 665 | if ( zerofill ) printf(" CAL is not in the acquisition! \n"); | if ( zerofill && debug ) printf(" CAL is not in the acquisition! \n"); | 
| 666 | }; | }; | 
| 667 | if ( AC  && (!(runinfo->ACQ_VAR_INFO & (1 << 1)) || !(runinfo->ACQ_VAR_INFO & (1 << 2))) ){ | if ( AC  && (!(runinfo->ACQ_VAR_INFO & (1 << 1)) || !(runinfo->ACQ_VAR_INFO & (1 << 2))) ){ | 
| 668 | DVSGN += 8; | DVSGN += 8; | 
| 669 | if ( tedious ) throw -33; | if ( tedious ) throw -33; | 
| 670 | if ( autom ){ | if ( autom ){ | 
| 671 | AC = 0; | AC = 0; | 
| 672 | printf(" AC excluded from processing \n"); | if ( debug ) printf(" AC excluded from processing \n"); | 
| 673 | }; | }; | 
| 674 | if ( zerofill ) printf(" AC is not in the acquisition! \n"); | if ( zerofill && debug ) printf(" AC is not in the acquisition! \n"); | 
| 675 | }; | }; | 
| 676 | if ( S4  && !(runinfo->ACQ_VAR_INFO & (1 << 5)) ){ | if ( S4  && !(runinfo->ACQ_VAR_INFO & (1 << 5)) ){ | 
| 677 | DVSGN += 16; | DVSGN += 16; | 
| 678 | if ( tedious ) throw -34; | if ( tedious ) throw -34; | 
| 679 | if ( autom ){ | if ( autom ){ | 
| 680 | S4 = 0; | S4 = 0; | 
| 681 | printf(" S4 excluded from processing \n"); | if ( debug ) printf(" S4 excluded from processing \n"); | 
| 682 | }; | }; | 
| 683 | if ( zerofill ) printf(" S4 is not in the acquisition! \n"); | if ( zerofill && debug ) printf(" S4 is not in the acquisition! \n"); | 
| 684 | }; | }; | 
| 685 | if ( ND  && !(runinfo->ACQ_VAR_INFO & (1 << 9)) ){ | if ( ND  && !(runinfo->ACQ_VAR_INFO & (1 << 9)) ){ | 
| 686 | DVSGN += 32; | DVSGN += 32; | 
| 687 | if ( tedious ) throw -35; | if ( tedious ) throw -35; | 
| 688 | if ( autom ){ | if ( autom ){ | 
| 689 | ND = 0; | ND = 0; | 
| 690 | printf(" ND excluded from processing \n"); | if ( debug ) printf(" ND excluded from processing \n"); | 
| 691 | }; | }; | 
| 692 | if ( zerofill ) printf(" ND is not in the acquisition! \n"); | if ( zerofill && debug ) printf(" ND is not in the acquisition! \n"); | 
| 693 | }; | }; | 
| 694 | // | // | 
| 695 | if ( !DVSGN ){ | if ( !DVSGN ){ | 
| 696 | printf(" OK! Start processing detector's data. \n"); | if ( debug ) printf(" OK! Start processing detector's data. \n"); | 
| 697 | } else { | } else { | 
| 698 | printf(" WARNING! missing detector(s)! Start anyway processing detector's data. \n"); | if ( debug ) printf(" WARNING! missing detector(s)! Start anyway processing detector's data. \n"); | 
| 699 | }; | }; | 
| 700 | printf("\n End pre-processing \n\n"); | if ( debug ) printf("\n End pre-processing \n\n"); | 
| 701 | // | // | 
| 702 |  | timer.Start(kTRUE); | 
| 703 | if ( TRK ) { | if ( TRK ) { | 
| 704 |  | glt->ResetCounters(); | 
| 705 | printf(" TrackerLevel2 called\n"); | printf(" TrackerLevel2 called\n"); | 
| 706 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start TrkCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start TrkCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | 
| 707 | TRKSGN = TrkCore(run,processFile,dbc,trkargc,trkargv); | TRKSGN = TrkCore(run,processFile,dbc,trkargc,trkargv); | 
| 708 | gSystem->Unlink("TrackerFolder"); //patch | gSystem->Unlink("TrackerFolder"); //patch | 
| 709 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end TrkCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end TrkCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 710 |  | NQTRK = glt->GetNqueries(); | 
| 711 | }; | }; | 
| 712 |  | timer.Stop(); | 
| 713 |  | trktime = timer.RealTime(); | 
| 714 |  | ctrktime = timer.CpuTime(); | 
| 715 |  | // | 
| 716 |  | timer.Start(kTRUE); | 
| 717 | if ( TOF ) { | if ( TOF ) { | 
| 718 |  | glt->ResetCounters(); | 
| 719 | printf(" ToFLevel2 called\n"); | printf(" ToFLevel2 called\n"); | 
| 720 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start ToFCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start ToFCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | 
| 721 | TOFSGN = ToFCore(run,processFile,dbc,tofargc,tofargv); | TOFSGN = ToFCore(run,processFile,dbc,tofargc,tofargv); | 
| 722 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end ToFCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end ToFCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 723 |  | NQTOF = glt->GetNqueries(); | 
| 724 | }; | }; | 
| 725 |  | timer.Stop(); | 
| 726 |  | toftime = timer.RealTime(); | 
| 727 |  | ctoftime = timer.CpuTime(); | 
| 728 |  | // | 
| 729 |  | timer.Start(kTRUE); | 
| 730 | if ( CAL ) { | if ( CAL ) { | 
| 731 |  | glt->ResetCounters(); | 
| 732 | printf(" CalorimeterLevel2 called\n"); | printf(" CalorimeterLevel2 called\n"); | 
| 733 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start CaloCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start CaloCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | 
| 734 | CALSGN = CaloCore(run,processFile,dbc,calargc,calargv); | CALSGN = CaloCore(run,processFile,dbc,calargc,calargv); | 
| 735 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end CaloCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end CaloCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 736 |  | NQCAL = glt->GetNqueries(); | 
| 737 | }; | }; | 
| 738 |  | timer.Stop(); | 
| 739 |  | caltime = timer.RealTime(); | 
| 740 |  | ccaltime = timer.CpuTime(); | 
| 741 |  | // | 
| 742 |  | timer.Start(kTRUE); | 
| 743 | if ( TRG ) { | if ( TRG ) { | 
| 744 |  | glt->ResetCounters(); | 
| 745 | printf(" TriggerLevel2 called\n"); | printf(" TriggerLevel2 called\n"); | 
| 746 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start TrigCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start TrigCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | 
| 747 | TRGSGN = TrigCore(run,processFile,dbc,trgargc,trgargv); | TRGSGN = TrigCore(run,processFile,dbc,trgargc,trgargv); | 
| 748 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end TrigCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end TrigCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 749 |  | NQTRG = glt->GetNqueries(); | 
| 750 | }; | }; | 
| 751 |  | timer.Stop(); | 
| 752 |  | trgtime = timer.RealTime(); | 
| 753 |  | ctrgtime = timer.CpuTime(); | 
| 754 |  | // | 
| 755 |  | timer.Start(kTRUE); | 
| 756 | if ( AC ) { | if ( AC ) { | 
| 757 |  | glt->ResetCounters(); | 
| 758 | printf(" AnticounterLevel2 called\n"); | printf(" AnticounterLevel2 called\n"); | 
| 759 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start AcCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start AcCore STDOUT |<<<<<<<<<<<<<<<<<<<\n"); | 
| 760 | ACSGN = AcCore(run,processFile,dbc,acargc,acargv); | ACSGN = AcCore(run,processFile,dbc,acargc,acargv); | 
| 761 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end AcCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end AcCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 762 |  | NQAC = glt->GetNqueries(); | 
| 763 | }; | }; | 
| 764 |  | timer.Stop(); | 
| 765 |  | actime = timer.RealTime(); | 
| 766 |  | cactime = timer.CpuTime(); | 
| 767 |  | // | 
| 768 |  | timer.Start(kTRUE); | 
| 769 | if ( S4 ) { | if ( S4 ) { | 
| 770 |  | glt->ResetCounters(); | 
| 771 | printf(" S4Level2 called\n"); | printf(" S4Level2 called\n"); | 
| 772 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start S4Core STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start S4Core STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 773 | S4SGN = S4Core(run,processFile,dbc,s4argc,s4argv); | S4SGN = S4Core(run,processFile,dbc,s4argc,s4argv); | 
| 774 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end S4Core STDOUT   |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end S4Core STDOUT   |<<<<<<<<<<<<<<<<<<<\n"); | 
| 775 |  | NQS4 = glt->GetNqueries(); | 
| 776 | }; | }; | 
| 777 |  | timer.Stop(); | 
| 778 |  | s4time = timer.RealTime(); | 
| 779 |  | cs4time = timer.CpuTime(); | 
| 780 |  | // | 
| 781 |  | timer.Start(kTRUE); | 
| 782 | if ( ND ) { | if ( ND ) { | 
| 783 |  | glt->ResetCounters(); | 
| 784 | printf(" NDLevel2 called\n"); | printf(" NDLevel2 called\n"); | 
| 785 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start NDCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start NDCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 786 | NDSGN = NDCore(run,processFile,dbc,ndargc,ndargv); | NDSGN = NDCore(run,processFile,dbc,ndargc,ndargv); | 
| 787 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end NDCore STDOUT   |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end NDCore STDOUT   |<<<<<<<<<<<<<<<<<<<\n"); | 
| 788 |  | NQND = glt->GetNqueries(); | 
| 789 | }; | }; | 
| 790 |  | timer.Stop(); | 
| 791 |  | ndtime = timer.RealTime(); | 
| 792 |  | cndtime = timer.CpuTime(); | 
| 793 |  | // | 
| 794 |  | timer.Start(kTRUE); | 
| 795 | if ( ORB ) { | if ( ORB ) { | 
| 796 |  | glt->ResetCounters(); | 
| 797 | printf(" OrbitalInfo called\n"); | printf(" OrbitalInfo called\n"); | 
| 798 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start OrbitalInfoCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>| start OrbitalInfoCore STDOUT  |<<<<<<<<<<<<<<<<<<<\n"); | 
| 799 | ORBSGN = OrbitalInfoCore(run,processFile,dbc,orbargc,orbargv); | ORBSGN = OrbitalInfoCore(run,processFile,dbc,orbargc,orbargv); | 
| 800 | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end OrbitalInfoCore STDOUT   |<<<<<<<<<<<<<<<<<<<\n"); | if ( debug ) printf("                      >>>>>>>>>>>>>>>>>>>|  end OrbitalInfoCore STDOUT   |<<<<<<<<<<<<<<<<<<<\n"); | 
| 801 |  | NQORB = glt->GetNqueries(); | 
| 802 | }; | }; | 
| 803 |  | timer.Stop(); | 
| 804 |  | orbtime = timer.RealTime(); | 
| 805 |  | corbtime = timer.CpuTime(); | 
| 806 |  | // | 
| 807 |  | NQTOT = 2 + NQRUN + NQTRK + NQCAL + NQND + NQS4 + NQAC + NQTRG + NQTOF + NQORB; | 
| 808 |  | // | 
| 809 |  | delete glt; | 
| 810 |  | delete runinfo; | 
| 811 | // | // | 
| 812 | } catch(Int_t signal) { | } catch(Int_t signal) { | 
| 813 | error = signal; | error = signal; | 
| 841 | case -53:  message += " GLTABLES - No entries matching GL_TRK_CALIB query"; break; | case -53:  message += " GLTABLES - No entries matching GL_TRK_CALIB query"; break; | 
| 842 | case -54:  message += " GLTABLES - No entries matching GL_CALO_CALIB query"; break; | case -54:  message += " GLTABLES - No entries matching GL_CALO_CALIB query"; break; | 
| 843 | case -55:  message += " GLTABLES - No entries matching GL_CALO_CALIB query"; break; | case -55:  message += " GLTABLES - No entries matching GL_CALO_CALIB query"; break; | 
| 844 |  | case -56:  message += " GLTABLES - No entries matching GL_TLE query"; break; | 
| 845 |  | case -57:  message += " GLTABLES - DB connection gone and not able to reconnect"; break; | 
| 846 | // | // | 
| 847 | case -100: message += " CALORIMETERLEVEL2 - No Level2 input file"; break; | case -100: message += " CALORIMETERLEVEL2 - No Level2 input file"; break; | 
| 848 | case -101: message += " CALORIMETERLEVEL2 -  Cannot open Level2 file"; break; | case -101: message += " CALORIMETERLEVEL2 -  Cannot open Level2 file"; break; | 
| 861 | case -114: message += " CALORIMETERLEVEL2 -  Help called"; break; | case -114: message += " CALORIMETERLEVEL2 -  Help called"; break; | 
| 862 | case -115: message += " CALORIMETERLEVEL2 -  No Calorimeter bad strip offline mask file"; break; | case -115: message += " CALORIMETERLEVEL2 -  No Calorimeter bad strip offline mask file"; break; | 
| 863 | case -116: message += " CALORIMETERLEVEL2 -  DB connection problems"; break; | case -116: message += " CALORIMETERLEVEL2 -  DB connection problems"; break; | 
| 864 |  | case -117: message += " CALORIMETERLEVEL2 -  Cannot reprocess file with Level1 data without calling Level1 routine"; break; | 
| 865 |  | case -118: message += " CALORIMETERLEVEL2 -  Cannot reprocess file without Level1 data calling Level1 routine"; break; | 
| 866 | // | // | 
| 867 | case -200: message += " TRACKERLEVEL2 - LEVEL1 framework unknown (HBOOK/ROOT)"; break; | case -200: message += " TRACKERLEVEL2 - LEVEL1 framework unknown (HBOOK/ROOT)"; break; | 
| 868 | case -201: message += " TRACKERLEVEL2 - LEVEL2 framework unknown (HBOOK/ROOT)"; break; | case -201: message += " TRACKERLEVEL2 - LEVEL2 framework unknown (HBOOK/ROOT)"; break; | 
| 951 | }; | }; | 
| 952 | if ( processFile ){ | if ( processFile ){ | 
| 953 | processFile->cd(); | processFile->cd(); | 
| 954 |  | processFile->WriteStreamerInfo(); | 
| 955 | processFile->Close(); | processFile->Close(); | 
| 956 | }; | }; | 
| 957 | // | // | 
| 958 |  | // print benchmark results (if the case) | 
| 959 |  | // | 
| 960 |  | dvtimer.Stop(); | 
| 961 |  | dvtime = dvtimer.RealTime(); | 
| 962 |  | cdvtime = dvtimer.CpuTime(); | 
| 963 |  | if ( bench ){ | 
| 964 |  | Float_t runrt = 0.; | 
| 965 |  | Float_t trkrt = 0.; | 
| 966 |  | Float_t calrt = 0.; | 
| 967 |  | Float_t tofrt = 0.; | 
| 968 |  | Float_t trgrt = 0.; | 
| 969 |  | Float_t acrt = 0.; | 
| 970 |  | Float_t s4rt = 0.; | 
| 971 |  | Float_t ndrt = 0.; | 
| 972 |  | Float_t orbrt = 0.; | 
| 973 |  | Float_t dvrt = nevents/dvtime; | 
| 974 |  | if ( RUN ) runrt = nruns/runtime; | 
| 975 |  | if ( TRK ) trkrt = nevents/trktime; | 
| 976 |  | if ( CAL ) calrt = nevents/caltime; | 
| 977 |  | if ( TOF ) tofrt = nevents/toftime; | 
| 978 |  | if ( TRG ) trgrt = nevents/trgtime; | 
| 979 |  | if ( AC ) acrt = nevents/actime; | 
| 980 |  | if ( S4 ) s4rt = nevents/s4time; | 
| 981 |  | if ( ND ) ndrt = nevents/ndtime; | 
| 982 |  | if ( ORB ) orbrt = nevents/orbtime; | 
| 983 |  | // | 
| 984 |  | printf("\n\n###########################################################################################\n"); | 
| 985 |  | printf("#              Benchmark results:      nevents = %10u     runs = %3u                #\n",nevents,nruns); | 
| 986 |  | printf("###########################################################################################\n"); | 
| 987 |  | printf("# Detector # Core routine called # Queries  #     Real Time   #   CPU time   #  Events/s  #\n"); | 
| 988 |  | printf("###########################################################################################\n"); | 
| 989 |  | printf("# RUN      #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",RUN,NQRUN,fabs(runtime),fabs(cruntime),runrt); | 
| 990 |  | printf("# TRK      #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",TRK,NQTRK,fabs(trktime),fabs(ctrktime),trkrt); | 
| 991 |  | printf("# CAL      #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",CAL,NQCAL,fabs(caltime),fabs(ccaltime),calrt); | 
| 992 |  | printf("# TOF      #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",TOF,NQTOF,fabs(toftime),fabs(ctoftime),tofrt); | 
| 993 |  | printf("# TRG      #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",TRG,NQTRG,fabs(trgtime),fabs(ctrgtime),trgrt); | 
| 994 |  | printf("# AC       #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",AC,NQAC,fabs(actime),fabs(cactime),acrt); | 
| 995 |  | printf("# S4       #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",S4,NQS4,fabs(s4time),fabs(cs4time),s4rt); | 
| 996 |  | printf("# ND       #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",ND,NQND,fabs(ndtime),fabs(cndtime),ndrt); | 
| 997 |  | printf("# ORB      #         %i           #   %3u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",ORB,NQORB,fabs(orbtime),fabs(corbtime),orbrt); | 
| 998 |  | printf("###########################################################################################\n"); | 
| 999 |  | printf("# Total    #                     #  %4u    #      %8.2f   #    %8.2f  #  %8.2f  #\n",NQTOT,fabs(dvtime),fabs(cdvtime),dvrt); | 
| 1000 |  | printf("###########################################################################################\n"); | 
| 1001 |  | }; | 
| 1002 |  | // | 
| 1003 |  | // | 
| 1004 | if ( error != 0 ) printf("\n\n WARNING: exiting with signal %i \n\n",error); | if ( error != 0 ) printf("\n\n WARNING: exiting with signal %i \n\n",error); | 
| 1005 | // | // | 
| 1006 | // | // |