techmodel/physics/AnticounterReader.cpp

/** @file
 * $Source: /home/cvsmanager/yoda/techmodel/physics/AnticounterReader.cpp,v $
 * $Id: AnticounterReader.cpp,v 2.1 2004/10/17 12:28:46 kusanagi Exp $
 * $Author: kusanagi $
 * 
 * Implementation of the AnticounterReader class.
 */

#include <string>
#include <log4cxx/logger.h>
#include "AnticounterReader.h"

extern "C" {
    #include "../forroutines/anticounter/AC.h"
    extern int ACphysics(int length, unsigned char* physicspointer, struct physicsstruct* physicspointer);
}

using namespace pamela;
using namespace pamela::anticounter;

static log4cxx::LoggerPtr logger = log4cxx::Logger::getLogger(_T("pamela.techmodel.anticounter.AnticounterReader"));

/**
 * Constructor. 
 */
AnticounterReader::AnticounterReader(void): 
  TechmodelAlgorithm(PacketType::Physics, "TechmodelAnticounterReader") { 
  logger->debug(_T("Constructor"));
  anticounter = new AnticounterEvent();
}

/**
 * Get a string with the version info of the algorithm.
 */
std::string AnticounterReader::GetVersionInfo(void) const {
  return 
    "$Header: /home/cvsmanager/yoda/techmodel/physics/AnticounterReader.cpp,v 2.1 2004/10/17 12:28:46 kusanagi Exp $";
}

/**
 * Initialize the algorithm with a special run. This will initialize the
 * event reader routines for all packet types.
 */
void AnticounterReader::Init(PamelaRun *run) {
  logger->debug(_T("Initialize"));
  SetInputStream(run);
  run->WriteSubPacket(this, &anticounter, anticounter->Class());
}

/**
 * Unpack the anticounter event from an input file.
 */
void AnticounterReader::RunEvent(int EventNumber) {
  
}

/**
 * Unpack the Anticounter data event from the physical packet.
 */
