1 |
/** @file |
/** @file |
2 |
* $Source: /home/cvsmanager/yoda/techmodel/PhysicsReader.cpp,v $ |
* $Source: /afs/ba.infn.it/user/pamela/src/CVS/yoda/techmodel/PhysicsReader.cpp,v $ |
3 |
* $Id: PhysicsReader.cpp,v 6.0 2006/02/07 17:11:10 kusanagi Exp $ |
* $Id: PhysicsReader.cpp,v 6.3 2006/09/29 10:19:25 mocchiut Exp $ |
4 |
* $Author: kusanagi $ |
* $Author: mocchiut $ |
5 |
* |
* |
6 |
* Implementation of the LogReader class. |
* Implementation of the LogReader class. |
7 |
* ToBeDone: |
* ToBeDone: |
19 |
|
|
20 |
#include <fstream> |
#include <fstream> |
21 |
#include "stdio.h" |
#include "stdio.h" |
|
#include <sys/wait.h> |
|
22 |
#include "ReaderAlgorithms.h" |
#include "ReaderAlgorithms.h" |
23 |
|
|
24 |
|
|
54 |
*/ |
*/ |
55 |
std::string PhysicsReader::GetVersionInfo(void) const { |
std::string PhysicsReader::GetVersionInfo(void) const { |
56 |
return |
return |
57 |
"$Header: /home/cvsmanager/yoda/techmodel/PhysicsReader.cpp,v 6.0 2006/02/07 17:11:10 kusanagi Exp $\n"; |
"$Header: /afs/ba.infn.it/user/pamela/src/CVS/yoda/techmodel/PhysicsReader.cpp,v 6.3 2006/09/29 10:19:25 mocchiut Exp $\n"; |
58 |
} |
} |
59 |
|
|
60 |
/** |
/** |
79 |
*/ |
*/ |
80 |
void PhysicsReader::RunEvent(int EventNumber, long int dataLenght) throw (Exception){ |
void PhysicsReader::RunEvent(int EventNumber, long int dataLenght) throw (Exception){ |
81 |
char *subData = new char[dataLenght]; |
char *subData = new char[dataLenght]; |
82 |
|
memset(subData, 0, dataLenght*sizeof(char)); |
83 |
InputFile->read(subData, sizeof(unsigned char)*dataLenght); |
InputFile->read(subData, sizeof(unsigned char)*dataLenght); |
84 |
|
|
85 |
/*-----------------*/ |
/*-----------------*/ |
|
/* |
|
86 |
//passo packetData a tutti i reader dei vari rivelatori |
//passo packetData a tutti i reader dei vari rivelatori |
87 |
int childtrk, childac, childcalo, childnd, childs4, childtof, childtrig, Status; |
triggerReader->RunEvent(EventNumber, subData, dataLenght); |
88 |
int retctrk, retcac, retccalo, retcnd, retcs4, retctof, retctrig; |
tofReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
|
|
if ((childtrk = fork()) > 0) { |
|
|
trackerReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
} |
|
|
if ((childac = fork()) > 0) { |
|
|
anticounterReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
} |
|
|
if ((childcalo = fork()) > 0) { |
|
|
calorimeterReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
} |
|
|
if ((childnd = fork()) > 0) { |
|
|
neutronReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
} |
|
|
if ((childs4 = fork()) > 0) { |
|
|
s4Reader->RunEvent(EventNumber, subData, dataLenght); |
|
|
} |
|
|
if ((childtof = fork()) > 0) { |
|
|
tofReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
} |
|
|
if ((childtrig = fork()) > 0) { |
|
|
triggerReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
} |
|
|
|
|
|
do { |
|
|
retctrk = waitpid(childtrk, &Status, 0); |
|
|
retcac = waitpid(childac, &Status, 0); |
|
|
retccalo = waitpid(childcalo, &Status, 0); |
|
|
retcnd = waitpid(childnd, &Status, 0); |
|
|
retcs4 = waitpid(childs4, &Status, 0); |
|
|
retctof = waitpid(childtof, &Status, 0); |
|
|
retctrig = waitpid(childtrig, &Status, 0); |
|
|
} while( (retctrk > 0 || (retctrk == -1)) && |
|
|
(retcac > 0 || (retcac == -1)) && |
|
|
(retccalo > 0 || (retccalo == -1)) && |
|
|
(retcnd > 0 || (retcnd == -1)) && |
|
|
(retcs4 > 0 || (retcs4 == -1)) && |
|
|
(retctof > 0 || (retctof == -1)) && |
|
|
(retctrig > 0 || (retctrig == -1)) ); |
|
|
*/ |
|
|
|
|
89 |
trackerReader->RunEvent(EventNumber, subData, dataLenght); |
trackerReader->RunEvent(EventNumber, subData, dataLenght); |
90 |
anticounterReader->RunEvent(EventNumber, subData, dataLenght); |
anticounterReader->RunEvent(EventNumber, subData, dataLenght); |
91 |
calorimeterReader->RunEvent(EventNumber, subData, dataLenght); |
calorimeterReader->RunEvent(EventNumber, subData, dataLenght); |
|
neutronReader->RunEvent(EventNumber, subData, dataLenght); |
|
92 |
s4Reader->RunEvent(EventNumber, subData, dataLenght); |
s4Reader->RunEvent(EventNumber, subData, dataLenght); |
93 |
tofReader->RunEvent(EventNumber, subData, dataLenght); |
neutronReader->RunEvent(EventNumber, subData, dataLenght); |
|
triggerReader->RunEvent(EventNumber, subData, dataLenght); |
|
|
|
|
94 |
/*-----------------*/ |
/*-----------------*/ |
95 |
delete [] subData; |
delete [] subData; |
96 |
} |
} |