Main class for real-time filtering of data. More...

Inheritance diagram for KM3NETDAQ::JDataFilter:

Classes
struct	JCircularBuffer_t
	Circular buffer. More...

Public Types
typedef JSocketInputChannel < JDAQAbstractPreamble >	JSocketInputChannel_t

typedef std::vector < JSocketInputChannel_t >	JChannelList_t

typedef double	hit_type

typedef JSuperFrame1D< hit_type >	JSuperFrame1D_t

typedef JSuperFrame2D< hit_type >	JSuperFrame2D_t

typedef JTimeslice< hit_type >	JTimeslice_t

typedef JBuildL1< hit_type >	JBuildL1_t

typedef JBuildL2< hit_type >	JBuildL2_t

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 std::string &path, const std::string &archive)
	Constructor. More...

virtual void	actionEnter () override
	Interface methods for actions corresponding to state transitions. More...

virtual void	actionExit () override

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

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

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

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

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

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

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

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

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

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

virtual void	actionRunning () override
	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 JSocketInputChannel_t &channel)
	Update queue with data frames. More...

void	processTimeSlice (const JDAQTimesliceL0 &timeslice)
	Process time slice. More...

void	typeout ()
	Report status to message logger. More...

virtual void	actionTagged (const JTag &tag, int length, const char *buffer) override
	Tagged action to handle alerts. More...

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

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

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

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

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

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

void	addSubscription (const JSubscription &subscription)
	Add custom subscription. 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...

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

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

virtual bool	filter (const JTag &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...

void	A1 (CHSM_ns_alias::event const &)

void	A2 (CHSM_ns_alias::event const &)

void	A3 (CHSM_ns_alias::event const &)

void	A4 (CHSM_ns_alias::event const &)

void	A5 (CHSM_ns_alias::event const &)

void	A6 (CHSM_ns_alias::event const &)

void	A7 (CHSM_ns_alias::event const &)

void	A8 (CHSM_ns_alias::event const &)

void	A9 (CHSM_ns_alias::event const &)

void	A10 (CHSM_ns_alias::event const &)

void	A11 (CHSM_ns_alias::event const &)

void	A12 (CHSM_ns_alias::event const &)

void	A13 (CHSM_ns_alias::event const &)

void	A14 (CHSM_ns_alias::event const &)

void	EAM4root (CHSM_ns_alias::state const &, CHSM_ns_alias::event const &)

void	XAM4root (CHSM_ns_alias::state const &, CHSM_ns_alias::event const &)

const std::string &	getName () const
	Get name of state machine. More...

const std::string &	getName () const
	Get name of state machine. More...

int	getDetectorID () const
	Get detector identifier. More...

int	getDetectorID () const
	Get detector identifier. More...

int	getRunNumber () const
	Get run number. More...

int	getRunNumber () const
	Get run number. More...

virtual void	actionError ()

virtual void	actionError ()

virtual void	actionRecover (int, const char *)

virtual void	actionRecover (int, const char *)

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

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

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

long long int	getClockDelay () const
	Get total delay time. 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...

const std::string &	getEventInfo () const
	Get last event information. More...

void	setEventInfo (const std::string &info)
	Set last event information. More...

Static Public Member Functions
static bool	compare (const JDAQProcess &first, const JDAQProcess &second)
	Sort DAQ process by index. More...

Public Attributes
JMeta	meta
	meta data More...

JDAQStateMachine::state_root	root

JDAQStateMachine::state_Main	Main

JDAQStateMachine::ev_daq_event	ev_daq

char	ev_daq_param_block [sizeof(ev_daq_event::param_block)]

JDAQStateMachine::ev_init_event	ev_init

char	ev_init_param_block [sizeof(ev_init_event::param_block)]

JDAQStateMachine::ev_configure_event	ev_configure

char	ev_configure_param_block [sizeof(ev_configure_event::param_block)]

JDAQStateMachine::ev_start_event	ev_start

char	ev_start_param_block [sizeof(ev_start_event::param_block)]

JDAQStateMachine::ev_pause_event	ev_pause

char	ev_pause_param_block [sizeof(ev_pause_event::param_block)]

JDAQStateMachine::ev_continue_event	ev_continue

char	ev_continue_param_block [sizeof(ev_continue_event::param_block)]

JDAQStateMachine::ev_stop_event	ev_stop

char	ev_stop_param_block [sizeof(ev_stop_event::param_block)]

JDAQStateMachine::ev_reset_event	ev_reset

char	ev_reset_param_block [sizeof(ev_reset_event::param_block)]

JDAQStateMachine::ev_quit_event	ev_quit

char	ev_quit_param_block [sizeof(ev_quit_event::param_block)]

JDAQStateMachine::ev_off_event	ev_off

char	ev_off_param_block [sizeof(ev_off_event::param_block)]

JDAQStateMachine::ev_check_event	ev_check

char	ev_check_param_block [sizeof(ev_check_event::param_block)]

JDAQStateMachine::ev_input_event	ev_input

char	ev_input_param_block [sizeof(ev_input_event::param_block)]

JDAQStateMachine::ev_recover_event	ev_recover

char	ev_recover_param_block [sizeof(ev_recover_event::param_block)]

JDAQStateMachine::ev_error_event	ev_error

char	ev_error_param_block [sizeof(ev_error_event::param_block)]

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

Protected Types
typedef void(JDAQCHSM::*	action )(int, const char *)
	Type definition of action method. More...

typedef void(JDAQCHSM::*	action )(int, const char *)
	Type definition of action method. More...

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

JMessageLogger	logger
	message logger More...

std::string	name

int	detector_id

int	run_number

JEventTable	eventTable
	event table More...

std::string	fullname

JTag	unique_tag

JTimekeeper	clock
	central clock More...

std::string	event_info
	event information More...

Private Types
typedef JControlHostObjectOutput < JDAQTypes_t >	JControlHost_t

Private Member Functions
template<class T >
void	put (const T &object)
	Auxiliary method to send object to data server. More...

Private Attributes
JSinglePointer< JControlHost_t >	datawriter
	controlhost of data server (to which data writer should be connected) More...

std::string	hostname
	host name of data server More...

int	port
	server socket port More...

int	backlog

JSinglePointer< JServerSocket >	serversocket
	server for data queue connections More...

JChannelList_t	channelList
	connections to data queue More...

JTimer	timer

JQuantile	Qt

JQuantile	Qx

std::deque< JDAQTimesliceL0 >	timeslices
	buffer with pending time slice data More...

int	current_slice_index

size_t	frames_per_slice

double	factor_per_slice

int	maximal_frame_index

std::set< int >	modules

	dataqueue_slice_index

JTriggerParameters	parameters

JSinglePointer< JTimesliceRouter >	timesliceRouter

JDetector	detector

JSinglePointer< JModuleRouter >	moduleRouter

JSinglePointer< JBuildL1_t >	buildL1

JSinglePointer< JBuildL2_t >	buildL2

JSinglePointer< JBuildL2_t >	buildSN

JSinglePointer< JBuildL2_t >	buildNB

JSinglePointer< JTriggerNB >	triggerNB

JSinglePointer< JTrigger3DMuon >	trigger3DMuon

JSinglePointer< JTrigger3DShower >	trigger3DShower

JSinglePointer< JTriggerMXShower >	triggerMXShower

JMessageScheduler	logErrorRun

JMessageScheduler	logErrorDetector

JMessageScheduler	logErrorIndex

JMessageScheduler	logErrorIncomplete

JMessageScheduler	logErrorOvercomplete

int	dumpCount

int	dumpLimit

JStatus	dumpMask

std::vector< JDAQProcess >	dataFilters

std::vector< JDAQProcess >	dataQueues

long long int	totalCPURAM

size_t	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

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

JCircularBuffer_t	c_buffer

Detailed Description

Main class for real-time filtering of data.

This class implements the action methods for each transition of the state machine.
When the state machine is entered, data are continually collected using custom implementation of virtual methods setSelect and actionSelect.

In state Running, all incoming data from the DataQueue.cc are buffered, referred to as "queue".
These data are formatted as a JDAQSuperFrame and aggregated into a JDAQTimeslice.
When a JDAQTimeslice is complete, it processed in the same way as applications JTriggerProcessor.cc and JTriggerEfficiency.cc.

The completeness of a time slice is defined by two parameters, namely frames_per_slice and factor_per_slice.
These are parsed in method actionConfigure as follows.

  numberOfFramesPerSlice = <frames per slice> = 1;
  factorOfFramesPerSlice = <factor per slice> = 1.0;

The expected number of frames in a time slices is defined by their product.
Note that the first parameter can change during operation (see below).

A timeout may occur when the total amount of data or the number of incomplete time slices in the queue exceeds one of the limits queueSize or queueDepth.
These are parsed in method actionConfigure as follows.

  queueSize  = <maximal queue size [B]>;
  queueDepth = <maximal queue depth>;

Note that these values apply per JDataFilter.
The parameter frames_per_slice is subject to a servo mechanism.
When a timeout occurs, it is set to the number of frames in the oldest time slice.
When data are received with a frame index below the current frame index, it is incremented by one.

In addition, a circular buffer based on a ROOT TTree for each JDAQTimeslice type can be maintained.
The following parameters can be used to configure the circular buffer.

  path     = <write directory for temporary circular buffer>;
  archive  = <write directory for archival of circular buffer>;
  c_sizeL0 = <L0 buffer size>;
  c_sizeL1 = <L1 buffer size>;
  c_sizeL2 = <L2 buffer size>;
  c_sizeSN = <SN buffer size>;

Note that when one (or more) of the buffer sizes is non-zero and the path corresponds to a valid directory:

There will always be a file created which is deleted when the state machine is exited;
The temporary file name is <path>/KM3NeT_<tag>.root;
Following an alert, the temporary file is archived to a file with name <path>/KM3NeT_YYYY-MM-DD_<tag>[_<index>].root;
After archival of the temporary file, a new temporary file will be opened;
L0, L1, L2 and SN buffer sizes are per JDataFilter;
The tag KM3NETDAQ::RC_ALERT defined in JDAQTags.hh has tentatively been reserved to trigger the archival of the temporary file following an external alert;

In this, YYYY, MM and DD correspond to the year, month and day at the time of the alert, respectively.
The <tag> corresponds to the unique JNET::JTag of the JDataFilter process.
The <index> is optional and will only be used to prevent overwriting of an existing file (e.g. when there is more than one alert on a given day).

Note that the application JConvert.cc can be used to readily convert multiple input files to a single output file.

The script $JPP_DIR/tests/JDataFilter/JDataFilter.sh can be used to test this application.

Definition at line 184 of file JDataFilter.cc.

Member Typedef Documentation

typedef JSocketInputChannel<JDAQAbstractPreamble> KM3NETDAQ::JDataFilter::JSocketInputChannel_t

Definition at line 189 of file JDataFilter.cc.

typedef std::vector<JSocketInputChannel_t> KM3NETDAQ::JDataFilter::JChannelList_t

Definition at line 190 of file JDataFilter.cc.

typedef double KM3NETDAQ::JDataFilter::hit_type

Definition at line 192 of file JDataFilter.cc.

typedef JSuperFrame1D<hit_type> KM3NETDAQ::JDataFilter::JSuperFrame1D_t

Definition at line 193 of file JDataFilter.cc.

typedef JSuperFrame2D<hit_type> KM3NETDAQ::JDataFilter::JSuperFrame2D_t

Definition at line 194 of file JDataFilter.cc.

typedef JTimeslice<hit_type> KM3NETDAQ::JDataFilter::JTimeslice_t

Definition at line 195 of file JDataFilter.cc.

typedef JBuildL1<hit_type> KM3NETDAQ::JDataFilter::JBuildL1_t

Definition at line 196 of file JDataFilter.cc.

typedef JBuildL2<hit_type> KM3NETDAQ::JDataFilter::JBuildL2_t

Definition at line 197 of file JDataFilter.cc.

typedef JControlHostObjectOutput<JDAQTypes_t> KM3NETDAQ::JDataFilter::JControlHost_t

private

Definition at line 1424 of file JDataFilter.cc.

typedef void(JDAQCHSM::* JDAQCHSM::action)(int, const char *)

protectedinherited

Type definition of action method.

Definition at line 141 of file JDAQCHSM.chsm.

typedef void(JDAQCHSM::* JDAQCHSM::action)(int, const char *)

protectedinherited

Type definition of action method.

Definition at line 152 of file JDAQCHSM.hh.

Constructor & Destructor Documentation

KM3NETDAQ::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 std::string &	path,
		const std::string &	archive
	)

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
path	directory for temporary storage
archive	directory for parmanent archival

replace tag to receive dfilter specific messages in configure

Definition at line 397 of file JDataFilter.cc.

                                           :
       JDAQClient (name,server,logger,level),
       hostname   (hostname),
       port       (port),
       backlog    (backlog),
       c_buffer   (path, archive, getUniqueTag())
     {
       replaceEvent(RC_CMD, RC_DFILTER, ev_configure); /// replace tag to receive dfilter specific messages in configure
 
       addSubscription(JSubscriptionAll(RC_ALERT));
       
       totalCPURAM          = getRAM();   
       current_slice_index  = -1;
       dataqueue_slice_index.clear();
       reporting            = false;
  
       this->server->setReceiveBufferSize(DFILTER_RECEIVE_BUFFER_SIZE);
     }

Member Function Documentation

static bool KM3NETDAQ::JDataFilter::compare	(	const JDAQProcess &	first,
		const JDAQProcess &	second
	)

inlinestatic

Sort DAQ process by index.

Parameters

first	first DAQ process
second	second DAQ process

Returns: true if index of first DAQ process less than that of second; else false

Definition at line 378 of file JDataFilter.cc.

     {
       return first.index < second.index;
     }

virtual void KM3NETDAQ::JDataFilter::actionEnter ( )

inlineoverridevirtual

Interface methods for actions corresponding to state transitions.

Reimplemented from JDAQCHSM.

Definition at line 425 of file JDataFilter.cc.

426 {}

