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) |