1 |
/** @file |
/** @file |
2 |
* $Author: kusanagi $ |
* $Author: kusanagi $ |
3 |
* $Date: 2005/03/06 04:29:20 $ |
* $Date: 2005/03/06 04:33:02 $ |
4 |
* $Revision: 3.1 $ |
* $Revision: 4.0 $ |
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. |
90 |
*/ |
*/ |
91 |
std::string EventReader::GetVersionInfo(void) const { |
std::string EventReader::GetVersionInfo(void) const { |
92 |
return |
return |
93 |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 3.1 2005/03/06 04:29:20 kusanagi Exp $\n"; |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 4.0 2005/03/06 04:33:02 kusanagi Exp $\n"; |
94 |
} |
} |
95 |
|
|
96 |
/** |
/** |
250 |
Header->GetPscuHeader()->SetFileOffset(((long int)(InputFile->tellg()) - 16)); |
Header->GetPscuHeader()->SetFileOffset(((long int)(InputFile->tellg()) - 16)); |
251 |
|
|
252 |
//commented out because of the above test code |
//commented out because of the above test code |
253 |
InputFile->seekg(Header->GetPscuHeader()->GetPacketLenght(), std::ios::cur); |
/*InputFile->seekg(Header->GetPscuHeader()->GetPacketLenght(), std::ios::cur); |
254 |
if (FindStart()) { |
if (FindStart()) { |
255 |
finalPos = (long int)InputFile->tellg() - (initPos + (long int)(Header->GetPscuHeader()->GetPacketLenght())); |
finalPos = (long int)InputFile->tellg() - (initPos + (long int)(Header->GetPscuHeader()->GetPacketLenght())); |
256 |
if(finalPos == 0){ |
if(finalPos == 0){ |
272 |
} |
} |
273 |
else { |
else { |
274 |
logger->debug(_T(" END OF FILE")); |
logger->debug(_T(" END OF FILE")); |
275 |
} |
}*/ |
276 |
|
|
277 |
InputFile->seekg(initPos, std::ios::beg); |
//InputFile->seekg(initPos, std::ios::beg); |
278 |
} else { |
} else { |
279 |
/*Here i should extract the block of Data for later analysis */ |
/*Here i should extract the block of Data for later analysis */ |
280 |
InputFile->seekg(-(13), std::ios::cur); |
InputFile->seekg(-(13), std::ios::cur); |
327 |
//------------------------------------------ |
//------------------------------------------ |
328 |
int subIndex = 0; |
int subIndex = 0; |
329 |
char dataByte; |
char dataByte; |
330 |
|
|
331 |
int buffSize = 100; |
int buffSize = 64; |
332 |
int index = 0; |
int index = 0; |
333 |
int loop = -1; |
int loop = -1; |
334 |
char buffer[buffSize]; |
char buffer[buffSize]; |
335 |
|
bool flagOverPad = false; |
336 |
|
|
337 |
while (!InputFile->eof()) { |
while (!InputFile->eof()) { |
338 |
InputFile->read(buffer, sizeof(buffer)); |
InputFile->read(buffer, sizeof(buffer)); |
343 |
if (dataByte == (char)(*(subSign+subIndex))){ |
if (dataByte == (char)(*(subSign+subIndex))){ |
344 |
if (subIndex++ == (subSignDim-1)) { |
if (subIndex++ == (subSignDim-1)) { |
345 |
InputFile->seekg( (index - (subIndex + buffSize)), std::ios::cur); |
InputFile->seekg( (index - (subIndex + buffSize)), std::ios::cur); |
346 |
|
if (flagOverPad){ |
347 |
|
oss.str(""); |
348 |
|
oss << "\n This packet beginning is farther than 64 byte from the end of the previous." |
349 |
|
<< "\n Below the is the currently unpacking packet"; |
350 |
|
logger->error(oss.str().c_str()); |
351 |
|
logger->error(Header->GetPscuHeader()->Print()); |
352 |
|
} |
353 |
return true; |
return true; |
354 |
} |
} |
355 |
} else { |
} else { |
358 |
} |
} |
359 |
} |
} |
360 |
//Needs to guarantee the overap of the buffer(s) in several loop |
//Needs to guarantee the overap of the buffer(s) in several loop |
361 |
|
flagOverPad = true; |
362 |
InputFile->seekg( (-1)*(subSignDim + 1) , std::ios::cur); |
InputFile->seekg( (-1)*(subSignDim + 1) , std::ios::cur); |
363 |
} |
} |
364 |
return false; |
return false; |