//_____________________________________________________________________________
AliAltroRawStream::AliAltroRawStream(const AliAltroRawStream& stream) :
TObject(stream),
- fNoAltroMapping(kTRUE),
- fIsOldRCUFormat(kFALSE),
- fIsShortDataHeader(kFALSE),
- fDDLNumber(-1),
- fPrevDDLNumber(-1),
- fRCUId(-1),
- fPrevRCUId(-1),
- fHWAddress(-1),
- fPrevHWAddress(-1),
- fTime(-1),
- fPrevTime(-1),
- fSignal(-1),
- fTimeBunch(-1),
- fRawReader(NULL),
- fData(NULL),
- fPosition(0),
- fCount(0),
- fBunchLength(0),
- fRCUTrailerData(NULL),
- fRCUTrailerSize(0)
+ fNoAltroMapping(stream.fNoAltroMapping),
+ fIsOldRCUFormat(stream.fIsOldRCUFormat),
+ fIsShortDataHeader(stream.fIsShortDataHeader),
+ fDDLNumber(stream.fDDLNumber),
+ fPrevDDLNumber(stream.fPrevDDLNumber),
+ fRCUId(stream.fRCUId),
+ fPrevRCUId(stream.fPrevRCUId),
+ fHWAddress(stream.fHWAddress),
+ fPrevHWAddress(stream.fPrevHWAddress),
+ fTime(stream.fTime),
+ fPrevTime(stream.fPrevTime),
+ fSignal(stream.fSignal),
+ fTimeBunch(stream.fTimeBunch),
+ fRawReader(stream.fRawReader),
+ fData(stream.fData),
+ fPosition(stream.fPosition),
+ fCount(stream.fCount),
+ fBunchLength(stream.fBunchLength),
+ fRCUTrailerData(stream.fRCUTrailerData),
+ fRCUTrailerSize(stream.fRCUTrailerSize)
{
- Fatal("AliAltroRawStream", "copy constructor not implemented");
+ fSegmentation[0] = stream.fSegmentation[0];
+ fSegmentation[1] = stream.fSegmentation[1];
+ fSegmentation[2] = stream.fSegmentation[2];
}
//_____________________________________________________________________________
-AliAltroRawStream& AliAltroRawStream::operator = (const AliAltroRawStream&
- /* stream */)
+AliAltroRawStream& AliAltroRawStream::operator = (const AliAltroRawStream& stream)
{
- Fatal("operator =", "assignment operator not implemented");
+ if(&stream == this) return *this;
+
+ fNoAltroMapping = stream.fNoAltroMapping;
+ fIsOldRCUFormat = stream.fIsOldRCUFormat;
+ fIsShortDataHeader = stream.fIsShortDataHeader;
+ fDDLNumber = stream.fDDLNumber;
+ fPrevDDLNumber = stream.fPrevDDLNumber;
+ fRCUId = stream.fRCUId;
+ fPrevRCUId = stream.fPrevRCUId;
+ fHWAddress = stream.fHWAddress;
+ fPrevHWAddress = stream.fPrevHWAddress;
+ fTime = stream.fTime;
+ fPrevTime = stream.fPrevTime;
+ fSignal = stream.fSignal;
+ fTimeBunch = stream.fTimeBunch;
+ fRawReader = stream.fRawReader;
+ fData = stream.fData;
+ fPosition = stream.fPosition;
+ fCount = stream.fCount;
+ fBunchLength = stream.fBunchLength;
+ fRCUTrailerData = stream.fRCUTrailerData;
+ fRCUTrailerSize = stream.fRCUTrailerSize;
+
+ fSegmentation[0] = stream.fSegmentation[0];
+ fSegmentation[1] = stream.fSegmentation[1];
+ fSegmentation[2] = stream.fSegmentation[2];
+
return *this;
}
fPosition = GetPosition();
}
- if (!ReadTrailer())
- AliFatal("Incorrect trailer information !");
+ ReadTrailer();
fBunchLength = 0;
}
UShort_t temp;
Int_t nFillWords = 0;
while ((temp = GetNextWord()) == 0x2AA) nFillWords++;
- if (nFillWords == 0)
- AliFatal("Incorrect trailer found ! Expected 0x2AA not found !");
+ if (nFillWords == 0) {
+ fRawReader->AddMajorErrorLog(kAltroTrailerErr,"no 0x2AA");
+ // PrintDebug();
+ AliWarning("Incorrect trailer found ! Expected 0x2AA not found !");
+ // trying to recover and find the next bunch
+ while ((fPosition > 5) && (temp != 0x2AA)) temp = GetNextWord();
+ if (temp != 0x2AA) {
+ fCount = fPosition = 0;
+ return kFALSE;
+ }
+ temp = GetNextWord();
+ }
//Then read the trailer
- if (fPosition <= 4)
- AliFatal(Form("Incorrect raw data size ! Expected at lest 4 words but found %d !",fPosition));
+ if (fPosition < 5) {
+ fRawReader->AddMajorErrorLog(kAltroTrailerErr,Form("size %d < 5",
+ fPosition));
+ // PrintDebug();
+ AliWarning(Form("Incorrect raw data size ! Expected at least 5 words but found %d !",fPosition));
+ fCount = fPosition = 0;
+ return kFALSE;
+ }
fCount = (temp << 4) & 0x3FF;
- if ((temp >> 6) != 0xA)
- AliFatal(Form("Incorrect trailer found ! Expecting 0xA but found %x !",temp >> 6));
+ if ((temp >> 6) != 0xA) {
+ fRawReader->AddMajorErrorLog(kAltroTrailerErr,"no 0xA");
+ // PrintDebug();
+ AliWarning(Form("Incorrect trailer found ! Expecting 0xA but found 0x%x !",temp >> 6));
+ fCount = 0;
+ return kFALSE;
+ }
temp = GetNextWord();
fHWAddress = (temp & 0x3) << 10;
- if (((temp >> 2) & 0xF) != 0xA)
- AliFatal(Form("Incorrect trailer found ! Expecting second 0xA but found %x !",(temp >> 2) & 0xF));
+ if (((temp >> 2) & 0xF) != 0xA) {
+ fRawReader->AddMajorErrorLog(kAltroTrailerErr,"no second 0xA");
+ // PrintDebug();
+ AliWarning(Form("Incorrect trailer found ! Expecting second 0xA but found 0x%x !",(temp >> 2) & 0xF));
+ fCount = 0;
+ return kFALSE;
+ }
fCount |= ((temp & 0x3FF) >> 6);
if (fCount == 0) return kFALSE;
-
+ if (fCount >= fPosition) {
+ fRawReader->AddMajorErrorLog(kAltroTrailerErr,"invalid size");
+ // PrintDebug();
+ AliWarning(Form("Incorrect trailer found ! The altro payload size is invalid (%d >= %d) !",fCount,fPosition));
+ fCount = 0;
+ return kFALSE;
+ }
temp = GetNextWord();
fHWAddress |= temp;
{
// Read altro payload in
// backward direction
- if (fPosition <= 0)
- AliFatal("Could not read bunch length !");
+ if (fCount <= 2) {
+ fRawReader->AddMinorErrorLog(kBunchLengthReadErr,"");
+ // PrintDebug();
+ AliWarning(Form("Could not read bunch length and time bin ! Only %d 10-bit words are left !",fCount));
+ fBunchLength = fTimeBunch = fCount = 0;
+ return;
+ }
fBunchLength = GetNextWord() - 2;
+ if (fBunchLength > fCount) {
+ fRawReader->AddMinorErrorLog(kBunchLengthReadErr,Form("bl=%d",fBunchLength));
+ // PrintDebug();
+ AliWarning(Form("Could not read bunch length ! Bunch length = %d (>%d)",fBunchLength,fCount));
+ fBunchLength = fTimeBunch = fCount = 0;
+ return;
+ }
fTimeBunch = fBunchLength;
fCount--;
- if (fPosition <= 0)
- AliFatal("Could not read time bin !");
-
fTime = GetNextWord();
fCount--;
void AliAltroRawStream::ReadAmplitude()
{
// Read next time bin amplitude
- if (fPosition <= 0)
- AliFatal("Could not read sample amplitude !");
+ if (fCount <= 0) {
+ fRawReader->AddMinorErrorLog(kAmplitudeReadErr,"");
+ // PrintDebug();
+ AliWarning("Could not read sample amplitude !");
+ fCount = fSignal = fBunchLength = 0;
+ return;
+ }
fSignal = GetNextWord();
+
fCount--;
fBunchLength--;
// Now read the beginning of the trailer
// where the payload size is written
- if (trailerSize < 2)
- AliFatal(Form("Invalid trailer size found (%d bytes) !",trailerSize*4));
+ if (trailerSize < 2) {
+ fRawReader->AddMajorErrorLog(kRCUTrailerErr,Form("tr=%d bytes",
+ trailerSize*4));
+ AliWarning(Form("Invalid trailer size found (%d bytes) !",
+ trailerSize*4));
+ }
fRCUTrailerSize = (trailerSize-2)*4;
index -= fRCUTrailerSize;
- if (index < 4)
- AliFatal(Form("Invalid trailer size found (%d bytes) ! The size is bigger than the raw data size (%d bytes)!",
- trailerSize*4,
- fRawReader->GetDataSize()));
+ if (index < 4) {
+ fRawReader->AddMajorErrorLog(kRCUTrailerErr,Form("tr=%d raw=%d bytes",
+ trailerSize*4,
+ fRawReader->GetDataSize()));
+ AliWarning(Form("Invalid trailer size found (%d bytes) ! The size is bigger than the raw data size (%d bytes)!",
+ trailerSize*4,
+ fRawReader->GetDataSize()));
+ }
fRCUTrailerData = fData + index;
Int_t position = Get32bitWord(index);
// The size is specified in a number of 40bits
position *= 5;
// Check the consistency of the header and trailer
- if ((fRawReader->GetDataSize() - trailerSize*4) != position)
- AliFatal(Form("Inconsistent raw data size ! Raw data size - %d bytes (from the header), RCU trailer - %d bytes, raw data paylod - %d bytes !",
+ if (((fRawReader->GetDataSize() - trailerSize*4) < position) ||
+ ((fRawReader->GetDataSize() - trailerSize*4) >= (position + 4))) {
+ fRawReader->AddMajorErrorLog(kRCUTrailerSizeErr,Form("h=%d tr=%d rcu=%d bytes",
+ fRawReader->GetDataSize(),
+ trailerSize*4,
+ position));
+ AliWarning(Form("Inconsistent raw data size ! Raw data size - %d bytes (from the header), RCU trailer - %d bytes, raw data paylod - %d bytes !",
fRawReader->GetDataSize(),
trailerSize*4,
position));
+ position = fRawReader->GetDataSize() - trailerSize*4;
+ }
return position * 8 / 10;
}
if (!fIsShortDataHeader) {
// Check the consistency of the header and trailer
- if ((fRawReader->GetDataSize() - 4) != position)
- AliFatal(Form("Inconsistent raw data size ! Expected %d bytes (from the header), found %d bytes (in the RCU trailer)!",
- fRawReader->GetDataSize()-4,
- position));
+ if (((fRawReader->GetDataSize() - 4) < position) ||
+ ((fRawReader->GetDataSize() - 4) >= (position + 4))) {
+ fRawReader->AddMajorErrorLog(kRCUTrailerSizeErr,Form("h=%d rcu=%d bytes",
+ fRawReader->GetDataSize()-4,
+ position));
+ // PrintDebug();
+ AliWarning(Form("Inconsistent raw data size ! Expected %d bytes (from the header), found %d bytes (in the RCU trailer)!",
+ fRawReader->GetDataSize()-4,
+ position));
+ position = fRawReader->GetDataSize()-4;
+ }
}
else {
// Check the consistency of the header and trailer
// In this case the header is shorter by 4 bytes
- if (fRawReader->GetDataSize() != position)
- AliFatal(Form("Inconsistent raw data size ! Expected %d bytes (from the header), found %d bytes (in the RCU trailer)!",
- fRawReader->GetDataSize(),
- position));
+ if ((fRawReader->GetDataSize() < position) ||
+ (fRawReader->GetDataSize() >= (position + 4))) {
+ fRawReader->AddMajorErrorLog(kRCUTrailerSizeErr,Form("h=%d rcu=%d bytes",
+ fRawReader->GetDataSize(),
+ position));
+ // PrintDebug();
+ AliWarning(Form("Inconsistent raw data size ! Expected %d bytes (from the header), found %d bytes (in the RCU trailer)!",
+ fRawReader->GetDataSize(),
+ position));
+ position = fRawReader->GetDataSize();
+ }
// 7 32-bit words Common Data Header
// therefore we have to shift back by 4 bytes
// The 'index' points to the beginning of the next word.
// The method is supposed to be endian (platform)
// independent.
- if (!fData)
+ if (!fData) {
+ PrintDebug();
AliFatal("Raw data paylod buffer is not yet initialized !");
- if (index < 4)
- AliFatal(Form("Invalid raw data payload index (%d) !",index));
+ }
+
+ if (index < 4) {
+ fRawReader->AddFatalErrorLog(k32bitWordReadErr,Form("pos = %d",index));
+ // PrintDebug();
+ AliWarning(Form("Invalid raw data payload position (%d) !",index));
+ }
UInt_t word = 0;
word = fData[--index] << 24;
return kTRUE;
}
+
+//_____________________________________________________________________________
+void AliAltroRawStream::PrintDebug() const
+{
+ // The method prints all the available
+ // debug information.
+ // Its is used in case of decoding errors.
+
+ AliError("Start of debug printout\n--------------------");
+
+ Dump();
+ if (fRawReader) fRawReader->Dump();
+
+ AliError("End of debug printout\n--------------------");
+}
+
+//_____________________________________________________________________________
+Int_t AliAltroRawStream::GetBranch() const
+{
+ // The method provides the RCU branch index (0 or 1)
+ // for the current hardware address.
+ // In case the hardware address has not been yet
+ // initialized, the method returns -1
+ if (fHWAddress == -1) return -1;
+
+ return ((fHWAddress >> 11) & 0x1);
+}
+
+//_____________________________________________________________________________
+Int_t AliAltroRawStream::GetFEC() const
+{
+ // The method provides the front-end card index
+ // for the current hardware address.
+ // In case the hardware address has not been yet
+ // initialized, the method returns -1
+ if (fHWAddress == -1) return -1;
+
+ return ((fHWAddress >> 7) & 0xF);
+}
+
+//_____________________________________________________________________________
+Int_t AliAltroRawStream::GetAltro() const
+{
+ // The method provides the altro chip index
+ // for the current hardware address.
+ // In case the hardware address has not been yet
+ // initialized, the method returns -1
+ if (fHWAddress == -1) return -1;
+
+ return ((fHWAddress >> 4) & 0x7);
+}
+
+//_____________________________________________________________________________
+Int_t AliAltroRawStream::GetChannel() const
+{
+ // The method provides the channel index
+ // for the current hardware address.
+ // In case the hardware address has not been yet
+ // initialized, the method returns -1
+ if (fHWAddress == -1) return -1;
+
+ return (fHWAddress & 0xF);
+}
+
+//_____________________________________________________________________________
+void AliAltroRawStream::AddMappingErrorLog(const char *message)
+{
+ // Signal a mapping error
+ // The method can be used by the TPC,PHOS,EMCAL,FMD raw stream
+ // classes in order to log an error related to bad altro mapping
+
+ if (fRawReader) fRawReader->AddMinorErrorLog(kBadAltroMapping,message);
+}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff