PamOffLineSW/techmodel/EventReader.cpp

/** @file
 * $Author: mocchiut $
 * $Date: 2009/07/24 13:53:45 $
 * $Revision: 1.3 $
 * 
 * Implementation of the functions of a sample Algorithm class.
 * This file can be used as a templace to develop your own algorithm.
 */

#include "EventReader.h"
#include "ReaderAlgorithms.h"

extern "C" {
    #include "CRC.h"
}

using namespace pamela;
using namespace pamela::techmodel;

EventReader::~EventReader(){
        if(Header){delete Header; Header=NULL;}
} 

/**
 * Constructor. 
 */

EventReader::EventReader(): 
        TechmodelAlgorithm(0, "TechmodelEventReader"){
        Header = new EventHeader();  
        
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::PhysEndRun,      new PhysEndRunReader));  
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCalPulse1,  new CalibCalPulse1Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCalPulse2,  new CalibCalPulse2Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Physics,         new PhysicsReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrkBoth,    new CalibTrkBothReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrk1,       new CalibTrk1Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrk2,       new CalibTrk2Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTof,        new CalibTofReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibS4,         new CalibS4Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCalPed,     new CalibCalPedReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib1_Ac1,      new Calib1_Ac1Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib2_Ac1,      new Calib2_Ac1Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib1_Ac2,      new Calib1_Ac2Reader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib2_Ac2,      new Calib2_Ac2Reader));
  //TODO: marco maybe a bug?:  due volte Calib2_Ac2. ??
//  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib2_Ac2,      new CalibCalReader));
  //TODO: marco maybe a bug?  
  //    questa dovrebbe essere cosi ma poi c'e' un errore in Pamela Run: in WriteHeaders non ho CalibCal
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCal,        new CalibCalReader));  
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::RunHeader,       new RunHeaderReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::RunTrailer,      new RunTrailerReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibHeader,     new CalibHeaderReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrailer,    new CalibTrailerReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitHeader,      new InitHeaderReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitTrailer,     new InitTrailerReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::EventTrk,        new EventTrkReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Log,             new LogReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::VarDump,         new VarDumpReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::ArrDump,         new ArrDumpReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TabDump,         new TabDumpReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Tmtc,            new TmtcReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Mcmd,            new McmdReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::ForcedFECmd,     new ForcedFECmdReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac1Init,         new Ac1InitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalInit,         new CalInitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrkInit,         new TrkInitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TofInit,         new TofInitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrgInit,         new TrgInitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::NdInit,          new NdInitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::S4Init,          new S4InitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac2Init,         new Ac2InitReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalAlarm,        new CalAlarmReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac1Alarm,        new Ac1AlarmReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrkAlarm,        new TrkAlarmReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrgAlarm,        new TrgAlarmReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TofAlarm,        new TofAlarmReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::S4Alarm,         new S4AlarmReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac2Alarm,        new Ac2AlarmReader));  
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TsbT,            new TsbTReader));
  TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TsbB,            new TsbBReader));
}

/**
 * Initialize the algorithm with a special run. This will initialize the
 * event reader routines for all packet types.
 */
void EventReader::Init(PamelaRun *run) {        
        //Create the structure of directories and create xxx.Header.root files
          run->WriteHeaders(this, &Header);   
    //Create the xxx.root in it's specific directory
    for (AlgorithmMap::iterator i = TechmodelAlgorithmMap.begin(); 
       i != TechmodelAlgorithmMap.end(); i++) {
       // cout << " Initializing algo " << i->second->GetAlgorithmName()<<endl;
       i->second->Init(run);
    }

    if ( Header ) { delete Header; Header = new EventHeader(); };  // EMILIANO, reset Counter when opening a new file

    Run=run;
}


