loon: FarmListModule Class Reference

00046 {
00047   RSMSyn << "FarmListModule::FarmListModule" << endl;
00048   fRun = 0;
00049   fSubRun = 0;
00050 
00051   fNTrigPlane = 0;
00052   fNTrigActivity = 0;
00053   fNTrigE4 = 0;
00054   fNTrigSpill = 0;
00055   fNTrigSpillIP = 0;
00056 
00057   fNSnarl = 0;
00058   fMaxPlane[0] = 0;
00059   fMaxPlane[1] = 0;
00060   fMaxPlane[2] = 0;
00061 
00062   fStartTime=VldTimeStamp((time_t) 0, 0);
00063   fEndTime=VldTimeStamp((time_t) 0, 0);
00064 
00065   fRunOUT = false;
00066 
00067   fMFileOutMode = ios::out | ios::app;
00068   fSFileOutMode = ios::out | ios::app;
00069 }

00072 {
00073   RSMSyn << "FarmListModule::~FarmListModule" << endl;
00074 }

00222 {
00223   RSMVer << "FarmListModule::Ana" << endl;
00224 
00225   const char* rcInStr = 0;
00226   RawRecord*  rawrec  = 0;
00227   RawDigitDataBlock* dblock = 0;
00228   RawDigit* digit = 0;
00229   //RawRunConfigBlock* rrcfgb = 0;
00230 
00231   TIter momitr = const_cast<MomNavigator*>(mom)->FragmentIter();
00232   TObject* momobj = 0;
00233   while ((momobj=momitr())) {
00234     rawrec=dynamic_cast<RawRecord*>(momobj);
00235     if(! rawrec) continue;
00236     const RawDaqHeader* dhdr =
00237       dynamic_cast<const RawDaqHeader*>(rawrec->GetRawHeader());
00238 
00239     VldContext vldc = dhdr->GetVldContext();
00240     if (fRun!=dhdr->GetRun() || fSubRun!=dhdr->GetSubRun()) {
00241       RSMDeb << "Run change: " <<
00242         fRun << "-" << fSubRun << " -> " <<
00243         dhdr->GetRun() << "-" << dhdr->GetSubRun() << endl;
00244       FarmFileOUT();
00245 
00246       fRunOUT = false;
00247       fRun = dhdr->GetRun();
00248       fSubRun = dhdr->GetSubRun();
00249       fDet = dhdr->GetVldContext().GetDetector();
00250       fStartTime = dhdr->GetVldContext().GetTimeStamp();
00251       fEndTime = dhdr->GetVldContext().GetTimeStamp();
00252     }
00253     //If we can't determine the stream of the RawRecord, skip it.
00254     if(!rawrec->GetTempTags().Get("stream",rcInStr)) continue;
00255 
00256     if(fEndTime<vldc.GetTimeStamp() &&
00257        vldc.GetTimeStamp()>fStartTime) {
00258       fEndTime = vldc.GetTimeStamp();
00259     }
00260 
00261     PlexHandle ph(vldc);
00262     TIter rawitr = rawrec->GetRawBlockIter(); rawitr.Reset();
00263     TObject *rawobj = 0;
00264     while ((rawobj=rawitr())) {
00265       if ((dblock = dynamic_cast<RawDigitDataBlock*>(rawobj))) {
00266         fNSnarl++;
00267 
00268         const RawSnarlHeaderBlock* hdrblk =
00269           dynamic_cast<const RawSnarlHeaderBlock*>
00270           (rawrec->FindRawBlock("RawSnarlHeaderBlock"));
00271         int TrigSrc = hdrblk->GetTriggerSource();
00272 
00273         if(TrigSrc&TRIGGER_BIT_PLANE) fNTrigPlane++;
00274         if(TrigSrc&TRIGGER_BIT_ACTIVITY) fNTrigActivity++;
00275         if(TrigSrc&TRIGGER_BIT_E4) fNTrigE4++;
00276         if(TrigSrc&TRIGGER_BIT_SPILL) fNTrigSpill++;
00277         if(TrigSrc&TRIGGER_BIT_SPILL_IP) fNTrigSpillIP++;
00278 
00279         //Don't do all the plane max crap for near
00280         if (fDet==Detector::kNear) continue;
00281 
00282         VldTimeStamp trigger_time = hdrblk->GetTriggerTime();
00283         TIter digitr = dblock->GetDatumIter();
00284         TObject *digobj = 0;
00285         while ((digobj=digitr())) {
00286           digit=dynamic_cast<RawDigit*>(digobj);
00287           if(!digit) continue; //Only Deal with RawDigit objects
00288           RawChannelId rawid =  digit->GetChannel();
00289 
00290           VldTimeStamp vt_T0 = digit->GetCrateT0();
00291           vt_T0.Add(VldTimeStamp(0,(Int_t)(1.5625*digit->GetTDC())));
00292           if(vt_T0 < trigger_time) continue;
00293 
00294           PlexSEIdAltL seidl = ph.GetSEIdAltL(rawid);
00295           if (!(seidl.IsVetoShield()) && seidl.IsValid()) {
00296 
00297             Int_t planenum = seidl.GetPlane();
00298 
00299             Int_t view_index = ((Int_t)seidl.GetEnd()) - 1;
00300             if (view_index<0 || view_index>1) {
00301               RSMWar << "Bad View Index " << view_index << endl;
00302               continue;
00303             }
00304 
00305             if (planenum<=MAXSMPLANE) {
00306               if (planenum>fMaxPlane[view_index+1]) {
00307                 fMaxPlane[view_index+1] = planenum;
00308               }
00309               if (planenum>fMaxPlane[0]) {
00310                 fMaxPlane[0] = planenum;
00311               }
00312             }
00313             else {
00314               cout << "Weird Plane" << endl;
00315               cout << seidl << endl;
00316               cout << rawid.AsString("e") << endl;
00317             }
00318           }
00319         }//digititr()
00320       }//RawDigitDataBlock
00321     }//rawitr()
00322   }//momitr()
00323   return JobCResult::kPassed;
00324 }

00327 {
00328   RSMSyn << "FarmListModule::BeginJob" << endl;
00329   fRun = 0;
00330   fSubRun = 0;
00331 
00332   fNSnarl = 0;
00333   fMaxPlane[0] = 0;
00334   fMaxPlane[1] = 0;
00335   fMaxPlane[2] = 0;
00336 
00337   fNTrigPlane = 0;
00338   fNTrigActivity = 0;
00339   fNTrigE4 = 0;
00340   fNTrigSpill = 0;
00341   fNTrigSpillIP = 0;
00342 
00343   fStartTime=VldTimeStamp( static_cast<time_t>(0), 0);
00344   fEndTime=VldTimeStamp( static_cast<time_t>(0), 0);
00345 
00346   fRunOUT = false;
00347 
00348   //ios_base::openmode fMFileOutMode;
00349   fMFileOutMode = ios::out | ios::app;
00350   if(!fAppendMFile) fMFileOutMode = ios::out;
00351 }

00400 {
00401   RSMSyn << "FarmListModule::Config" << endl;
00402   int tmpi = 0;
00403   const char* tmps = 0;
00404 
00405   if(r.Get("MinSecond",tmpi)) fMinSecond=tmpi;
00406   if(r.Get("MinSnarl",tmpi)) fMinSnarl=tmpi;
00407   if(r.Get("MinTrigPlane",tmpi)) fMinTrigPlane=tmpi;
00408   if(r.Get("MinTrigE4",tmpi)) fMinTrigE4=tmpi;
00409   if(r.Get("MinTrigActivity",tmpi)) fMinTrigActivity=tmpi;
00410   if(r.Get("MinTrigSpill",tmpi)) fMinTrigSpill=tmpi;
00411   if(r.Get("MinTrigSpillIP",tmpi)) fMinTrigSpillIP=tmpi;
00412 
00413   if(r.Get("MFileName",tmps)) fMFileName=tmps;
00414   if(r.Get("MFileDir",tmps)) fMFileDir=tmps;
00415   if(r.Get("MonthlyMFileDir",tmpi)) fMonthlyMFileDir=static_cast<bool>(tmpi);
00416   if(r.Get("AppendMFile",tmpi)) fAppendMFile=static_cast<bool>(tmpi);
00417 
00418   if(r.Get("SFileName",tmps)) fSFileName=tmps;
00419   if(r.Get("SFileDir",tmps)) fSFileDir=tmps;
00420   if(r.Get("MonthlySFileDir",tmpi)) fMonthlySFileDir=static_cast<bool>(tmpi);
00421   if(r.Get("AppendSFile",tmpi)) fAppendSFile=static_cast<bool>(tmpi);
00422 
00423   if (r.Get("MonthlyDir",tmpi)) {
00424     fMonthlyMFileDir=static_cast<bool>(tmpi);
00425     fMonthlySFileDir=static_cast<bool>(tmpi);
00426   }
00427 
00428   if (r.Get("AppendFiles",tmpi)) {
00429     fAppendMFile=static_cast<bool>(tmpi);
00430     fAppendSFile=static_cast<bool>(tmpi);
00431   }
00432 
00433   if(!fAppendMFile) fMFileOutMode = ios::out;
00434   else fMFileOutMode = ios::out | ios::app;
00435 
00436   if(!fAppendSFile) fSFileOutMode = ios::out;
00437   else fSFileOutMode = ios::out | ios::app;
00438 }

00363 {
00364   RSMSyn << "FarmListModule::DefaultConfig" << endl;
00365 
00366   static Registry r;
00367 
00368   string name = this->JobCModule::GetName();
00369   r.SetName((name+".config.default").c_str());
00370   r.UnLockValues();
00371 
00372   r.Set("MinSecond",10);
00373 
00374   r.Set("MinSnarl",0);
00375   r.Set("MinTrigPlane",0);
00376   r.Set("MinTrigE4",0);
00377   r.Set("MinTrigActivity",0);
00378   r.Set("MinTrigSpill",0);
00379   r.Set("MinTrigSpillIP",0);
00380 
00381   r.Set("MFileName","summary.mail");
00382   r.Set("MFileDir","./");
00383   r.Set("MonthlyMFileDir",0);
00384   r.Set("AppendMFile",1);
00385 
00386   r.Set("SFileName","summary.simple");
00387   r.Set("SFileDir","./");
00388   r.Set("MonthlySFileDir",0);
00389   r.Set("AppendSFile",1);
00390 
00391   r.Set("MonthlyDir",0);
00392   r.Set("AppendFiles",1);
00393 
00394   r.LockValues();
00395 
00396   return r;
00397 }

00354 {
00355   RSMSyn << "FarmListModule::EndJob" << endl;
00356 
00357   RSMDeb << "Final output in EndJob: " << fRun
00358          << "-" << fSubRun << endl;
00359   FarmFileOUT();
00360 }

00077 {
00078   RSMDeb << "FarmListModule::FarmFileOUT" << endl;
00079 
00080   if (fRunOUT) {
00081     RSMErr << "Multiple output attempt for: " <<
00082       fRun << "-" << fSubRun << endl;
00083     return;
00084   }
00085 
00086   if (fRun==0 && fSubRun==0) {
00087     RSMDeb << "Output attempt for: " <<
00088       fRun << "-" << fSubRun << endl;
00089     return;
00090   }
00091 
00092   Bool_t Passed = true;
00093 
00094   UInt_t SecondsPassed = fEndTime.GetSec() - fStartTime.GetSec();
00095   Passed = Passed && (SecondsPassed>=fMinSecond);
00096   Passed = Passed && (fNSnarl>=fMinSnarl);
00097   Passed = Passed && (fNTrigPlane>=fMinTrigPlane);
00098   Passed = Passed && (fNTrigActivity>=fMinTrigActivity);
00099   Passed = Passed && (fNTrigE4>=fMinTrigE4);
00100   Passed = Passed && (fNTrigSpill>=fMinTrigSpill);
00101   Passed = Passed && (fNTrigSpillIP>=fMinTrigSpillIP);
00102 
00103   Int_t Year = fEndTime.GetDate()/10000;
00104   Int_t Month = fEndTime.GetDate()/100 - 100*Year;
00105 
00106   if (fMFileName != "") {
00107     string fdir = fMFileDir;
00108     if(fMonthlyMFileDir) fdir += Form("/%04d_%02d/", Year, Month);
00109     if(!UtilRSM::CheckDir(fdir.c_str())) exit(0);
00110 
00111     string fname = fMFileName;
00112     if(!Passed) fname += ".sup";
00113 
00114     ofstream fout((fdir+fname).c_str(), fMFileOutMode);
00115 
00116     RSMInf << "Writing to " << fname << " in " << fdir << endl;
00117 
00118     ostringstream ThisLine;
00119     if (fDet==Detector::kFar) {
00120       fout << Form("F%08d_%04d", fRun, fSubRun) << "  "
00121            << Form("% 4d-%02d", Year, Month)
00122            << Form("% 8d", fNSnarl)
00123            << Form("% 5d", fMaxPlane[0]) << endl;
00124     }
00125     else if(fDet==Detector::kNear) {
00126       fout << Form("N%08d_%04d", fRun, fSubRun) << "  "
00127            << Form("% 4d-%02d", Year, Month)
00128            << Form("% 8d", fNSnarl) << endl;
00129     }
00130     else {
00131       RSMWar << "Can't use this detector: " 
00132              << Detector::AsString(fDet) << endl;
00133       return;
00134     }
00135 
00136     if (SecondsPassed < fMinSecond) {
00137       fout << "  Failed MinSeconds >= " << fMinSecond
00138            << " with " << SecondsPassed << endl;
00139     }
00140     if (fNSnarl < fMinSnarl) {
00141       fout << "  Failed MinSnarl >= " << fMinSnarl
00142            << " with " << fNSnarl << endl;
00143     }
00144     if (fNTrigPlane < fMinTrigPlane) {
00145       fout << "  Failed MinTrigPlane >= " << fMinTrigPlane
00146            << " with " << fNTrigPlane << endl;
00147     }
00148     if (fNTrigActivity < fMinTrigActivity) {
00149       fout << "  Failed MinTrigActivity >= " << fMinTrigActivity
00150            << " with " << fNTrigActivity << endl;
00151     }
00152     if (fNTrigE4 < fMinTrigE4) {
00153       fout << "  Failed MinTrigE4 >= " << fMinTrigE4
00154            << " with " << fNTrigE4 << endl;
00155     }
00156     if (fNTrigSpill < fMinTrigSpill) {
00157       fout << "  Failed MinTrigSpill >= " << fMinTrigSpill
00158            << " with " << fNTrigSpill << endl;
00159     }
00160     if (fNTrigSpillIP < fMinTrigSpillIP) {
00161       fout << "  Failed MinTrigSpillIP >= " << fMinTrigSpillIP
00162            << " with " << fNTrigSpillIP << endl;
00163     }
00164 
00165     fout.close();
00166   }
00167 
00168   if (fSFileName != "") {
00169     string fdir = fSFileDir;
00170     if(fMonthlySFileDir) fdir += Form("/%04d_%02d/", Year, Month);
00171     if(!UtilRSM::CheckDir(fdir.c_str())) exit(0);
00172 
00173     string fname = fSFileName;
00174     if(!Passed) fname += ".sup";
00175 
00176     ofstream fout((fdir+fname).c_str(), fSFileOutMode);
00177 
00178     RSMInf << "Writing to " << fname << " in " << fdir << endl;
00179 
00180     ostringstream ThisLine;
00181     if (fDet==Detector::kFar) {
00182       fout << Form("F%08d_%04d", fRun, fSubRun) << "  "
00183            << Form("% 4d-%02d", Year, Month) << endl;
00184     }
00185     else if(fDet==Detector::kNear) {
00186       fout << Form("N%08d_%04d", fRun, fSubRun) << "  "
00187            << Form("% 4d-%02d", Year, Month) << endl;
00188     }
00189     else {
00190       RSMWar << "Can't use this detector: " 
00191              << Detector::AsString(fDet) << endl;
00192       return;
00193     }
00194 
00195     fout.close();
00196   }
00197 
00198   RSMDeb << "--Counters-- (" << SecondsPassed << " seconds)" << endl
00199          << "  NSnarl: " << fNSnarl << endl
00200          << "  NTrigPlane: " << fNTrigPlane << endl
00201          << "  NTrigActivity: " << fNTrigActivity << endl
00202          << "  NTrigE4: " << fNTrigE4 << endl
00203          << "  NTrigSpill: " << fNTrigSpill << endl
00204          << "  NTrigSpillIP: " << fNTrigSpillIP << endl;
00205 
00206   fNTrigPlane = 0;
00207   fNTrigActivity = 0;
00208   fNTrigE4 = 0;
00209   fNTrigSpill = 0;
00210   fNTrigSpillIP = 0;
00211 
00212   fNSnarl = 0;
00213   fMaxPlane[0] = 0;
00214   fMaxPlane[1] = 0;
00215   fMaxPlane[2] = 0;
00216 
00217   fRunOUT = true;
00218   return;
00219 }

FarmListModule Class Reference

Public Member Functions

Private Member Functions

Private Attributes

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation


Public Member Functions
	FarmListModule ()
	~FarmListModule ()
JobCResult	Ana (const MomNavigator *mom)
void	BeginJob ()
void	EndJob ()
const Registry &	DefaultConfig () const
void	Config (const Registry &r)
Private Member Functions
void	FarmFileOUT ()
Private Attributes
Int_t	fRun
Short_t	fSubRun
Int_t	fMaxPlane [3]
UInt_t	fNSnarl
UInt_t	fNTrigPlane
UInt_t	fNTrigActivity
UInt_t	fNTrigE4
UInt_t	fNTrigSpill
UInt_t	fNTrigSpillIP
VldTimeStamp	fStartTime
VldTimeStamp	fEndTime
Detector::Detector_t	fDet
Bool_t	fRunOUT
UInt_t	fMinSecond
UInt_t	fMinSnarl
UInt_t	fMinTrigPlane
UInt_t	fMinTrigActivity
UInt_t	fMinTrigE4
UInt_t	fMinTrigSpill
UInt_t	fMinTrigSpillIP
std::string	fMFileName
std::string	fMFileDir
Bool_t	fMonthlyMFileDir
Bool_t	fAppendMFile
std::ios_base::openmode	fMFileOutMode
std::string	fSFileName
std::string	fSFileDir
Bool_t	fMonthlySFileDir
Bool_t	fAppendSFile
std::ios_base::openmode	fSFileOutMode