o add Reset function to CalPad and CalROC o Add functionality to AliTPCdataQA - Reset...
[u/mrichter/AliRoot.git] / MUON / AliMUONRawStreamTrigger.cxx
CommitLineData
972432c1 1/**************************************************************************
2 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
3 * *
4 * Author: The ALICE Off-line Project. *
5 * Contributors are mentioned in the code where appropriate. *
6 * *
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 **************************************************************************/
15
bf4d93eb 16/* $Id$ */
972432c1 17
3d1463c8 18//-----------------------------------------------------------------------------
c4ee792d 19/// \class AliMUONRawStreamTrigger
972432c1 20/// This class provides access to MUON digits in raw data.
21///
22/// It loops over all MUON digits in the raw data given by the AliRawReader.
b921196a 23/// The Next method goes to the next local response. If there are no local response left
24/// it returns kFALSE.
972432c1 25/// It can loop also over DDL and store the decoded rawdata in TClonesArrays
313a427d 26/// in payload class.
972432c1 27///
b921196a 28/// Version implement for Trigger
c4ee792d 29/// \author Christian Finck
3d1463c8 30//-----------------------------------------------------------------------------
972432c1 31
b921196a 32#include <TArrayS.h>
33
972432c1 34#include "AliMUONRawStreamTrigger.h"
b921196a 35#include "AliMUONDarcHeader.h"
36#include "AliMUONRegHeader.h"
37#include "AliMUONLocalStruct.h"
38#include "AliMUONDDLTrigger.h"
39#include "AliMUONLogger.h"
972432c1 40
41#include "AliRawReader.h"
42#include "AliRawDataHeader.h"
9527c389 43#include "AliRawDataHeaderV3.h"
9e378ff4 44#include "AliDAQ.h"
972432c1 45#include "AliLog.h"
46
b921196a 47#include <cassert>
48
00e86732 49/// \cond CLASSIMP
972432c1 50ClassImp(AliMUONRawStreamTrigger)
00e86732 51/// \endcond
972432c1 52
36f90a1a 53const Int_t AliMUONRawStreamTrigger::fgkMaxDDL = 2;
07a5b6b7 54
55//___________________________________________
ce350193 56AliMUONRawStreamTrigger::AliMUONRawStreamTrigger(TRootIOCtor* /*dummy*/)
57: AliMUONVRawStreamTrigger(),
58fPayload(0x0),
59fCurrentDDL(0x0),
60fCurrentDDLIndex(fgkMaxDDL),
61fCurrentDarcHeader(0x0),
62fCurrentRegHeader(0x0),
63fCurrentRegHeaderIndex(0),
64fCurrentLocalStruct(0x0),
65fCurrentLocalStructIndex(0),
66fLocalStructRead(kFALSE),
67fDDL(0),
68fNextDDL(kFALSE)
69{
70 ///
71 /// create an object to read MUON raw digits
72 /// Default ctor with no mem allocation for I/O
73 ///
74}
75
76//___________________________________________
972432c1 77AliMUONRawStreamTrigger::AliMUONRawStreamTrigger()
1788245f 78: AliMUONVRawStreamTrigger(),
9f5dcca3 79 fPayload(new AliMUONPayloadTrigger()),
b921196a 80 fCurrentDDL(0x0),
81 fCurrentDDLIndex(fgkMaxDDL),
82 fCurrentDarcHeader(0x0),
83 fCurrentRegHeader(0x0),
84 fCurrentRegHeaderIndex(0),
85 fCurrentLocalStruct(0x0),
86 fCurrentLocalStructIndex(0),
87 fLocalStructRead(kFALSE),
4a3224ff 88 fDDL(0),
9ee1d6ff 89 fNextDDL(kFALSE)
972432c1 90{
00e86732 91 ///
92 /// create an object to read MUON raw digits
93 /// Default ctor for monitoring purposes
94 ///
972432c1 95
972432c1 96
97}
98
99//_________________________________________________________________
100AliMUONRawStreamTrigger::AliMUONRawStreamTrigger(AliRawReader* rawReader)
1788245f 101 : AliMUONVRawStreamTrigger(rawReader),
9f5dcca3 102 fPayload(new AliMUONPayloadTrigger()),
b921196a 103 fCurrentDDL(0x0),
104 fCurrentDDLIndex(fgkMaxDDL),
105 fCurrentDarcHeader(0x0),
106 fCurrentRegHeader(0x0),
107 fCurrentRegHeaderIndex(0),
108 fCurrentLocalStruct(0x0),
109 fCurrentLocalStructIndex(0),
110 fLocalStructRead(kFALSE),
4a3224ff 111 fDDL(0),
9ee1d6ff 112 fNextDDL(kFALSE)
972432c1 113{
00e86732 114 ///
115 /// ctor with AliRawReader as argument
116 /// for reconstruction purpose
117 ///
972432c1 118
972432c1 119}
120
121//___________________________________
122AliMUONRawStreamTrigger::~AliMUONRawStreamTrigger()
123{
00e86732 124 ///
125 /// clean up
126 ///
313a427d 127 delete fPayload;
972432c1 128}
129
130//_____________________________________________________________
b921196a 131Bool_t AliMUONRawStreamTrigger::Next(UChar_t& id, UChar_t& dec, Bool_t& trigY,
132 UChar_t& yPos, UChar_t& sXDev, UChar_t& xDev,
133 UChar_t& xPos, Bool_t& triggerY, Bool_t& triggerX,
134 TArrayS& xPattern, TArrayS& yPattern)
135{
136 ///
137 /// read the next raw digit (local structure)
138 /// returns kFALSE if there is no digit left
139 /// Should call First() before this method to start the iteration.
140 ///
141
142 if ( IsDone() ) return kFALSE;
143
144 if ( fLocalStructRead ) {
145
146 Bool_t ok = GetNextLocalStruct();
147 if (!ok)
148 {
149 // this is the end
150 return kFALSE;
151 }
152 }
153
154 fLocalStructRead = kTRUE;
155
156 id = fCurrentLocalStruct->GetId();
157 dec = fCurrentLocalStruct->GetDec();
158 trigY = fCurrentLocalStruct->GetTrigY();
159 yPos = fCurrentLocalStruct->GetYPos();
160 sXDev = fCurrentLocalStruct->GetSXDev();
161 xDev = fCurrentLocalStruct->GetXDev();
162 xPos = fCurrentLocalStruct->GetXPos();
163
164 triggerX = fCurrentLocalStruct->GetTriggerX();
165 triggerY = fCurrentLocalStruct->GetTriggerY();
166
167 fCurrentLocalStruct->GetXPattern(xPattern);
168 fCurrentLocalStruct->GetYPattern(yPattern);
169
170 return kTRUE;
171}
172
173//______________________________________________________
174Bool_t AliMUONRawStreamTrigger::IsDone() const
972432c1 175{
b921196a 176 /// Whether the iteration is finished or not
177 return (fCurrentLocalStruct==0);
178}
179
180//______________________________________________________
181void AliMUONRawStreamTrigger::First()
182{
183 /// Initialize the iteration process.
184
185 fCurrentDDLIndex = -1;
186 // Must reset all the pointers because if we return before calling
187 // GetNextLocalStruct() the user might call CurrentDDL(), CurrentBlockHeader(),
188 // CurrentRegHeader() or CurrentLocalStruct() which should return reasonable
189 // results in that case.
190 fCurrentDDL = 0;
191 fCurrentDarcHeader = 0;
192 fCurrentRegHeader = 0;
193 fCurrentLocalStruct = 0;
194
195 // Find the first non-empty structure
196 if (not GetNextDDL()) return;
197 if (not GetNextRegHeader()) return;
198 GetNextLocalStruct();
199}
200
201//______________________________________________________
202Bool_t AliMUONRawStreamTrigger::GetNextDDL()
203{
204 /// Returns the next DDL present
205
206 assert( GetReader() != 0 );
f4ee80d2 207
b921196a 208
209 Bool_t kFound(kFALSE);
210
211 while ( fCurrentDDLIndex < fgkMaxDDL-1 && !kFound )
212 {
213 ++fCurrentDDLIndex;
214 GetReader()->Reset();
215 GetReader()->Select("MUONTRG",fCurrentDDLIndex,fCurrentDDLIndex);
216 if ( GetReader()->ReadHeader() )
217 {
218 kFound = kTRUE;
219 }
220 }
221
222 if ( !kFound )
223 {
224 // fCurrentDDLIndex is set to fgkMaxDDL so that we exit the above loop immediately
225 // for a subsequent call to this method, unless NextEvent is called in between.
226 fCurrentDDLIndex = fgkMaxDDL;
227 // We have not actually been able to complete the loading of the new DDL so
228 // we are still on the old one. In this case we do not need to reset fCurrentDDL.
229 //fCurrentDDL = 0;
6817de1c 230 if (IsErrorLogger()) AddErrorMessage();
b921196a 231 return kFALSE;
232 }
233
234 Int_t totalDataWord = GetReader()->GetDataSize(); // in bytes
235
e9463054 236 AliRawReader * reader = GetReader();
237 if (!reader) return kFALSE;
238
239 const AliRawDataHeader * cdh = reader->GetDataHeader();
240 const AliRawDataHeaderV3 * cdh3 = reader->GetDataHeaderV3();
241
242 if (!cdh && !cdh3) return kFALSE;
243
244 Bool_t scalerEvent = ((cdh ? cdh->GetL1TriggerMessage() : cdh3->GetL1TriggerMessage()) & 0x1) == 0x1;
f4ee80d2 245
b921196a 246 AliDebug(3, Form("DDL Number %d totalDataWord %d\n", fCurrentDDLIndex,
247 totalDataWord));
248
249 UInt_t *buffer = new UInt_t[totalDataWord/4];
f4ee80d2 250
b921196a 251 if ( !GetReader()->ReadNext((UChar_t*)buffer, totalDataWord) )
252 {
253 // We have not actually been able to complete the loading of the new DDL so
254 // we are still on the old one. In this case we do not need to reset fCurrentDDL.
255 //fCurrentDDL = 0;
256 delete [] buffer;
257 return kFALSE;
258 }
259
260#ifndef R__BYTESWAP
47c48013 261 Swap(buffer, totalDataWord / sizeof(UInt_t)); // swap needed for mac power pc
b921196a 262#endif
263
264 fPayload->ResetDDL();
265
f4ee80d2 266
267
268 Bool_t ok = fPayload->Decode(buffer, scalerEvent);
b921196a 269
270 delete[] buffer;
271
272 fCurrentDDL = fPayload->GetDDLTrigger();
273
274 fCurrentDarcHeader = fCurrentDDL->GetDarcHeader();
275
276 fCurrentRegHeaderIndex = -1;
277
278
279 return ok;
280}
281
282
283//______________________________________________________
284Bool_t AliMUONRawStreamTrigger::GetNextRegHeader()
285{
286 /// Returns the next Reg Header present
287
288 assert( fCurrentDarcHeader != 0 );
289 assert( fCurrentDDL != 0 );
290
291 fCurrentRegHeader = 0;
292
293 Int_t i = fCurrentRegHeaderIndex;
294
295 while ( fCurrentRegHeader == 0 && i < fCurrentDarcHeader->GetRegHeaderEntries()-1 )
296 {
297 ++i;
298 fCurrentRegHeader = fCurrentDarcHeader->GetRegHeaderEntry(i);
299 }
300
301 if ( !fCurrentRegHeader )
302 {
303 Bool_t ok = GetNextDDL();
304 if (!ok)
305 {
306 return kFALSE;
307 }
308 else
309 {
310 return GetNextRegHeader();
311 }
312 }
313
314 fCurrentRegHeaderIndex = i;
315
316 fCurrentLocalStructIndex = -1;
317
318 return kTRUE;
319}
320
321//______________________________________________________
322Bool_t AliMUONRawStreamTrigger::GetNextLocalStruct()
323{
324 /// Find the next non-empty local structure
325
326 assert( fCurrentRegHeader != 0 );
327
328 fCurrentLocalStruct = 0;
329
330 Int_t i = fCurrentLocalStructIndex;
331
332 while ( fCurrentLocalStruct == 0 && i < fCurrentRegHeader->GetLocalEntries()-1 )
333 {
334 ++i;
335 fCurrentLocalStruct = fCurrentRegHeader->GetLocalEntry(i);
336 }
337
338 if ( !fCurrentLocalStruct )
339 {
340 Bool_t ok = GetNextRegHeader();
341 if (!ok)
342 {
343 return kFALSE;
344 }
345 else
346 {
347 return GetNextLocalStruct();
348 }
349 }
350
351 fCurrentLocalStructIndex = i;
352
353 fLocalStructRead = kFALSE;
354
355 return kTRUE;
972432c1 356}
357
358//______________________________________________________
359Bool_t AliMUONRawStreamTrigger::NextDDL()
360{
00e86732 361 /// reading tracker DDL
b921196a 362 /// store local info into Array
363 /// store only non-empty structures
972432c1 364
972432c1 365 // reset TClones
313a427d 366 fPayload->ResetDDL();
367
972432c1 368
369 // loop over the two ddl's
07a5b6b7 370
36f90a1a 371 while ( fDDL < fgkMaxDDL ) {
b921196a 372 GetReader()->Reset();
373 GetReader()->Select("MUONTRG", fDDL, fDDL); //Select the DDL file to be read
374 if (GetReader()->ReadHeader()) break;
07a5b6b7 375 AliDebug(3,Form("Skipping DDL %d which does not seem to be there",fDDL));
376 ++fDDL;
377 }
378
36f90a1a 379 if (fDDL >= fgkMaxDDL) {
972432c1 380 fDDL = 0;
6817de1c 381 if (IsErrorLogger()) AddErrorMessage();
972432c1 382 return kFALSE;
383 }
9e378ff4 384
07a5b6b7 385 AliDebug(3, Form("DDL Number %d\n", fDDL ));
972432c1 386
b921196a 387 Int_t totalDataWord = GetReader()->GetDataSize(); // in bytes
07a5b6b7 388
e9463054 389 AliRawReader * reader = GetReader();
390 if (!reader) return kFALSE;
391
392 const AliRawDataHeader * cdh = reader->GetDataHeader();
393 const AliRawDataHeaderV3 * cdh3 = reader->GetDataHeaderV3();
394
395 if (!cdh && !cdh3) return kFALSE;
396
397 Bool_t scalerEvent = ((cdh ? cdh->GetL1TriggerMessage() : cdh3->GetL1TriggerMessage()) & 0x1) == 0x1;
f4ee80d2 398
399
972432c1 400 UInt_t *buffer = new UInt_t[totalDataWord/4];
401
d6ac560d 402 // check not necessary yet, but for future developments
b921196a 403 if (!GetReader()->ReadNext((UChar_t*)buffer, totalDataWord)) return kFALSE;
972432c1 404
47c48013 405#ifndef R__BYTESWAP
406 Swap(buffer, totalDataWord / sizeof(UInt_t)); // swap needed for mac power pc
b921196a 407#endif
408
f4ee80d2 409 fPayload->Decode(buffer, scalerEvent);
6817de1c 410
972432c1 411
313a427d 412 fDDL++;
972432c1 413
972432c1 414 delete [] buffer;
415
ea59383d 416
972432c1 417 return kTRUE;
418}
419
bfbfa5da 420// //______________________________________________________
421// void AliMUONRawStreamTrigger::SetMaxReg(Int_t reg)
422// {
423// /// set regional card number
424// fPayload->SetMaxReg(reg);
425// }
972432c1 426
427//______________________________________________________
428void AliMUONRawStreamTrigger::SetMaxLoc(Int_t loc)
429{
00e86732 430 /// set local card number
313a427d 431 fPayload->SetMaxLoc(loc);
972432c1 432}
ea59383d 433
434//______________________________________________________
435void AliMUONRawStreamTrigger::AddErrorMessage()
436{
437/// add message into logger of AliRawReader per event
438
9b4aee57 439 TString msg;
b921196a 440 Int_t occurance = 0;
441 AliMUONLogger* log = fPayload->GetErrorLogger();
442
443 log->ResetItr();
444 while(log->Next(msg, occurance))
445 {
446 if (msg.Contains("Darc"))
447 GetReader()->AddMajorErrorLog(kDarcEoWErr, msg.Data());
ea59383d 448
b921196a 449 if (msg.Contains("Global"))
450 GetReader()->AddMajorErrorLog(kGlobalEoWErr, msg.Data());
ea59383d 451
b921196a 452 if (msg.Contains("Regional"))
453 GetReader()->AddMajorErrorLog(kRegEoWErr, msg.Data());
ea59383d 454
b921196a 455 if (msg.Contains("Local"))
456 GetReader()->AddMajorErrorLog(kLocalEoWErr, msg.Data());
457 }
6817de1c 458
459 log->Clear(); // clear after each event
ea59383d 460}