/**
 * Read the next event header, call the reader algorithms that
 * correspond to its packet type, and read the event trailer.
 * if the packet is saved return 0.
 * 
 * return values:      meaning:
                0            packet good
            1            exception but used    //never happen
            2                    CRC exception but used
            3                    CALIBRATION PACKET with error but used
           -1                    CRC exception  packet DISCARDED
           -2                    FATAL exception packet DISCARDED //never happen
           -3                    No way to read events of this type. packet DISCARDED( es CalibCal --old)
        //in PacketUser I will put      ret = 10 
         ret = 10 if the packet is good but comes from a cadre with VRL problems
        
 * 
 */
int EventReader::PKT_RunEvent(char* headerPkt, char* pamPkt, long int length, const PacketType* type){
        stringstream oss;
        string msg;
        int ret=0;
        PKT_UnpackPscuHeader(headerPkt);        
        AlgorithmMap::iterator i = TechmodelAlgorithmMap.find(type); 
        if (i != TechmodelAlgorithmMap.end()) 
        {
                TechmodelAlgorithm* EventAlgorithm(i->second);
                try{
                        EventAlgorithm->PKT_RunEvent(pamPkt, length);
                }               
                catch (WrongCRCException_PKTUsed &exc){
                        //questo tipo di eccezione NON mi preoccupa, 
                        //il pacchetto e' stato utilizzato e salvato ugualmente
                        ret=2;
                        oss.str("");
                        oss << exc.print();      
                        oss << " Return "<<ret;
                        msg=oss.str();
                        PamOffLineSW::mainLogUtil->logWarning(msg);     
                }  
                catch (CalibException &exc){                    
                        //questo tipo di eccezione mi preoccupa un pochino, 
                        //il pacchetto e' stato utilizzato e salvato ugualmente 
                        ret=3;
                        oss.str("");
                        oss << exc.print();      
                        oss << " Return "<<ret;
                        msg=oss.str();
                        PamOffLineSW::mainLogUtil->logWarning(msg);
                }           
                catch (WrongCRCException &exc){
                        //questo tipo di eccezione  mi preoccupa, 
                        //il pacchetto non e' stato utilizzato ne salvato 
                        ret=-1;
                        oss.str("");
                        oss << exc.print();
                        oss << " The Packet is Discarded ";  
                        oss << " Return "<<ret;
                        msg=oss.str();
                        PamOffLineSW::mainLogUtil->logError(msg);                       
                        return ret;     
                }
                catch (FatalException &exc){
                        ret=-2;
                        oss.str("");
                        oss << exc.print();
                        oss << " The Packet is Discarded ";  
                        oss << " Return "<<ret;
                        msg=oss.str();
                        PamOffLineSW::mainLogUtil->logError(msg);                                       
                        return ret; 
                }
                catch (Exception &exc){
                        ret=1;
                        oss.str("");
                        oss << exc.print();
                        oss << " Return "<<ret;
                        msg=oss.str();
                        PamOffLineSW::mainLogUtil->logWarning(msg);
                }      
                // catch (NotExistingAlgorithmException exc) {} 

                Run->FillTrees(type);
                //              cout << Header->GetCounter()->Get(type) << endl;
                Header->GetCounter()->Increment(type);
                //              cout << Header->GetCounter()->Get(type) << endl;
        }
        else
        {
                ret=-3;
                oss.str("");
                //              oss << " No way to read events of type  " << type->GetName().c_str()<<". The Packet is skipped ";  
                oss << " No way to read events of type  " << type->GetName()<<". The Packet is skipped ";  
                oss << " Return "<<ret;
                msg=oss.str();
                PamOffLineSW::mainLogUtil->logWarning(msg);   
                return ret;
        }
        return ret;
}

/**
 * Unpack the PSCU header from the pkt into the structure.
 */     
//fill the header structure, 
void EventReader::PKT_UnpackPscuHeader(char* buff) 
{
  unsigned char PacketId1    = buff[3];
  unsigned char PacketId2    = buff[4];
  unsigned int  Counter      = (((UINT32)buff[5]<<16)&0x00FF0000) + (((UINT32)buff[6]<<8)&0x0000FF00) + (((UINT32)buff[7])&0x000000FF);
  unsigned int  OrbitalTime  = (((UINT32)buff[8]<<24)&0xFF000000) + (((UINT32)buff[9]<<16)&0x00FF0000) +  (((UINT32)buff[10]<<8)&0x0000FF00) + (((UINT32)buff[11])&0x000000FF);
  unsigned int  PacketLenght = (((UINT32)buff[12]<<16)&0x00FF0000) +  (((UINT32)buff[13]<<8)&0x0000FF00) + (((UINT32)buff[14])&0x000000FF);
  unsigned char CRC          = buff[15];
  //  unsigned char FileOffset   = 0;// ??

  Header->GetPscuHeader()->SetPacketId(PacketId1, PacketId2);
  Header->GetPscuHeader()->SetCounter(Counter);
  Header->GetPscuHeader()->SetOrbitalTime(OrbitalTime);
 //PacketLength is the length of the whole DATApacket starting from the first byte after the header
  //plus the CRC legth (which varies for each type of packet)
  Header->GetPscuHeader()->SetPacketLenght(PacketLenght);
  
  Header->GetPscuHeader()->SetCRC(CRC);
  Header->GetPscuHeader()->SetFileOffset(0);//I don't need this !!
}


/**
 * Get a string with the version info of the algorithm.
 */
std::string EventReader::GetVersionInfo(void) const {
        return 
    "$Header: /afs/ba.infn.it/user/pamela/src/CVS/chewbacca/PamOffLineSW/techmodel/EventReader.cpp,v 1.3 2009/07/24 13:53:45 mocchiut Exp $\n";
}


ClassImp(EventReader)
1	/** @file
2	* $Author: mocchiut $
3	* $Date: 2009/07/24 13:53:45 $
4	* $Revision: 1.3 $
5	*
6	* Implementation of the functions of a sample Algorithm class.
7	* This file can be used as a templace to develop your own algorithm.
8	*/
9
10	#include "EventReader.h"
11	#include "ReaderAlgorithms.h"
12
13	extern "C" {
14	#include "CRC.h"
15	}
16
17	using namespace pamela;
18	using namespace pamela::techmodel;
19
20	EventReader::~EventReader(){
21	if(Header){delete Header; Header=NULL;}
22	}
23
24	/**
25	* Constructor.
26	*/
27
28	EventReader::EventReader():
29	TechmodelAlgorithm(0, "TechmodelEventReader"){
30	Header = new EventHeader();
31
32	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::PhysEndRun, new PhysEndRunReader));
33	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCalPulse1, new CalibCalPulse1Reader));
34	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCalPulse2, new CalibCalPulse2Reader));
35	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Physics, new PhysicsReader));
36	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrkBoth, new CalibTrkBothReader));
37	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrk1, new CalibTrk1Reader));
38	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrk2, new CalibTrk2Reader));
39	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTof, new CalibTofReader));
40	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibS4, new CalibS4Reader));
41	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCalPed, new CalibCalPedReader));
42	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib1_Ac1, new Calib1_Ac1Reader));
43	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib2_Ac1, new Calib2_Ac1Reader));
44	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib1_Ac2, new Calib1_Ac2Reader));
45	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib2_Ac2, new Calib2_Ac2Reader));
46	//TODO: marco maybe a bug?: due volte Calib2_Ac2. ??
47	// TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Calib2_Ac2, new CalibCalReader));
48	//TODO: marco maybe a bug?
49	// questa dovrebbe essere cosi ma poi c'e' un errore in Pamela Run: in WriteHeaders non ho CalibCal
50	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibCal, new CalibCalReader));
51	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::RunHeader, new RunHeaderReader));
52	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::RunTrailer, new RunTrailerReader));
53	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibHeader, new CalibHeaderReader));
54	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalibTrailer, new CalibTrailerReader));
55	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitHeader, new InitHeaderReader));
56	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::InitTrailer, new InitTrailerReader));
57	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::EventTrk, new EventTrkReader));
58	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Log, new LogReader));
59	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::VarDump, new VarDumpReader));
60	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::ArrDump, new ArrDumpReader));
61	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TabDump, new TabDumpReader));
62	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Tmtc, new TmtcReader));
63	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Mcmd, new McmdReader));
64	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::ForcedFECmd, new ForcedFECmdReader));
65	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac1Init, new Ac1InitReader));
66	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalInit, new CalInitReader));
67	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrkInit, new TrkInitReader));
68	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TofInit, new TofInitReader));
69	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrgInit, new TrgInitReader));
70	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::NdInit, new NdInitReader));
71	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::S4Init, new S4InitReader));
72	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac2Init, new Ac2InitReader));
73	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::CalAlarm, new CalAlarmReader));
74	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac1Alarm, new Ac1AlarmReader));
75	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrkAlarm, new TrkAlarmReader));
76	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TrgAlarm, new TrgAlarmReader));
77	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TofAlarm, new TofAlarmReader));
78	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::S4Alarm, new S4AlarmReader));
79	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::Ac2Alarm, new Ac2AlarmReader));
80	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TsbT, new TsbTReader));
81	TechmodelAlgorithmMap.insert(AlgorithmMap::value_type(PacketType::TsbB, new TsbBReader));
82	}
83
84	/**
85	* Initialize the algorithm with a special run. This will initialize the
86	* event reader routines for all packet types.
87	*/
88	void EventReader::Init(PamelaRun *run) {
89	//Create the structure of directories and create xxx.Header.root files
90	run->WriteHeaders(this, &Header);
91	//Create the xxx.root in it's specific directory
92	for (AlgorithmMap::iterator i = TechmodelAlgorithmMap.begin();
93	i != TechmodelAlgorithmMap.end(); i++) {
94	// cout << " Initializing algo " << i->second->GetAlgorithmName()<<endl;
95	i->second->Init(run);
96	}
97
98	if ( Header ) { delete Header; Header = new EventHeader(); }; // EMILIANO, reset Counter when opening a new file
99
100	Run=run;
101	}
102
103
104	/**
105	* Read the next event header, call the reader algorithms that
106	* correspond to its packet type, and read the event trailer.
107	* if the packet is saved return 0.
108	*
109	* return values: meaning:
110	0 packet good
111	1 exception but used //never happen
112	2 CRC exception but used
113	3 CALIBRATION PACKET with error but used
114	-1 CRC exception packet DISCARDED
115	-2 FATAL exception packet DISCARDED //never happen
116	-3 No way to read events of this type. packet DISCARDED( es CalibCal --old)
117	//in PacketUser I will put ret = 10
118	ret = 10 if the packet is good but comes from a cadre with VRL problems
119
120	*
121	*/
122	int EventReader::PKT_RunEvent(char* headerPkt, char* pamPkt, long int length, const PacketType* type){
123	stringstream oss;
124	string msg;
125	int ret=0;
126	PKT_UnpackPscuHeader(headerPkt);
127	AlgorithmMap::iterator i = TechmodelAlgorithmMap.find(type);
128	if (i != TechmodelAlgorithmMap.end())
129	{
130	TechmodelAlgorithm* EventAlgorithm(i->second);
131	try{
132	EventAlgorithm->PKT_RunEvent(pamPkt, length);
133	}
134	catch (WrongCRCException_PKTUsed &exc){
135	//questo tipo di eccezione NON mi preoccupa,
136	//il pacchetto e' stato utilizzato e salvato ugualmente
137	ret=2;
138	oss.str("");
139	oss << exc.print();
140	oss << " Return "<<ret;
141	msg=oss.str();
142	PamOffLineSW::mainLogUtil->logWarning(msg);
143	}
144	catch (CalibException &exc){
145	//questo tipo di eccezione mi preoccupa un pochino,
146	//il pacchetto e' stato utilizzato e salvato ugualmente
147	ret=3;
148	oss.str("");
149	oss << exc.print();
150	oss << " Return "<<ret;
151	msg=oss.str();
152	PamOffLineSW::mainLogUtil->logWarning(msg);
153	}
154	catch (WrongCRCException &exc){
155	//questo tipo di eccezione mi preoccupa,
156	//il pacchetto non e' stato utilizzato ne salvato
157	ret=-1;
158	oss.str("");
159	oss << exc.print();
160	oss << " The Packet is Discarded ";
161	oss << " Return "<<ret;
162	msg=oss.str();
163	PamOffLineSW::mainLogUtil->logError(msg);
164	return ret;
165	}
166	catch (FatalException &exc){
167	ret=-2;
168	oss.str("");
169	oss << exc.print();
170	oss << " The Packet is Discarded ";
171	oss << " Return "<<ret;
172	msg=oss.str();
173	PamOffLineSW::mainLogUtil->logError(msg);
174	return ret;
175	}
176	catch (Exception &exc){
177	ret=1;
178	oss.str("");
179	oss << exc.print();
180	oss << " Return "<<ret;
181	msg=oss.str();
182	PamOffLineSW::mainLogUtil->logWarning(msg);
183	}
184	// catch (NotExistingAlgorithmException exc) {}
185
186	Run->FillTrees(type);
187	// cout << Header->GetCounter()->Get(type) << endl;
188	Header->GetCounter()->Increment(type);
189	// cout << Header->GetCounter()->Get(type) << endl;
190	}
191	else
192	{
193	ret=-3;
194	oss.str("");
195	// oss << " No way to read events of type " << type->GetName().c_str()<<". The Packet is skipped ";
196	oss << " No way to read events of type " << type->GetName()<<". The Packet is skipped ";
197	oss << " Return "<<ret;
198	msg=oss.str();
199	PamOffLineSW::mainLogUtil->logWarning(msg);
200	return ret;
201	}
202	return ret;
203	}
204
205	/**
206	* Unpack the PSCU header from the pkt into the structure.
207	*/
208	//fill the header structure,
209	void EventReader::PKT_UnpackPscuHeader(char* buff)
210	{
211	unsigned char PacketId1 = buff[3];
212	unsigned char PacketId2 = buff[4];
213	unsigned int Counter = (((UINT32)buff[5]<<16)&0x00FF0000) + (((UINT32)buff[6]<<8)&0x0000FF00) + (((UINT32)buff[7])&0x000000FF);
214	unsigned int OrbitalTime = (((UINT32)buff[8]<<24)&0xFF000000) + (((UINT32)buff[9]<<16)&0x00FF0000) + (((UINT32)buff[10]<<8)&0x0000FF00) + (((UINT32)buff[11])&0x000000FF);
215	unsigned int PacketLenght = (((UINT32)buff[12]<<16)&0x00FF0000) + (((UINT32)buff[13]<<8)&0x0000FF00) + (((UINT32)buff[14])&0x000000FF);
216	unsigned char CRC = buff[15];
217	// unsigned char FileOffset = 0;// ??
218
219	Header->GetPscuHeader()->SetPacketId(PacketId1, PacketId2);
220	Header->GetPscuHeader()->SetCounter(Counter);
221	Header->GetPscuHeader()->SetOrbitalTime(OrbitalTime);
222	//PacketLength is the length of the whole DATApacket starting from the first byte after the header
223	//plus the CRC legth (which varies for each type of packet)
224	Header->GetPscuHeader()->SetPacketLenght(PacketLenght);
225
226	Header->GetPscuHeader()->SetCRC(CRC);
227	Header->GetPscuHeader()->SetFileOffset(0);//I don't need this !!
228	}
229
230
231
232	/**
233	* Get a string with the version info of the algorithm.
234	*/
235	std::string EventReader::GetVersionInfo(void) const {
236	return
237	"$Header: /afs/ba.infn.it/user/pamela/src/CVS/chewbacca/PamOffLineSW/techmodel/EventReader.cpp,v 1.3 2009/07/24 13:53:45 mocchiut Exp $\n";
238	}
239
240
241	ClassImp(EventReader)