1 |
/** @file |
/** @file |
2 |
* $Author: kusanagi $ |
* $Author: kusanagi $ |
3 |
* $Date: 2005/05/28 08:30:11 $ |
* $Date: 2005/05/28 10:44:11 $ |
4 |
* $Revision: 4.3 $ |
* $Revision: 4.4 $ |
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. |
88 |
*/ |
*/ |
89 |
std::string EventReader::GetVersionInfo(void) const { |
std::string EventReader::GetVersionInfo(void) const { |
90 |
return |
return |
91 |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 4.3 2005/05/28 08:30:11 kusanagi Exp $\n"; |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 4.4 2005/05/28 10:44:11 kusanagi Exp $\n"; |
92 |
} |
} |
93 |
|
|
94 |
/** |
/** |
161 |
oss.str(""); |
oss.str(""); |
162 |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
163 |
logger->error(oss.str().c_str()); |
logger->error(oss.str().c_str()); |
164 |
|
InputFile->seekg( (-1)*(Header->GetPscuHeader()->GetPacketLenght() + 15) , std::ios::cur); |
165 |
} catch (UnidentifiedPacketException exc) { |
} catch (UnidentifiedPacketException exc) { |
166 |
oss.str(""); |
oss.str(""); |
167 |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
174 |
oss.str(""); |
oss.str(""); |
175 |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
176 |
logger->error(oss.str().c_str()); |
logger->error(oss.str().c_str()); |
177 |
|
} catch (BackwardCounterException exc) { |
178 |
|
oss.str(""); |
179 |
|
oss << exc.print() << " " << Header->GetPscuHeader()->Print(); |
180 |
|
logger->error(oss.str().c_str()); |
181 |
} catch (...) { |
} catch (...) { |
182 |
logger->error("Couldn't read the event. Skipping to the next header. \n"); |
logger->error("Couldn't read the event. Skipping to the next header. \n"); |
183 |
} |
} |
198 |
/** |
/** |
199 |
* Unpack the PSCU header from a file into the structure. |
* Unpack the PSCU header from a file into the structure. |
200 |
*/ |
*/ |
201 |
void EventReader::UnpackPscuHeader(void) throw (WrongCRCHeaderException, LengthException) { |
void EventReader::UnpackPscuHeader(void) throw (WrongCRCHeaderException, LengthException, BackwardCounterException) { |
202 |
stringstream oss; |
stringstream oss; |
203 |
int response = false; |
int response = 0; |
204 |
char buff[16]; |
char buff[16]; |
205 |
InputFile->read(buff, sizeof(buff)); |
InputFile->read(buff, sizeof(buff)); |
206 |
|
|
213 |
unsigned char CRC = buff[15]; |
unsigned char CRC = buff[15]; |
214 |
unsigned char FileOffset = buff[15]; |
unsigned char FileOffset = buff[15]; |
215 |
|
|
216 |
|
|
217 |
if (Counter < prevPckCounter){ |
if (Counter < prevPckCounter){ |
218 |
oss.str(""); |
response = prevPckCounter - Counter; |
219 |
oss << "Packet counter is less than before of " << (prevPckCounter - Counter); |
//oss.str(""); |
220 |
logger->error(oss.str().c_str()); |
//oss << "Packet counter is less than before of " << (prevPckCounter - Counter); |
221 |
|
//throw BackwardCounterException(oss.str().c_str()); |
222 |
|
//logger->error(oss.str().c_str()); |
223 |
} |
} |
224 |
|
|
225 |
if (Counter > prevPckCounter + 1){ |
if (Counter > prevPckCounter + 1){ |
280 |
logger->debug(_T(" END OF FILE")); |
logger->debug(_T(" END OF FILE")); |
281 |
}*/ |
}*/ |
282 |
|
|
|
//InputFile->seekg(initPos, std::ios::beg); |
|
283 |
} else { |
} else { |
284 |
/*Here i should extract the block of Data for later analysis */ |
/*Here i should extract the block of Data for later analysis */ |
285 |
InputFile->seekg(-(13), std::ios::cur); |
InputFile->seekg(-(13), std::ios::cur); |
288 |
throw WrongCRCHeaderException(oss.str().c_str()); |
throw WrongCRCHeaderException(oss.str().c_str()); |
289 |
} |
} |
290 |
|
|
291 |
|
if (response > 0){ |
292 |
|
oss.str(""); |
293 |
|
oss << "Packet counter is less than before of " << response; |
294 |
|
throw BackwardCounterException(oss.str().c_str()); |
295 |
|
} |
296 |
|
|
297 |
/* char tmpId1[4]; |
/* char tmpId1[4]; |
298 |
char tmpId2[4]; |
char tmpId2[4]; |
299 |
char tmpLength[12]; |
char tmpLength[12]; |