1 /**************************************************************************
2 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
4 * Author: The ALICE Off-line Project. *
5 * Contributors are mentioned in the code where appropriate. *
7 * Permission to use, copy, modify and distribute this software and its *
8 * documentation strictly for non-commercial purposes is hereby granted *
9 * without fee, provided that the above copyright notice appears in all *
10 * copies and that both the copyright notice and this permission notice *
11 * appear in the supporting documentation. The authors make no claims *
12 * about the suitability of this software for any purpose. It is *
13 * provided "as is" without express or implied warranty. *
14 **************************************************************************/
16 /* $Id: AliTriggerRunScalers.cxx 22322 2007-11-22 11:43:14Z cvetan $ */
18 ///////////////////////////////////////////////////////////////////////////////
20 // Class to define the ALICE Trigger Scalers Record per Run.
23 //////////////////////////////////////////////////////////////////////////////
25 #include <Riostream.h>
30 #include <TObjString.h>
31 #include <TObjArray.h>
36 #include "AliTimeStamp.h"
37 #include "AliTriggerScalers.h"
38 #include "AliTriggerScalersRecord.h"
39 #include "AliTriggerRunScalers.h"
40 #include "AliCDBEntry.h"
41 #include "AliCDBManager.h"
42 #include "AliCDBStorage.h"
44 ClassImp( AliTriggerRunScalers )
46 //_____________________________________________________________________________
47 AliTriggerRunScalers::AliTriggerRunScalers():
55 // Default constructor
58 //_____________________________________________________________________________
59 void AliTriggerRunScalers::AddTriggerScalers( AliTriggerScalersRecord* scaler )
62 fScalersRecord.AddLast( scaler );
63 if (!AliTriggerRunScalers::ConsistencyCheck()) AliErrorClass("Trigger counters not in the right order or decreasing!");
64 // fScalersRecord.Sort();
67 //_____________________________________________________________________________
68 AliTriggerRunScalers* AliTriggerRunScalers::ReadScalers( TString & filename )
71 if( gSystem->AccessPathName( filename.Data() ) ) {
72 AliErrorClass( Form( "file (%s) not found", filename.Data() ) );
76 ifstream *file = new ifstream ( filename.Data() );
78 AliErrorClass(Form("Error opening file (%s) !\n",filename.Data()));
84 AliTriggerRunScalers* rScaler = new AliTriggerRunScalers();
87 Bool_t verflag = kFALSE;
88 Bool_t classflag = kFALSE;
90 while (strLine.ReadLine(*file)) {
91 if (strLine.BeginsWith("#")) continue;
93 TObjArray *tokens = strLine.Tokenize(" \t");
94 Int_t ntokens = tokens->GetEntriesFast();
95 // 1st line, version, it is one number,
98 AliErrorClass( Form( "Error reading version number from (%s), line :%s\n",
99 filename.Data() , strLine.Data() ) );
102 // cout << "Version "<< ((TObjString*)tokens->At(0))->String().Atoi() << endl;
103 rScaler->SetVersion( ((TObjString*)tokens->At(0))->String().Atoi() );
109 // 2nd line, run number , number of classes, list of classes used in this partition
112 if ( !((TObjString*)tokens->At(1))->String().IsDigit() ) {
113 AliErrorClass( Form( "Error reading Run number from (%s)\n", filename.Data() ));
115 // cout << "Run Number " << ((TObjString*)tokens->At(0))->String().Atoi() << endl;
116 rScaler->SetRunNumber( ((TObjString*)tokens->At(0))->String().Atoi() );
117 nclass = (UChar_t)((TObjString*)tokens->At(1))->String().Atoi();
118 // cout << "Number of classes " << nclass << endl;
119 rScaler->SetNumClasses( nclass );
120 if ( nclass != ntokens - 2 ) {
121 AliErrorClass( Form( "Error reading number of classes from (%s)\n", filename.Data() ));
123 for (UChar_t i=0; i<nclass; ++i) {
124 rScaler->SetClass( i, (Char_t)((TObjString*)tokens->At(2+i))->String().Atoi() );
132 // Each record consists of 1+(number of classes in partition) lines
133 // 1st line of record = time stamp (4 words)
134 // 1st word = ORBIT(24 bits)
135 // 2nd word = Period Counter (28 bit)
136 // 3rd word = seconds (32 bits) from epoch
137 // 4th word = microsecs (32 bits)
138 // other lines = 6 words of counters (L0 before,L0 after, ....)
140 AliErrorClass( Form( "Error reading timestamp from (%s): line (%s)",
141 filename.Data(), strLine.Data() ));
145 UInt_t orbit = strtoul(((TObjString*)tokens->At(0))->String(), NULL, 10);
146 UInt_t period = strtoul(((TObjString*)tokens->At(1))->String(), NULL, 10);
147 UInt_t seconds = strtoul(((TObjString*)tokens->At(2))->String(), NULL, 10);
148 UInt_t microSecs = strtoul(((TObjString*)tokens->At(3))->String(), NULL, 10);
150 AliTriggerScalersRecord * rec = new AliTriggerScalersRecord();
151 rec->SetTimeStamp( orbit, period, seconds, microSecs );
153 for (Int_t i=0; i<nclass; ++i) {
154 strLine1.ReadLine(*file);
155 if (strLine1.BeginsWith("#")) continue;
156 TObjArray *tokens1 = strLine1.Tokenize(" \t");
157 Int_t ntokens1 = tokens1->GetEntriesFast();
158 if( ntokens1 != 6 ) {
159 AliErrorClass( Form( "Error reading scalers from (%s): line (%s)",
160 filename.Data(), strLine1.Data() ));
164 UInt_t LOCB = strtoul(((TObjString*)tokens1->At(0))->String(), NULL, 10);
165 UInt_t LOCA = strtoul(((TObjString*)tokens1->At(1))->String(), NULL, 10);
166 UInt_t L1CB = strtoul(((TObjString*)tokens1->At(2))->String(), NULL, 10);
167 UInt_t L1CA = strtoul(((TObjString*)tokens1->At(3))->String(), NULL, 10);
168 UInt_t L2CB = strtoul(((TObjString*)tokens1->At(4))->String(), NULL, 10);
169 UInt_t L2CA = strtoul(((TObjString*)tokens1->At(5))->String(), NULL, 10);
171 rScaler->GetClass(i);
172 rec->AddTriggerScalers( rScaler->GetClass(i),
177 rScaler->AddTriggerScalers( rec );
187 //_____________________________________________________________________________
188 Int_t AliTriggerRunScalers::FindNearestScalersRecord( AliTimeStamp * stamp )
190 // Find Trigger scaler record with the closest timestamp <= "stamp"
191 // using a binary search.
192 // return the index in the array of records, if the timestamp
193 // is out of range return -1
195 Int_t base, position=-1, last, result = 0;
196 AliTimeStamp *op2 = NULL;
198 fScalersRecord.Sort();
201 last = fScalersRecord.GetEntriesFast();
203 while (last >= base) {
204 position = (base+last) / 2;
205 cout << "pos " << position<< " base " << base << "last " << last << endl;
206 AliTriggerScalersRecord* rec = (AliTriggerScalersRecord*)fScalersRecord.At(position);
207 if( rec ) op2 = rec->GetTimeStamp();
208 if( op2 && (result = stamp->Compare(op2)) == 0 )
209 return position; // exact match
210 cout << "result " << result << " op2 " << op2 << " rec "<< rec << endl;
211 if (!op2 || result < 0)
217 if( (position == 0 && result < 0) || position >= fScalersRecord.GetEntriesFast() )
218 return -1; // out of range
220 return (result < 0 ) ? position-1 : position; // nearst < stamp
222 //_____________________________________________________________________________
223 Bool_t AliTriggerRunScalers::ConsistencyCheck()
226 UInt_t LOCB_2, LOCA_2, L1CB_2, L1CA_2, L2CB_2, L2CA_2, LOCB_1, LOCA_1, L1CB_1, L1CA_1, L2CB_1, L2CA_1;
227 char *LOCBstat = "NULL", *LOCAstat = "NULL", *L1CBstat = "NULL", *L1CAstat = "NULL", *L2CBstat = "NULL", *L2CAstat = "NULL";
228 Int_t position = fScalersRecord.GetEntriesFast()-1;
230 if (position == 0) return 1;
232 AliTriggerScalersRecord* Scalers2 = (AliTriggerScalersRecord*)fScalersRecord.At(position);
233 AliTriggerScalersRecord* Scalers1 = (AliTriggerScalersRecord*)fScalersRecord.At(position-1);
234 if (Scalers2->Compare((AliTriggerScalersRecord*)fScalersRecord.At(position-1)) == -1) return 0;
235 else for( Int_t i=0; i<fnClasses; ++i ){
237 TObjArray* ScalersArray2 = (TObjArray*)Scalers2->GetTriggerScalers();
238 AliTriggerScalers* counters2 = (AliTriggerScalers*)ScalersArray2->At(i);
239 LOCB_2 = counters2->GetLOCB();
240 LOCA_2 = counters2->GetLOCA();
241 L1CB_2 = counters2->GetL1CB();
242 L1CA_2 = counters2->GetL1CA();
243 L2CB_2 = counters2->GetL2CB();
244 L2CA_2 = counters2->GetL2CA();
246 TObjArray* ScalersArray1 = (TObjArray*)Scalers1->GetTriggerScalers();
247 AliTriggerScalers* counters1 = (AliTriggerScalers*)ScalersArray1->At(i);
248 LOCB_1 = counters1->GetLOCB();
249 LOCA_1 = counters1->GetLOCA();
250 L1CB_1 = counters1->GetL1CB();
251 L1CA_1 = counters1->GetL1CA();
252 L2CB_1 = counters1->GetL2CB();
253 L2CA_1 = counters1->GetL2CA();
255 if ( LOCB_2 > LOCB_1 ) LOCBstat = "increase";
256 else if ( LOCB_2 < LOCB_1 && (LOCB_1 - LOCB_2) > 1000000000) LOCBstat = "overflow";
259 if ( LOCA_2 > LOCA_1 ) LOCAstat = "increase";
260 else if ( LOCA_2 < LOCA_1 && (LOCA_1 - LOCA_2) > 1000000000) LOCAstat = "overflow";
263 if ( L1CB_2 > L1CB_1 ) L1CBstat = "increase";
264 else if ( L1CB_2 < L1CB_1 && (L1CB_1 - L1CB_2) > 1000000000) L1CBstat = "overflow";
267 if ( L1CA_2 > L1CA_1 ) L1CAstat = "increase";
268 else if ( L1CA_2 < L1CA_1 && (L1CA_1 - L1CA_2) > 1000000000) L1CAstat = "overflow";
271 if ( L2CB_2 > L2CB_1 ) L2CBstat = "increase";
272 else if ( L2CB_2 < L2CB_1 && (L2CB_1 - L2CB_2) > 1000000000) L2CBstat = "overflow";
275 if ( L2CA_2 > L2CA_1 ) L2CAstat = "increase";
276 else if ( L2CA_2 < L2CA_1 && (L2CA_1 - L2CA_2) > 1000000000) L2CAstat = "overflow";
280 if ( (LOCB_2 - LOCB_1) < (LOCA_2 - LOCA_1) && LOCBstat == "increase" && LOCAstat == "increase" ) return 0;
281 else if ( (4294967295ul - LOCB_1 + LOCB_2 ) < (LOCA_2 - LOCA_1) && LOCBstat == "overflow" && LOCAstat == "increase" ) return 0;
282 else if ( (LOCB_2 - LOCB_1) < (4294967295ul - LOCA_1 + LOCA_2) && LOCBstat == "increase" && LOCAstat == "overflow" ) return 0;
283 else if ( (4294967295ul - LOCB_1 + LOCB_2 ) < (4294967295ul - LOCA_1 + LOCA_2) && LOCBstat == "overflow" && LOCAstat == "overflow" ) return 0;
285 if ( (LOCA_2 - LOCA_1) < (L1CB_2 - L1CB_1) && LOCAstat == "increase" && L1CBstat == "increase" ) return 0;
286 else if ( (4294967295ul - LOCA_1 + LOCA_2 ) < (L1CB_2 - L1CB_1) && LOCAstat == "overflow" && L1CBstat == "increase" ) return 0;
287 else if ( (LOCA_2 - LOCA_1) < (4294967295ul - L1CB_1 + L1CB_2) && LOCAstat == "increase" && L1CBstat == "overflow" ) return 0;
288 else if ( (4294967295ul - LOCA_1 + LOCA_2 ) < (4294967295ul - L1CB_1 + L1CB_2) && LOCAstat == "overflow" && L1CBstat == "overflow" ) return 0;
290 if ( (L1CB_2 - L1CB_1) < (L1CA_2 - L1CA_1) && L1CBstat == "increase" && L1CAstat == "increase" ) return 0;
291 else if ( (4294967295ul - L1CB_1 + L1CB_2 ) < (L1CA_2 - L1CA_1) && L1CBstat == "overflow" && L1CAstat == "increase" ) return 0;
292 else if ( (L1CB_2 - L1CB_1) < (4294967295ul - L1CA_1 + L1CA_2) && L1CBstat == "increase" && L1CAstat == "overflow" ) return 0;
293 else if ( (4294967295ul - L1CB_1 + L1CB_2 ) < (4294967295ul - L1CA_1 + L1CA_2) && L1CBstat == "overflow" && L1CAstat == "overflow" ) return 0;
295 if ( (L1CA_2 - L1CA_1) < (L2CB_2 - L2CB_1) && L1CAstat == "increase" && L2CBstat == "increase" ) return 0;
296 else if ( (4294967295ul- L1CA_1 + L1CA_2 ) < (L2CB_2 - L2CB_1) && L1CAstat == "overflow" && L2CBstat == "increase" ) return 0;
297 else if ( (L1CA_2 - L1CA_1) < (4294967295ul- L2CB_1 + L2CB_2) && L1CAstat == "increase" && L2CBstat == "overflow" ) return 0;
298 else if ( (4294967295ul- L1CA_1 + L1CA_2 ) < (4294967295ul- L2CB_1 + L2CB_2) && L1CAstat == "overflow" && L2CBstat == "overflow" ) return 0;
300 if ( (L2CB_2 - L2CB_1) < (L2CA_2 - L2CA_1) && L2CBstat == "increase" && L2CAstat == "increase" ) return 0;
301 else if ( (4294967295ul- L2CB_1 + L2CB_2 ) < (L2CA_2 - L2CA_1) && L2CBstat == "overflow" && L2CAstat == "increase" ) return 0;
302 else if ( (L2CB_2 - L2CB_1) < (4294967295ul- L2CA_1 + L2CA_2) && L2CBstat == "increase" && L2CAstat == "overflow" ) return 0;
303 else if ( (4294967295ul- L2CB_1 + L2CB_2 ) < (4294967295ul- L2CA_1 + L2CA_2) && L2CBstat == "overflow" && L2CAstat == "overflow" ) return 0;
308 cout<<"LOCB_1 =" << LOCB_1 <<" LOCB_2="<<LOCB_2<<endl;
309 if ( L1CB_2 < L1CB_1 || L1CA_2 < L1CA_1 || L2CB_2 < L2CB_1 || L2CA_2 < L2CA_1) return 0;
310 else if ( LOCB_2 < LOCB_1 && ((LOCB_1 - LOCB_2) < 1000000000) ) return 0;//verify this number with Roman!
316 //_____________________________________________________________________________
317 void AliTriggerRunScalers::Print( const Option_t* ) const
320 cout << "Trigger Scalers Record per Run: " << endl;
321 cout << " File version :" << fVersion << endl;
322 cout << " Run Number :" << fRunNumber << endl;
323 cout << " Number of Classes :" << (Int_t)fnClasses << endl;
324 cout << " Classes ID:";
325 for( Int_t i=0; i<fnClasses; ++i )
326 cout << " " << (Int_t)fClassIndex[i];
329 for( Int_t i=0; i<fScalersRecord.GetEntriesFast(); ++i )
330 ((AliTriggerScalersRecord*)fScalersRecord.At(i))->Print();