--- yoda/techmodel/CalibTrk1Reader.cpp 2004/07/17 20:03:38 1.3 +++ yoda/techmodel/CalibTrk1Reader.cpp 2006/02/04 12:37:44 5.1 @@ -1,7 +1,7 @@ /** @file * $Source: /home/cvsmanager/yoda/techmodel/CalibTrk1Reader.cpp,v $ - * $Id: CalibTrk1Reader.cpp,v 1.2 2004/07/06 13:31:18 kusanagi Exp $ - * $Author: kusanagi $ + * $Id: CalibTrk1Reader.cpp,v 5.0 2005/08/29 09:46:13 Maurizio Nagni Exp $ + * $Author: Maurizio Nagni $ * * Implementation of the LogReader class. * ToBeDone: @@ -11,58 +11,55 @@ #define UINT unsigned int #define BYTE unsigned char #include -#include +#include +#include +#include "stdio.h" +#include "ReaderAlgorithms.h" +#include "event/PamelaRun.h" + +#include "event/CalibTrk1Event.h" + extern "C" { #include "CRC.h" - //The int* return the error code - //The char* is the path to the temporary file - extern void trkcalibpkt_(int*, char*); + extern void trkcalibpkt_(int*, unsigned char[], long int*, int*); //(*) //Struct per il passaggio di dati da e verso la chiamata fortran extern struct { - int DAQmode[6]; - int DSPnumber[6]; - int calibnumber[6]; - int ncalib_event[6]; - int ped_l1[6]; - int ped_l2[6]; - int ped_l3[6]; - int sig_l1[6]; - int sig_l2[6]; - int sig_l3[6]; - int nbad_l1[6]; - int nbad_l2[6]; - int nbad_l3[6]; - int cal_flag[6]; - int checksum[6]; - int DSPbad_par[6][3072]; - float DSPped_par[6][3072]; - float DSPsig_par[6][3072]; + int good0; + int DAQmode[6]; + int DSPnumber[6]; + int calibnumber[6]; + int ncalib_event[6]; + int ped_l1[6]; + int ped_l2[6]; + int ped_l3[6]; + int sig_l1[6]; + int sig_l2[6]; + int sig_l3[6]; + int nbad_l1[6]; + int nbad_l2[6]; + int nbad_l3[6]; + int cal_flag[6]; + float DSPped_par[3072][6]; + float DSPsig_par[3072][6]; + int DSPbad_par[3072][6]; + int crc_cal[3][6]; + int crc_hcal[6]; } trkcalib_; - #include } -#include -#include "stdio.h" -#include "ReaderAlgorithms.h" -#include "event/PamelaRun.h" - -#include "event/CalibTrk1Event.h" - using namespace pamela; using namespace pamela::techmodel; -static log4cpp::Category& cat = log4cpp::Category::getInstance("pamela.techmodel.CalibTrk1Reader"); +static log4cxx::LoggerPtr logger = log4cxx::Logger::getLogger(_T("pamela.techmodel.CalibTrk1Reader")); /** * Constructor. */ CalibTrk1Reader::CalibTrk1Reader(void): TechmodelAlgorithm(PacketType::CalibTrk1, "TechmodelCalibTrk1Reader") { - cat << log4cpp::Priority::DEBUG - << "Constructor " - << "\n " << log4cpp::CategoryStream::ENDLINE; + logger->debug(_T("Constructor")); calibTrk1 = new CalibTrk1Event(); } @@ -71,7 +68,7 @@ */ std::string CalibTrk1Reader::GetVersionInfo(void) const { return - "$Header: /home/cvsmanager/yoda/techmodel/CalibTrk1Reader.cpp,v 1.2 2004/07/06 13:31:18 kusanagi Exp $\n"; + "$Header: /home/cvsmanager/yoda/techmodel/CalibTrk1Reader.cpp,v 5.0 2005/08/29 09:46:13 Maurizio Nagni Exp $\n"; } /** @@ -79,6 +76,7 @@ * event reader routines for all packet types. */ void CalibTrk1Reader::Init(PamelaRun *run) { + logger->debug(_T("Initialize")); SetInputStream(run); run->WriteSubPacket(this, &calibTrk1, calibTrk1->Class()); } @@ -87,70 +85,64 @@ * Unpack the CalibTrk event from an input file. */ //void CalibTrkReader::RunEvent(int EventNumber, long int length, char *subData) { -void CalibTrk1Reader::RunEvent(int EventNumber, long int length) { - - char *subData; - char eventCRC[2]; - UINT16 subCRC; //CRC of the data - UINT16 readCRC; //CRC read from the end of the subpacket - long int dataLength; - - //the 2 bytes subtracted belong to the final event CRC bytes - dataLength = length - (long int)2; - - subData = new char[dataLength]; +void CalibTrk1Reader::RunEvent(int EventNumber, long int dataLength) throw (Exception){ + std::stringstream oss; + char subData[dataLength]; + int ERROR; InputFile->read(subData, sizeof(unsigned char)*dataLength); - subCRC = CM_Compute_CRC16(0, (BYTE*)subData, dataLength); - //took the final CRC to compare it with the previous calculated CRC of the data - InputFile->read(eventCRC, sizeof(eventCRC)); - readCRC = (((UINT16)(eventCRC[0]<<8))&0xFF00) + (((UINT16)eventCRC[1])&0x00FF); + char *data = new char[dataLength]; + memcpy(data, subData, dataLength); + int curpos=1; - if (subCRC == readCRC){ - int ERROR; - //Scrivo un file temporaneo per passarlo alla routine - //Speriamo di cambiare la routine per passargli un buffer..... - DIR *dirp; - std::string pathDir((char*)getenv("YODA_DATA")); - pathDir = pathDir + "/todatemp.dat";; - FILE *pfile; - pfile = fopen((char*)pathDir.c_str(), "wb"); - fwrite(subData, 1, dataLength, pfile); - fclose(pfile); + //Call to the FORTRAN routin that unpack tracker events + trkcalibpkt_( &ERROR,(unsigned char*)data, &dataLength, &curpos); - //Call to the FORTRAN routin that unpack tracker events - trkcalibpkt_(&ERROR, (char*)pathDir.c_str()); - - remove((char*)pathDir.c_str()); - - //Store the unpacked data - memcpy(calibTrk1->DAQmode, trkcalib_.DAQmode, sizeof(calibTrk1->DAQmode)); - memcpy(calibTrk1->DSPnumber, trkcalib_.DSPnumber, sizeof(calibTrk1->DSPnumber)); - memcpy(calibTrk1->calibnumber, trkcalib_.calibnumber, sizeof(calibTrk1->calibnumber)); - memcpy(calibTrk1->DSPnumber, trkcalib_.ncalib_event, sizeof(calibTrk1->ncalib_event)); - memcpy(calibTrk1->ped_l1, trkcalib_.ped_l1, sizeof(calibTrk1->ped_l1)); - memcpy(calibTrk1->ped_l2, trkcalib_.ped_l2, sizeof(calibTrk1->ped_l2)); - memcpy(calibTrk1->ped_l3, trkcalib_.ped_l3, sizeof(calibTrk1->ped_l3)); - memcpy(calibTrk1->sig_l1, trkcalib_.sig_l1, sizeof(calibTrk1->sig_l1)); - memcpy(calibTrk1->sig_l2, trkcalib_.sig_l2, sizeof(calibTrk1->sig_l2)); - memcpy(calibTrk1->sig_l3, trkcalib_.sig_l3, sizeof(calibTrk1->sig_l3)); - memcpy(calibTrk1->nbad_l1, trkcalib_.nbad_l1, sizeof(calibTrk1->nbad_l1)); - memcpy(calibTrk1->nbad_l2, trkcalib_.nbad_l2, sizeof(calibTrk1->nbad_l2)); - memcpy(calibTrk1->nbad_l3, trkcalib_.nbad_l3, sizeof(calibTrk1->nbad_l3)); - memcpy(calibTrk1->cal_flag, trkcalib_.cal_flag, sizeof(calibTrk1->cal_flag)); - memcpy(calibTrk1->checksum, trkcalib_.checksum, sizeof(calibTrk1->checksum)); - memcpy(calibTrk1->DSPbad_par,trkcalib_.DSPbad_par, sizeof(calibTrk1->DSPbad_par)); - memcpy(calibTrk1->DSPped_par,trkcalib_.DSPped_par, sizeof(calibTrk1->DSPped_par)); - memcpy(calibTrk1->DSPsig_par,trkcalib_.DSPsig_par, sizeof(calibTrk1->DSPsig_par)); - - cat << log4cpp::Priority::ERROR - << "Fortran77 function trkcalibpkt error code = " << ERROR - << "\n " << log4cpp::CategoryStream::ENDLINE; - free(subData); - } else { - cat << log4cpp::Priority::ERROR - << "Wrong CRC for CalibTrk1 Packet " - << "\n " << log4cpp::CategoryStream::ENDLINE; + calibTrk1->unpackError = ERROR; + if (ERROR != 0) { + oss.str(""); + oss << "Fortran77 function trkcalibpkt error code = " << ERROR; + logger->warn(oss.str().c_str()); + } + + //Store the unpacked data + calibTrk1->good0 = trkcalib_.good0; + memcpy(calibTrk1->DAQmode, trkcalib_.DAQmode, sizeof(calibTrk1->DAQmode)); + memcpy(calibTrk1->DSPnumber, trkcalib_.DSPnumber, sizeof(calibTrk1->DSPnumber)); + memcpy(calibTrk1->calibnumber, trkcalib_.calibnumber, sizeof(calibTrk1->calibnumber)); + memcpy(calibTrk1->ncalib_event, trkcalib_.ncalib_event, sizeof(calibTrk1->ncalib_event)); + memcpy(calibTrk1->ped_l1, trkcalib_.ped_l1, sizeof(calibTrk1->ped_l1)); + memcpy(calibTrk1->ped_l2, trkcalib_.ped_l2, sizeof(calibTrk1->ped_l2)); + memcpy(calibTrk1->ped_l3, trkcalib_.ped_l3, sizeof(calibTrk1->ped_l3)); + memcpy(calibTrk1->sig_l1, trkcalib_.sig_l1, sizeof(calibTrk1->sig_l1)); + memcpy(calibTrk1->sig_l2, trkcalib_.sig_l2, sizeof(calibTrk1->sig_l2)); + memcpy(calibTrk1->sig_l3, trkcalib_.sig_l3, sizeof(calibTrk1->sig_l3)); + memcpy(calibTrk1->nbad_l1, trkcalib_.nbad_l1, sizeof(calibTrk1->nbad_l1)); + memcpy(calibTrk1->nbad_l2, trkcalib_.nbad_l2, sizeof(calibTrk1->nbad_l2)); + memcpy(calibTrk1->nbad_l3, trkcalib_.nbad_l3, sizeof(calibTrk1->nbad_l3)); + memcpy(calibTrk1->cal_flag, trkcalib_.cal_flag, sizeof(calibTrk1->cal_flag)); + + int tempBad_par[3072][6]; + float tempPed_par[3072][6]; + float tempSig_par[3072][6]; + int tempCrc_cal[3][6]; + memcpy(tempBad_par,trkcalib_.DSPbad_par, sizeof(tempBad_par)); + memcpy(tempPed_par,trkcalib_.DSPped_par, sizeof(tempPed_par)); + memcpy(tempSig_par,trkcalib_.DSPsig_par, sizeof(tempSig_par)); + memcpy(tempCrc_cal,trkcalib_.crc_cal, sizeof(tempCrc_cal)); + + for (int i = 0; i < 6; i++){ + for (int j = 0; j < 3072; j++){ + calibTrk1->DSPbad_par[i][j] = tempBad_par[j][i]; + calibTrk1->DSPped_par[i][j] = tempPed_par[j][i]; + calibTrk1->DSPsig_par[i][j] = tempSig_par[j][i]; + } + for (int k = 0; k < 3; k++){ + calibTrk1->crc_cal[i][k] = tempCrc_cal[k][i]; + } } +//----------------------------------------------------------------------------------------- + } +