virtual void KM3NETDAQ::JDataFilter::actionExit ( )

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 429 of file JDataFilter.cc.

     { 
       if (c_buffer.is_open()) {
 
         JStatusStream(logger) << "Close and remove circular buffer " << c_buffer;
 
         c_buffer.close(false);
       }
 
       datawriter.reset();
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 442 of file JDataFilter.cc.

     { 
       JDebugStream(logger) << "actionInit() " << std::string(buffer,length);
 
       try {
 
         JDebugStream(logger) << "Start server.";
 
         if (serversocket.is_valid()) {
           serversocket->shutdown();
         }
 
         serversocket.reset(new JServerSocket(port,backlog));
       }   
       catch(const std::exception& error) {
         JErrorStream(logger) << "Error \"" << error.what() << "\"; trigger ev_error.";
         ev_error();
       }
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 463 of file JDataFilter.cc.

     { 
       using namespace std;
     
       JDebugStream(logger) << "actionConfigure() " << endl << std::string(buffer,length);
   
       string _hostname_ = "";
 
       long long int update_s = 20;
       long long int logger_s = 10;
 
       parameters .reset();
       dataFilters.clear();
       dataQueues .clear();
 
       reporting = false;
       dumpCount = 0;
       dumpLimit = numeric_limits<int>::max();
       dumpMask  = 0;
       dumpMask.set(JChecksum::EPMT_t);
       dumpMask.set(JChecksum::ETDC_t);
       dumpMask.set(JChecksum::TIME_t);
       //dumpMask.set(JChecksum::EUDP_t);
       dumpMask.set(JChecksum::SIZE_t);
 
       detector.comment.clear();
       detector.clear();
       
       JProperties properties(JEquationParameters("=", ";", "", ""), 0);
 
       properties["dataWriter"]             = _hostname_;
       properties["numberOfFramesPerSlice"] = frames_per_slice = 1;
       properties["factorOfFramesPerSlice"] = factor_per_slice = 1.0;
       properties["detector"]               = detector;
       properties["triggerParameters"]      = parameters;
       properties["queueSize"]              = maxQueueSize  = (totalCPURAM - GIGABYTE);  // leave 1 GB left ...
       properties["queueDepth"]             = maxQueueDepth = 20;                        // to be optimized
       properties["frameIndex"]             = maximal_frame_index = 100000;
       properties["logger_s"]               = logger_s;
       properties["update_s"]               = update_s;
       properties["JDataFilter"]            = dataFilters;
       properties["DataQueue"]              = dataQueues;
       properties["path"]                   = c_buffer.path;
       properties["archive"]                = c_buffer.archive;
       properties["c_sizeL0"]               = c_buffer.sizeL0;
       properties["c_sizeL1"]               = c_buffer.sizeL1;
       properties["c_sizeL2"]               = c_buffer.sizeL2;
       properties["c_sizeSN"]               = c_buffer.sizeSN;
       properties["dumpLimit"]              = dumpLimit;
       properties["dumpMask"]               = dumpMask;
 
       try {
         properties.read(string(buffer, length));
       }
       catch(const std::exception& error) {
         JErrorStream(logger) << error.what();
       }
     
       if (update_s <=  0) { update_s = 20; }
       if (logger_s <=  0) { logger_s = 10; }
 
       setClockInterval(update_s * 1000000LL);
 
       _hostname_ = trim(_hostname_);
 
       if (_hostname_ != "" && _hostname_ != hostname) {
 
         datawriter.reset();
 
         hostname = _hostname_;
       }
 
       bool status = datawriter.is_valid();
 
       if (status) {
 
         try {
           status = datawriter->Connected() == 0;
         }
         catch (const exception&) {
           status = false;
         }
       }
 
       if (!status) {
 
         datawriter.reset(new JControlHost_t(hostname));
 
         datawriter->MyId(getFullName());
       }
     
       datawriter->setSendBufferSize(DFILTER_SEND_BUFFER_SIZE);
 
       // 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(), compare);
     
       unsigned int numberOfDataFiltersOnThisMachine = 0;
       vector<JDAQProcess>::iterator thisProcess     = dataFilters.end();
 
       const vector<string> IP = getListOfIPaddresses();
       
       for (vector<JDAQProcess>::iterator i = dataFilters.begin(); i != dataFilters.end(); ++i) {
 
         if (find(IP.begin(), IP.end(), i->hostname) != IP.end()) {
 
           numberOfDataFiltersOnThisMachine++;
         
           if (i->port == this->port) {
             thisProcess = i;
           }
         }
       }
     
       if (numberOfDataFiltersOnThisMachine == 0) {
         JNoticeStream(logger) << "Zero data filters on this machine according to process list (if it exists). "
                               << "Assuming one datafilter on this machine.";
         numberOfDataFiltersOnThisMachine = 1;
       }
     
       if (thisProcess == dataFilters.end()) {
 
         JErrorStream error(logger);
 
         error << "This process cannot be found in the process list. Why do I exist?";
         error << " my IP addresses:";
 
         for (vector<string>::const_iterator i = IP.begin(); i != IP.end(); ++i) {
           error << ' ' << *i;
         }
 
         error << " my port: " << this->port;
         error << " process list";
 
         for (vector<JDAQProcess>::iterator i = dataFilters.begin(); i != dataFilters.end(); ++i) {
           error << ' ' << i->hostname << ':' << i->port;
         }
       }
 
       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." ;  
       }
     
       // detector
 
       if (parameters.disableHighRateVeto) {
 
         JNoticeStream(logger) << "Disabling high-rate veto of all PMTs.";
 
         detector.setPMTStatus(HIGH_RATE_VETO_DISABLE);
       }
 
       // trigger parameters
     
       parameters.set(getMaximalDistance(detector));
     
       triggerNB      .reset(new JTriggerNB      (parameters));
       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 data filter process will report.";
         JNoticeStream(logger) << "Detector version/size " << detector.getVersion() << '/' << detector.size();
         JDebugStream (logger) << "Trigger parameters: "   << parameters;
         JDebugStream (logger) << "Detector description: " << endl << detector;
         JNoticeStream(logger) << "Update period [s]: "    << 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));
       buildNB.reset(new JBuildL2_t(parameters.NB));
    
       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."; }
       if (buildNB.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));
       logErrorOvercomplete = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
 
       if (c_buffer.is_enabled()) {
 
         if (!c_buffer.is_open()) {
 
           c_buffer.open();
 
           if (c_buffer.is_open()) {
 
             putObject(c_buffer.getFile(), meta);
             
             JStatusStream(logger) << "Created circular buffer " << c_buffer;
             
           } else {
             
             JErrorStream (logger) << "Failed to create circular buffer in directory <" << c_buffer.path << ">; disable functionality.";
           }
 
         } else {
 
           JNoticeStream(logger) << "Continue using circular buffer " << c_buffer;
         }
       }
 
       if (c_buffer.is_open()) {
         if (c_buffer.sizeL0 > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceL0>&>(c_buffer).SetCircular(c_buffer.sizeL0); }
         if (c_buffer.sizeL1 > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceL1>&>(c_buffer).SetCircular(c_buffer.sizeL1); }
         if (c_buffer.sizeL2 > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceL2>&>(c_buffer).SetCircular(c_buffer.sizeL2); }
         if (c_buffer.sizeSN > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceSN>&>(c_buffer).SetCircular(c_buffer.sizeSN); }
       } else {
         c_buffer.disable();
       }
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 708 of file JDataFilter.cc.

     {
       using namespace std;
 
       if (reporting) {
         JNoticeStream(logger) << "Start run " << getRunNumber();
       }
     
       timeslices.clear();
 
       current_slice_index = -1;
       dataqueue_slice_index.clear();
       queueSize           =  0;
     
       numberOfEvents                        = 0;
       numberOfBytes                         = 0;
       numberOfTimeslicesProcessed           = 0;
       numberOfIncompleteTimeslicesProcessed = 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.
 
       JDAQTriggerCounter::reset();
 
       logErrorRun         .reset();
       logErrorDetector    .reset();
       logErrorIndex       .reset();
       logErrorIncomplete  .reset();
       logErrorOvercomplete.reset();
     
       timer.reset();
       timer.start();
 
       Qt.reset();
       Qx.reset();
 
       // send trigger parameters to the datawriter
       
       ostringstream os;
     
       os << getRunNumber() << ' ' << parameters;
     
       datawriter->PutFullString(IO_TRIGGER_PARAMETERS, os.str());
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 761 of file JDataFilter.cc.

     { 
       using namespace std;
 
       if (!timeslices.empty()) {
 
         JNoticeStream(logger) << "Flushing " << timeslices.size() << " slices.";
 
         for (deque<JDAQTimesliceL0>::const_iterator i = timeslices.begin(); i != timeslices.end(); ++i) {
           queueSize -= getSizeof(*i);
         }
 
         timeslices.clear();
       }
 
       { // force clearance of memory
 
         deque<JDAQTimesliceL0> buffer;
         
         timeslices.swap(buffer);
       }
 
       if (queueSize != 0) {
         JWarningStream(logger) << "Pending data in queue " << queueSize << " [B]";
       }
 
       current_slice_index = -1;
       dataqueue_slice_index.clear();
       queueSize           =  0;
 
       timer.stop();    
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 795 of file JDataFilter.cc.

     {
       timer.start();    
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 801 of file JDataFilter.cc.

     {
       typeout();
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 807 of file JDataFilter.cc.

     {
       if (serversocket.is_valid()) {
         serversocket->shutdown();
       }
 
       serversocket.reset();
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 817 of file JDataFilter.cc.

     {
       datawriter.reset();
     }

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

inlineoverridevirtual

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 from KM3NETDAQ::JDAQClient.

Definition at line 823 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 KM3NETDAQ::JDataFilter::actionSelect ( const JFileDescriptorMask & mask )

inlineoverridevirtual

Action method following last select call.

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

Parameters

mask	file descriptor mask

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 837 of file JDataFilter.cc.

     {
       using namespace std;
 
       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()) {
               
               try {
                 updateFrameQueue(*channel);
               }
               catch(const std::exception& error) {
 
                 JErrorStream(logErrorRun) << "Update frame queue " << channel->getFileDescriptor() << ' ' << channel->size() << ' ' << error.what(); 
 
                 number_of_packets_discarded += 1;
               }
 
             } else {
 
               JErrorStream(logErrorRun) << "Receiving data while not running.";
 
               number_of_packets_discarded += 1;
             }
 
             channel->reset();
           }
 
           ++channel;
         }
         catch(const std::exception& error) {
 
           if (isRunning()) {
             JErrorStream(logger) << "Disconnect channel " << channel->getFileDescriptor() << ' ' << error.what(); 
           }
 
           channel->shutdown();
 
           channel = channelList.erase(channel);
         }
       }
      
 
       if (serversocket.is_valid()) {
 
         if (mask.has(*serversocket)) {
 
           JTCPSocket socket(serversocket->getFileDescriptor());
         
           socket.setReceiveBufferSize(DFILTER_DQUEUE_BUFFER_SIZE);
         
           socket.setKeepAlive  (true);
           socket.setNonBlocking(false);
         
           JStatusStream(logger) << "New channel" << '[' << socket.getFileDescriptor() << ']' << ' ' << socket.getReceiveBufferSize();
         
           channelList.push_back(JSocketInputChannel_t(socket));
         }
       }
 
 
       if (!timeslices.empty()) {
 
         const size_t number_of_frames  =  getNumberOfFrames(frames_per_slice, factor_per_slice);
         const size_t maximum_in_queue  =  getMaximum(make_array(next(timeslices.begin()), timeslices.end(), &JDAQTimesliceL0::size), (size_t) 0);
 
         if (((timeslices[0].size()          >=  number_of_frames &&                // normal   
               timeslices[0].getFrameIndex() <   dataqueue_slice_index.min())   ||
 
              (maximum_in_queue              >=  number_of_frames &&                // intermittent problem
               timeslices[0].getFrameIndex() <   dataqueue_slice_index.min())   ||
 
              (timeslices.size()             >=  maxQueueDepth)                 ||  // timeout
              (queueSize                     >=  maxQueueSize))) {
       
 
           const JDAQTimesliceL0& pending_slice  = timeslices.front();
           queueSize                            -= getSizeof(pending_slice);
       
           current_slice_index = pending_slice.getFrameIndex();
           minFrameNumber      = min(minFrameNumber, pending_slice.getFrameIndex());
           maxFrameNumber      = max(maxFrameNumber, pending_slice.getFrameIndex());
           
           for (JDAQTimesliceL0::const_iterator i = pending_slice.begin(); i != pending_slice.end(); ++i) {
             modules.insert(i->getModuleID());
           }
 
 
           if (isRunning()) {
 
             const localtime_t t0 = getLocalTime();
 
             if (!pending_slice.empty()) {
               processTimeSlice(pending_slice);
             }
 
             const localtime_t t1 = getLocalTime();
 
             numberOfTimeslicesProcessed += 1;
 
             Qt.put(t1 - t0);
 
           } else {
 
             JErrorStream(logErrorRun) << "Skip processing of data while not running.";
           }
 
 
           if (modules.size() > frames_per_slice) {
         
             JErrorStream(logErrorOvercomplete) << "More active modules than expected "
                                                << modules.size() << " > " << frames_per_slice
                                                << " adjusting frames per slice to " << modules.size();
           
             frames_per_slice = modules.size();
           }
 
 
           if (pending_slice.size() < number_of_frames) {
 
             numberOfIncompleteTimeslicesProcessed += 1;
 
             ostringstream error;
 
             error << "Timeout -> processed incomplete timeslice: " 
                   << "Frame index = "       << pending_slice.getFrameIndex() << ';'
                   << "Size of timeslice = " << pending_slice.size()          << ';'
                   << "Queue depth = "       << timeslices.size()             << ';'
                   << "Queue size = "        << queueSize                     << ';'
                   << "DataQueue min = "     << dataqueue_slice_index.min()   << ';'
                   << "DataQueue max = "     << dataqueue_slice_index.max()   << ';';
 
             if (maximum_in_queue >= number_of_frames) {
 
               error << " intermittent problem -> continues as-is";
 
             } else {
 
               modules.clear();  // remove history
 
               for (JDAQTimesliceL0::const_iterator i = pending_slice.begin(); i != pending_slice.end(); ++i) {
                 modules.insert(i->getModuleID());
               }
 
               error << " adjusting frames per timeslice from " << frames_per_slice << " to " << modules.size();
             
               frames_per_slice = modules.size();
             }
 
             JErrorStream(logErrorIncomplete) << error.str();
           }
 
 
           timeslices.pop_front();
         }
       }
     }

virtual void KM3NETDAQ::JDataFilter::actionRunning ( )

inlineoverridevirtual

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 1008 of file JDataFilter.cc.

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

void KM3NETDAQ::JDataFilter::updateFrameQueue ( const JSocketInputChannel_t & channel )

inline

Update queue with data frames.

Note that any discarded data will be reported.

Parameters

channel incoming data channel

Definition at line 1023 of file JDataFilter.cc.

     {
       using namespace std;
     
       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()
                                   << " != "        << getRunNumber()
                                   << " -> Dropping frame.";
 
         number_of_packets_discarded += 1;
       
         return;
       }
     
       if (header.getFrameIndex() <= current_slice_index) {
 
         number_of_packets_discarded += 1;
       
         if (modules.insert(header.getModuleID()).second) {
         
           frames_per_slice = modules.size();
 
           JErrorStream(logErrorIndex) << "Frame index " << header.getFrameIndex() << " <= " << current_slice_index
                                       << " module "     << header.getModuleID() 
                                       << " -> dropping frame;" 
                                       << " increase number of frames expected to: " << frames_per_slice;
         }
 
         return;
       }
     
       if (current_slice_index != -1 && header.getFrameIndex() > current_slice_index + maximal_frame_index) {
       
         number_of_packets_discarded += 1;
       
         JErrorStream(logErrorIndex) << "Frame index " << header.getFrameIndex() << " > " << current_slice_index + maximal_frame_index 
                                     << " module "     << header.getModuleID() 
                                     << " -> Dropping frame.";
       
         return;
       }
 
       deque<JDAQTimesliceL0>::iterator timesliceIterator = timeslices.begin();
 
       while (timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() < header.getFrameIndex()) {
         ++timesliceIterator;
       }
     
       if (timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() == header.getFrameIndex()) {
 
         // The corresponding time slice already exists
         
       } else {
 
         // This is the first frame of this time slice; insert a new time slice in the buffer at the right position in the list
 
         timesliceIterator = timeslices.insert(timesliceIterator, JDAQTimesliceL0());
         
         timesliceIterator->setDAQChronometer(header.getDAQChronometer());
 
         queueSize += getSizeof(*timesliceIterator);
       }
    
       timesliceIterator->push_back(JDAQSuperFrame(header));
       
       in >> static_cast<JDAQFrame&>(*(timesliceIterator->rbegin()));
 
       queueSize += getSizeof(*timesliceIterator->rbegin());
     
       dataqueue_slice_index[channel.getFileDescriptor()] = header.getFrameIndex();
     }

