| 1 |
/** @file |
/** @file |
| 2 |
* $Author: kusanagi $ |
* $Author: kusanagi $ |
| 3 |
* $Date: 2006/05/30 19:10:02 $ |
* $Date: 2006/05/30 19:10:03 $ |
| 4 |
* $Revision: 6.4 $ |
* $Revision: 6.5 $ |
| 5 |
* |
* |
| 6 |
* Implementation of the functions of a sample Algorithm class. |
* Implementation of the functions of a sample Algorithm class. |
| 7 |
* This file can be used as a templace to develop your own algorithm. |
* This file can be used as a templace to develop your own algorithm. |
| 87 |
*/ |
*/ |
| 88 |
std::string EventReader::GetVersionInfo(void) const { |
std::string EventReader::GetVersionInfo(void) const { |
| 89 |
return |
return |
| 90 |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 6.4 2006/05/30 19:10:02 kusanagi Exp $\n"; |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 6.5 2006/05/30 19:10:03 kusanagi Exp $\n"; |
| 91 |
} |
} |
| 92 |
|
|
| 93 |
/** |
/** |
| 151 |
oss.str(""); |
oss.str(""); |
| 152 |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
| 153 |
logger->error(oss.str().c_str()); |
logger->error(oss.str().c_str()); |
| 154 |
//archiveCorruptedPacket(Header->GetPscuHeader()->FileOffset, Header->GetPscuHeader()->PacketLenght); |
archiveCorruptedPacket(Header->GetPscuHeader()->FileOffset, Header->GetPscuHeader()->PacketLenght); |
|
//InputFile->seekg( (-1)*(Header->GetPscuHeader()->GetPacketLenght() + 14) , std::ios::cur); |
|
| 155 |
|
|
| 156 |
} catch (UnidentifiedPacketException exc) { |
} catch (UnidentifiedPacketException exc) { |
| 157 |
oss.str(""); |
oss.str(""); |
| 184 |
/** |
/** |
| 185 |
* Unpack the PSCU header from a file into the structure. |
* Unpack the PSCU header from a file into the structure. |
| 186 |
*/ |
*/ |
| 187 |
void EventReader::UnpackPscuHeader(void) throw (WrongCRCHeaderException, LengthException) { |
void EventReader::UnpackPscuHeader(void) throw (WrongCRCHeaderException, LengthException, BackwardCounterException) { |
| 188 |
stringstream oss; |
stringstream oss; |
| 189 |
int response = 0; |
int response = 0; |
| 190 |
char buff[16]; |
char buff[16]; |
| 315 |
return false; |
return false; |
| 316 |
} |
} |
| 317 |
|
|
| 318 |
/* |
|
| 319 |
int EventReader::archiveCorruptedPacket(long int offset, long int length) { |
int EventReader::archiveCorruptedPacket(long int offset, long int length) { |
| 320 |
if (!corruptedPacketFile.is_open()) { |
if (!corruptedPacketFile.is_open()) { |
| 321 |
oss.str(""); |
oss.str(""); |
| 331 |
corruptedPacketFile.write(buffer, length); |
corruptedPacketFile.write(buffer, length); |
| 332 |
InputFile->seekg(offset + 1, ios_base::beg ); |
InputFile->seekg(offset + 1, ios_base::beg ); |
| 333 |
} |
} |
| 334 |
*/ |
|
| 335 |
ClassImp(EventReader) |
ClassImp(EventReader) |