| 1 |
/** @file |
/** @file |
| 2 |
* $Author: kusanagi $ |
* $Author: kusanagi $ |
| 3 |
* $Date: 2006/02/15 15:47:14 $ |
* $Date: 2006/04/05 07:30:54 $ |
| 4 |
* $Revision: 6.1 $ |
* $Revision: 6.2 $ |
| 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. |
| 84 |
*/ |
*/ |
| 85 |
std::string EventReader::GetVersionInfo(void) const { |
std::string EventReader::GetVersionInfo(void) const { |
| 86 |
return |
return |
| 87 |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 6.1 2006/02/15 15:47:14 kusanagi Exp $\n"; |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 6.2 2006/04/05 07:30:54 kusanagi Exp $\n"; |
| 88 |
} |
} |
| 89 |
|
|
| 90 |
/** |
/** |
| 148 |
oss.str(""); |
oss.str(""); |
| 149 |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
| 150 |
logger->error(oss.str().c_str()); |
logger->error(oss.str().c_str()); |
| 151 |
archiveCorruptedPacket(Header->GetPscuHeader()->FileOffset, Header->GetPscuHeader()->PacketLenght); |
//archiveCorruptedPacket(Header->GetPscuHeader()->FileOffset, Header->GetPscuHeader()->PacketLenght); |
| 152 |
//InputFile->seekg( (-1)*(Header->GetPscuHeader()->GetPacketLenght() + 14) , std::ios::cur); |
//InputFile->seekg( (-1)*(Header->GetPscuHeader()->GetPacketLenght() + 14) , std::ios::cur); |
| 153 |
|
|
| 154 |
} catch (UnidentifiedPacketException exc) { |
} catch (UnidentifiedPacketException exc) { |
| 176 |
logger->info(oss.str().c_str()); |
logger->info(oss.str().c_str()); |
| 177 |
} |
} |
| 178 |
Header->GetCounter()->PrintCounters(); |
Header->GetCounter()->PrintCounters(); |
| 179 |
if (corruptedPacketFile.is_open()) corruptedPacketFile.close(); |
//if (corruptedPacketFile.is_open()) corruptedPacketFile.close(); |
| 180 |
} |
} |
| 181 |
|
|
| 182 |
/** |
/** |
| 183 |
* Unpack the PSCU header from a file into the structure. |
* Unpack the PSCU header from a file into the structure. |
| 184 |
*/ |
*/ |
| 185 |
void EventReader::UnpackPscuHeader(void) throw (WrongCRCHeaderException, LengthException, BackwardCounterException) { |
void EventReader::UnpackPscuHeader(void) throw (WrongCRCHeaderException, LengthException) { |
| 186 |
stringstream oss; |
stringstream oss; |
| 187 |
int response = 0; |
int response = 0; |
| 188 |
char buff[16]; |
char buff[16]; |
| 313 |
return false; |
return false; |
| 314 |
} |
} |
| 315 |
|
|
| 316 |
|
/* |
| 317 |
int EventReader::archiveCorruptedPacket(long int offset, long int length) { |
int EventReader::archiveCorruptedPacket(long int offset, long int length) { |
| 318 |
if (!corruptedPacketFile.is_open()) { |
if (!corruptedPacketFile.is_open()) { |
| 319 |
oss.str(""); |
oss.str(""); |
| 329 |
corruptedPacketFile.write(buffer, length); |
corruptedPacketFile.write(buffer, length); |
| 330 |
InputFile->seekg(offset + 1, ios_base::beg ); |
InputFile->seekg(offset + 1, ios_base::beg ); |
| 331 |
} |
} |
| 332 |
|
*/ |
| 333 |
ClassImp(EventReader) |
ClassImp(EventReader) |