PadmeAmidala/src/PadmeAmidala.cpp

//
// C/C++ headers
//
#include <iostream>
#include <iomanip>
#include <fstream>
#include <sstream>
#include <string.h>
//
// ROOT headers
//
#include <TSQLServer.h>
#include <TString.h>
#include <TTimeStamp.h>
#include <TFile.h>
#include <TSystem.h>
#include <TChain.h>
#include <TH1.h>
#include <TTree.h>
#include <TKey.h>
#include <Riostream.h>
#include <TObjString.h>
#include <TClass.h>
//
// Detector's package headers
//
#include <RunGlue.h>
//
using namespace std;
//
//
//
#include <PadmeAmidalaVerl2.h>
//
//
// Usage subroutine
//
void amidalausage(){
  printf("\nUsage:\n");
  printf("\n Amidala [ options ]\n");
  printf("\n Options are:\n\n");
  printf(" --version        print informations about compilation and exit\n");
  printf(" -h | --help      print this help and exit \n");
  printf(" -g | --debug     set debug flag\n");
  printf(" -p | --pedantic  merge only when all level2 run files are present (default NOT pedantic, merge whatever it finds)\n");
  printf(" -idRun run       merge all runs in the directory which have the same date of run \"run\"\n");
  printf(" -outdir dir      output directory \"dir\"\n");
  printf(" -dir dir         merge all runs in the directory \"dir\"\n");
  printf(" -d | -delete     delete original DarthVader runs once merged\n");
  printf(" -no-DBupdate     do not update the DB\n");
  printf(" -host            name of the DB host [default = $PAM_DBHOST or mysql://localhost/pamelaprod]\n");
  printf(" -user            username for the DB connection [default = $PAM_DBUSER or \"anonymous\"] \n");
  printf(" -psw             password for the DB connection [default = $PAM_DBPSW or \"\"]\n");
  printf("\nExamples: \n");
  printf("      Amidala -idRun 1085 \n");
  printf("      Amidala -dir /home/pamela/level2/ \n\n");
};
//
// Here the main
//
int main(int numinp, char *inps[]){
  //
  // Variables booking
  //
  TString message;
  //
  UInt_t run = 0;
  //
  TString dir = "";
  TString outdir = "";
  TString dectlist = "";
  //
  TSQLServer *dbc = 0;
  TString host = "mysql://localhost/pamelaprod";
  TString user = "anonymous";
  TString psw = "";
  Bool_t debug = false;
  Bool_t delop = false;
  Bool_t dbup = true;
  Bool_t pedantic = false;
  //
  const char *pamdbhost=gSystem->Getenv("PAM_DBHOST");
  const char *pamdbuser=gSystem->Getenv("PAM_DBUSER");
  const char *pamdbpsw=gSystem->Getenv("PAM_DBPSW");
  if ( !pamdbhost ) pamdbhost = "";
  if ( !pamdbuser ) pamdbuser = "";
  if ( !pamdbpsw ) pamdbpsw = "";
  if ( strcmp(pamdbhost,"") ) host = pamdbhost;
  if ( strcmp(pamdbuser,"") ) user = pamdbuser;
  if ( strcmp(pamdbpsw,"") ) psw = pamdbpsw;
  //
  stringstream myquery;
  //
  // Checking input parameters
  //
  Int_t i = 0;
  if ( numinp > 1 ){
    while ( i < numinp ){
      if ( !strcmp(inps[i],"--version") ){
        AmidalaInfo(true);
        exit(0);
      };
      if ( !strcmp(inps[i],"-h") || !strcmp(inps[i],"--help") ){
        amidalausage();
        exit(0);
      };
      if ( !strcmp(inps[i],"-g") || !strcmp(inps[i],"--debug") ){
        debug = true;
      };
      if ( !strcmp(inps[i],"-d") || !strcmp(inps[i],"-delete") ){
        delop = true;
      };
      if ( !strcmp(inps[i],"-p") || !strcmp(inps[i],"--pedantic") ){
        pedantic = true;
      }
      if ( !strcmp(inps[i],"-no-DBupdate") ){
        dbup = false;
      };
      if ( !strcmp(inps[i],"-idRun") ) {
        if ( numinp-1 < i+1 ) {
          amidalausage();
          exit(-3);
        };
        run = (UInt_t)atoll(inps[i+1]); 
      };
      if ( !strcmp(inps[i],"-dir") ) {
        if ( numinp-1 < i+1 ){
          amidalausage();
          exit(-3);
        };
        dir = (TString)inps[i+1];       
      };
      if ( !strcmp(inps[i],"-outdir") ) {
        if ( numinp-1 < i+1 ){
          amidalausage();
          exit(-3);
        };
        outdir = (TString)inps[i+1];    
      };
      if ( !strcmp(inps[i],"-host") ) {
        if ( numinp-1 < i+1 ){
          amidalausage();
          exit(-3);
        };
        host = (TString)inps[i+1];      
      };
      if ( !strcmp(inps[i],"-user") ) {
        if ( numinp-1 < i+1 ){
          amidalausage();
          exit(-3);
        };
        user = (TString)inps[i+1];      
      };
      if ( !strcmp(inps[i],"-psw") ) {
        if ( numinp-1 < i+1 ){
          amidalausage();
          exit(-3);
        };
        psw = (TString)inps[i+1];       
      };
      //
      if ( !strcmp(inps[i],"-CAL") ) {
        dectlist +=" -CAL";
      };
      if ( !strcmp(inps[i],"-CAL1") ) {
        dectlist +=" -CAL1";
      };
      if ( !strcmp(inps[i],"-TRK") ) {
        dectlist +=" -TRK";
      };
      if ( !strcmp(inps[i],"-TRK1") ) {
        dectlist +=" -TRK1";
      };
      if ( !strcmp(inps[i],"-TRKh") ) {
        dectlist +=" -TRKh";
      };
      if ( !strcmp(inps[i],"-TOF") ) {
        dectlist +=" -TOF";
      };
      if ( !strcmp(inps[i],"-TRG") ) {
        dectlist +=" -TRG";
      };
      if ( !strcmp(inps[i],"-S4") ) {
        dectlist +=" -S4";
      };
      if ( !strcmp(inps[i],"-ND") ) {
        dectlist +=" -ND";
      };
      if ( !strcmp(inps[i],"-AC") ) {
        dectlist +=" -AC";
      };
      if ( !strcmp(inps[i],"-RUN") ) {
        dectlist +=" -RUN";
      };
      if ( !strcmp(inps[i],"-ORB") ) {
        dectlist +=" -ORB";
      };
      //
      if ( !strcmp(inps[i],"-all") || !strcmp(inps[i],"-ALL") ) {
        dectlist +=" -ALL";       
      };
      //
      if ( !strcmp(inps[i],"+all") || !strcmp(inps[i],"+ALL") ) {
        dectlist +=" +ALL";       
      };
      if ( !strcmp(inps[i],"+auto") || !strcmp(inps[i],"+AUTO") ) {
        dectlist +=" +AUTO";      
      };
      if ( !strcmp(inps[i],"+CAL") ) {
        dectlist +=" +CAL";
      };
      if ( !strcmp(inps[i],"+CAL1") ) {
        dectlist +=" +CAL1";
      };
      if ( !strcmp(inps[i],"+TRK") ) {
        dectlist +=" +TRK";
      };
      if ( !strcmp(inps[i],"+TRK1") ) {
        dectlist +=" +TRK1";
      };
      if ( !strcmp(inps[i],"+TRKh") ) {
        dectlist +=" +TRKh";
      };
      if ( !strcmp(inps[i],"+TOF") ) {
        dectlist +=" +TOF";
      };
      if ( !strcmp(inps[i],"+TRG") ) {
        dectlist +=" +TRG";
      };
      if ( !strcmp(inps[i],"+S4") ) {
        dectlist +=" +S4";
      };
      if ( !strcmp(inps[i],"+ND") ) {
        dectlist +=" +ND";
      };
      if ( !strcmp(inps[i],"+AC") ) {
        dectlist +=" +AC";
      };
      if ( !strcmp(inps[i],"+RUN") ) {
        dectlist +=" +RUN";
      };
      if ( !strcmp(inps[i],"+ORB") ) {
        dectlist +=" +ORB";
      };
      //
      i++;
    };
    //
  } else {
    //
    // no input parameters exit with error, we need at least the run id.
    //
    amidalausage();
    exit(-2);
  };
  //
  if ( run && strcmp(dir.Data(),"") ){
    amidalausage();
    printf(" Cannot give as input both ID run and directory \n\n");
    exit(-2);
  };
  if ( !run && !strcmp(dir.Data(),"") ){
    amidalausage();
    printf(" You must give as input or an ID run or a directory \n\n");
    exit(-2);
  };
  //
  // Connect to the DB
  //
  dbc = TSQLServer::Connect(host.Data(),user.Data(),psw.Data());
  if( !dbc ) throw -2;    
  //
  bool connect = dbc->IsConnected();
  //
  if( !connect ){
    printf(" Error, not connected to DB\n");
    exit(-1);
  };    
  //
  myquery.str("");
  myquery << "SET time_zone='+0:00';";
  delete dbc->Query(myquery.str().c_str());
  delete dbc->Query("SET sql_mode = 'NO_UNSIGNED_SUBTRACTION';");
  //
  RunGlue *rg = new RunGlue(dbc,run,dir,outdir);
  //
  if ( debug ) rg->SetDebug(true);
  if ( !dbup ) rg->SetUpgrade(false);
  rg->SetDList(dectlist);
  //
  TList *l = 0;
  //
  Int_t RET=0;
  //
  //  TString treelist="+AUTO";
  //
  while ( !rg->End() ){
    //
    l = rg->GetRunList();
    //
    if ( l && !(rg->HasDiscardedRuns() && pedantic) ){
      //
      if ( rg->FileIsOpen() ){
        //
        rg->MergeRootfile(l);
        //
        if ( dbup ) rg->UpdateDB(l);
        //
        if ( delop ) rg->DeleteRunFiles(l);
        //
        rg->Clean();
        //
      } else {
        RET = 255;
      };
    } else {
      RET = 255;
      if (rg->HasDiscardedRuns() && pedantic){
        printf(" Missing runs (and pedantic selected), cannot merge file %s \n",rg->GetFilename().Data());
        rg->Clean();
      }
    }
    delete l;
    //
  }
  //
  delete rg;
  //
  // Close the DB connection
  //
  if ( dbc ) dbc->Close();
  //
  if ( debug ) printf(" exit with error code %i \n",RET);
  // 
  printf("\n");
  //
  exit(RET);
}
1	mocchiut	1.1	//
2			// C/C++ headers
3			//
4			#include <iostream>
5			#include <iomanip>
6			#include <fstream>
7			#include <sstream>
8			#include <string.h>
9			//
10			// ROOT headers
11			//
12			#include <TSQLServer.h>
13			#include <TString.h>
14			#include <TTimeStamp.h>
15			#include <TFile.h>
16			#include <TSystem.h>
17			#include <TChain.h>
18			#include <TH1.h>
19			#include <TTree.h>
20			#include <TKey.h>
21			#include <Riostream.h>
22			#include <TObjString.h>
23			#include <TClass.h>
24			//
25			// Detector's package headers
26			//
27			#include <RunGlue.h>
28			//
29			using namespace std;
30			//
31			//
32			//
33			#include <PadmeAmidalaVerl2.h>
34			//
35			//
36			// Usage subroutine
37			//
38			void amidalausage(){
39			printf("\nUsage:\n");
40			printf("\n Amidala [ options ]\n");
41			printf("\n Options are:\n\n");
42			printf(" --version print informations about compilation and exit\n");
43			printf(" -h \| --help print this help and exit \n");
44			printf(" -g \| --debug set debug flag\n");
45	mocchiut	1.13	printf(" -p \| --pedantic merge only when all level2 run files are present (default NOT pedantic, merge whatever it finds)\n");
46	mocchiut	1.1	printf(" -idRun run merge all runs in the directory which have the same date of run \"run\"\n");
47			printf(" -outdir dir output directory \"dir\"\n");
48			printf(" -dir dir merge all runs in the directory \"dir\"\n");
49			printf(" -d \| -delete delete original DarthVader runs once merged\n");
50	mocchiut	1.3	printf(" -no-DBupdate do not update the DB\n");
51	mocchiut	1.1	printf(" -host name of the DB host [default = $PAM_DBHOST or mysql://localhost/pamelaprod]\n");
52			printf(" -user username for the DB connection [default = $PAM_DBUSER or \"anonymous\"] \n");
53			printf(" -psw password for the DB connection [default = $PAM_DBPSW or \"\"]\n");
54			printf("\nExamples: \n");
55			printf(" Amidala -idRun 1085 \n");
56			printf(" Amidala -dir /home/pamela/level2/ \n\n");
57			};
58			//
59			// Here the main
60			//
61			int main(int numinp, char *inps[]){
62			//
63			// Variables booking
64			//
65			TString message;
66			//
67			UInt_t run = 0;
68			//
69			TString dir = "";
70			TString outdir = "";
71			TString dectlist = "";
72			//
73			TSQLServer *dbc = 0;
74			TString host = "mysql://localhost/pamelaprod";
75			TString user = "anonymous";
76			TString psw = "";
77			Bool_t debug = false;
78			Bool_t delop = false;
79	mocchiut	1.3	Bool_t dbup = true;
80	mocchiut	1.13	Bool_t pedantic = false;
81	mocchiut	1.1	//
82			const char *pamdbhost=gSystem->Getenv("PAM_DBHOST");
83			const char *pamdbuser=gSystem->Getenv("PAM_DBUSER");
84			const char *pamdbpsw=gSystem->Getenv("PAM_DBPSW");
85			if ( !pamdbhost ) pamdbhost = "";
86			if ( !pamdbuser ) pamdbuser = "";
87			if ( !pamdbpsw ) pamdbpsw = "";
88			if ( strcmp(pamdbhost,"") ) host = pamdbhost;
89			if ( strcmp(pamdbuser,"") ) user = pamdbuser;
90			if ( strcmp(pamdbpsw,"") ) psw = pamdbpsw;
91			//
92			stringstream myquery;
93			//
94			// Checking input parameters
95			//
96			Int_t i = 0;
97			if ( numinp > 1 ){
98			while ( i < numinp ){
99			if ( !strcmp(inps[i],"--version") ){
100			AmidalaInfo(true);
101			exit(0);
102			};
103			if ( !strcmp(inps[i],"-h") \|\| !strcmp(inps[i],"--help") ){
104			amidalausage();
105			exit(0);
106			};
107			if ( !strcmp(inps[i],"-g") \|\| !strcmp(inps[i],"--debug") ){
108			debug = true;
109			};
110			if ( !strcmp(inps[i],"-d") \|\| !strcmp(inps[i],"-delete") ){
111			delop = true;
112			};
113	mocchiut	1.13	if ( !strcmp(inps[i],"-p") \|\| !strcmp(inps[i],"--pedantic") ){
114			pedantic = true;
115			}
116	mocchiut	1.3	if ( !strcmp(inps[i],"-no-DBupdate") ){
117			dbup = false;
118			};
119	mocchiut	1.1	if ( !strcmp(inps[i],"-idRun") ) {
120			if ( numinp-1 < i+1 ) {
121			amidalausage();
122			exit(-3);
123			};
124			run = (UInt_t)atoll(inps[i+1]);
125			};
126			if ( !strcmp(inps[i],"-dir") ) {
127			if ( numinp-1 < i+1 ){
128			amidalausage();
129			exit(-3);
130			};
131			dir = (TString)inps[i+1];
132			};
133			if ( !strcmp(inps[i],"-outdir") ) {
134			if ( numinp-1 < i+1 ){
135			amidalausage();
136			exit(-3);
137			};
138			outdir = (TString)inps[i+1];
139			};
140			if ( !strcmp(inps[i],"-host") ) {
141			if ( numinp-1 < i+1 ){
142			amidalausage();
143			exit(-3);
144			};
145			host = (TString)inps[i+1];
146			};
147			if ( !strcmp(inps[i],"-user") ) {
148			if ( numinp-1 < i+1 ){
149			amidalausage();
150			exit(-3);
151			};
152			user = (TString)inps[i+1];
153			};
154			if ( !strcmp(inps[i],"-psw") ) {
155			if ( numinp-1 < i+1 ){
156			amidalausage();
157			exit(-3);
158			};
159			psw = (TString)inps[i+1];
160			};
161			//
162			if ( !strcmp(inps[i],"-CAL") ) {
163			dectlist +=" -CAL";
164			};
165			if ( !strcmp(inps[i],"-CAL1") ) {
166			dectlist +=" -CAL1";
167			};
168			if ( !strcmp(inps[i],"-TRK") ) {
169			dectlist +=" -TRK";
170			};
171			if ( !strcmp(inps[i],"-TRK1") ) {
172			dectlist +=" -TRK1";
173			};
174			if ( !strcmp(inps[i],"-TRKh") ) {
175			dectlist +=" -TRKh";
176			};
177			if ( !strcmp(inps[i],"-TOF") ) {
178			dectlist +=" -TOF";
179			};
180			if ( !strcmp(inps[i],"-TRG") ) {
181			dectlist +=" -TRG";
182			};
183			if ( !strcmp(inps[i],"-S4") ) {
184			dectlist +=" -S4";
185			};
186			if ( !strcmp(inps[i],"-ND") ) {
187			dectlist +=" -ND";
188			};
189			if ( !strcmp(inps[i],"-AC") ) {
190			dectlist +=" -AC";
191			};
192			if ( !strcmp(inps[i],"-RUN") ) {
193			dectlist +=" -RUN";
194			};
195			if ( !strcmp(inps[i],"-ORB") ) {
196			dectlist +=" -ORB";
197			};
198			//
199			if ( !strcmp(inps[i],"-all") \|\| !strcmp(inps[i],"-ALL") ) {
200			dectlist +=" -ALL";
201			};
202			//
203			if ( !strcmp(inps[i],"+all") \|\| !strcmp(inps[i],"+ALL") ) {
204			dectlist +=" +ALL";
205			};
206	pamela	1.6	if ( !strcmp(inps[i],"+auto") \|\| !strcmp(inps[i],"+AUTO") ) {
207			dectlist +=" +AUTO";
208			};
209	mocchiut	1.1	if ( !strcmp(inps[i],"+CAL") ) {
210			dectlist +=" +CAL";
211			};
212			if ( !strcmp(inps[i],"+CAL1") ) {
213			dectlist +=" +CAL1";
214			};
215			if ( !strcmp(inps[i],"+TRK") ) {
216			dectlist +=" +TRK";
217			};
218			if ( !strcmp(inps[i],"+TRK1") ) {
219			dectlist +=" +TRK1";
220			};
221			if ( !strcmp(inps[i],"+TRKh") ) {
222			dectlist +=" +TRKh";
223			};
224			if ( !strcmp(inps[i],"+TOF") ) {
225			dectlist +=" +TOF";
226			};
227			if ( !strcmp(inps[i],"+TRG") ) {
228			dectlist +=" +TRG";
229			};
230			if ( !strcmp(inps[i],"+S4") ) {
231			dectlist +=" +S4";
232			};
233			if ( !strcmp(inps[i],"+ND") ) {
234			dectlist +=" +ND";
235			};
236			if ( !strcmp(inps[i],"+AC") ) {
237			dectlist +=" +AC";
238			};
239			if ( !strcmp(inps[i],"+RUN") ) {
240			dectlist +=" +RUN";
241			};
242			if ( !strcmp(inps[i],"+ORB") ) {
243			dectlist +=" +ORB";
244			};
245			//
246			i++;
247			};
248			//
249			} else {
250			//
251			// no input parameters exit with error, we need at least the run id.
252			//
253			amidalausage();
254			exit(-2);
255			};
256			//
257			if ( run && strcmp(dir.Data(),"") ){
258			amidalausage();
259			printf(" Cannot give as input both ID run and directory \n\n");
260			exit(-2);
261			};
262			if ( !run && !strcmp(dir.Data(),"") ){
263			amidalausage();
264			printf(" You must give as input or an ID run or a directory \n\n");
265			exit(-2);
266			};
267			//
268			// Connect to the DB
269			//
270			dbc = TSQLServer::Connect(host.Data(),user.Data(),psw.Data());
271			if( !dbc ) throw -2;
272			//
273			bool connect = dbc->IsConnected();
274			//
275			if( !connect ){
276			printf(" Error, not connected to DB\n");
277			exit(-1);
278			};
279			//
280			myquery.str("");
281	mocchiut	1.12	myquery << "SET time_zone='+0:00';";
282			delete dbc->Query(myquery.str().c_str());
283			delete dbc->Query("SET sql_mode = 'NO_UNSIGNED_SUBTRACTION';");
284	mocchiut	1.1	//
285	mocchiut	1.5	RunGlue *rg = new RunGlue(dbc,run,dir,outdir);
286	mocchiut	1.1	//
287			if ( debug ) rg->SetDebug(true);
288	mocchiut	1.10	if ( !dbup ) rg->SetUpgrade(false);
289	mocchiut	1.1	rg->SetDList(dectlist);
290			//
291			TList *l = 0;
292			//
293	mocchiut	1.8	Int_t RET=0;
294			//
295	mocchiut	1.7	// TString treelist="+AUTO";
296	mocchiut	1.1	//
297			while ( !rg->End() ){
298			//
299			l = rg->GetRunList();
300			//
301	mocchiut	1.14	if ( l && !(rg->HasDiscardedRuns() && pedantic) ){
302	mocchiut	1.1	//
303	mocchiut	1.2	if ( rg->FileIsOpen() ){
304	mocchiut	1.1	//
305			rg->MergeRootfile(l);
306			//
307	mocchiut	1.3	if ( dbup ) rg->UpdateDB(l);
308	mocchiut	1.1	//
309			if ( delop ) rg->DeleteRunFiles(l);
310			//
311			rg->Clean();
312			//
313	mocchiut	1.8	} else {
314			RET = 255;
315	mocchiut	1.1	};
316	mocchiut	1.9	} else {
317			RET = 255;
318	mocchiut	1.14	if (rg->HasDiscardedRuns() && pedantic){
319			printf(" Missing runs (and pedantic selected), cannot merge file %s \n",rg->GetFilename().Data());
320			rg->Clean();
321			}
322			}
323	mocchiut	1.1	delete l;
324			//
325	mocchiut	1.14	}
326	mocchiut	1.1	//
327			delete rg;
328			//
329			// Close the DB connection
330			//
331			if ( dbc ) dbc->Close();
332			//
333	mocchiut	1.9	if ( debug ) printf(" exit with error code %i \n",RET);
334			//
335	mocchiut	1.1	printf("\n");
336			//
337	mocchiut	1.8	exit(RET);
338	mocchiut	1.1	}