1 |
/** @file |
/** @file |
2 |
* $Author: kusanagi $ |
* $Author: kusanagi $ |
3 |
* $Date: 2005/08/29 09:26:54 $ |
* $Date: 2005/08/29 09:46:13 $ |
4 |
* $Revision: 4.5 $ |
* $Revision: 5.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. |
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.5 2005/08/29 09:26:54 kusanagi Exp $\n"; |
"$Header: /home/cvsmanager/yoda/techmodel/EventReader.cpp,v 5.0 2005/08/29 09:46:13 kusanagi Exp $\n"; |
92 |
} |
} |
93 |
|
|
94 |
/** |
/** |
118 |
* Read the next event header, call the reader algorithms that |
* Read the next event header, call the reader algorithms that |
119 |
* correspond to its packet type, and read the event trailer. |
* correspond to its packet type, and read the event trailer. |
120 |
*/ |
*/ |
|
|
|
|
// 15 June 2004 ---note------------------ |
|
|
// A nice refacoring would require to not read again the packet data (which is |
|
|
// read in the UnpackPscuHeader() and put directly in the |
|
|
// EventAlgorithm->RunEvent(....) directly the data inside the packet.... will see later.... |
|
|
// 15 June 2004 ---note------------------ |
|
121 |
void EventReader::RunEvent(int EventNumber) { |
void EventReader::RunEvent(int EventNumber) { |
|
//for now i'll suppose that the raw file starts immediately with the right bytes |
|
|
//to insert a GetPacketStart() |
|
122 |
stringstream oss; |
stringstream oss; |
123 |
int step = 0; |
int step = 0; |
124 |
const PacketType* type; |
const PacketType* type; |
181 |
Header->GetCounter()->PrintCounters(); |
Header->GetCounter()->PrintCounters(); |
182 |
} |
} |
183 |
|
|
|
static void SkipToNextHeader(ifstream* TechmodelFile) { |
|
|
// yeah. |
|
|
} |
|
|
|
|
|
|
|
|
|
|
184 |
/** |
/** |
185 |
* Unpack the PSCU header from a file into the structure. |
* Unpack the PSCU header from a file into the structure. |
186 |
*/ |
*/ |
240 |
Header->GetPscuHeader()->SetPacketLenght(PacketLenght); |
Header->GetPscuHeader()->SetPacketLenght(PacketLenght); |
241 |
Header->GetPscuHeader()->SetCRC(CRC); |
Header->GetPscuHeader()->SetCRC(CRC); |
242 |
Header->GetPscuHeader()->SetFileOffset(((long int)(InputFile->tellg()) - 16)); |
Header->GetPscuHeader()->SetFileOffset(((long int)(InputFile->tellg()) - 16)); |
|
|
|
|
//commented out because of the above test code |
|
|
/*InputFile->seekg(Header->GetPscuHeader()->GetPacketLenght(), std::ios::cur); |
|
|
if (FindStart()) { |
|
|
finalPos = (long int)InputFile->tellg() - (initPos + (long int)(Header->GetPscuHeader()->GetPacketLenght())); |
|
|
if(finalPos == 0){ |
|
|
logger->debug(_T(" Correct packet length")); |
|
|
} |
|
|
if (finalPos > 0 && finalPos < 64) { |
|
|
oss.str(""); |
|
|
oss << "Correct packet length: Padded of " << finalPos << " bytes"; |
|
|
logger->debug(oss.str().c_str()); |
|
|
} |
|
|
if (finalPos > 64){ |
|
|
oss.str(""); |
|
|
oss << "\n The begin of the next packet is far more than 64 byte from the end of the previous." |
|
|
<< "\n Below the is the now unpacking packet"; |
|
|
logger->error(oss.str().c_str()); |
|
|
logger->error(Header->GetPscuHeader()->Print()); |
|
|
//throw LengthException("The begin of the next packet is far more than 64 byte from the end of the previous."); |
|
|
} |
|
|
} |
|
|
else { |
|
|
logger->debug(_T(" END OF FILE")); |
|
|
}*/ |
|
|
|
|
243 |
} else { |
} else { |
244 |
/*Here i should extract the block of Data for later analysis */ |
/*Here i should extract the block of Data for later analysis */ |
245 |
InputFile->seekg(-(13), std::ios::cur); |
InputFile->seekg(-(13), std::ios::cur); |
253 |
oss << "Packet counter is less than before of " << response; |
oss << "Packet counter is less than before of " << response; |
254 |
throw BackwardCounterException(oss.str().c_str()); |
throw BackwardCounterException(oss.str().c_str()); |
255 |
} |
} |
|
|
|
|
/* char tmpId1[4]; |
|
|
char tmpId2[4]; |
|
|
char tmpLength[12]; |
|
|
char tmpStart[100]; |
|
|
char tmpCRC[4]; |
|
|
sprintf(tmpId1, "%02X", PacketId1); |
|
|
sprintf(tmpId2, "%02X", PacketId2); |
|
|
sprintf(tmpLength, "%06X", Header->GetPscuHeader()->GetPacketLenght()); |
|
|
sprintf(tmpStart, "%X", Header->GetPscuHeader()->GetFileOffset()); |
|
|
sprintf(tmpCRC, "%02X", CRC); |
|
|
oss.flush(); |
|
|
oss << "\n Packet Counter (decimal) : " << Counter |
|
|
<< "\n Id1 - Id2 : " << tmpId1 << " - " << tmpId2 |
|
|
<< "\n Orbital Time (decimal) : " << OrbitalTime |
|
|
<< "\n Lenght : " << tmpLength |
|
|
<< "\n CRC : " << tmpCRC |
|
|
<< "\n Header Start Position : " << tmpStart; |
|
|
logger->info(oss.str().c_str()); |
|
|
*/ |
|
256 |
} |
} |
257 |
|
|
258 |
/** |
/** |