/[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.3 by mocchiut, Wed Sep 24 15:17:23 2008 UTC revision 1.5 by mocchiut, Tue Feb 16 13:38:14 2010 UTC
# Line 33  void PhysEndRunReader::Init(PamelaRun *r Line 33  void PhysEndRunReader::Init(PamelaRun *r
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;    
         UINT16    subCRC;      //CRC of the data  
         UINT16    readCRC;     //CRC read from the end of the subpacket  
   
36    
37          // baco  /gpfs/wizard/flight/production/preRawreader/05510005.pam          // baco  /gpfs/wizard/flight/production/preRawreader/05510005.pam
38          if (length<21)          if (length<21)
39          {            {
40                  oss.str("");              oss.str("");
41                  oss<<"Wrong Lenght for PhysEndRun Packet: "<<" length = "<< length<<" too small to be real";              oss<<"Wrong Lenght for PhysEndRun Packet: "<<" length = "<< length<<" too small to be real";
42                  msg=oss.str();              msg=oss.str();
43                  PamOffLineSW::mainLogUtil->logError(msg);                                            PamOffLineSW::mainLogUtil->logError(msg);                          
44                  //the packet is not good and will be discarded              //the packet is not good and will be discarded
45                  throw FatalException(" Wrong Lenght for PhysEndRun Packet ");                        throw FatalException(" Wrong Lenght for PhysEndRun Packet ");      
46          }            }
47    
48          long int  dataLength = length - 2;              long int  dataLength = length ; // -2    
49          long int  tbInitPos  = dataLength - 19; // 19 is the length of th TB          long int  tbInitPos  = dataLength - 19; // 19 is the length of th TB
50    
         subCRC = CM_Compute_CRC16(0, (UINT8*)subData, dataLength);  
         readCRC = (((UINT16)(subData[length - 2]<<8))&0xFF00) + (((UINT16)subData[length - 1])&0x00FF);  
         //  std::cout<<"computedCRC "<< (UINT16)subCRC<<" readCRC "<< (UINT16)readCRC<<" readCRC_1 "<<(UINT16)subData[length-2]<<" readCRC_2 "<<(UINT16)subData[length-1]<<endl;  
   
   
51          //--------------- CALO SECTION------------------------------------          //--------------- CALO SECTION------------------------------------
52          long int offset = 0;          long int offset = 0;
53          int j = 0;          int j = 0;
54          //physEndRun->CALO_ENDRUN.          // physEndRun->CALO_ENDRUN.
55          while(offset < tbInitPos){          while(offset < tbInitPos){
56                    if ( offset >= length ) return;
57            physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_HK     = (((UINT8)subData[offset])&0xFF);            physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_HK     = (((UINT8)subData[offset])&0xFF);
58                    if ( offset+1 >= length ) return;
59            physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK = ((UINT8)subData[offset+1]);            physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK = ((UINT8)subData[offset+1]);
60            //subData[offset+2--->3] is a fixed word = 0x23            //
           //If this bit is ? the subsequent CALO_HK are not valid  
           //      printf(" j %i calo_board_id_hk %X \n",j,physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_HK);  
           //      printf(" j %i calo_board_status_hk %X \n",j,physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK);  
61            if (!(physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK & 0x02)) {            if (!(physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK & 0x02)) {
62              UInt_t kk = 0;              Int_t kk = 0;
63              for(int k = 0; k < 11 ; k++){              for(int k = 0; k < 11 ; k++){
64                //              physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (UINT8)(subData[offset+4+kk])+ 255 + (UINT8)(subData[offset+5+kk]);                  if ( offset+5+kk >= length ) return;
65                physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (((UINT16)(subData[offset+4+kk]<<8))&0xFF00) + (((UINT16)subData[offset+5+kk])&0x00FF);                physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (((UINT16)(subData[offset+4+kk]<<8))&0xFF00) + (((UINT16)subData[offset+5+kk])&0x00FF);
66                    if ( offset+27+kk >= length ) return;
67                physEndRun->CALO_ENDRUN[j].CALO_HK1[k] = (((UINT16)(subData[offset+26+kk]<<8))&0xFF00) + (((UINT16)subData[offset+27+kk])&0x00FF);                physEndRun->CALO_ENDRUN[j].CALO_HK1[k] = (((UINT16)(subData[offset+26+kk]<<8))&0xFF00) + (((UINT16)subData[offset+27+kk])&0x00FF);
               //              printf(" j %i k %i calo_hk0 %X \n",j,k,physEndRun->CALO_ENDRUN[j].CALO_HK0[k]);  
               //              printf(" j %i k %i calo_hk1 %X \n",j,k,physEndRun->CALO_ENDRUN[j].CALO_HK1[k]);  
68                kk += 2;                kk += 2;
69              }                    }      
70              offset = offset + 50; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + 2*CALO_HKx + CRC (2Bytes)              offset = offset + 50; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + 2*CALO_HKx + CRC (2Bytes)
71            } else offset = offset + 4; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + CRC (2Bytes)            } else offset = offset + 4; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + CRC (2Bytes)
           //subData[offset+(3+k)--->(15+k)] have a CRC(what?) in subData[offset+ 23--->24]  
72            //            //
73            for(int k = 0; k < 7 ; k++){            for(int k = 0; k < 7 ; k++){
74              //              //
75              // 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.              // 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.
76              //              //
77              //    printf(" INLOPP k %i subdata %X \n",k,(UINT8)(subData[offset]));                  if ( offset >= length ) return;
78              physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_REG[k]     = ((UINT8)(subData[offset])&0xFF);              physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_REG[k]     = ((UINT8)(subData[offset])&0xFF);
79              offset++;              offset++;
80                    if ( offset >= length ) return;
81              physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_REG[k] = (UINT8)(subData[offset]);              physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_REG[k] = (UINT8)(subData[offset]);
82              offset++;              offset++;
             //      printf(" j %i k %i calo_board_id_reg %X \n",j,k,physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_REG[k]);  
             //      printf(" j %i k %i calo_board_status_reg %X \n",j,k,physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_REG[k]);  
83              offset++;              offset++;
             //subData[offset+2--->3] is a fixed word = 0x2 that is the data lenght  
84              offset++;              offset++;
85                    if ( offset+1 >= length ) return;
86              physEndRun->CALO_ENDRUN[j].CALO_REG[k] = (((UINT16)(subData[offset]<<8))&0xFF00) + (((UINT16)subData[offset+1])&0x00FF);              physEndRun->CALO_ENDRUN[j].CALO_REG[k] = (((UINT16)(subData[offset]<<8))&0xFF00) + (((UINT16)subData[offset+1])&0x00FF);
             //      printf(" j %i k %i calo_reg %X \n",j,k,physEndRun->CALO_ENDRUN[j].CALO_REG[k]);  
87              offset++;              offset++;
88              // CRC              // CRC
89              offset++;              offset++;
90              offset++;              offset++;
             //  
91              offset++;              offset++;
92              //    physEndRun->CALO_ENDRUN[j].CALO_REG[1] = (((UINT16)(subData[offset+6]<<8))&0xFF00) + (((UINT16)subData[offset+7])&0x00FF);              //
             //    physEndRun->CALO_ENDRUN[j].CALO_REG[2] = 0;  
             //    physEndRun->CALO_ENDRUN[j].CALO_REG[3] = 0;  
             //    physEndRun->CALO_ENDRUN[j].CALO_REG[4] = 0;  
             //    physEndRun->CALO_ENDRUN[j].CALO_REG[5] = 0;  
             //    physEndRun->CALO_ENDRUN[j].CALO_REG[6] = 0;  
             //subData[offset+ 0--->5] have a CRC(what?) in subData[offset+ 6--->7]  
             //    offset = offset + 56; //CALO_BOARD_ID_REG + CALO_BOARD_STATUS_REG + CALO_REG + CRC(2Byte)  
93            };            };
94            //            //
95            j++;            j++;
96          }          }
97            //
98  //      //--------------- CALO SECTION------------------------------------                  if ( offset+2 >= length ) return;
 //      long int offset = 0;  
 //      int j = 0;  
 //      //physEndRun->CALO_ENDRUN.  
 //      while(offset < tbInitPos){  
 //              physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_HK     = (((UINT8)subData[offset])&0x1F);  
 //         physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK = ((UINT8)subData[offset+1]);  
 //         //subData[offset+2--->3] is a fixed word = 0x23  
 //         //If this bit is ? the subsequent CALO_HK are not valid  
 //         if (!(physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_HK & 0x02)) {  
 //          UInt_t kk = 0;  
 //             for(int k = 0; k < 11 ; k++){  
 //            //              physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (UINT8)(subData[offset+4+kk])+ 255 + (UINT8)(subData[offset+5+kk]);  
 //            physEndRun->CALO_ENDRUN[j].CALO_HK0[k] = (((UINT16)(subData[offset+4+kk]<<8))&0xFF00) + (((UINT16)subData[offset+5+kk])&0x00FF);  
 //            physEndRun->CALO_ENDRUN[j].CALO_HK1[k] = (((UINT16)(subData[offset+26+kk]<<8))&0xFF00) + (((UINT16)subData[offset+27+kk])&0x00FF);  
 //            kk += 2;  
 //             }              
 //             offset = offset + 50; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + 2*CALO_HKx + CRC (2Bytes)  
 //         } else offset = offset + 4; //CALO_BOARD_ID_HK + CALO_BOARD_STATUS_HK + CRC (2Bytes)  
 //         //subData[offset+(3+k)--->(15+k)] have a CRC(what?) in subData[offset+ 23--->24]  
   
 //      //        for(int k = 0; k < 7 ; k++){  
 //      physEndRun->CALO_ENDRUN[j].CALO_BOARD_ID_REG     = ((UINT8)(subData[offset])&0x1F);  
 //      physEndRun->CALO_ENDRUN[j].CALO_BOARD_STATUS_REG = (UINT8)(subData[offset+1]);  
 //      //subData[offset+2--->3] is a fixed word = 0x2  
 //      physEndRun->CALO_ENDRUN[j].CALO_REG[0] = (((UINT16)(subData[offset+4]<<8))&0xFF00) + (((UINT16)subData[offset+5])&0x00FF);  
 //      physEndRun->CALO_ENDRUN[j].CALO_REG[1] = (((UINT16)(subData[offset+6]<<8))&0xFF00) + (((UINT16)subData[offset+7])&0x00FF);  
 //      physEndRun->CALO_ENDRUN[j].CALO_REG[2] = 0;  
 //      physEndRun->CALO_ENDRUN[j].CALO_REG[3] = 0;  
 //      physEndRun->CALO_ENDRUN[j].CALO_REG[4] = 0;  
 //      physEndRun->CALO_ENDRUN[j].CALO_REG[5] = 0;  
 //      physEndRun->CALO_ENDRUN[j].CALO_REG[6] = 0;  
 //      //subData[offset+ 0--->5] have a CRC(what?) in subData[offset+ 6--->7]  
 //      offset = offset + 56; //CALO_BOARD_ID_REG + CALO_BOARD_STATUS_REG + CALO_REG + CRC(2Byte)  
 //      //        }  
 //         j++;  
 //     }  
           
         //--------------- TB SECTION------------------------------------  
         //      for (Int_t pi=-8; pi<40; pi++){  
         //        printf(" subdata[%u]  %X \n",offset+pi,(UINT8)subData[offset+pi]);  
         //      };  
   
 //     UINT32  TB_ALARM_MASK;  
 //     UINT32  TB_PMT_MASK_S3S2S12;  
 //     UINT32  TB_PMT_MASK_S11CRC;  
 //     UINT16  TB_S4_CAL_MASK;  
 //     UINT32  TB_BUSY_MASK;  
 //     UINT32  TB_TRIG_CONF;          
   
99          physEndRun->TB_ENDRUN.TB_ALARM_MASK   = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);          physEndRun->TB_ENDRUN.TB_ALARM_MASK   = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);
100          offset += 3;          offset += 3;
101          //          //
102                    if ( offset+3 >= length ) return;
103          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);          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);
104          offset += 4;          offset += 4;
105          //          //
106                    if ( offset+2 >= length ) return;
107          physEndRun->TB_ENDRUN.TB_PMT_MASK_S11CRC = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);          physEndRun->TB_ENDRUN.TB_PMT_MASK_S11CRC = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);
108          offset += 3;          offset += 3;
109          //          //
110                    if ( offset+1 >= length ) return;
111          physEndRun->TB_ENDRUN.TB_S4_CAL_MASK = (((UINT16)(subData[offset]<<8))&0xFF00) + (((UINT16)(subData[offset + 1]))&0x00FF);          physEndRun->TB_ENDRUN.TB_S4_CAL_MASK = (((UINT16)(subData[offset]<<8))&0xFF00) + (((UINT16)(subData[offset + 1]))&0x00FF);
112          offset += 2;          offset += 2;
113          //          //
114                    if ( offset+3 >= length ) return;
115          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);          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);
116          offset += 4;          offset += 4;
117          //          //
118                    if ( offset+2 >= length ) return;
119          physEndRun->TB_ENDRUN.TB_TRIG_CONF = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);          physEndRun->TB_ENDRUN.TB_TRIG_CONF = (((UINT32)(subData[offset]<<16))&0x00FF0000) + (((UINT32)(subData[offset + 1]<<8))&0x0000FF00) + (((UINT32)(subData[offset + 2]))&0x000000FF);
120          offset += 3;          offset += 3;
121          //          //
122            // PHYSENDRUN HAS NOT CRC AT THE END!!!
123          //      printf(" physEndRun->TB_ENDRUN.TB_ALARM_MASK %X \n",(UInt_t)physEndRun->TB_ENDRUN.TB_ALARM_MASK);          //
         //      printf(" physEndRun->TB_ENDRUN.TB_PMT_MASK_S3S2S12 %X \n",(UInt_t)physEndRun->TB_ENDRUN.TB_PMT_MASK_S3S2S12);  
         //      printf(" physEndRun->TB_ENDRUN.TB_PMT_MASK_S11CRC %X \n",(UInt_t)physEndRun->TB_ENDRUN.TB_PMT_MASK_S11CRC);  
         //      printf(" physEndRun->TB_ENDRUN.TB_S4_CAL_MASK %X \n",(UInt_t)physEndRun->TB_ENDRUN.TB_S4_CAL_MASK);  
         //      printf(" physEndRun->TB_ENDRUN.TB_BUSY_MASK %X \n",(UInt_t)physEndRun->TB_ENDRUN.TB_BUSY_MASK);  
         //      printf(" physEndRun->TB_ENDRUN.TB_TRIG_CONF %X \n",(UInt_t)physEndRun->TB_ENDRUN.TB_TRIG_CONF);  
   
         // I want to use the packet so the exception is thrown here after all ..  
         if (subCRC != readCRC)  
           {  
             oss.str("");  
             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 ");    
           }  
124  }  }
125    
126  /**  /**
# Line 209  void PhysEndRunReader::PKT_RunEvent(char Line 128  void PhysEndRunReader::PKT_RunEvent(char
128   */   */
129  std::string PhysEndRunReader::GetVersionInfo(void) const {  std::string PhysEndRunReader::GetVersionInfo(void) const {
130    return    return
131      "$Header: /afs/ba.infn.it/user/pamela/src/CVS/chewbacca/PamOffLineSW/techmodel/PhysEndRunReader.cpp,v 1.2 2008/09/24 08:47:53 mocchiut Exp $\n";      "$Header: /afs/ba.infn.it/user/pamela/src/CVS/chewbacca/PamOffLineSW/techmodel/PhysEndRunReader.cpp,v 1.4 2008/10/02 14:37:19 mocchiut Exp $\n";
132  }  }
Legend:
Removed from v.1.3  
changed lines
  Added in v.1.5
  ViewVC Help
Powered by ViewVC 1.1.23