/[PAMELA software]/chewbacca/PamOffLineSW/techmodel/PhysEndRunReader.cpp
ViewVC logotype

Diff of /chewbacca/PamOffLineSW/techmodel/PhysEndRunReader.cpp

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.1 by mocchiut, Tue Sep 23 07:20:24 2008 UTC revision 1.4 by mocchiut, Thu Oct 2 14:37:19 2008 UTC
# Line 1  Line 1 
1  // Implementation of the PhysEndRunReader class.  // Implementation of the PhysEndRunReader class.
2  //new version...  //new version...
3  extern "C" {  extern "C" {
4  #include "CRC.h"  #include "CRC.h"
5  }  }
6    
7  #include "ReaderAlgorithms.h"  #include "ReaderAlgorithms.h"
8    
9  using namespace pamela::techmodel;  using namespace pamela::techmodel;
10    
11    
12  /**  /**
13   * Constructor.   * Constructor.
14   */   */
15  PhysEndRunReader::PhysEndRunReader(void):  PhysEndRunReader::PhysEndRunReader(void):
16    TechmodelAlgorithm(PacketType::PhysEndRun, "TechmodelPhysEndRunReader") {    TechmodelAlgorithm(PacketType::PhysEndRun, "TechmodelPhysEndRunReader") {
17    physEndRun = new PhysEndRunEvent();    physEndRun = new PhysEndRunEvent();
18  }  }
19    
20  /**  /**
21   * Initialize the algorithm with a special run. This will initialize the   * Initialize the algorithm with a special run. This will initialize the
22   * event reader routines for all packet types.   * event reader routines for all packet types.
23   */   */
24  void PhysEndRunReader::Init(PamelaRun *run) {  void PhysEndRunReader::Init(PamelaRun *run) {
25    run->WriteSubPacket(this, &physEndRun, physEndRun->Class());    run->WriteSubPacket(this, &physEndRun, physEndRun->Class());
26  }  }
27    
28  /**  /**
29   * Unpack the PhysEndRun event from an input file.   * Unpack the PhysEndRun event from an input file.
30   * void PhysEndRunReader::PKT_RunEvent(char* subData, long int length) throw (WrongCRCException_PKTUsed){   * void PhysEndRunReader::PKT_RunEvent(char* subData, long int length) throw (WrongCRCException_PKTUsed){
31   *   *
32   */   */
33  void PhysEndRunReader::PKT_RunEvent(char* subData, long int length) throw (Exception){  void PhysEndRunReader::PKT_RunEvent(char* subData, long int length) throw (Exception){
34          std::stringstream oss;          std::stringstream oss;
35          string msg;              string msg;    
36          UINT16    subCRC;      //CRC of the data  
37          UINT16    readCRC;     //CRC read from the end of the subpacket          // baco  /gpfs/wizard/flight/production/preRawreader/05510005.pam
38            if (length<21)
39              {
40          // baco  /gpfs/wizard/flight/production/preRawreader/05510005.pam              oss.str("");
41          if (length<21)              oss<<"Wrong Lenght for PhysEndRun Packet: "<<" length = "<< length<<" too small to be real";
42          {              msg=oss.str();
43                  oss.str("");              PamOffLineSW::mainLogUtil->logError(msg);                          
44                  oss<<"Wrong Lenght for PhysEndRun Packet: "<<" length = "<< length<<" too small to be real";              //the packet is not good and will be discarded
45                  msg=oss.str();              throw FatalException(" Wrong Lenght for PhysEndRun Packet ");      
46                  PamOffLineSW::mainLogUtil->logError(msg);                                          }
47                  //the packet is not good and will be discarded  
48                  throw FatalException(" Wrong Lenght for PhysEndRun Packet ");                    long int  dataLength = length ; // -2    
49          }          long int  tbInitPos  = dataLength - 19; // 19 is the length of th TB
50    
51          long int  dataLength = length - 2;              //--------------- CALO SECTION------------------------------------
52          long int  tbInitPos  = dataLength - 19; // 19 is the length of th TB          long int offset = 0;
53            int j = 0;
54          subCRC = CM_Compute_CRC16(0, (UINT8*)subData, dataLength);          // physEndRun->CALO_ENDRUN.
55          readCRC = (((UINT16)(subData[length - 2]<<8))&0xFF00) + (((UINT16)subData[length - 1])&0x00FF);          while(offset < tbInitPos){
56          //  std::cout<<"computedCRC "<< (UINT16)subCRC<<" readCRC "<< (UINT16)readCRC<<" readCRC_1 "<<(UINT16)subData[length-2]<<" readCRC_2 "<<(UINT16)subData[length-1]<<endl;            physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_HK     = (((UINT8)subData[offset])&0xFF);
57              physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK = ((UINT8)subData[offset+1]);
58          //--------------- CALO SECTION------------------------------------            //
59          long int offset = 0;            if (!(physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK & 0x02)) {
60          int j = 0;              UInt_t kk = 0;
61          //physEndRun->CALO_ENDRUN.              for(int k = 0; k < 11 ; k++){
62          while(offset < tbInitPos){                physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (((UINT16)(subData[offset+4+kk]<<8))&0xFF00) + (((UINT16)subData[offset+5+kk])&0x00FF);
63                  physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_HK     = (((UINT8)subData[offset])&0x1F);                physEndRun->CALO_ENDRUN[j].CALO_HK1[k] = (((UINT16)(subData[offset+26+kk]<<8))&0xFF00) + (((UINT16)subData[offset+27+kk])&0x00FF);
64          physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK = ((UINT8)subData[offset+1]);                kk += 2;
65          //subData[offset+2--->3] is a fixed word = 0x23              }      
66          //If this bit is ? the subsequent CALO_HK are not valid              offset = offset + 50; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + 2*CALO_HKx + CRC (2Bytes)
67          if (!(physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK & 0x02)) {            } else offset = offset + 4; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + CRC (2Bytes)
68              UInt_t kk = 0;            //
69              for(int k = 0; k < 11 ; k++){            for(int k = 0; k < 7 ; k++){
70                //              physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (UINT8)(subData[offset+4+kk])+ 255 + (UINT8)(subData[offset+5+kk]);              //
71                physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (((UINT16)(subData[offset+4+kk]<<8))&0xFF00) + (((UINT16)subData[offset+5+kk])&0x00FF);              // in CALO_BOARD_ID_REG and CALO_BOARD_STATUS_REG we save only the last id and status register of the 7 and we don't save the CRC for each register.
72                physEndRun->CALO_ENDRUN[j].CALO_HK1[k] = (((UINT16)(subData[offset+26+kk]<<8))&0xFF00) + (((UINT16)subData[offset+27+kk])&0x00FF);              //
73                kk += 2;              physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_REG[k]     = ((UINT8)(subData[offset])&0xFF);
74              }                    offset++;
75              offset = offset + 50; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + 2*CALO_HKx + CRC (2Bytes)              physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_REG[k] = (UINT8)(subData[offset]);
76          } else offset = offset + 4; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + CRC (2Bytes)              offset++;
77          //subData[offset+(3+k)--->(15+k)] have a CRC(what?) in subData[offset+ 23--->24]              offset++;
78                offset++;
79          //        for(int k = 0; k < 7 ; k++){              physEndRun->CALO_ENDRUN[j].CALO_REG[k] = (((UINT16)(subData[offset]<<8))&0xFF00) + (((UINT16)subData[offset+1])&0x00FF);
80          physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_REG     = ((UINT8)(subData[offset])&0x1F);              offset++;
81          physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_REG = (UINT8)(subData[offset+1]);              // CRC
82          //subData[offset+2--->3] is a fixed word = 0x2              offset++;
83          physEndRun->CALO_ENDRUN[j].CALO_REG[0] = (((UINT16)(subData[offset+4]<<8))&0xFF00) + (((UINT16)subData[offset+5])&0x00FF);              offset++;
84          physEndRun->CALO_ENDRUN[j].CALO_REG[1] = (((UINT16)(subData[offset+6]<<8))&0xFF00) + (((UINT16)subData[offset+7])&0x00FF);              offset++;
85          physEndRun->CALO_ENDRUN[j].CALO_REG[2] = 0;              //
86          physEndRun->CALO_ENDRUN[j].CALO_REG[3] = 0;            };
87          physEndRun->CALO_ENDRUN[j].CALO_REG[4] = 0;            //
88          physEndRun->CALO_ENDRUN[j].CALO_REG[5] = 0;            j++;
89          physEndRun->CALO_ENDRUN[j].CALO_REG[6] = 0;          }
90          //subData[offset+ 0--->5] have a CRC(what?) in subData[offset+ 6--->7]          //
91          offset = offset + 56; //CALO_BOARD_ID_REG + CALO_BOARD_STATUS_REG + CALO_REG + CRC(2Byte)          physEndRun->TB_ENDRUN.TB_ALARM_MASK   = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);
92          //        }          offset += 3;
93          j++;          //
94      }          physEndRun->TB_ENDRUN.TB_PMT_MASK_S3S2S12 = (((UINT32)(subData[offset]<<24))&0xFF000000) + (((UINT32)(subData[offset + 1]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 2]<<8))&0x0000FF00)  + (((UINT32)(subData[offset + 3]))&0x000000FF);
95                offset += 4;
96      //--------------- TB SECTION------------------------------------          //
97      physEndRun->TB_ENDRUN.TB_ALARM_MASK   = (((UINT16)(subData[offset]<<8))&0xFF00) + (((UINT16)subData[offset + 1])&0x00FF);          physEndRun->TB_ENDRUN.TB_PMT_MASK_S11CRC = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);
98      //subData[offset+ 0--->1] have a CRC(what?) in subData[offset+2]          offset += 3;
99      physEndRun->TB_ENDRUN.TB_PMT_MASK_S3  = ((((UINT16)(subData[offset+2]))<<4)&0x0FF0) + (((UINT16)subData[offset + 3]>>4)&0x000F);          //
100      physEndRun->TB_ENDRUN.TB_PMT_MASK_S2  = ((((UINT8)(subData[offset+3]))<<4)&0xF0) + (((UINT8)subData[offset + 4]>>4)&0x0F);          physEndRun->TB_ENDRUN.TB_S4_CAL_MASK = (((UINT16)(subData[offset]<<8))&0xFF00) + (((UINT16)(subData[offset + 1]))&0x00FF);
101      physEndRun->TB_ENDRUN.TB_PMT_MASK_S12 = ((((UINT16)(subData[offset+4]))<<8)&0x0F00) + (((UINT16)subData[offset + 5])&0x00FF);          offset += 2;
102      physEndRun->TB_ENDRUN.TB_PMT_MASK_S11 = ((((UINT16)(subData[offset+6]))<<8)&0xFF00) + (((UINT16)subData[offset + 7])&0x00FF);          //
103      //subData[offset+ 3--->8] have a CRC(what?) in subData[offset+9]          physEndRun->TB_ENDRUN.TB_BUSY_MASK = (((UINT32)(subData[offset]<<24))&0xFF000000) + (((UINT32)(subData[offset + 1]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 2]<<8))&0x0000FF00)  + (((UINT32)(subData[offset + 3]))&0x000000FF);
104      physEndRun->TB_ENDRUN.TB_CALO_MASK    = ((UINT8)subData[offset+10])>>5;          offset += 4;
105      physEndRun->TB_ENDRUN.TB_S4_MASK      = (((UINT8)subData[offset+10])>>1)&0x0F;          //
106      //subData[tbInitPos+9] have a CRC(what?) in subData[tbInitPos+11]          physEndRun->TB_ENDRUN.TB_TRIG_CONF = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);
107      physEndRun->TB_ENDRUN.TB_BUSY_MASK    = (((UINT32)subData[offset+12]<<16)&0x00FF0000) +  (((UINT32)subData[offset+13]<<8)&0x0000FF00) + (((UINT32)subData[offset+14])&0x000000FF);          offset += 3;
108      //subData[tbInitPos+ 12--->14] have a CRC(what?) in subData[tbInitPos+15]          //
109      physEndRun->TB_ENDRUN.TB_CALIB_FLAG   = ((UINT8)subData[offset+16])>>7;          // PHYSENDRUN HAS NOT CRC AT THE END!!!
110      physEndRun->TB_ENDRUN.TB_CALO_TRIG    = ((UINT8)subData[offset+16])>>6;          //
111      physEndRun->TB_ENDRUN.TB_S4_TRIG      = ((UINT8)subData[offset+16])>>5;  }
112      physEndRun->TB_ENDRUN.TB_TOF_TRIG     = (UINT8)(subData[offset+16]<<3) + (UINT8)(subData[offset+17]>>6);  
113      //subData[tbInitPos+ 16--->17] have a CRC(what?) in subData[tbInitPos+18]  /**
114     * Get a string with the version info of the algorithm.
115      // I want to use the packet so the exception is thrown here after all ..   */
116      if (subCRC != readCRC)  std::string PhysEndRunReader::GetVersionInfo(void) const {
117      {    return
118          oss.str("");      "$Header: /afs/ba.infn.it/user/pamela/src/CVS/chewbacca/PamOffLineSW/techmodel/PhysEndRunReader.cpp,v 1.3 2008/09/24 15:17:23 mocchiut Exp $\n";
         oss<<"Wrong CRC for PhysEndRun Packet: "<<" CRC COMPUTED= "<< subCRC<<" CRC READ=  "<< readCRC;  
         msg=oss.str();  
         PamOffLineSW::mainLogUtil->logWarning(msg);                              
         //the packet is not good but used  
         throw WrongCRCException_PKTUsed(" Wrong CRC for PhysEndRun Packet ");    
     }  
 }  
   
 /**  
  * Get a string with the version info of the algorithm.  
  */  
 std::string PhysEndRunReader::GetVersionInfo(void) const {  
   return  
     "$Header: /repository/PamOffLineSW/techmodel/PhysEndRunReader.cpp,v 1.12 2008-03-05 16:52:18 messineo Exp $\n";  
119  }  }
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.4
  ViewVC Help
Powered by ViewVC 1.1.23