void KM3NETDAQ::JDataFilter::processTimeSlice ( const JDAQTimesliceL0 & timeslice )

inline

Process time slice.

Parameters

timeslice time slice

Definition at line 1121 of file JDataFilter.cc.

     {
       using namespace std;
 
       try {
 
         timesliceRouter->configure(timeslice);
 
         if (parameters.writeSummary()) {
           this->put(JDAQSummaryslice(timeslice));
         }
       
         if (parameters.trigger3DMuon.enabled    || 
             parameters.trigger3DShower.enabled  || 
             parameters.triggerMXShower.enabled  || 
             parameters.triggerNB.enabled        || 
             parameters.writeL0.prescale         ||
             parameters.writeL1.prescale         ||
             parameters.writeL2.prescale         ||
             parameters.writeSN.prescale         ||
             c_buffer.is_enabled()) {
 
           JTimeslice_t    timesliceL0(timeslice.getDAQChronometer());
           JTimeslice_t    timesliceL1(timeslice.getDAQChronometer());
           JTimeslice_t    timesliceL2(timeslice.getDAQChronometer());
           JTimeslice_t    timesliceSN(timeslice.getDAQChronometer());
           JTimeslice_t    timesliceNB(timeslice.getDAQChronometer());
           JDAQTimeslice   timesliceTX(timeslice.getDAQChronometer());
 
           for (JDAQTimesliceL0::const_iterator frame = timeslice.begin(); frame != timeslice.end(); ++frame) {
           
             if (moduleRouter->hasModule(frame->getModuleID())) {
 
               const JChecksum::result_type& result = checksum(*frame);
 
               if (!result) {
 
                 JWarningStream(logger) << "Invalid data at "
                                        << "run = "         << timeslice.getRunNumber()  << ";"
                                        << "frame index = " << timeslice.getFrameIndex() << ";"
                                        << "module = "      << frame->getModuleID()      << ";"
                                        << "discard" << (dumpCount < dumpLimit ? " and dump" : "");
 
                 if (dumpCount < dumpLimit && result.has(dumpMask)) {
                   timesliceTX.push_back(*frame);
                 }
 
                 continue;
               }
 
               const JModule&   module = moduleRouter->getModule(frame->getModuleID()); 
               JSuperFrame2D_t& buffer = JSuperFrame2D_t::demultiplex(*frame, module);
       
               // Apply high-rate veto
             
               buffer.applyHighRateVeto(parameters.highRateVeto_Hz);
 
               // L0
 
               timesliceL0.push_back(JSuperFrame1D_t(buffer));
 
               // Nano-beacon trigger
 
               if (parameters.triggerNB.enabled) {
 
                 JSuperFrame2D_t::iterator __end = partition(buffer.begin(), buffer.end(), parameters.triggerNB.pmts);
 
                 if (buffer.begin() != __end) {
 
                   timesliceNB.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
                                                         frame->getModuleIdentifier(),
                                                         module.getPosition()));
 
                   JSuperFrame1D_t zbuf;
 
                   (*buildL1)(buffer.begin(), __end , back_inserter(zbuf));
 
                   (*buildNB)(buffer.begin() , __end, zbuf, back_inserter(*timesliceNB.rbegin()));
                 }
               }
 
               // L1
       
               timesliceL1.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
                                                     frame->getModuleIdentifier(),
                                                     module.getPosition()));
             
               (*buildL1)(*timesliceL0.rbegin(), back_inserter(*timesliceL1.rbegin()));
             
               // L2
             
               timesliceL2.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
                                                     frame->getModuleIdentifier(),
                                                     module.getPosition()));
       
               (*buildL2)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceL2.rbegin()));
             
               // SN
             
               timesliceSN.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
                                                     frame->getModuleIdentifier(),
                                                     module.getPosition()));
       
               (*buildSN)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceSN.rbegin()));
       
             } else {
 
               JErrorStream(logErrorDetector) << "No detector information for module " << frame->getModuleID(); 
             }
           }
 
           if (!timesliceTX.empty()) {
 
             if (dumpCount < dumpLimit) {
 
               this->put(timesliceTX);
 
               dumpCount += 1;
             }
           }
         
           // Trigger
         
           if (parameters.triggerNB.enabled) {      
 
             const JTriggerInput  trigger_input(timesliceNB);
 
             for (JTriggerInput::const_iterator hit = trigger_input.begin(); hit != trigger_input.end(); ++hit) {
 
               if (parameters.triggerNB.write()) {
 
                 JTriggeredEvent tev(timesliceNB.getDAQChronometer(),
                                     getTriggerMask(triggerNB->getTriggerBit()),
                                     *hit, 
                                     *timesliceRouter, 
                                     *moduleRouter, 
                                     parameters.TMaxLocal_ns, 
                                     parameters.triggerNB.DMax_m,
                                     getTimeRange(parameters.triggerNB));
 
                 this->put(tev);
               }
             }
           }
 
           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) {
             
             const JTriggeredEvent object(*event, *timesliceRouter, *moduleRouter, parameters.TMaxLocal_ns, getTimeRange(parameters));
 
             this->put(object);
 
             numberOfEvents += 1;
           }
 
           if (parameters.writeL1() || c_buffer.sizeL1 > 0) {
       
             const JTimesliceL1<JDAQTimesliceL1> object(timesliceL1, *timesliceRouter, *moduleRouter, parameters.TMaxLocal_ns);
 
             if (parameters.writeL1)  { this->put(object);  }
             if (c_buffer.sizeL1 > 0) { c_buffer.put(object); }
           }
 
           if (parameters.writeL2() || c_buffer.sizeL2 > 0) {
       
             const JTimesliceL1<JDAQTimesliceL2> object(timesliceL2, *timesliceRouter, *moduleRouter, parameters.L2.TMaxLocal_ns);
 
             if (parameters.writeL2)  { this->put(object); }
             if (c_buffer.sizeL2 > 0) { c_buffer.put(object); }
           }
 
           if (parameters.writeSN() || c_buffer.sizeSN > 0) {
       
             const JTimesliceL1<JDAQTimesliceSN> object(timesliceSN, *timesliceRouter, *moduleRouter, parameters.SN.TMaxLocal_ns);
 
             if (parameters.writeSN)  { this->put(object); }
             if (c_buffer.sizeSN > 0) { c_buffer.put(object); }
           }
 
           if (parameters.writeL0() || c_buffer.sizeL0 > 0) {
         
             if (parameters.writeL0)  { this->put(timeslice); }
             if (c_buffer.sizeL0 > 0) { c_buffer.put(timeslice); }
           }
         }
 
       } catch(const std::exception& error) {
 
         JErrorStream(logger) << "Error = "       << error.what()              << ";"
                              << "run = "         << timeslice.getRunNumber()  << ";"
                              << "frame index = " << timeslice.getFrameIndex() << ";"
                              << "time slice not correctly processed;"
                              << "discard" << (dumpCount < dumpLimit ? " and dump" : "");
 
         if (dumpCount < dumpLimit) {
 
           this->put(static_cast<const JDAQTimeslice&>(timeslice));
 
           dumpCount += 1;
         }
       }
 
       timesliceRouter->reset();
     }

