8 TB.
checkFile(gSystem->Getenv(
"CWB_ROOTLOGON_FILE"));
9 TB.
checkFile(gSystem->Getenv(
"CWB_PARAMETERS_FILE"));
10 TB.
checkFile(gSystem->Getenv(
"CWB_UPARAMETERS_FILE"));
49 int estat = gSystem->GetPathInfo(condor_dag_file,&
id,&size,&
flags,&mt);
53 int ncondor_jobs = jobList.size();
54 int* jobStatus =
new int[ncondor_jobs+1];
55 for(
int i=0;
i<=ncondor_jobs;
i++) jobStatus[
i]=1;
58 cout <<
"Starting reading output directory ..." << endl;
60 for(
int n=0;
n<fileList.size();
n++) {
63 if (
n%1000==0) cout <<
"cwb_condor check - " <<
n <<
"/" << fileList.size() <<
" files" << endl;
66 if(!ifile.IsOpen()) {cout <<
"Failed to open " << fileList[
n].Data() << endl;
exit(-1);}
69 if(ihistory==NULL) ihistory = (
CWB::History*)ifile.Get(
"CWB::History");
70 if(ihistory==NULL) { cout <<
"Error : history is not present!!!" << endl;
exit(1); }
77 if(jobId>ncondor_jobs)
continue;
78 if(ifile.IsZombie()) {
82 if(log==
"STOP JOB") jobStatus[
jobId]=3;
89 for(
int i=1;
i<=ncondor_jobs;
i++) {
90 if(jobStatus[
i]==1) njobCondor++;
91 if(jobStatus[
i]==2) njobZombie++;
92 if(jobStatus[
i]==3) njobProcessed++;
96 cout <<
"Number of Jobs : " <<
nfactor*ncondor_jobs << endl;
97 cout <<
"Number of Processed Jobs : " << njobProcessed << endl;
98 cout <<
"Number of Jobs to be Processed : " << njobCondor << endl;
char condor_dag_file[256]
char * GetLog(char *Stage, int index)
int GetLogSize(char *Stage)
cout<< "Starting reading output directory ..."<< endl;vector< TString > fileList
sprintf(full_condor_dir,"%s/%s", work_dir, condor_dir)
char full_condor_dir[512]