1 |
/** @file |
/** @file |
2 |
* $Author: kusanagi $ |
* $Author: kusanagi $ |
3 |
* $Date: 2005/08/29 09:26:54 $ |
* $Date: 2006/02/04 12:37:45 $ |
4 |
* $Revision: 4.5 $ |
* $Revision: 5.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. |
8 |
*/ |
*/ |
9 |
|
|
10 |
#include <log4cxx/logger.h> |
#include <log4cxx/logger.h> |
|
#include <fstream> |
|
11 |
#include "EventReader.h" |
#include "EventReader.h" |
12 |
#include "ReaderAlgorithms.h" |
#include "ReaderAlgorithms.h" |
13 |
|
|
|
|
|
14 |
extern "C" { |
extern "C" { |
15 |
#include "CRC.h" |
#include "CRC.h" |
16 |
} |
} |
53 |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrailer, new CalibTrailerReader)); |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrailer, new CalibTrailerReader)); |
54 |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitHeader, new InitHeaderReader)); |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitHeader, new InitHeaderReader)); |
55 |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitTrailer, new InitTrailerReader)); |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitTrailer, new InitTrailerReader)); |
|
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::EventTrk, new EventTrkReader)); |
|
|
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TestTrk, new TestTrkReader)); |
|
|
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TestTof, new TestTofReader)); |
|
56 |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Log, new LogReader)); |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Log, new LogReader)); |
57 |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::VarDump, new VarDumpReader)); |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::VarDump, new VarDumpReader)); |
58 |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::ArrDump, new ArrDumpReader)); |
TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::ArrDump, new ArrDumpReader)); |
83 |
*/ |
*/ |
84 |
std::string EventReader::GetVersionInfo(void) const { |
std::string EventReader::GetVersionInfo(void) const { |
85 |
return |
return |
86 |
"$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.2 2006/02/04 12:37:45 kusanagi Exp $\n"; |
87 |
} |
} |
88 |
|
|
89 |
/** |
/** |
113 |
* Read the next event header, call the reader algorithms that |
* Read the next event header, call the reader algorithms that |
114 |
* correspond to its packet type, and read the event trailer. |
* correspond to its packet type, and read the event trailer. |
115 |
*/ |
*/ |
|
|
|
|
// 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------------------ |
|
116 |
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() |
|
117 |
stringstream oss; |
stringstream oss; |
118 |
int step = 0; |
int step = 0; |
119 |
const PacketType* type; |
const PacketType* type; |
176 |
Header->GetCounter()->PrintCounters(); |
Header->GetCounter()->PrintCounters(); |
177 |
} |
} |
178 |
|
|
|
static void SkipToNextHeader(ifstream* TechmodelFile) { |
|
|
// yeah. |
|
|
} |
|
|
|
|
|
|
|
|
|
|
179 |
/** |
/** |
180 |
* Unpack the PSCU header from a file into the structure. |
* Unpack the PSCU header from a file into the structure. |
181 |
*/ |
*/ |
235 |
Header->GetPscuHeader()->SetPacketLenght(PacketLenght); |
Header->GetPscuHeader()->SetPacketLenght(PacketLenght); |
236 |
Header->GetPscuHeader()->SetCRC(CRC); |
Header->GetPscuHeader()->SetCRC(CRC); |
237 |
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")); |
|
|
}*/ |
|
|
|
|
238 |
} else { |
} else { |
239 |
/*Here i should extract the block of Data for later analysis */ |
/*Here i should extract the block of Data for later analysis */ |
240 |
InputFile->seekg(-(13), std::ios::cur); |
InputFile->seekg(-(13), std::ios::cur); |
248 |
oss << "Packet counter is less than before of " << response; |
oss << "Packet counter is less than before of " << response; |
249 |
throw BackwardCounterException(oss.str().c_str()); |
throw BackwardCounterException(oss.str().c_str()); |
250 |
} |
} |
|
|
|
|
/* 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()); |
|
|
*/ |
|
251 |
} |
} |
252 |
|
|
253 |
/** |
/** |