56 char nodedir_cint[1024];
57 TGlobal* GLOBAL = (TGlobal*)gROOT->GetGlobal(
"nodedir",
true);
59 memcpy((
void*)&nodedir_cint,(
void*)GLOBAL->GetAddress(),1024*
sizeof(char));
61 sprintf(cmd,
"chmod g+r %s",nodedir_cint);
65 unsigned int Pid = gSystem->GetPid();
72 sprintf(tmpOut,
"%s/%s_%s_%s_%d.out", nodedir_cint,srunID.Data(),slabel.Data(),sstage.Data(),Pid);
74 cout << tmpOut << endl; cout << outLog << endl;
77 sprintf(tmpErr,
"%s/%s_%s_%s_%d.err", nodedir_cint,srunID.Data(),slabel.Data(),sstage.Data(),Pid);
79 cout << tmpErr << endl; cout << errLog << endl;
99 freopen(tmpOut,
"w",stdout);
100 freopen(tmpErr,
"w",stderr);
110 if(eced) cfg->
Import(gSystem->ExpandPathName(
"$CWB_MACROS/cwb_eced.C"));
111 cfg->
Import(gSystem->ExpandPathName(
"$CWB_MACROS/cwb_inet.C"));
121 char nodedir_cint[1024];
122 TGlobal* GLOBAL = (TGlobal*)gROOT->GetGlobal(
"nodedir",
true);
124 memcpy((
void*)&nodedir_cint,(
void*)GLOBAL->GetAddress(),1024*
sizeof(char));
132 if(eced) gROOT->Macro(gSystem->ExpandPathName(
"$CWB_MACROS/cwb_eced.C"));
133 cfg->
Import(gSystem->ExpandPathName(
"$CWB_MACROS/cwb_inet.C"));
147 cout <<
"cwb_xnet - Error : analysis must be 1G or 2G" << endl;
152 if(ftell(stdout)!=-1)
fclose(stdout);
153 if(ftell(stderr)!=-1)
fclose(stderr);
160 estat = gSystem->GetPathInfo(tmpOut,&
id,&size,&flags,&mt);
161 if (estat==0 && size<1000000) {
162 sprintf(cmd,
"mv %s %s",tmpOut,outLog);
167 estat = gSystem->GetPathInfo(tmpErr,&
id,&size,&flags,&mt);
168 if (estat==0 && size<1000000) {
169 sprintf(cmd,
"mv %s %s",tmpErr,errLog);
189 while(ecommand&&(ntry<maxtry)) {
190 ecommand=gSystem->Exec(command);
191 if(ecommand) gSystem->Sleep(
int(gRandom->Uniform(1000,3000)));
194 if(ecommand) {cout <<
"cwb_xnet.C - Error -> " << command << endl;gSystem->Exit(1);}
204 if(srunID!=
"@")
return;
208 if(cwb_gps_event.CompareTo(
"")!=0) {
209 if(!cwb_gps_event.IsFloat()) {cout<<
"Error : CWB_GPS_EVENT is not a number" << endl;
exit(1);}
210 if(cwb_gps_event.Atoi()>0) gps_event=cwb_gps_event.Atoi();
214 TString exec_cmd = TString::Format(
"%s/cwb_dump.csh sjob",cwb_scripts.Data());
215 int ret=gSystem->Exec(exec_cmd);
216 if(ret) {cout <<
"Error while executing cwb_dum sjob !!!" << endl;
exit(1);}
224 in.open(sjob_file.Data(),
ios::in);
225 if (!in.good()) {cout <<
"Error Opening File : " << sjob_file << endl;
exit(1);}
231 if(!in.good())
break;
233 if(gps_event>=start && gps_event<=stop) {
234 TString sjob = TString::Format(
"%d",job);
235 gSystem->Setenv(
"CWB_JOBID",sjob.Data());
void Import(TString umacro="")
static TString GetStageString(CWB_STAGE jstage)
void SetupStage(CWB_STAGE jstage)
virtual void run(int runID=0)
CWB::config * GetConfig()
PrintLogoCWB(GetLALVersion())
sprintf(tfres,"(1/%g)x(%g) (sec)x(Hz)", 2 *df, df)
void cwb_xnet(TString fName, CWB_STAGE jstage=CWB_STAGE_FULL, TString uName="", bool batch=false, bool eced=false)
void SystemExec(char *command, int maxtry=3)