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