void AnticounterReader::RunEvent(int EventNumber, const char subData[], long int length) {
    char *data = new char[length];
    memcpy(data, subData, length);
    int        ERROR;
    struct physicsstruct output[2];
    
    //Call to the routine that unpack anitocounter events
    //ERROR = ACphysics(length, (unsigned char*) data, &output);
    anticounter->ERROR = ACphysics(length, (unsigned char*) data, &(*output));
    
    //TO BE activated as soon i will know what codes means "error"
    /*if (ERROR != 0) {
        char *errmsg;
        switch (ERROR){
            case 1: errmsg = "---------------------";
        }
    } else {*/

    for (int i = 0; i<2; i++){
        memcpy(anticounter->header, output[i].header, sizeof(output[i].header));
        anticounter->status[i] = output[i].status;
        anticounter->hitmap[i] = output[i].hitmap;
        memcpy(anticounter->regist,     output[i].regist,    sizeof(output[i].regist));
        memcpy(anticounter->shift,      output[i].shift,     sizeof(output[i].shift));
        memcpy(anticounter->counters,   output[i].counters,  sizeof(output[i].counters));
        memcpy(anticounter->coinc,      output[i].coinc,     sizeof(output[i].coinc));
        anticounter->trigg[i] = output[i].trigg;
        memcpy(anticounter->clock,      output[i].clock,     sizeof(output[i].clock));
        memcpy(anticounter->temp,       output[i].temp,      sizeof(output[i].temp));
        memcpy(anticounter->DAC,        output[i].DAC,       sizeof(output[i].DAC));
        anticounter->CRC[i] = output[i].CRC;
    }

    //}
    delete[] data;
}
1	kusanagi	1.1	/** @file
2			* $Source: /home/cvsmanager/yoda/techmodel/physics/AnticounterReader.cpp,v $
3	kusanagi	2.2	* $Id: AnticounterReader.cpp,v 2.1 2004/10/17 12:28:46 kusanagi Exp $
4	kusanagi	1.1	* $Author: kusanagi $
5			*
6			* Implementation of the AnticounterReader class.
7			*/
8
9			#include <string>
10	kusanagi	1.3	#include <log4cxx/logger.h>
11	kusanagi	1.1	#include "AnticounterReader.h"
12
13			extern "C" {
14	kusanagi	2.1	#include "../forroutines/anticounter/AC.h"
15			extern int ACphysics(int length, unsigned char* physicspointer, struct physicsstruct* physicspointer);
16	kusanagi	1.1	}
17
18			using namespace pamela;
19			using namespace pamela::anticounter;
20
21	kusanagi	1.3	static log4cxx::LoggerPtr logger = log4cxx::Logger::getLogger(_T("pamela.techmodel.anticounter.AnticounterReader"));
22	kusanagi	1.1
23			/**
24			* Constructor.
25			*/
26			AnticounterReader::AnticounterReader(void):
27			TechmodelAlgorithm(PacketType::Physics, "TechmodelAnticounterReader") {
28	kusanagi	1.3	logger->debug(_T("Constructor"));
29	kusanagi	1.1	anticounter = new AnticounterEvent();
30			}
31
32			/**
33			* Get a string with the version info of the algorithm.
34			*/
35			std::string AnticounterReader::GetVersionInfo(void) const {
36			return
37	kusanagi	2.2	"$Header: /home/cvsmanager/yoda/techmodel/physics/AnticounterReader.cpp,v 2.1 2004/10/17 12:28:46 kusanagi Exp $";
38	kusanagi	1.1	}
39
40			/**
41			* Initialize the algorithm with a special run. This will initialize the
42			* event reader routines for all packet types.
43			*/
44			void AnticounterReader::Init(PamelaRun *run) {
45	kusanagi	1.3	logger->debug(_T("Initialize"));
46	kusanagi	1.1	SetInputStream(run);
47			run->WriteSubPacket(this, &anticounter, anticounter->Class());
48			}
49
50			/**
51			* Unpack the anticounter event from an input file.
52			*/
53			void AnticounterReader::RunEvent(int EventNumber) {
54
55			}
56
57			/**
58			* Unpack the Anticounter data event from the physical packet.
59			*/
60			void AnticounterReader::RunEvent(int EventNumber, const char subData[], long int length) {
61	kusanagi	1.3	char *data = new char[length];
62	kusanagi	1.1	memcpy(data, subData, length);
63			int ERROR;
64	kusanagi	2.2	struct physicsstruct output[2];
65	kusanagi	1.1
66			//Call to the routine that unpack anitocounter events
67	kusanagi	2.2	//ERROR = ACphysics(length, (unsigned char*) data, &output);
68			anticounter->ERROR = ACphysics(length, (unsigned char) data, &(output));
69
70	kusanagi	1.2	//TO BE activated as soon i will know what codes means "error"
71			/*if (ERROR != 0) {
72			char *errmsg;
73			switch (ERROR){
74			case 1: errmsg = "---------------------";
75			}
76			} else {*/
77	kusanagi	2.2
78			for (int i = 0; i<2; i++){
79			memcpy(anticounter->header, output[i].header, sizeof(output[i].header));
80			anticounter->status[i] = output[i].status;
81			anticounter->hitmap[i] = output[i].hitmap;
82			memcpy(anticounter->regist, output[i].regist, sizeof(output[i].regist));
83			memcpy(anticounter->shift, output[i].shift, sizeof(output[i].shift));
84			memcpy(anticounter->counters, output[i].counters, sizeof(output[i].counters));
85			memcpy(anticounter->coinc, output[i].coinc, sizeof(output[i].coinc));
86			anticounter->trigg[i] = output[i].trigg;
87			memcpy(anticounter->clock, output[i].clock, sizeof(output[i].clock));
88			memcpy(anticounter->temp, output[i].temp, sizeof(output[i].temp));
89			memcpy(anticounter->DAC, output[i].DAC, sizeof(output[i].DAC));
90			anticounter->CRC[i] = output[i].CRC;
91			}
92
93	kusanagi	1.2	//}
94	kusanagi	1.3	delete[] data;
95	kusanagi	1.1	}