void KM3NETDAQ::JDataFilter::typeout ( )

inline

Report status to message logger.

Definition at line 1338 of file JDataFilter.cc.

     { 
       timer.stop();
 
       const double T_us = (double) timer.usec_wall;
     
       JStatusStream(logger) << "Elapsed real (wall) time [s] "          << T_us / 1e6;
       JStatusStream(logger) << "Elapsed user CPU time [s] "             << (double) timer.usec_ucpu/ 1e6;
       JStatusStream(logger) << "Elapsed system CPU time [s] "           << (double) timer.usec_scpu/ 1e6;
       JStatusStream(logger) << "Elapsed real time per time slice [ms] " << Qt.getMean(0.0) * 1.0e-3  << " <= " << Qt.getXmax() * 1.0e-3;
       JStatusStream(logger) << "Number of packets received/discarded "  << number_of_packets_received << "/" << number_of_packets_discarded;
       JStatusStream(logger) << "Number of events/MB/us "                << numberOfEvents             << "/" << numberOfBytes/1e6 << "/" << Qx.getMean(0.0);
 
       if (number_of_packets_received > 0) {
         JStatusStream(logger) << "Number of reads/packet " << (double) number_of_reads / (double) number_of_packets_received;
       }
     
       JStatusStream(logger) << "Current queue depth/size " << timeslices.size() << "/" << queueSize;
       JStatusStream(logger) << "Current number of frames per slice expected: " << frames_per_slice << ' ' << FIXED(5,3) << factor_per_slice;
     
       JStatusStream(logger) << "Number of timeslices processed total/incomplete " << numberOfTimeslicesProcessed << "/" << numberOfIncompleteTimeslicesProcessed;
     
       const double processedSlicesTime_us   =  numberOfTimeslicesProcessed      * getFrameTime() / 1000;
       const double processedDetectorTime_us = (maxFrameNumber - minFrameNumber) * getFrameTime() / 1000;
     
       if (processedSlicesTime_us   > 0) {
         JStatusStream(logger) << "Performance factor (inaccurate estimate): "                << T_us / processedSlicesTime_us;
       }
       if (processedDetectorTime_us > 0) {
         JStatusStream(logger) << "Performance factor whole detector (inaccurate estimate): " << T_us / processedDetectorTime_us;
       }
 
       timer.start();
     }

virtual void KM3NETDAQ::JDataFilter::actionTagged	(	const JTag &	tag,
		int	length,
		const char *	buffer
	)

inlineoverridevirtual

Tagged action to handle alerts.

Parameters

tag	tag
length	number of characters
buffer	message

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 1381 of file JDataFilter.cc.

     {
       using namespace std;
       
       JDebugStream(logger) << "Received message <" << tag.toString() << "> \"" << string(buffer, length) << "\"";
 
       if (tag == RC_ALERT) {
 
         if (c_buffer.is_open()) {
 
           JStatusStream(logger) << "Archive circular buffer in <" << c_buffer.archive << ">";
 
           c_buffer.close(true);
         }
 
         if (c_buffer.is_enabled()) {
           
           c_buffer.open();
 
           if (c_buffer.is_open()) {
             
             JStatusStream(logger) << "Created circular buffer " << c_buffer;
           
             putObject(c_buffer.getFile(), meta);
             
           } else {
             
             JErrorStream (logger) << "Failed to create circular buffer in directory <" << c_buffer.path << ">; disable functionality.";
 
             c_buffer.disable();
           }
         }
 
       } else {
 
         JWarningStream(logger) << "Tag <" << tag.toString() << "> not implemented";
       }
     }

template<class T >

void KM3NETDAQ::JDataFilter::put ( const T & object )

inlineprivate

Auxiliary method to send object to data server.

Parameters

object object to be sent

Definition at line 1434 of file JDataFilter.cc.

     {
       try {
 
         const localtime_t t0 = getLocalTime();
 
         datawriter->put(object);
 
         const localtime_t t1 = getLocalTime();
 
         numberOfBytes += getSizeof(object);
 
         Qx.put(t1 - t0);
       }
       catch(const std::exception& error) {
         JErrorStream(logger) << "Error \"" << error.what() << "\"; trigger ev_error.";
         ev_error();
       }
     }

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

Returns: true if okay; else false

Definition at line 392 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 std::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 std::exception& error) {
         cerr << error.what() << endl;
         return false;
       }
     }

virtual bool KM3NETDAQ::JDAQClient::enter ( )

inlineoverridevirtualinherited

Enter the state machine.

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

Returns: true if okay; else false

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 447 of file JDAQClient.hh.

     {
       using namespace std;
       using namespace JPP;
 
       if (server.is_valid() && logger.is_valid()) {
 
         const JSubscriptionList buffer = getSubscription(eventTable) + subscription;
 
         try {
           
           server->Subscribe(buffer);
           server->SendMeAlways();
           server->MyId(getFullName());
 
           JStatusStream(logger) << "Process with nick name \"" << getFullName() << "\" version \"" << getGITVersion() << "\" subscription: " << buffer.toString();
 
           return CHSM::machine::enter();
         }
         catch(const std::exception& error) {
           JErrorStream(logger) << error.what();
         }
 
       } else {
         cerr << "Message server or logger not properly initialised." << endl;
       }
 
       return false;
     }

virtual bool KM3NETDAQ::JDAQClient::exit ( )

inlineoverridevirtualinherited

Exit the state machine.

This method releases the various resources.

Returns: true if okay; else false

Definition at line 485 of file JDAQClient.hh.

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

bool KM3NETDAQ::JDAQClient::isRunning ( ) const

inlineinherited

Check if this client is in runnig state.

Returns: true if running; else false

Definition at line 508 of file JDAQClient.hh.

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

void KM3NETDAQ::JDAQClient::replaceEvent	(	const JTag &	oldTag,
		const 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 521 of file JDAQClient.hh.

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

JDAQEvent_t* KM3NETDAQ::JDAQClient::findEvent	(	const 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 536 of file JDAQClient.hh.

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

void KM3NETDAQ::JDAQClient::addSubscription ( const JSubscription & subscription )

inlineinherited

Add custom subscription.

Parameters

subscription subscription

Definition at line 552 of file JDAQClient.hh.

     {
       this->subscription.add(subscription);
     }

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 565 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 579 of file JDAQClient.hh.

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

void KM3NETDAQ::JDAQClient::setSelect ( )

inlineinherited

Set the file descriptor mask for the select call.

Definition at line 588 of file JDAQClient.hh.

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

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

inlineoverridevirtualinherited

This method is called at ev_input.

Parameters

length	length of data
buffer	pointer to data

Reimplemented from JDAQCHSM.

Reimplemented in KM3NETDAQ::DataQueue.

Definition at line 635 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 JTag &	tag,
		int	length,
		const char *	buffer
	)

inlinevirtualinherited

Filter message.

The filter method can be overwritten 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 662 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 690 of file JDAQClient.hh.

     {
       using namespace std;
       using namespace JPP;
 
       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 std::exception& error) {
                   logger.error(error.what());
                 }             
               }
 
             } while (isRunning());
             
             if (numberOfCalls != 0) {
               JNoticeStream(logger) << "Delay per call " << clock.getDelay() / numberOfCalls / 1000 << " ms";
             }
           }
         }
         catch(const JPP::JSocketException& error) {
           JErrorStream(logger) << "method run(): \"" << error.what() << "\" -> trigger ev_error.";
           ev_error();
         }
         catch(const std::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 775 of file JDAQClient.hh.

     {
       JControlHostServer local_server(port);
 
       for ( ; ; ) {
 
         JControlHost* ps = local_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 820 of file JDAQClient.hh.

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

void JDAQStateMachine::A1 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 344 of file JDAQCHSM.cc.

344 { actionError(); }

JDAQCHSM::actionError

virtual void actionError()

Definition: JDAQCHSM.chsm:124

void JDAQStateMachine::A2 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 346 of file JDAQCHSM.cc.

346 { execute(&JDAQCHSM::actionInit, event); }

JDAQCHSM::actionInit

virtual void actionInit(int, const char *)

Definition: JDAQCHSM.chsm:112

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::A3 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 348 of file JDAQCHSM.cc.

348 { JDAQCHSM::exit(); }

exit

Definition: JPizza.sh:36

void JDAQStateMachine::A4 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 350 of file JDAQCHSM.cc.

350 { execute(&JDAQCHSM::actionConfigure, event); }

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

JDAQCHSM::actionConfigure

virtual void actionConfigure(int, const char *)

Definition: JDAQCHSM.chsm:113

void JDAQStateMachine::A5 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 352 of file JDAQCHSM.cc.

352 { execute(&JDAQCHSM::actionReset, event); }

JDAQCHSM::actionReset

virtual void actionReset(int, const char *)

Definition: JDAQCHSM.chsm:118

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::A6 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 354 of file JDAQCHSM.cc.

                                                            { 
 
             std::istringstream is(std::string(ev_start->buffer, ev_start->length));
 
             is >> run_number >> detector_id; 
 
             execute(&JDAQCHSM::actionStart, event);
           
             }

void JDAQStateMachine::A7 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 364 of file JDAQCHSM.cc.

364 { execute(&JDAQCHSM::actionQuit, event); }

JDAQCHSM::actionQuit

virtual void actionQuit(int, const char *)

Definition: JDAQCHSM.chsm:119

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::A8 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 366 of file JDAQCHSM.cc.

366 { execute(&JDAQCHSM::actionContinue, event); }

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

JDAQCHSM::actionContinue

virtual void actionContinue(int, const char *)

Definition: JDAQCHSM.chsm:116

void JDAQStateMachine::A9 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 368 of file JDAQCHSM.cc.

368 { execute(&JDAQCHSM::actionStop, event); }

JDAQCHSM::actionStop

virtual void actionStop(int, const char *)

Definition: JDAQCHSM.chsm:117

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::A10 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 370 of file JDAQCHSM.cc.

370 { execute(&JDAQCHSM::actionPause, event); }

JDAQCHSM::actionPause

virtual void actionPause(int, const char *)

Definition: JDAQCHSM.chsm:115

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::A11 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 372 of file JDAQCHSM.cc.

372 { execute(&JDAQCHSM::actionRecover, event); }

JDAQCHSM::actionRecover

virtual void actionRecover(int, const char *)

Definition: JDAQCHSM.chsm:125

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::A12 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 374 of file JDAQCHSM.cc.

374 { JDAQCHSM::exit(); }

exit

Definition: JPizza.sh:36

void JDAQStateMachine::A13 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 376 of file JDAQCHSM.cc.

376 { execute(&JDAQCHSM::actionCheck, event); }

JDAQCHSM::actionCheck

virtual void actionCheck(int, const char *)

Definition: JDAQCHSM.chsm:121

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::A14 ( CHSM_ns_alias::event const & event )

inherited

Definition at line 378 of file JDAQCHSM.cc.

378 { execute(&JDAQCHSM::actionInput, event); }

JDAQCHSM::actionInput

virtual void actionInput(int, const char *)

Definition: JDAQCHSM.chsm:122

JDAQCHSM::execute

virtual void execute(action __action, const CHSM::event &__event)=0

The method to execute the action.

void JDAQStateMachine::EAM4root	(	CHSM_ns_alias::state const &	chsm_state_,
		CHSM_ns_alias::event const &	event
	)

inherited

Definition at line 337 of file JDAQCHSM.cc.

                                                                                                         {
 #line 164 "JDAQCHSM.chsm"
         CHSM_ns_alias::cluster const &state = (CHSM_ns_alias::cluster const&)chsm_state_; actionEnter(); }

void JDAQStateMachine::XAM4root	(	CHSM_ns_alias::state const &	chsm_state_,
		CHSM_ns_alias::event const &	event
	)

inherited

Definition at line 340 of file JDAQCHSM.cc.

                                                                                                         {
 #line 165 "JDAQCHSM.chsm"
         CHSM_ns_alias::cluster const &state = (CHSM_ns_alias::cluster const&)chsm_state_; actionExit();  }

const std::string& JDAQCHSM::getName ( ) const

inlineinherited

Get name of state machine.

Returns: name

Definition at line 78 of file JDAQCHSM.chsm.

   {
     return name;
   }

const std::string& JDAQCHSM::getName ( ) const

inlineinherited

Get name of state machine.

Returns: name

Definition at line 89 of file JDAQCHSM.hh.

   {
     return name;
   }

int JDAQCHSM::getDetectorID ( ) const

inlineinherited

Get detector identifier.

Returns: detector identifier.

Definition at line 89 of file JDAQCHSM.chsm.

   { 
     return detector_id; 
   }

int JDAQCHSM::getDetectorID ( ) const

inlineinherited

Get detector identifier.

Returns: detector identifier.

Definition at line 100 of file JDAQCHSM.hh.

   { 
     return detector_id; 
   }

int JDAQCHSM::getRunNumber ( ) const

inlineinherited

Get run number.

Returns: run number

Definition at line 100 of file JDAQCHSM.chsm.

   { 
     return run_number; 
   }

int JDAQCHSM::getRunNumber ( ) const

inlineinherited

Get run number.

Returns: run number

Definition at line 111 of file JDAQCHSM.hh.

   { 
     return run_number; 
   }

virtual void JDAQCHSM::actionError ( )

inlinevirtualinherited

Definition at line 124 of file JDAQCHSM.chsm.

124 {}

virtual void JDAQCHSM::actionError ( )

inlinevirtualinherited

Definition at line 135 of file JDAQCHSM.hh.

135 {}

virtual void JDAQCHSM::actionRecover	(	int	,
		const char *
	)

inlinevirtualinherited

Definition at line 125 of file JDAQCHSM.chsm.

125 {}

virtual void JDAQCHSM::actionRecover	(	int	,
		const char *
	)

inlinevirtualinherited

Definition at line 136 of file JDAQCHSM.hh.

136 {}

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

inlineinherited

Get hostname.

Returns: host name

Definition at line 109 of file JDAQClient.hh.

     {
       return hostname;
     }

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

inlineinherited

Get full name of this run control client.

Returns: full name

Definition at line 120 of file JDAQClient.hh.

     {
       return fullname;
     }

const JTag& KM3NETDAQ::JDAQClient_t::getUniqueTag ( ) const

inlineinherited

Get unique tag of this run control client.

Returns: unique tag

Definition at line 131 of file JDAQClient.hh.

     {
       return unique_tag;
     }

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

inlineinherited

Get total delay time.

Returns: delay time [us]

Definition at line 142 of file JDAQClient.hh.

     {
       return clock.getDelay();
     }

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

inlineinherited

Get interval time.

Returns: interval time [us]

Definition at line 154 of file JDAQClient.hh.

     {
       return clock.getInterval();
     }

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

inlineinherited

Set interval time.

Parameters

interval_us interval time [us]

Definition at line 165 of file JDAQClient.hh.

     {
       clock.setInterval(interval_us);
     }

void KM3NETDAQ::JDAQClient_t::resetClock ( )

inlineinherited

Reset clock.

Definition at line 174 of file JDAQClient.hh.

     {
       clock.reset();
     }

const std::string& KM3NETDAQ::JDAQClient_t::getEventInfo ( ) const

inlineinherited

Get last event information.

Returns: event information

Definition at line 185 of file JDAQClient.hh.

     {
       return event_info;
     }

void KM3NETDAQ::JDAQClient_t::setEventInfo ( const std::string & info )

inlineinherited

Set last event information.

Parameters

info	event information

Definition at line 196 of file JDAQClient.hh.

     {
       this->event_info = info;
     }

Member Data Documentation

JMeta KM3NETDAQ::JDataFilter::meta

meta data

Definition at line 1420 of file JDataFilter.cc.

JSinglePointer<JControlHost_t> KM3NETDAQ::JDataFilter::datawriter

private

controlhost of data server (to which data writer should be connected)

Definition at line 1425 of file JDataFilter.cc.

std::string KM3NETDAQ::JDataFilter::hostname

private

host name of data server

Definition at line 1426 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::port

private

server socket port

Definition at line 1455 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::backlog

private

Definition at line 1456 of file JDataFilter.cc.

JSinglePointer<JServerSocket> KM3NETDAQ::JDataFilter::serversocket

private

server for data queue connections

Definition at line 1458 of file JDataFilter.cc.

JChannelList_t KM3NETDAQ::JDataFilter::channelList

private

connections to data queue

Definition at line 1459 of file JDataFilter.cc.

JTimer KM3NETDAQ::JDataFilter::timer

private

Definition at line 1461 of file JDataFilter.cc.

JQuantile KM3NETDAQ::JDataFilter::Qt

private

Definition at line 1462 of file JDataFilter.cc.

JQuantile KM3NETDAQ::JDataFilter::Qx

private

Definition at line 1462 of file JDataFilter.cc.

std::deque<JDAQTimesliceL0> KM3NETDAQ::JDataFilter::timeslices

private

buffer with pending time slice data

Definition at line 1464 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::current_slice_index

private

Definition at line 1465 of file JDataFilter.cc.

size_t KM3NETDAQ::JDataFilter::frames_per_slice

private

Definition at line 1466 of file JDataFilter.cc.

double KM3NETDAQ::JDataFilter::factor_per_slice

private

Definition at line 1467 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::maximal_frame_index

private

Definition at line 1468 of file JDataFilter.cc.

std::set<int> KM3NETDAQ::JDataFilter::modules

private

Definition at line 1469 of file JDataFilter.cc.

KM3NETDAQ::JDataFilter::dataqueue_slice_index

private

JTriggerParameters KM3NETDAQ::JDataFilter::parameters

private

Definition at line 1528 of file JDataFilter.cc.

JSinglePointer<JTimesliceRouter> KM3NETDAQ::JDataFilter::timesliceRouter

private

Definition at line 1529 of file JDataFilter.cc.

JDetector KM3NETDAQ::JDataFilter::detector

private

Definition at line 1531 of file JDataFilter.cc.

JSinglePointer<JModuleRouter> KM3NETDAQ::JDataFilter::moduleRouter

private

Definition at line 1532 of file JDataFilter.cc.

JSinglePointer<JBuildL1_t> KM3NETDAQ::JDataFilter::buildL1

private

Definition at line 1533 of file JDataFilter.cc.

JSinglePointer<JBuildL2_t> KM3NETDAQ::JDataFilter::buildL2

private

Definition at line 1534 of file JDataFilter.cc.

JSinglePointer<JBuildL2_t> KM3NETDAQ::JDataFilter::buildSN

private

Definition at line 1535 of file JDataFilter.cc.

JSinglePointer<JBuildL2_t> KM3NETDAQ::JDataFilter::buildNB

private

Definition at line 1536 of file JDataFilter.cc.

JSinglePointer<JTriggerNB> KM3NETDAQ::JDataFilter::triggerNB

private

Definition at line 1538 of file JDataFilter.cc.

JSinglePointer<JTrigger3DMuon> KM3NETDAQ::JDataFilter::trigger3DMuon

private

Definition at line 1539 of file JDataFilter.cc.

JSinglePointer<JTrigger3DShower> KM3NETDAQ::JDataFilter::trigger3DShower

private

Definition at line 1540 of file JDataFilter.cc.

JSinglePointer<JTriggerMXShower> KM3NETDAQ::JDataFilter::triggerMXShower

private

Definition at line 1541 of file JDataFilter.cc.

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorRun

private

Definition at line 1543 of file JDataFilter.cc.

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorDetector

private

Definition at line 1544 of file JDataFilter.cc.

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorIndex

private

Definition at line 1545 of file JDataFilter.cc.

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorIncomplete

private

Definition at line 1546 of file JDataFilter.cc.

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorOvercomplete

private

Definition at line 1547 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::dumpCount

private

Definition at line 1549 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::dumpLimit

private

Definition at line 1550 of file JDataFilter.cc.

JStatus KM3NETDAQ::JDataFilter::dumpMask

private

Definition at line 1551 of file JDataFilter.cc.

std::vector<JDAQProcess> KM3NETDAQ::JDataFilter::dataFilters

private

Definition at line 1555 of file JDataFilter.cc.

std::vector<JDAQProcess> KM3NETDAQ::JDataFilter::dataQueues

private

Definition at line 1556 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::totalCPURAM

private

Definition at line 1560 of file JDataFilter.cc.

size_t KM3NETDAQ::JDataFilter::maxQueueDepth

private

Definition at line 1561 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::maxQueueSize

private

Definition at line 1562 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::queueSize

private

Definition at line 1563 of file JDataFilter.cc.

bool KM3NETDAQ::JDataFilter::reporting

private

Definition at line 1567 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::numberOfEvents

private

Definition at line 1569 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::numberOfBytes

private

Definition at line 1570 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::numberOfTimeslicesProcessed

private

Definition at line 1571 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::numberOfIncompleteTimeslicesProcessed

private

Definition at line 1572 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::minFrameNumber

private

Definition at line 1574 of file JDataFilter.cc.

int KM3NETDAQ::JDataFilter::maxFrameNumber

private

Definition at line 1575 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::number_of_packets_received

private

Definition at line 1579 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::number_of_packets_discarded

private

Definition at line 1580 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::number_of_reads

private

Definition at line 1581 of file JDataFilter.cc.

long long int KM3NETDAQ::JDataFilter::number_of_bytes_received

private

Definition at line 1582 of file JDataFilter.cc.

JCircularBuffer_t KM3NETDAQ::JDataFilter::c_buffer

private

Definition at line 1586 of file JDataFilter.cc.

JSharedPointer<JControlHost> KM3NETDAQ::JDAQClient::server

protectedinherited

message server

Definition at line 834 of file JDAQClient.hh.

JMessageLogger KM3NETDAQ::JDAQClient::logger

protectedinherited

message logger

Definition at line 835 of file JDAQClient.hh.

JDAQStateMachine::state_root JDAQStateMachine::root

inherited

JDAQStateMachine::state_Main JDAQStateMachine::Main

inherited

JDAQStateMachine::ev_daq_event JDAQStateMachine::ev_daq

inherited

char JDAQStateMachine::ev_daq_param_block[sizeof(ev_daq_event::param_block)]

inherited

Definition at line 238 of file JDAQCHSM.hh.

JDAQStateMachine::ev_init_event JDAQStateMachine::ev_init

inherited

char JDAQStateMachine::ev_init_param_block[sizeof(ev_init_event::param_block)]

inherited

Definition at line 258 of file JDAQCHSM.hh.

JDAQStateMachine::ev_configure_event JDAQStateMachine::ev_configure

inherited

char JDAQStateMachine::ev_configure_param_block[sizeof(ev_configure_event::param_block)]

inherited

Definition at line 278 of file JDAQCHSM.hh.

JDAQStateMachine::ev_start_event JDAQStateMachine::ev_start

inherited

char JDAQStateMachine::ev_start_param_block[sizeof(ev_start_event::param_block)]

inherited

Definition at line 298 of file JDAQCHSM.hh.

JDAQStateMachine::ev_pause_event JDAQStateMachine::ev_pause

inherited

char JDAQStateMachine::ev_pause_param_block[sizeof(ev_pause_event::param_block)]

inherited

Definition at line 318 of file JDAQCHSM.hh.

JDAQStateMachine::ev_continue_event JDAQStateMachine::ev_continue

inherited

char JDAQStateMachine::ev_continue_param_block[sizeof(ev_continue_event::param_block)]

inherited

Definition at line 338 of file JDAQCHSM.hh.

JDAQStateMachine::ev_stop_event JDAQStateMachine::ev_stop

inherited

char JDAQStateMachine::ev_stop_param_block[sizeof(ev_stop_event::param_block)]

inherited

Definition at line 358 of file JDAQCHSM.hh.

JDAQStateMachine::ev_reset_event JDAQStateMachine::ev_reset

inherited

char JDAQStateMachine::ev_reset_param_block[sizeof(ev_reset_event::param_block)]

inherited

Definition at line 378 of file JDAQCHSM.hh.

JDAQStateMachine::ev_quit_event JDAQStateMachine::ev_quit

inherited

char JDAQStateMachine::ev_quit_param_block[sizeof(ev_quit_event::param_block)]

inherited

Definition at line 398 of file JDAQCHSM.hh.

JDAQStateMachine::ev_off_event JDAQStateMachine::ev_off

inherited

char JDAQStateMachine::ev_off_param_block[sizeof(ev_off_event::param_block)]

inherited

Definition at line 418 of file JDAQCHSM.hh.

JDAQStateMachine::ev_check_event JDAQStateMachine::ev_check

inherited

char JDAQStateMachine::ev_check_param_block[sizeof(ev_check_event::param_block)]

inherited

Definition at line 438 of file JDAQCHSM.hh.

JDAQStateMachine::ev_input_event JDAQStateMachine::ev_input

inherited

char JDAQStateMachine::ev_input_param_block[sizeof(ev_input_event::param_block)]

inherited

Definition at line 458 of file JDAQCHSM.hh.

JDAQStateMachine::ev_recover_event JDAQStateMachine::ev_recover

inherited

char JDAQStateMachine::ev_recover_param_block[sizeof(ev_recover_event::param_block)]

inherited

Definition at line 478 of file JDAQCHSM.hh.

JDAQStateMachine::ev_error_event JDAQStateMachine::ev_error

inherited

char JDAQStateMachine::ev_error_param_block[sizeof(ev_error_event::param_block)]

inherited

Definition at line 495 of file JDAQCHSM.hh.

std::string JDAQCHSM::name

protectedinherited

Definition at line 154 of file JDAQCHSM.chsm.

int JDAQCHSM::detector_id

protectedinherited

Definition at line 155 of file JDAQCHSM.chsm.

int JDAQCHSM::run_number

protectedinherited

Definition at line 156 of file JDAQCHSM.chsm.

const int KM3NETDAQ::JDAQClient_t::TIMEOUT_S = 1

staticinherited

time out of update [s]

Definition at line 63 of file JDAQClient.hh.

JEventTable KM3NETDAQ::JDAQClient_t::eventTable

protectedinherited

event table

Definition at line 203 of file JDAQClient.hh.

std::string KM3NETDAQ::JDAQClient_t::fullname

protectedinherited

Definition at line 205 of file JDAQClient.hh.

JTag KM3NETDAQ::JDAQClient_t::unique_tag

protectedinherited

Definition at line 206 of file JDAQClient.hh.

JTimekeeper KM3NETDAQ::JDAQClient_t::clock

protectedinherited

central clock

Definition at line 207 of file JDAQClient.hh.

std::string KM3NETDAQ::JDAQClient_t::event_info

protectedinherited

event information

Definition at line 208 of file JDAQClient.hh.

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

JDataFilter.cc

Classes

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Static Public Attributes

Protected Types

Protected Attributes

Private Types

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation