Inheritance diagram for JDataFilter:

Public Member Functions
	JDataFilter (const std::string &name, const std::string &server, const std::string &hostname, JLogger *logger, const int level, const int port, const int backlog, const int buffer_size)
	Constructor. More...

virtual void	actionEnter ()

virtual void	actionExit ()

virtual void	actionInit (int length, const char *buffer)

virtual void	actionConfigure (int length, const char *buffer)

virtual void	actionStart (int length, const char *buffer)

virtual void	actionPause (int length, const char *buffer)

virtual void	actionContinue (int length, const char *buffer)

virtual void	actionStop (int length, const char *buffer)

virtual void	actionReset (int length, const char *buffer)

virtual void	actionQuit (int length, const char *buffer)

virtual void	setSelect (JFileDescriptorMask &mask) const

virtual void	actionSelect (const JFileDescriptorMask &mask)

virtual void	actionRunning ()
	This method is repeatedly called when this client machine is in state Running and the clock interval time is non-zero. More...

void	updateFrameQueue (const JChannelList_t::const_iterator channel)

void	processTimeSlice (const JDAQTimesliceL0 &pending_slice)

void	typeout ()

virtual bool	enter (const JArgs &args)
	Enter the state machine. More...

virtual bool	enter ()
	Enter the state machine. More...

virtual bool	exit ()
	Exit the state machine. More...

const std::string &	getFullName () const
	Get full name of this run control client. More...

const JNET::JTag &	getUniqueTag () const
	Get unique tag of this run control client. More...

int	getEventNumber () const
	Get last event number. More...

bool	isRunning () const
	Check if this client is in runnig state. More...

void	replaceEvent (const JNET::JTag &oldTag, const JNET::JTag &newTag, JDAQEvent_t &event)
	Replace tag of given event in event table. More...

JDAQEvent_t *	findEvent (const JNET::JTag &tag, const std::string &event_name)
	Find event in event table. More...

template<class T >
void	addParameter (const char option, T &parameter)
	Add parameter to parser used in method enter(). More...

template<class T >
void	addParameter (const char option, T &parameter, const T &value)
	Add parameter to parser used in method enter(). More...

long long int	getClockDelay () const
	Get total delay time. More...

const std::string &	getHostname () const
	Get hostname. More...

long long int	getClockInterval () const
	Get interval time. More...

void	setClockInterval (const long long int interval_us)
	Set interval time. More...

void	resetClock ()
	Reset clock. More...

void	setSelect ()
	Set the file descriptor mask for the select call. More...

virtual void	setSelect (JFileDescriptorMask &mask) const
	Set the file descriptor mask for the select call. More...

virtual void	actionSelect (const JFileDescriptorMask &mask)
	Action method following last select call. More...

virtual void	actionInput (int length, const char *buffer)
	This method is called at `ev_input`. More...

virtual bool	filter (const std::string &tag, int length, const char *buffer)
	Filter message. More...

void	run ()
	Run as run control client following command messages via JNET::JControlHost. More...

void	run (const int port)
	Run for ever. More...

void	run (std::istream &in)
	Run client with commands from input stream (e.g for debugging). More...

Static Public Attributes
static const int	TIMEOUT_S = 1
	time out of update [s] More...

Protected Attributes
JSharedPointer< JControlHost >	server
	message server More...

JMessageLogger	logger
	message logger More...

Private Types
typedef JControlHostObjectOutput < JDAQTypes_t >	JControlHost_t

Private Attributes
JSinglePointer< JControlHost_t >	datawriter

std::string	hostname
	controlhost to send data to the datawriter More...

int	port

int	backlog
	serversocket port More...

int	buffer_size

JSinglePointer< JServerSocket >	serversocket

JChannelList_t	channelList

JTimer	timer

list< JDAQTimesliceL0 >	timeslices

int	current_slice_index

unsigned int	frames_per_slice

unsigned int	maximum_frames_per_slice

JTriggerParameters	parameters

string	interfaceInput

JSinglePointer< JTimesliceRouter >	timesliceRouter

JDetector	detector

JSinglePointer< JModuleRouter >	moduleRouter

JSinglePointer< JBuildL1_t >	buildL1

JSinglePointer< JBuildL2_t >	buildL2

JSinglePointer< JBuildL2_t >	buildSN

JSinglePointer< JTrigger3DMuon >	trigger3DMuon

JSinglePointer< JTrigger3DShower >	trigger3DShower

JSinglePointer< JTriggerMXShower >	triggerMXShower

JMessageScheduler	logErrorRun

JMessageScheduler	logErrorDetector

JMessageScheduler	logErrorIndex

JMessageScheduler	logErrorIncomplete

JMessageScheduler	logErrorInvalidPMTs

vector< JDAQProcess >	dataFilters

vector< JDAQProcess >	dataQueues

long long int	totalCPURAM

unsigned int	maxQueueDepth

long long int	maxQueueSize

long long int	queueSize

bool	reporting

long long int	numberOfEvents

long long int	numberOfBytes

long long int	numberOfTimeslicesProcessed

long long int	numberOfIncompleteTimeslicesProcessed

long long int	numberOfFramesWithInvalidPMTs

int	minFrameNumber

int	maxFrameNumber

long long int	number_of_packets_received

long long int	number_of_packets_discarded

long long int	number_of_reads

long long int	number_of_bytes_received

bool	checkForInvalidPMTs

int	maxHitsFrame

Detailed Description

Definition at line 99 of file JDataFilter.cc.

Member Typedef Documentation

typedef JControlHostObjectOutput<JDAQTypes_t> JDataFilter::JControlHost_t

private

Definition at line 874 of file JDataFilter.cc.

Constructor & Destructor Documentation

JDataFilter::JDataFilter	(	const std::string &	name,
		const std::string &	server,
		const std::string &	hostname,
		JLogger *	logger,
		const int	level,
		const int	port,
		const int	backlog,
		const int	buffer_size
	)

inline

Constructor.

Parameters

name	name of client
server	name of command message server
hostname	name of data server
logger	pointer to logger
level	debug level
port	server port
backlog	server backlog
buffer_size	server buffer

replace tag to receive dfilter specific messages in configure

Definition at line 115 of file JDataFilter.cc.

                                               :
     JDAQClient(name,server,logger,level),
     hostname  (hostname),
     parameters()
   {
     this->port        = port;
     this->backlog     = backlog;
     this->buffer_size = buffer_size;
 
     replaceEvent(RC_CMD, RC_DFILTER, ev_configure); /// replace tag to receive dfilter specific messages in configure
     
     totalCPURAM       = getRAM();   
     
     current_slice_index  = -1;
   
     reporting = false;
   }

Member Function Documentation

virtual void JDataFilter::actionEnter ( )

inlinevirtual

Definition at line 141 of file JDataFilter.cc.

   {     
     try {
 
       JDebugStream(logger) << "Start server.";
 
       serversocket.reset(new JServerSocket(port,backlog));
     }   
     catch(const std::exception& error) {
       JErrorStream(logger) << error.what();
     }
   }

virtual void JDataFilter::actionExit ( )

inlinevirtual

Definition at line 155 of file JDataFilter.cc.

   { 
     JDebugStream(logger) << "Stop server.";
 
     serversocket.reset();
     datawriter  .reset();
   }

virtual void JDataFilter::actionInit	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 164 of file JDataFilter.cc.

   { 
     JDebugStream(logger) << "actionInit() " << std::string(buffer,length);
   }

virtual void JDataFilter::actionConfigure	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 170 of file JDataFilter.cc.

   { 
 
     // todo:
     
     // 3) receive and set site id
    
     
     using namespace std;
     using namespace JPP;
     
     JDebugStream(logger) << "actionConfigure() " << std::string(buffer,length);
   
     long long int logger_s =  5;
 
     parameters .reset();
 
     dataFilters.clear();
     dataQueues .clear();
 
     reporting = false;
     
     JProperties properties(JEquationParameters("=", ";", "", ""), 0);
 
     properties["dataWriter"]             = hostname;
     properties["numberOfFramesPerSlice"] = frames_per_slice = 1;
     properties["detector"]               = detector;
     properties["triggerParameters"]      = parameters;
     properties["queueSize"]              = maxQueueSize  = (totalCPURAM - GIGABYTE);  // leave 1 GB left ...
     properties["queueDepth"]             = maxQueueDepth = 20;                        // to be optimized
     properties["logger_s"]               = logger_s;
     properties["JDataFilter"]            = dataFilters;
     properties["DataQueue"]              = dataQueues;
     properties["pmtIdCheck"]             = checkForInvalidPMTs = false;
     properties["maxHitsFrame"]           = maxHitsFrame  = 31*2000;                    // default is 20 kHz
 
     try {
       properties.read(string(buffer, length));
     }
     catch(const exception& error) {
       JErrorStream(logger) << error.what();
     }
     
     hostname = trim(hostname);
 
     if (hostname != "") 
       datawriter.reset(new JControlHost_t(hostname));  // may throw an error
     else
       throw JException("Undefined data writer host name.");
     
     maximum_frames_per_slice = frames_per_slice;
     
     // process processlist
     
     if(dataFilters.empty()) {
       JNoticeStream(logger) << "No DataFilters in process list, or no process list. Assuming that this process is the only process on this CPU and setting parameters accordingly.";
     }
 
     
     sort(dataFilters.begin(), dataFilters.end(), processIndexSorter);
     
     unsigned int numberOfDataFiltersOnThisMachine = 0;
     vector<JDAQProcess>::iterator thisProcess     = dataFilters.end();
     
     for(vector<JDAQProcess>::iterator i = dataFilters.begin(); i != dataFilters.end(); ++i) {
       
       if(i->hostname == getHostname() ||
          i->hostname == getIPaddress()) {
 
         numberOfDataFiltersOnThisMachine++;
         
         if (i->port == this->port) {
           thisProcess = i;
         }
       }
     }
     
     if (numberOfDataFiltersOnThisMachine == 0) {
       JNoticeStream(logger) << "Zero datafilters on this machine according to process list (if it exists). Assuming one datafilter on this machine.";
       numberOfDataFiltersOnThisMachine = 1;
     }
     
     if (thisProcess == dataFilters.end()) {
       JErrorStream(logger) << "This process cannot be found in the process list. Why do I exist?";      
     }
     
     if (thisProcess != dataFilters.end() && thisProcess->index != getName()) {
       JErrorStream(logger) << "Mismatch between given process names: "
                            << "I am called " << getName() << ", but in the process list I am referred to as " << thisProcess->index;
     }
     
     if (dataFilters.begin() == thisProcess || dataFilters.empty()) {                    // set reporting
       reporting = true;
     }
 
     if (maxQueueSize > (totalCPURAM-GIGABYTE)/(numberOfDataFiltersOnThisMachine)) {     // check maximum size of queue
         
       maxQueueSize = (totalCPURAM-GIGABYTE)/(numberOfDataFiltersOnThisMachine);
 
       JNoticeStream(logger) << "Maximum queue size is too large given the number of processes on this machine. Queue size reduced to " 
                             << maxQueueSize << " bytes." ;  
     }
     
     // trigger parameters
     
     parameters.set(getMaximalDistance(detector));
     
     trigger3DMuon  .reset(new JTrigger3DMuon  (parameters));
     trigger3DShower.reset(new JTrigger3DShower(parameters));
     triggerMXShower.reset(new JTriggerMXShower(parameters, detector));
     
     moduleRouter.reset(new JModuleRouter(detector));
    
     if (reporting) {
       JNoticeStream(logger) << "This JDataFilter process will report.";
       JNoticeStream(logger) << "Number of modules: "    << (*moduleRouter)->size();
       JNoticeStream(logger) << "Trigger parameters: "   << parameters;
       JNoticeStream(logger) << "Detector description: " << endl << detector;
       JNoticeStream(logger) << "Clock interval: "       << getClockInterval();
     }
     
     timesliceRouter.reset(new JTimesliceRouter(parameters.numberOfBins));
 
     // set L1, L2 and SN builders
     
     buildL1.reset(new JBuildL1_t(parameters));
     buildL2.reset(new JBuildL2_t(parameters.L2));
     buildSN.reset(new JBuildL2_t(parameters.SN));
    
     if (buildL1.get() == NULL) { JErrorStream(logger) << "Failed to allocate buildL1."; }
     if (buildL2.get() == NULL) { JErrorStream(logger) << "Failed to allocate buildL2."; }
     if (buildSN.get() == NULL) { JErrorStream(logger) << "Failed to allocate buildSN."; }
      
     logErrorRun         = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
     logErrorDetector    = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
     logErrorIndex       = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
     logErrorIncomplete  = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
     logErrorInvalidPMTs = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
   }

virtual void JDataFilter::actionStart	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 311 of file JDataFilter.cc.

   { 
     if (reporting) {
       JNoticeStream(logger) << "Start run " << getRunNumber();
     }
     
     timeslices.clear();
 
     current_slice_index = -1;
     queueSize           =  0;
     
     numberOfEvents                        = 0;
     numberOfBytes                         = 0;
     numberOfTimeslicesProcessed           = 0;
     numberOfIncompleteTimeslicesProcessed = 0;
     
     numberOfFramesWithInvalidPMTs         = 0;
 
     number_of_packets_received  = 0;
     number_of_packets_discarded = 0;
     number_of_bytes_received    = 0;
     number_of_reads             = 0;
 
     minFrameNumber = numeric_limits<int>::max();
     maxFrameNumber = numeric_limits<int>::min();
 
     // Reset global trigger counter.
 
     KM3NETDAQ::JDAQTriggerCounter::reset();
 
     logErrorRun        .reset();
     logErrorDetector   .reset();
     logErrorIndex      .reset();
     logErrorIncomplete .reset();
     logErrorInvalidPMTs.reset();
     
     timer.reset();
     timer.start();
 
     // send trigger parameters to the datawriter
       
     ostringstream os;
     
     os << getRunNumber() << ' ' << parameters;
     
     datawriter->PutFullString(IO_TRIGGER_PARAMETERS, os.str());
   }

virtual void JDataFilter::actionPause	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 360 of file JDataFilter.cc.

   { 
     if (!timeslices.empty()) {
 
       JNoticeStream(logger) << "Flushing " << timeslices.size() << " slices.";
 
       for (list<JDAQTimesliceL0>::const_iterator i = timeslices.begin(); i != timeslices.begin(); ++i) {
         queueSize -= i->getSize();
       }
 
       timeslices.clear();
     }
 
     if (queueSize != 0) {
       JWarningStream(logger) << "Pending data in queue [B] " << queueSize;
     }
 
     current_slice_index = -1;
     queueSize           =  0;
 
     timer.stop();    
   }

virtual void JDataFilter::actionContinue	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 384 of file JDataFilter.cc.

   {
     timer.start();    
   }

virtual void JDataFilter::actionStop	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 390 of file JDataFilter.cc.

   {
     typeout();
   }

virtual void JDataFilter::actionReset	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 396 of file JDataFilter.cc.

397 {}

virtual void JDataFilter::actionQuit	(	int	length,
		const char *	buffer
	)

inlinevirtual

Definition at line 400 of file JDataFilter.cc.

   {
     datawriter.reset();
   }

virtual void JDataFilter::setSelect ( JFileDescriptorMask & mask ) const

inlinevirtual

Definition at line 406 of file JDataFilter.cc.

   {
     if (serversocket.is_valid()) {
       mask.set(*serversocket);
     }
     
     for (JChannelList_t::const_iterator channel = channelList.begin(); channel != channelList.end(); ++channel) {      
       if (!channel->isReady()) {
         mask.set(channel->getFileDescriptor());   
       }
     }
   }

virtual void JDataFilter::actionSelect ( const JFileDescriptorMask & mask )

inlinevirtual

Definition at line 420 of file JDataFilter.cc.

   {
     for (JChannelList_t::iterator channel = channelList.begin(); channel != channelList.end(); ) {
       
       try {
           
         if (mask.has(channel->getFileDescriptor())) {
           channel->read();
         }
 
         if (channel->isReady()) {
 
           number_of_packets_received += 1;
           number_of_reads            += channel->getCounter();
           number_of_bytes_received   += channel->size();
             
           if (isRunning()) {
 
             updateFrameQueue(channel);
 
           } else {
 
             JErrorStream(logErrorRun) << "Receiving data while not running.";
 
             number_of_packets_discarded += 1;
           }
 
           channel->reset();
         }
 
         ++channel;
       }
       catch(const JSocketException& error) {
 
         JNoticeStream(logger) << "Disconnecting channel " << channel->getFileDescriptor() << ' ' << error.what(); 
 
         channel->shutdown();
 
         channel = channelList.erase(channel);
       }
     }
      
 
     if (serversocket.is_valid()) {
 
       if (mask.has(*serversocket)) {
 
         JSocket socket;
         
         socket.accept(serversocket->getFileDescriptor());
         
         //socket.setSendBufferSize   (buffer_size);
         socket.setReceiveBufferSize(buffer_size);
         
         socket.setKeepAlive  (true);
         socket.setNonBlocking(true);
         
         JNoticeStream(logger) <<"New channel" << '[' << socket.getFileDescriptor() << ']';
         
         channelList.push_back(JSocketInputChannel_t(socket));
       }
     }
 
 
     if (!timeslices.empty() && (timeslices.front().size() >=  frames_per_slice ||
                                 timeslices.size()         >=  maxQueueDepth    ||
                                 queueSize                 >=  maxQueueSize)) {
       
       JDAQTimesliceL0 pending_slice  = timeslices.front();
       queueSize                     -= pending_slice.getSize();
       timeslices.pop_front();
       
       current_slice_index = pending_slice.getFrameIndex();
       minFrameNumber      = min(minFrameNumber, pending_slice.getFrameIndex());
       maxFrameNumber      = max(maxFrameNumber, pending_slice.getFrameIndex());
       
       if(pending_slice.size()>frames_per_slice) {
         
         JErrorStream(logger) << "More frames in timeslice than expected : " << pending_slice.size();
         
         if(pending_slice.size()<=maximum_frames_per_slice) { 
           
           JErrorStream(logger) << "Adjusting expected frames per timeslice to " << pending_slice.size();
           
           frames_per_slice = pending_slice.size();
         }
       }
       
       if (!pending_slice.empty()) {
 
         processTimeSlice(pending_slice);
 
         numberOfTimeslicesProcessed += 1;
         
         if (pending_slice.size() < frames_per_slice) {
           numberOfIncompleteTimeslicesProcessed += 1;
           JErrorStream(logErrorIncomplete) << "Timeout -> processed incomplete timeslice " 
                                            << "Timeslice frameindex " << pending_slice.getFrameIndex() << ' '
                                            << "Size of timeslice " << pending_slice.size() << ' '
                                            << "Queue depth " << timeslices.size()             << ' '
                                            << "Queue size "  << queueSize;
           
           if(!timeslices.empty()) {
             JErrorStream(logger) << "Adjusting expected frames per timeslice from " << frames_per_slice << " to " << pending_slice.size();
             frames_per_slice = pending_slice.size();
           }
         }
       }
     }
   }

virtual void JDataFilter::actionRunning ( )

inlinevirtual

This method is repeatedly called when this client machine is in state Running and the clock interval time is non-zero.

This implementation does nothing but may be redefined by the derived class. Care has to be taken so that the time needed to execute this method should be less than the specified clock interval time (see method setClockInterval()).

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 532 of file JDataFilter.cc.

   {
     if (reporting) {
       typeout();
     }
   }

void JDataFilter::updateFrameQueue ( const JChannelList_t::const_iterator channel )

inline

Definition at line 540 of file JDataFilter.cc.

   {
     JIO::JByteArrayReader in(channel->data(), channel->size()); 
    
     JDAQPreamble         preamble;
     JDAQSuperFrameHeader header;
                
     in >> preamble;
     in >> header;    
     
     if(preamble.getLength()!=channel->size()) {
       
       JErrorStream(logErrorRun) << "Size of received data does not match size reported by preamble." 
                                 << " preamble.getLength(): " << preamble.getLength() 
                                 << " channel->size(): " << channel->size() ;
       number_of_packets_discarded += 1;
        
       return;
     }
     
     if (header.getRunNumber() != getRunNumber()) {
 
       JErrorStream(logErrorRun) << "Run number " << header.getRunNumber() << " unequal to current run " << getRunNumber() << " -> Dropping frame.";
 
       number_of_packets_discarded += 1;
       
       return;
     }
     
     if (header.getFrameIndex() <= current_slice_index) {
       
       JErrorStream(logErrorIndex) << "FrameIndex " << header.getFrameIndex()  <<" already processed, dropping frame.";
       
       number_of_packets_discarded += 1;
       
       if(frames_per_slice<maximum_frames_per_slice) {
         
         frames_per_slice++;
 
         JErrorStream(logErrorIndex) << "Increased number of frames expected to: " << frames_per_slice;
       } 
       
       return;
     }
     
     list<JDAQTimesliceL0>::iterator timesliceIterator;
      
     for (timesliceIterator  = timeslices.begin();
          timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() < header.getFrameIndex();
          ++timesliceIterator) ;
     
     if (timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() == header.getFrameIndex()) {
       
     } else {
 
       // This is the first frame of its slice; insert a new slice at the right position in the list
 
       timesliceIterator  = timeslices.insert(timesliceIterator, JDAQTimesliceL0());
       timesliceIterator->setDAQChronometer(header.getDAQChronometer());
 
       queueSize += timesliceIterator->getSize();
     }
     
    
     if (checkForInvalidPMTs) {
      
       JDAQSuperFrame frame(header);
       
       in >> static_cast<JDAQFrame&> (frame);
         
       if(frame.size()>maxHitsFrame) {
         JErrorStream(logger) << "Frame size exceeds limit. Size: " << frame.size()<< " Frame discarded.";
         return;
       }
       JDAQSuperFrame::const_iterator hit = frame.begin() ;
       
       //  std::vector<unsigned int> prevHitT(30,0);
       
       for (; hit!=frame.end(); ++hit) {
         
         if(hit->getPMT()>30) //||
           // hit->getT()<prevHitT[hit->getPMT()])
           {
             break;
           }
         
         //   prevHitT[hit->getPMT()]=hit->getT();
       }
       
       if(hit!=frame.end()) {
         numberOfFramesWithInvalidPMTs +=1;
         JErrorStream(logErrorInvalidPMTs)<< "Frame with invalid PMT id or wrong time ordering discarded. Total discarded: "<< numberOfFramesWithInvalidPMTs;
       } 
       else 
         {
         
           
           timesliceIterator->push_back(frame);
           queueSize += timesliceIterator->rbegin()->getSize();
         }  
     }
     else {
       
       
       timesliceIterator->push_back(JDAQSuperFrame(header));
       
       in >> static_cast<JDAQFrame&>(*(timesliceIterator->rbegin()));
       queueSize += timesliceIterator->rbegin()->getSize();
     }
     
   }

void JDataFilter::processTimeSlice ( const JDAQTimesliceL0 & pending_slice )

inline

Definition at line 653 of file JDataFilter.cc.

   {
     //JDebugStream(logger) << "Processing slice: " 
     //                   << pending_slice.getRunNumber()  << " " 
     //                   << pending_slice.getFrameIndex() << " " 
     //                   << pending_slice.size();
    
     try {
 
       if (parameters.writeSummary()) {
       
         try {
 
           JDAQSummaryslice object(pending_slice);
 
           datawriter->put(object);
 
           numberOfBytes  += object.getSize();
         }
         catch(const JControlHostException& error) {
           JErrorStream(logger) << error;
         }
       }
       
       timesliceRouter->configure(pending_slice);
       
       if (parameters.trigger3DMuon.enabled    || 
           parameters.trigger3DShower.enabled  || 
           parameters.triggerMXShower.enabled  || 
           parameters.writeL1.prescale         ||
           parameters.writeL2.prescale         ||
           parameters.writeSN.prescale) {
         
       
         JTimeslice_t    timesliceL0(pending_slice.getDAQChronometer());
         JTimeslice_t    timesliceL1(pending_slice.getDAQChronometer());
         JTimeslice_t    timesliceL2(pending_slice.getDAQChronometer());
         JTimeslice_t    timesliceSN(pending_slice.getDAQChronometer());
         
         for (JDAQTimesliceL0::const_iterator super_frame = pending_slice.begin(); super_frame != pending_slice.end(); ++super_frame) {
           
           if (moduleRouter->hasModule(super_frame->getModuleID())) {
           
             const JModule&   module = moduleRouter->getModule(super_frame->getModuleID()); 
             JSuperFrame2D_t& buffer = JSuperFrame2D_t::demultiplex(*super_frame, module);
       
             // Apply high-rate veto
             
             buffer.applyHighRateVeto(parameters.highRateVeto_Hz);
 
             // L0
 
             timesliceL0.push_back(JSuperFrame1D_t(buffer));
 
             // L1
 
       
             timesliceL1.push_back(JSuperFrame1D_t(super_frame->getDAQChronometer(),
                                                   super_frame->getModuleIdentifier(),
                                                   module.getPosition()));
             
             (*buildL1)(*timesliceL0.rbegin(), back_inserter(*timesliceL1.rbegin()));
             
             // L2
             
             timesliceL2.push_back(JSuperFrame1D_t(super_frame->getDAQChronometer(),
                                                   super_frame->getModuleIdentifier(),
                                                   module.getPosition()));
       
             (*buildL2)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceL2.rbegin()));
             
             // SN
             
             timesliceSN.push_back(JSuperFrame1D_t(super_frame->getDAQChronometer(),
                                                   super_frame->getModuleIdentifier(),
                                                   module.getPosition()));
       
             (*buildSN)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceSN.rbegin()));
       
           } else {
 
             JErrorStream(logErrorDetector) << "No detector information for module " << super_frame->getModuleID(); 
           }
         }
         
         // Trigger
         
         JTriggerInput  trigger_input(timesliceL2);
         JTriggerOutput trigger_output;
           
         (*trigger3DMuon)  (trigger_input, back_inserter(trigger_output));
         (*trigger3DShower)(trigger_input, back_inserter(trigger_output));
         (*triggerMXShower)(trigger_input, timesliceL0, back_inserter(trigger_output));
         
         trigger_output.merge(JEventOverlap(parameters.TMaxEvent_ns));
         
         for (JTriggerOutput::const_iterator event = trigger_output.begin(); event != trigger_output.end(); ++event) {
             
           try {
             
             JTriggeredEvent object(*event, *timesliceRouter, *moduleRouter, parameters.TMaxLocal_ns, getTimeRange(parameters));
             
             datawriter->put(object);
             
             numberOfEvents += 1;
             numberOfBytes  += object.getSize();
           }
           catch(const JControlHostException& error) {
             JErrorStream(logger) << error;
           }
         }
 
         if (parameters.writeL1()) {
       
           try {
 
             JTimesliceL1<JDAQTimesliceL1> object(timesliceL1, *timesliceRouter, *moduleRouter, parameters.TMaxLocal_ns);
 
             datawriter->put(object);
 
             numberOfBytes  += object.getSize();
           }
           catch(const JControlHostException& error) {
             JErrorStream(logger) << error;
           }
         }
 
         if (parameters.writeL2()) {
       
           try {
 
             JTimesliceL1<JDAQTimesliceL2> object(timesliceL2, *timesliceRouter, *moduleRouter, parameters.L2.TMaxLocal_ns);
 
             datawriter->put(object);
 
             numberOfBytes  += object.getSize();
           }
           catch(const JControlHostException& error) {
             JErrorStream(logger) << error;
           }
         }
 
         if (parameters.writeSN()) {
       
           try {
 
             JTimesliceL1<JDAQTimesliceSN> object(timesliceSN, *timesliceRouter, *moduleRouter, parameters.SN.TMaxLocal_ns);
 
             datawriter->put(object);
 
             numberOfBytes  += object.getSize();
           }
           catch(const JControlHostException& error) {
             JErrorStream(logger) << error;
           }
         }
       }
 
       if (parameters.writeTimeslices() || parameters.writeL0()) { // backward compatible, remove later
         
         try {
 
           datawriter->put(pending_slice);         
 
           numberOfBytes  += pending_slice.getSize();
         }
         catch(const JControlHostException& error) {
           JErrorStream(logger)<<error;    
         }
       }
 
     } catch(const JTriggerException& error) {
       JErrorStream(logger) << error.what();
       JErrorStream(logger) << "Run: " << pending_slice.getRunNumber() << " frame index: " <<  pending_slice.getFrameIndex() << " not processed!";
     }
   }

void JDataFilter::typeout ( )

inline

Definition at line 831 of file JDataFilter.cc.

   { 
     timer.stop();
 
     const double T_us = (double) timer.usec_wall;
     
     JNoticeStream(logger) << "Reporting statistics for this datafilter.";
     JNoticeStream(logger) << "Elapsed real (wall) time [s] "          << T_us / 1e6;
     JNoticeStream(logger) << "Elapsed user CPU time [s] "             << (double) timer.usec_ucpu/ 1e6;
     JNoticeStream(logger) << "Elapsed system CPU  time [s] "          << (double) timer.usec_scpu/ 1e6;
     JNoticeStream(logger) << "Number of packets received/discarded "  << number_of_packets_received << "/" << number_of_packets_discarded;
     JNoticeStream(logger) << "Number of events/MB sent "              << numberOfEvents             << "/" << numberOfBytes/1e6;
 
     if (number_of_packets_received > 0) { JNoticeStream(logger) << "Number of reads/packet " << (double) number_of_reads / (double) number_of_packets_received; }
     
     JNoticeStream(logger) << "Current queue depth " << timeslices.size();
     JNoticeStream(logger) << "Current queue size "  << queueSize;
     JNoticeStream(logger) << "Current number of frames per slice expected: " << frames_per_slice;
     
     //if (T_us > 0) { JNoticeStream(logger) << "Packet rate  [kHz] "      << number_of_packets_received * 1000 / T_us; }
     //if (T_us > 0) { JNoticeStream(logger) << "Data   rate [MB/s] "      << number_of_bytes_received          / T_us; }    
     //if (T_us > 0) { JNoticeStream(logger) << "Event rate  [Hz] "        << numberOfEvents * 1e6 / T_us; }
     //if (T_us > 0) { JNoticeStream(logger) << "Output data rate [MB/s] " << numberOfBytes        / T_us; }
     
     JNoticeStream(logger) << "Number of timeslices processed total/incomplete " << numberOfTimeslicesProcessed << "/" << numberOfIncompleteTimeslicesProcessed;
     JNoticeStream(logger) << "Number of frames with invalid PMTs dropped "      << numberOfFramesWithInvalidPMTs;
     
     if (numberOfTimeslicesProcessed > 0) { JNoticeStream(logger) << "Real time per timeslice [ms] "       << timer.usec_wall / 1000 / numberOfTimeslicesProcessed; }
     if (numberOfTimeslicesProcessed > 0) { JNoticeStream(logger) << "User CPU  time per timeslice [ms] "  << timer.usec_ucpu / 1000 / numberOfTimeslicesProcessed; }
     if (numberOfTimeslicesProcessed > 0) { JNoticeStream(logger) << "System CPU time per timeslice [ms] " << timer.usec_scpu / 1000 / numberOfTimeslicesProcessed; }
     
     const double processedSlicesTimeMus   =  numberOfTimeslicesProcessed      * getFrameTime() / 1000;
     const double processedDetectorTimeMus = (maxFrameNumber - minFrameNumber) * getFrameTime() / 1000;
     
     if (processedSlicesTimeMus   > 0) { JNoticeStream(logger) << "Performance factor (inaccurate estimate): "                << T_us / processedSlicesTimeMus;   }
     if (processedDetectorTimeMus > 0) { JNoticeStream(logger) << "Performance factor whole detector (inaccurate estimate): " << T_us / processedDetectorTimeMus; }
 
     timer.start();
   }

virtual bool KM3NETDAQ::JDAQClient::enter ( const JArgs & args )

inlinevirtualinherited

Enter the state machine.

This overloaded method enter reproduces the constructor. All necessary input is parsed from the list of arguments. In case of an error, the state machine is not entered.

Parameters

args	array of command line arguments

Definition at line 143 of file JDAQClient.hh.

     {
       using namespace std;
 
       string  server;
       string  logger;
       int     level;
       bool    use_cout;
 
       try {
         
         parser['H'] = make_field(server)    = "localhost";
         parser['M'] = make_field(logger)    = "localhost";
         parser['d'] = make_field(level)     = 0;
         parser['c'] = make_field(use_cout);
         
         if (parser.read(args) != 0) {
           return false;
         }
       }
       catch(const exception &error) {
         cerr << error.what() << endl;
         return false;
       }
 
       try {
 
         JLogger* out = NULL;
 
         if (use_cout)
           out = new JStreamLogger(cout);
         else
           out = new JControlHostLogger(logger);
         
         this->logger = JMessageLogger(out, getName(), level);
 
         this->server.reset(new JControlHost(server));
 
         return enter();
       } 
       catch(const JControlHostException& error) {
         cerr << error << endl;
         return false;
       }
     }

virtual bool KM3NETDAQ::JDAQClient::enter ( )

inlinevirtualinherited

Enter the state machine.

This method activates the subscription to JNET::JControlHost messages. In case of an error, the state machine is not entered.

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 195 of file JDAQClient.hh.

     {
       using namespace std;
 
       if (server.is_valid() && logger.is_valid()) {
 
         try {
           
           server->Subscribe(getSubscription(eventTable));
           server->SendMeAlways();
           server->MyId(getFullName());
           
           return CHSM::machine::enter();
         }
         catch(const JControlHostException& error) {
           JErrorStream(logger) << error;
         }
 
       } else {
         cerr << "Message server or logger not properly initialised." << endl;
       }
 
       return false;
     }

virtual bool KM3NETDAQ::JDAQClient::exit ( )

inlinevirtualinherited

Exit the state machine.

This method releases the various resources.

Definition at line 225 of file JDAQClient.hh.

     {
       try { 
         if (server.is_valid()) server.reset(NULL);
       }
       catch(const JControlHostException& error) {
       }
 
       try {
         if (logger.is_valid()) logger.reset(NULL);
       }
       catch(const JControlHostException& error) {
       }
 
       return CHSM::machine::exit();
     }

const std::string& KM3NETDAQ::JDAQClient::getFullName ( ) const

inlineinherited

Get full name of this run control client.

Returns: full name

Definition at line 248 of file JDAQClient.hh.

     {
       return full_name;
     }

const JNET::JTag& KM3NETDAQ::JDAQClient::getUniqueTag ( ) const

inlineinherited

Get unique tag of this run control client.

Returns: unique tag

Definition at line 259 of file JDAQClient.hh.

     {
       return unique_tag;
     }

int KM3NETDAQ::JDAQClient::getEventNumber ( ) const

inlineinherited

Get last event number.

Returns: event number

Definition at line 270 of file JDAQClient.hh.

     {
       return event_number;
     }

bool KM3NETDAQ::JDAQClient::isRunning ( ) const

inlineinherited

Check if this client is in runnig state.

Returns: true if running; else false

Definition at line 281 of file JDAQClient.hh.

     {
       return Main.RunControl.Operational.Running.active();
     }

void KM3NETDAQ::JDAQClient::replaceEvent	(	const JNET::JTag &	oldTag,
		const JNET::JTag &	newTag,
		JDAQEvent_t &	event
	)

inlineinherited

Replace tag of given event in event table.

Parameters

oldTag	old tag
newTag	new tag
event	event

Definition at line 294 of file JDAQClient.hh.

     {
       eventTable.replace(oldTag, newTag, event);
     }

JDAQEvent_t* KM3NETDAQ::JDAQClient::findEvent	(	const JNET::JTag &	tag,
		const std::string &	event_name
	)

inlineinherited

Find event in event table.

Parameters

tag	tag
event_name	event name

Returns: pointer to event or NULL

Definition at line 309 of file JDAQClient.hh.

     {
       JEventTable::const_iterator i = eventTable.find(tag, event_name);
             
       if (i != eventTable.end())
         return i->second;
       else
         return NULL;
     }

template<class T >

void KM3NETDAQ::JDAQClient::addParameter	(	const char	option,
		T &	parameter
	)

inlineinherited

Add parameter to parser used in method enter().

Parameters

option	option
parameter	parameter

Definition at line 327 of file JDAQClient.hh.

     {
       parser[option] = make_field(parameter);
     }

template<class T >

void KM3NETDAQ::JDAQClient::addParameter	(	const char	option,
		T &	parameter,
		const T &	value
	)

inlineinherited

Add parameter to parser used in method enter().

Parameters

option	option
parameter	parameter
value	default value

Definition at line 341 of file JDAQClient.hh.

     {
       parser[option] = make_field(parameter) = value;
     }

long long int KM3NETDAQ::JDAQClient::getClockDelay ( ) const

inlineinherited

Get total delay time.

Returns: delay time [us]

Definition at line 352 of file JDAQClient.hh.

     {
       return clock.getDelay();
     }

const std::string& KM3NETDAQ::JDAQClient::getHostname ( ) const

inlineinherited

Get hostname.

Returns: host name

Definition at line 363 of file JDAQClient.hh.

     {
       return hostname;
     }

long long int KM3NETDAQ::JDAQClient::getClockInterval ( ) const

inlineinherited

Get interval time.

Returns: interval time [us]

Definition at line 374 of file JDAQClient.hh.

     {
       return clock.getInterval();
     }

void KM3NETDAQ::JDAQClient::setClockInterval ( const long long int interval_us )

inlineinherited

Set interval time.

Parameters

interval_us interval time [us]

Definition at line 385 of file JDAQClient.hh.

     {
       clock.setInterval(interval_us);
     }

void KM3NETDAQ::JDAQClient::resetClock ( )

inlineinherited

Reset clock.

Definition at line 394 of file JDAQClient.hh.

     {
       clock.reset();
     }

void KM3NETDAQ::JDAQClient::setSelect ( )

inlineinherited

Set the file descriptor mask for the select call.

Definition at line 403 of file JDAQClient.hh.

     {
       select.reset();
       
       setSelect(select.getReaderMask());
 
       select.setReaderMask(*server);
     }

virtual void KM3NETDAQ::JDAQClient::setSelect ( JFileDescriptorMask & mask ) const

inlinevirtualinherited

Set the file descriptor mask for the select call.

This implementation does nothing but may be redefined by the derived class.

Parameters

mask	file descriptor mask

Reimplemented in KM3NETDAQ::JDataWriter, and KM3NETDAQ::MonitorRouter.

Definition at line 419 of file JDAQClient.hh.

420 {}

virtual void KM3NETDAQ::JDAQClient::actionSelect ( const JFileDescriptorMask & mask )

inlinevirtualinherited

Action method following last select call.

This implementation does nothing but may be redefined by the derived class.

Parameters

mask	file descriptor mask

Reimplemented in KM3NETDAQ::DataQueue, KM3NETDAQ::JDataWriter, and KM3NETDAQ::MonitorRouter.

Definition at line 429 of file JDAQClient.hh.

430 {}

virtual void KM3NETDAQ::JDAQClient::actionInput	(	int	length,
		const char *	buffer
	)

inlinevirtualinherited

This method is called at ev_input.

Parameters

length	length of data
buffer	pointer to data

Reimplemented in AcousticDataFilter.

Definition at line 450 of file JDAQClient.hh.

     {
       using namespace std;
 
       JProperties properties(JEquationParameters("=", ";", "", ""), 1);
 
       int level = this->logger.getLevel();
 
       properties["debug"] = level;
 
       properties.read(string(buffer, length));
 
       this->logger.setLevel(level);
     }

virtual bool KM3NETDAQ::JDAQClient::filter	(	const std::string &	tag,
		int	length,
		const char *	buffer
	)

inlinevirtualinherited

Filter message.

The filter method can be overloaded so that a specific action is made before the corresponding message is processed by the state machine. The message is ignored if true is returned, else it is normally processed.

Parameters

tag	tag
length	number of characters
buffer	message

Returns: skip message or not

Definition at line 477 of file JDAQClient.hh.

     {
       return false;
     }

void KM3NETDAQ::JDAQClient::run ( )

inlineinherited

Run as run control client following command messages via JNET::JControlHost.

This method can be called once the state machine is entered. It returns when the state machine is exited. If the clock interval is non-zero, the method actionRunning() is repeatedly called when this client machine is in state Running. The file descriptor mask can be set to interrupt the timeout of the select call and clock method wait() in this calling sequence (see methods setSelect() and actionSelect()).

Definition at line 493 of file JDAQClient.hh.

     {
       using namespace std;
 
       while (active()) {
 
         try {
 
           setSelect();
 
           if (select(JTimeval(TIMEOUT_S,0)) > 0) {
             
             if (select.hasReaderMask(*server)) {
               update();
             }
             
             actionSelect(select.getReaderMask());
 
           } else {
 
             continue;
           }
 
 
           if (isRunning() && clock.getInterval() != 0LL) {
 
             long long int numberOfCalls = 0;
             
             clock.reset();
             
             do {
               
               ++numberOfCalls;
               
               setSelect();
 
               if (clock.wait(select.getReaderMask())) {
                 
                 if (select.hasReaderMask(*server)) {
                   update();
                 }
 
                 actionSelect(select.getReaderMask());
 
               } else {
 
                 try {
                   actionRunning();
                 }
                 catch(const exception& error) {
                   logger.error(error.what());
                 }             
               }
 
             } while (isRunning());
             
             if (numberOfCalls != 0) {
               JNoticeStream(logger) << "Delay per call " << clock.getDelay() / numberOfCalls / 1000 << " ms";
             }
           }
         }
         catch(const exception& error) {
           JErrorStream(logger) << "method run(): " << error.what();
         }
       }
     }

void KM3NETDAQ::JDAQClient::run ( const int port )

inlineinherited

Run for ever.

This method can be used when the run control client is started before the run control (e.g. at boot time of the host processor). This method should be called before the state machine is entered. It launches a server which accepts a JNET::JControlHost connection from a designated application e.g. the JDAQClientStarter.cc program. The state machine is entered using the available data in the JNET::JControlHost message. After the state machine is exited, it accepts a new a JNET::JControlHost connection.

Parameters

port	port number

Definition at line 573 of file JDAQClient.hh.

     {
       JControlHostServer server(port);
 
       for ( ; ; ) {
 
         JControlHost* ps = server.AcceptClient();
         
         ps->Connected();
 
         JNET::JPrefix prefix;
 
         ps->WaitHead(prefix);
 
         const int length = prefix.getSize();
 
         char* buffer = new char[length];
         
         ps->GetFullData(buffer, length);        
         ps->PutFullData(prefix.toString(), buffer, length);
 
         delete ps;
 
         enter(JArgs(std::string(buffer, length)));
 
         delete [] buffer;
         
         run();
 
         exit();
       }
     }

void KM3NETDAQ::JDAQClient::run ( std::istream & in )

inlineinherited

Run client with commands from input stream (e.g for debugging).

Example input format:

<tag> <event name>[#data];
<tag> <event name>[#data];

Parameters

in	input stream

Definition at line 618 of file JDAQClient.hh.

     {
       using std::string;
 
       string tag;
       string buffer;
 
       while (in >> tag && getline(in, buffer, ';')) {
         update(tag, buffer.length(), buffer.data());
       }
     }

Member Data Documentation

JSinglePointer<JControlHost_t> JDataFilter::datawriter

private

Definition at line 875 of file JDataFilter.cc.

std::string JDataFilter::hostname

private

controlhost to send data to the datawriter

host name of data server

Definition at line 877 of file JDataFilter.cc.

int JDataFilter::port

private

Definition at line 878 of file JDataFilter.cc.

int JDataFilter::backlog

private

serversocket port

Definition at line 879 of file JDataFilter.cc.

int JDataFilter::buffer_size

private

Definition at line 880 of file JDataFilter.cc.

JSinglePointer<JServerSocket> JDataFilter::serversocket

private

Definition at line 882 of file JDataFilter.cc.

JChannelList_t JDataFilter::channelList

private

Definition at line 883 of file JDataFilter.cc.

JTimer JDataFilter::timer

private

Definition at line 885 of file JDataFilter.cc.

list<JDAQTimesliceL0> JDataFilter::timeslices

private

Definition at line 887 of file JDataFilter.cc.

int JDataFilter::current_slice_index

private

Definition at line 888 of file JDataFilter.cc.

unsigned int JDataFilter::frames_per_slice

private

Definition at line 890 of file JDataFilter.cc.

unsigned int JDataFilter::maximum_frames_per_slice

private

Definition at line 891 of file JDataFilter.cc.

JTriggerParameters JDataFilter::parameters

private

Definition at line 895 of file JDataFilter.cc.

string JDataFilter::interfaceInput

private

Definition at line 896 of file JDataFilter.cc.

JSinglePointer<JTimesliceRouter> JDataFilter::timesliceRouter

private

Definition at line 897 of file JDataFilter.cc.

JDetector JDataFilter::detector

private

Definition at line 899 of file JDataFilter.cc.

JSinglePointer<JModuleRouter> JDataFilter::moduleRouter

private

Definition at line 900 of file JDataFilter.cc.

JSinglePointer<JBuildL1_t> JDataFilter::buildL1

private

Definition at line 901 of file JDataFilter.cc.

JSinglePointer<JBuildL2_t> JDataFilter::buildL2

private

Definition at line 902 of file JDataFilter.cc.

JSinglePointer<JBuildL2_t> JDataFilter::buildSN

private

Definition at line 903 of file JDataFilter.cc.

JSinglePointer<JTrigger3DMuon> JDataFilter::trigger3DMuon

private

Definition at line 905 of file JDataFilter.cc.

JSinglePointer<JTrigger3DShower> JDataFilter::trigger3DShower

private

Definition at line 906 of file JDataFilter.cc.

JSinglePointer<JTriggerMXShower> JDataFilter::triggerMXShower

private

Definition at line 907 of file JDataFilter.cc.

JMessageScheduler JDataFilter::logErrorRun

private

Definition at line 909 of file JDataFilter.cc.

JMessageScheduler JDataFilter::logErrorDetector

private

Definition at line 910 of file JDataFilter.cc.

JMessageScheduler JDataFilter::logErrorIndex

private

Definition at line 911 of file JDataFilter.cc.

JMessageScheduler JDataFilter::logErrorIncomplete

private

Definition at line 912 of file JDataFilter.cc.

JMessageScheduler JDataFilter::logErrorInvalidPMTs

private

Definition at line 913 of file JDataFilter.cc.

vector<JDAQProcess> JDataFilter::dataFilters

private

Definition at line 916 of file JDataFilter.cc.

vector<JDAQProcess> JDataFilter::dataQueues

private

Definition at line 917 of file JDataFilter.cc.

long long int JDataFilter::totalCPURAM

private

Definition at line 921 of file JDataFilter.cc.

unsigned int JDataFilter::maxQueueDepth

private

Definition at line 922 of file JDataFilter.cc.

long long int JDataFilter::maxQueueSize

private

Definition at line 923 of file JDataFilter.cc.

long long int JDataFilter::queueSize

private

Definition at line 924 of file JDataFilter.cc.

bool JDataFilter::reporting

private

Definition at line 928 of file JDataFilter.cc.

long long int JDataFilter::numberOfEvents

private

Definition at line 930 of file JDataFilter.cc.

long long int JDataFilter::numberOfBytes

private

Definition at line 931 of file JDataFilter.cc.

long long int JDataFilter::numberOfTimeslicesProcessed

private

Definition at line 932 of file JDataFilter.cc.

long long int JDataFilter::numberOfIncompleteTimeslicesProcessed

private

Definition at line 933 of file JDataFilter.cc.

long long int JDataFilter::numberOfFramesWithInvalidPMTs

private

Definition at line 934 of file JDataFilter.cc.

int JDataFilter::minFrameNumber

private

Definition at line 936 of file JDataFilter.cc.

int JDataFilter::maxFrameNumber

private

Definition at line 937 of file JDataFilter.cc.

long long int JDataFilter::number_of_packets_received

private

Definition at line 941 of file JDataFilter.cc.

long long int JDataFilter::number_of_packets_discarded

private

Definition at line 942 of file JDataFilter.cc.

long long int JDataFilter::number_of_reads

private

Definition at line 943 of file JDataFilter.cc.

long long int JDataFilter::number_of_bytes_received

private

Definition at line 944 of file JDataFilter.cc.

bool JDataFilter::checkForInvalidPMTs

private

Definition at line 946 of file JDataFilter.cc.

int JDataFilter::maxHitsFrame

private

Definition at line 947 of file JDataFilter.cc.

const int KM3NETDAQ::JDAQClient::TIMEOUT_S = 1

staticinherited

time out of update [s]

Definition at line 631 of file JDAQClient.hh.

JSharedPointer<JControlHost> KM3NETDAQ::JDAQClient::server

protectedinherited

message server

Definition at line 635 of file JDAQClient.hh.

JMessageLogger KM3NETDAQ::JDAQClient::logger

protectedinherited

message logger

Definition at line 636 of file JDAQClient.hh.

The documentation for this class was generated from the following file:

JDataFilter.cc

Public Member Functions

Static Public Attributes

Protected Attributes

Private Types

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation