Jpp
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 | Static Private Attributes | List of all members
KM3NETDAQ::JDataFilter Class Reference

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

Inheritance diagram for KM3NETDAQ::JDataFilter:
KM3NETDAQ::JDAQClient JDAQStateMachine KM3NETDAQ::JDAQClient_t JDAQCHSM

Classes

struct  JCircularBuffer_t
 Circular buffer. More...
 

Public Types

typedef JSocketInputChannel< JDAQAbstractPreambleJSocketInputChannel_t
 
typedef std::vector< JSocketInputChannel_tJChannelList_t
 
typedef double hit_type
 
typedef JSuperFrame1D< hit_typeJSuperFrame1D_t
 
typedef JSuperFrame2D< hit_typeJSuperFrame2D_t
 
typedef JTimeslice< hit_typeJTimeslice_t
 
typedef JBuildL1< hit_typeJBuildL1_t
 
typedef JBuildL2< hit_typeJBuildL2_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 int buffer_size, const std::string &path)
 Constructor. More...
 
virtual void actionEnter ()
 Interface methods for actions corresponding to state transitions. More...
 
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
 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 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)
 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)
 Tagged action to handle alerts. More...
 
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...
 
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_tfindEvent (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)
 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. 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...
 
int getDetectorID () const
 Get detector identifier. More...
 
int getRunNumber () const
 Get run number. More...
 
virtual void actionError ()
 
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 JTaggetUniqueTag () 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...
 
int getEventNumber () const
 Get last event number. More...
 
void setEventNumber (const int event_number)
 Set last event number. More...
 

Static Public Member Functions

static bool processIndexSorter (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 MAXIMUM_FILE_NUMBER = 100
 maximum file number for overwrite protection. More...
 
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...
 

Protected Attributes

JSharedPointer< JControlHostserver
 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...
 
int event_number
 number of last event More...
 

Private Types

typedef JControlHostObjectOutput< JDAQTypes_tJControlHost_t
 

Private Member Functions

template<class T >
bool put (const T &object)
 Auxiliary method to send object to data server. More...
 
void update ()
 Update state machine. More...
 
void update (const JTag &tag, int length, const char *buffer)
 Update state machine. More...
 
void configure ()
 Configure client. More...
 
std::string getMessage (const CHSM::state &state, const CHSM::event &event) const
 Get event message. More...
 
virtual void enterState (const CHSM::state &state, const CHSM::event &event)
 Action when entering state. More...
 
virtual void actionCheck (int length, const char *buffer)
 This method is called at ev_check and reports a system check by mimicing an enter state action. More...
 
void execute (action __action, const CHSM::event &__event)
 The method to execute the action. More...
 
const CHSM::state * getState () const
 Get current state. More...
 

Private Attributes

JSinglePointer< JControlHost_tdatawriter
 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
 
int buffer_size
 
JSinglePointer< JServerSocketserversocket
 server for data queue connections More...
 
JChannelList_t channelList
 connections to data queue More...
 
JTimer timer
 
JQuantile Qt
 
std::list< JDAQTimesliceL0timeslices
 buffer with pending time slice data More...
 
int current_slice_index
 
unsigned int frames_per_slice
 
unsigned int maximum_frames_per_slice
 
int maximal_frame_index
 
JTriggerParameters parameters
 
JSinglePointer< JTimesliceRoutertimesliceRouter
 
JDetector detector
 
JSinglePointer< JModuleRoutermoduleRouter
 
JSinglePointer< JBuildL1_tbuildL1
 
JSinglePointer< JBuildL2_tbuildL2
 
JSinglePointer< JBuildL2_tbuildSN
 
JSinglePointer< JTriggerNBtriggerNB
 
JSinglePointer< JTrigger3DMuontrigger3DMuon
 
JSinglePointer< JTrigger3DShowertrigger3DShower
 
JSinglePointer< JTriggerMXShowertriggerMXShower
 
JMessageScheduler logErrorRun
 
JMessageScheduler logErrorDetector
 
JMessageScheduler logErrorIndex
 
JMessageScheduler logErrorIncomplete
 
std::vector< JDAQProcessdataFilters
 
std::vector< JDAQProcessdataQueues
 
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
 
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
 
std::string path
 directory for writing circular buffer More...
 
JSelectReader select
 select call More...
 
JParser parser
 parser method enter() More...
 
JSubscriptionList subscription
 custom subscription More...
 
CHSM_ns_alias::state * state_ [11]
 
const CHSM_ns_alias::event * taken_ [14]
 
CHSM_ns_alias::state * target_ [14]
 

Static Private Attributes

static const int ev_daq_transitions []
 
static const int ev_init_transitions []
 
static const int ev_configure_transitions []
 
static const int ev_start_transitions []
 
static const int ev_pause_transitions []
 
static const int ev_continue_transitions []
 
static const int ev_stop_transitions []
 
static const int ev_reset_transitions []
 
static const int ev_quit_transitions []
 
static const int ev_off_transitions []
 
static const int ev_check_transitions []
 
static const int ev_input_transitions []
 
static const int ev_recover_transitions []
 
static const int ev_error_transitions []
 
static const CHSM_ns_alias::transition transition_ []
 

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 JDataFilter::setSelect and JDataFilter::actionSelect.

In state Running, all incoming data are buffered, referred to as "queue".
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 the parameter frames_per_slice which, together with other parameters, is parsed in method JDataFilter::actionConfigure.

  numberOfFramesPerSlice = frames_per_slice = 1;

Note that this 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 the corresponding pre-set limit:

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

Note that these values apply per JDataFilter.
When a timeout occurs, the parameter frames_per_slice< 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, the parameter frames_per_slice is incremented by one, upto the original value set at JDataFilter::actionConfigure.
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 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 path is set to a valid director:

After closure of the file, a new file will be opened if path is set;

In this, YYYY, MM and DD are the year, month and day at the time of the configuration or alert and <tag> corresponds to the unique 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).

The application/script JConvert.cc/JConvert.sh can be used to readily convert multiple input files to a single output file.

The script JDOMandDataFilter.sh can be used to test this application.

Definition at line 145 of file JDataFilter.cc.

Member Typedef Documentation

◆ JSocketInputChannel_t

Definition at line 150 of file JDataFilter.cc.

◆ JChannelList_t

Definition at line 151 of file JDataFilter.cc.

◆ hit_type

Definition at line 153 of file JDataFilter.cc.

◆ JSuperFrame1D_t

Definition at line 154 of file JDataFilter.cc.

◆ JSuperFrame2D_t

Definition at line 155 of file JDataFilter.cc.

◆ JTimeslice_t

Definition at line 156 of file JDataFilter.cc.

◆ JBuildL1_t

Definition at line 157 of file JDataFilter.cc.

◆ JBuildL2_t

Definition at line 158 of file JDataFilter.cc.

◆ JControlHost_t

Definition at line 1190 of file JDataFilter.cc.

◆ action

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

◆ JDataFilter()

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 int  buffer_size,
const std::string &  path 
)
inline

Constructor.

Parameters
namename of client
servername of command message server
hostnamename of data server
loggerpointer to logger
leveldebug level
portserver port
backlogserver backlog
buffer_sizeserver buffer
pathdirectory for writing circular buffer

replace tag to receive dfilter specific messages in configure

Definition at line 289 of file JDataFilter.cc.

297  :
298  JDAQClient (name,server,logger,level),
299  hostname (hostname),
300  port (port),
301  backlog (backlog),
303  path (path)
304  {
305  replaceEvent(RC_CMD, RC_DFILTER, ev_configure); /// replace tag to receive dfilter specific messages in configure
306 
307  addSubscription(JSubscriptionAll(RC_ALERT));
308 
309  totalCPURAM = getRAM();
310  current_slice_index = -1;
311  reporting = false;
312  }

Member Function Documentation

◆ processIndexSorter()

static bool KM3NETDAQ::JDataFilter::processIndexSorter ( const JDAQProcess first,
const JDAQProcess second 
)
inlinestatic

Sort DAQ process by index.

Parameters
firstfirst DAQ process
secondsecond DAQ process
Returns
true if index of first DAQ process less than that of second; else false

Definition at line 270 of file JDataFilter.cc.

271  {
272  return first.index < second.index;
273  }

◆ actionEnter()

virtual void KM3NETDAQ::JDataFilter::actionEnter ( )
inlinevirtual

Interface methods for actions corresponding to state transitions.

Reimplemented from JDAQCHSM.

Definition at line 315 of file JDataFilter.cc.

316  {}

◆ actionExit()

virtual void KM3NETDAQ::JDataFilter::actionExit ( )
inlinevirtual

Reimplemented from JDAQCHSM.

Definition at line 319 of file JDataFilter.cc.

320  {
321  if (c_buffer.is_open()) {
322 
323  JNoticeStream(logger) << "Close circular buffer " << c_buffer;
324 
325  c_buffer.close();
326  }
327 
328  datawriter.reset();
329  }

◆ actionInit()

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

Reimplemented from JDAQCHSM.

Definition at line 332 of file JDataFilter.cc.

333  {
334  JDebugStream(logger) << "actionInit() " << std::string(buffer,length);
335 
336  try {
337 
338  JDebugStream(logger) << "Start server.";
339 
340  serversocket.reset(new JServerSocket(port,backlog));
341  }
342  catch(const std::exception& error) {
343  JErrorStream(logger) << "Error \"" << error.what() << "\"; trigger ev_error.";
344  ev_error();
345  }
346  }

◆ actionConfigure()

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

Reimplemented from JDAQCHSM.

Definition at line 349 of file JDataFilter.cc.

350  {
351  using namespace std;
352 
353  JDebugStream(logger) << "actionConfigure() " << endl << std::string(buffer,length);
354 
355  long long int update_s = 10;
356  long long int logger_s = 5;
357 
358  parameters .reset();
359  dataFilters.clear();
360  dataQueues .clear();
361 
362  reporting = false;
363 
364  JProperties properties(JEquationParameters("=", ";", "", ""), 0);
365 
366  properties["dataWriter"] = hostname;
367  properties["numberOfFramesPerSlice"] = frames_per_slice = 1;
368  properties["detector"] = detector;
369  properties["triggerParameters"] = parameters;
370  properties["queueSize"] = maxQueueSize = (totalCPURAM - GIGABYTE); // leave 1 GB left ...
371  properties["queueDepth"] = maxQueueDepth = 20; // to be optimized
372  properties["frameIndex"] = maximal_frame_index = 100000;
373  properties["logger_s"] = logger_s;
374  properties["update_s"] = update_s;
375  properties["JDataFilter"] = dataFilters;
376  properties["DataQueue"] = dataQueues;
377  properties["path"] = path;
378  properties["c_sizeL0"] = c_buffer.sizeL0;
379  properties["c_sizeL1"] = c_buffer.sizeL1;
380  properties["c_sizeL2"] = c_buffer.sizeL2;
381  properties["c_sizeSN"] = c_buffer.sizeSN;
382 
383  try {
384  properties.read(string(buffer, length));
385  }
386  catch(const exception& error) {
387  JErrorStream(logger) << error.what();
388  }
389 
390  if (update_s <= 0) { update_s = 1; }
391  if (logger_s <= 0) { logger_s = 1; }
392 
393  setClockInterval(update_s * 1000000LL);
394 
396 
397  if (hostname != "")
399  else
400  throw JException("Undefined data writer host name.");
401 
403 
404  // process processlist
405 
406  if (dataFilters.empty()) {
407  JNoticeStream(logger) << "No DataFilters in process list, or no process list. "
408  << "Assuming that this process is the only process on this CPU and setting parameters accordingly.";
409  }
410 
411  sort(dataFilters.begin(), dataFilters.end(), processIndexSorter);
412 
413  unsigned int numberOfDataFiltersOnThisMachine = 0;
414  vector<JDAQProcess>::iterator thisProcess = dataFilters.end();
415 
417 
418  {
419  JNoticeStream notice(logger);
420 
421  notice << "My IP addresses:";
422 
423  for (vector<string>::const_iterator i = IP.begin(); i != IP.end(); ++i) {
424  notice << ' ' << *i;
425  }
426  }
427 
428  for (vector<JDAQProcess>::iterator i = dataFilters.begin(); i != dataFilters.end(); ++i) {
429 
430  JDebugStream(logger) << "Test IP address \"" << i->hostname << "\" " << (find(IP.begin(), IP.end(), i->hostname) != IP.end());
431 
432  if (find(IP.begin(), IP.end(), i->hostname) != IP.end()) {
433 
434  numberOfDataFiltersOnThisMachine++;
435 
436  if (i->port == this->port) {
437  thisProcess = i;
438  }
439  }
440  }
441 
442  if (numberOfDataFiltersOnThisMachine == 0) {
443  JNoticeStream(logger) << "Zero data filters on this machine according to process list (if it exists). "
444  << "Assuming one datafilter on this machine.";
445  numberOfDataFiltersOnThisMachine = 1;
446  }
447 
448  if (thisProcess == dataFilters.end()) {
449  JErrorStream(logger) << "This process cannot be found in the process list. Why do I exist?";
450  }
451 
452  if (thisProcess != dataFilters.end() && thisProcess->index != getName()) {
453  JErrorStream(logger) << "Mismatch between given process names: "
454  << "I am called " << getName()
455  << ", but in the process list I am referred to as " << thisProcess->index;
456  }
457 
458  if (dataFilters.begin() == thisProcess || dataFilters.empty()) { // set reporting
459  reporting = true;
460  }
461 
462  if (maxQueueSize > (totalCPURAM-GIGABYTE)/(numberOfDataFiltersOnThisMachine)) { // check maximum size of queue
463 
464  maxQueueSize = (totalCPURAM-GIGABYTE)/(numberOfDataFiltersOnThisMachine);
465 
466  JNoticeStream(logger) << "Maximum queue size is too large given the number of processes on this machine. "
467  << "Queue size reduced to "
468  << maxQueueSize << " bytes." ;
469  }
470 
471  // trigger parameters
472 
474 
475  triggerNB .reset(new JTriggerNB (parameters));
476  trigger3DMuon .reset(new JTrigger3DMuon (parameters));
477  trigger3DShower.reset(new JTrigger3DShower(parameters));
478  triggerMXShower.reset(new JTriggerMXShower(parameters, detector));
479 
480  moduleRouter.reset(new JModuleRouter(detector));
481 
482  if (reporting) {
483  JNoticeStream(logger) << "This data filter process will report.";
484  JNoticeStream(logger) << "Number of modules: " << (*moduleRouter)->size();
485  JDebugStream (logger) << "Trigger parameters: " << parameters;
486  JDebugStream (logger) << "Detector description: " << endl << detector;
487  JNoticeStream(logger) << "Update period [s]: " << getClockInterval();
488  }
489 
490  timesliceRouter.reset(new JTimesliceRouter(parameters.numberOfBins));
491 
492  // set L1, L2 and SN builders
493 
497 
498  if (buildL1.get() == NULL) { JErrorStream(logger) << "Failed to allocate buildL1."; }
499  if (buildL2.get() == NULL) { JErrorStream(logger) << "Failed to allocate buildL2."; }
500  if (buildSN.get() == NULL) { JErrorStream(logger) << "Failed to allocate buildSN."; }
501 
502  logErrorRun = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
503  logErrorDetector = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
504  logErrorIndex = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
505  logErrorIncomplete = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
506 
507  if (c_buffer.is_enabled()) {
508 
509  if (!c_buffer.is_open()) {
510 
512 
513  if (c_buffer.is_open()) {
514 
515  JNoticeStream(logger) << "Created circular buffer " << c_buffer;
516 
518 
519  } else {
520 
521  JErrorStream (logger) << "Failed to create circular buffer in directory <" << path << ">; disable functionality.";
522 
523  c_buffer.disable();
524  }
525 
526  } else {
527 
528  JNoticeStream(logger) << "Continue using circular buffer " << c_buffer;
529  }
530 
531  if (c_buffer.sizeL0 > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceL0>&>(c_buffer).SetCircular(c_buffer.sizeL0); }
532  if (c_buffer.sizeL1 > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceL1>&>(c_buffer).SetCircular(c_buffer.sizeL1); }
533  if (c_buffer.sizeL2 > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceL2>&>(c_buffer).SetCircular(c_buffer.sizeL2); }
534  if (c_buffer.sizeSN > 0) { static_cast<JTreeWriterObjectOutput<JDAQTimesliceSN>&>(c_buffer).SetCircular(c_buffer.sizeSN); }
535 
536  } else {
537 
538  if (c_buffer.is_open()) {
539  c_buffer.close();
540  }
541  }
542  }

◆ actionStart()

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

Reimplemented from JDAQCHSM.

Definition at line 545 of file JDataFilter.cc.

546  {
547  using namespace std;
548 
549  if (reporting) {
550  JNoticeStream(logger) << "Start run " << getRunNumber();
551  }
552 
553  timeslices.clear();
554 
555  current_slice_index = -1;
556  queueSize = 0;
557 
558  numberOfEvents = 0;
559  numberOfBytes = 0;
562 
566  number_of_reads = 0;
567 
568  minFrameNumber = numeric_limits<int>::max();
569  maxFrameNumber = numeric_limits<int>::min();
570 
571  // Reset global trigger counter.
572 
574 
575  logErrorRun .reset();
577  logErrorIndex .reset();
579 
580  timer.reset();
581  timer.start();
582 
583  Qt.reset();
584 
585  // send trigger parameters to the datawriter
586 
587  ostringstream os;
588 
589  os << getRunNumber() << ' ' << parameters;
590 
591  datawriter->PutFullString(IO_TRIGGER_PARAMETERS, os.str());
592  }

◆ actionPause()

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

Reimplemented from JDAQCHSM.

Definition at line 595 of file JDataFilter.cc.

596  {
597  using namespace std;
598 
599  if (!timeslices.empty()) {
600 
601  JNoticeStream(logger) << "Flushing " << timeslices.size() << " slices.";
602 
603  for (list<JDAQTimesliceL0>::const_iterator i = timeslices.begin(); i != timeslices.end(); ++i) {
604  queueSize -= i->getSize();
605  }
606 
607  timeslices.clear();
608  }
609 
610  { // force clearance of memory
611 
613 
614  timeslices.swap(buffer);
615  }
616 
617  if (queueSize != 0) {
618  JWarningStream(logger) << "Pending data in queue " << queueSize << " [B]";
619  }
620 
621  current_slice_index = -1;
622  queueSize = 0;
623 
624  timer.stop();
625  }

◆ actionContinue()

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

Reimplemented from JDAQCHSM.

Definition at line 628 of file JDataFilter.cc.

629  {
630  timer.start();
631  }

◆ actionStop()

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

Reimplemented from JDAQCHSM.

Definition at line 634 of file JDataFilter.cc.

635  {
636  typeout();
637 
638  datawriter.reset();
639  }

◆ actionReset()

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

Reimplemented from JDAQCHSM.

Definition at line 642 of file JDataFilter.cc.

643  {
645  }

◆ actionQuit()

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

Reimplemented from JDAQCHSM.

Definition at line 648 of file JDataFilter.cc.

649  {
650  datawriter.reset();
651  }

◆ setSelect() [1/2]

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

Set the file descriptor mask for the select call.

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

Parameters
maskfile descriptor mask

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 654 of file JDataFilter.cc.

655  {
656  if (serversocket.is_valid()) {
657  mask.set(*serversocket);
658  }
659 
660  for (JChannelList_t::const_iterator channel = channelList.begin(); channel != channelList.end(); ++channel) {
661  if (!channel->isReady()) {
662  mask.set(channel->getFileDescriptor());
663  }
664  }
665  }

◆ actionSelect()

virtual void KM3NETDAQ::JDataFilter::actionSelect ( const JFileDescriptorMask mask)
inlinevirtual

Action method following last select call.

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

Parameters
maskfile descriptor mask

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 668 of file JDataFilter.cc.

669  {
670  using namespace std;
671 
672  for (JChannelList_t::iterator channel = channelList.begin(); channel != channelList.end(); ) {
673 
674  try {
675 
676  if (mask.has(channel->getFileDescriptor())) {
677  channel->read();
678  }
679 
680  if (channel->isReady()) {
681 
683  number_of_reads += channel->getCounter();
684  number_of_bytes_received += channel->size();
685 
686  if (isRunning()) {
687 
688  updateFrameQueue(channel);
689 
690  } else {
691 
692  JErrorStream(logErrorRun) << "Receiving data while not running.";
693 
695  }
696 
697  channel->reset();
698  }
699 
700  ++channel;
701  }
702  catch(const exception& error) {
703 
704  JNoticeStream(logger) << "Disconnecting channel " << channel->getFileDescriptor() << ' ' << error.what();
705 
706  channel->shutdown();
707 
708  channel = channelList.erase(channel);
709  }
710  }
711 
712 
713  if (serversocket.is_valid()) {
714 
715  if (mask.has(*serversocket)) {
716 
717  JSocket socket;
718 
719  socket.accept(serversocket->getFileDescriptor());
720 
721  //socket.setSendBufferSize (buffer_size);
722  socket.setReceiveBufferSize(buffer_size);
723 
724  socket.setKeepAlive (true);
725  socket.setNonBlocking(true);
726 
727  JNoticeStream(logger) << "New channel" << '[' << socket.getFileDescriptor() << ']';
728 
729  channelList.push_back(JSocketInputChannel_t(socket));
730  }
731  }
732 
733 
734  if (!timeslices.empty() && (timeslices.front().size() >= frames_per_slice ||
735  timeslices.size() >= maxQueueDepth ||
736  queueSize >= maxQueueSize)) {
737 
738  const JDAQTimesliceL0& pending_slice = timeslices.front();
739  queueSize -= pending_slice.getSize();
740 
741  current_slice_index = pending_slice.getFrameIndex();
742  minFrameNumber = min(minFrameNumber, pending_slice.getFrameIndex());
743  maxFrameNumber = max(maxFrameNumber, pending_slice.getFrameIndex());
744 
745  if (pending_slice.size() > frames_per_slice) {
746 
747  JErrorStream(logger) << "More frames in timeslice than expected "
748  << pending_slice.size() << " > " << frames_per_slice;
749 
750  if (pending_slice.size() <= maximum_frames_per_slice) {
751 
752  JErrorStream(logger) << "Adjusting expected frames per timeslice to " << pending_slice.size();
753 
754  frames_per_slice = pending_slice.size();
755  }
756  }
757 
758  if (!pending_slice.empty()) {
759 
760  const localtime_t t0 = getLocalTime();
761 
762  processTimeSlice(pending_slice);
763 
764  const localtime_t t1 = getLocalTime();
765 
767 
768  Qt.put(t1 - t0);
769 
770  if (pending_slice.size() < frames_per_slice) {
771 
773 
774  JErrorStream(logErrorIncomplete) << "Timeout -> processed incomplete timeslice: "
775  << "Frame index = " << pending_slice.getFrameIndex() << ';'
776  << "Size of timeslice = " << pending_slice.size() << ';'
777  << "Queue depth = " << timeslices.size() << ';'
778  << "Queue size = " << queueSize;
779 
780  if (!timeslices.empty()) {
781 
782  JErrorStream(logger) << "Adjusting expected frames per timeslice from " << frames_per_slice << " to " << pending_slice.size();
783 
784  frames_per_slice = pending_slice.size();
785  }
786  }
787  }
788 
789  timeslices.pop_front();
790  }
791  }

◆ actionRunning()

virtual void KM3NETDAQ::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 794 of file JDataFilter.cc.

795  {
796  if (reporting) {
797  typeout();
798  }
799  }

◆ updateFrameQueue()

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

Update queue with data frames.

Note that any discarded data will be reported.

Parameters
channelincoming data channel

Definition at line 809 of file JDataFilter.cc.

810  {
811  using namespace std;
812 
813  JByteArrayReader in(channel->data(), channel->size());
814 
815  JDAQPreamble preamble;
816  JDAQSuperFrameHeader header;
817 
818  in >> preamble;
819  in >> header;
820 
821  if (preamble.getLength() != channel->size()) {
822 
823  JErrorStream(logErrorRun) << "Size of received data does not match size reported by preamble: "
824  << "preamble.getLength() = " << preamble.getLength() << ';'
825  << "channel->size(): " << channel->size() << ';';
826 
828 
829  return;
830  }
831 
832  if (header.getRunNumber() != getRunNumber()) {
833 
834  JErrorStream(logErrorRun) << "Run number " << header.getRunNumber()
835  << " unequal to current run " << getRunNumber()
836  << " -> Dropping frame.";
837 
839 
840  return;
841  }
842 
843  if (header.getFrameIndex() <= current_slice_index) {
844 
845  JErrorStream(logErrorIndex) << "Frame index " << header.getFrameIndex() << " <= " << current_slice_index
846  << " -> Dropping frame.";
847 
849 
851 
853 
854  JErrorStream(logErrorIndex) << "Increase number of frames expected to: " << frames_per_slice;
855  }
856 
857  return;
858  }
859 
860  if (header.getFrameIndex() > current_slice_index + maximal_frame_index) {
861 
862  JErrorStream(logErrorIndex) << "Frame index " << header.getFrameIndex() << " > " << current_slice_index + maximal_frame_index
863  << " -> Dropping frame.";
864 
866 
867  return;
868  }
869 
870  list<JDAQTimesliceL0>::iterator timesliceIterator = timeslices.begin();
871 
872  while (timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() < header.getFrameIndex()) {
873  ++timesliceIterator;
874  }
875 
876  if (timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() == header.getFrameIndex()) {
877 
878  // The corresponding time slice already exists
879 
880  } else {
881 
882  // This is the first frame of this time slice; insert a new time slice in the buffer at the right position in the list
883 
884  timesliceIterator = timeslices.insert(timesliceIterator, JDAQTimesliceL0());
885 
886  timesliceIterator->setDAQChronometer(header.getDAQChronometer());
887 
888  queueSize += timesliceIterator->getSize();
889  }
890 
891  timesliceIterator->push_back(JDAQSuperFrame(header));
892 
893  in >> static_cast<JDAQFrame&>(*(timesliceIterator->rbegin()));
894 
895  queueSize += timesliceIterator->rbegin()->getSize();
896  }

◆ processTimeSlice()

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

Process time slice.

Parameters
timeslicetime slice

Definition at line 904 of file JDataFilter.cc.

905  {
906  using namespace std;
907 
908  try {
909 
910  if (parameters.writeSummary()) {
911  this->put(JDAQSummaryslice(timeslice));
912  }
913 
922  c_buffer.is_enabled()) {
923 
924  timesliceRouter->configure(timeslice);
925 
926  JTimeslice_t timesliceL0(timeslice.getDAQChronometer());
927  JTimeslice_t timesliceL1(timeslice.getDAQChronometer());
928  JTimeslice_t timesliceL2(timeslice.getDAQChronometer());
929  JTimeslice_t timesliceSN(timeslice.getDAQChronometer());
930  JTimeslice_t timesliceNB(timeslice.getDAQChronometer());
931  JDAQTimeslice timesliceTX(timeslice.getDAQChronometer());
932 
933  for (JDAQTimesliceL0::const_iterator frame = timeslice.begin(); frame != timeslice.end(); ++frame) {
934 
935  if (moduleRouter->hasModule(frame->getModuleID())) {
936 
937  if (!checksum(*frame)) {
938 
939  JErrorStream(logger) << "Invalid data at "
940  << "run = " << timeslice.getRunNumber() << ";"
941  << "frame index = " << timeslice.getFrameIndex() << ";"
942  << "module = " << frame->getModuleID() << ";"
943  << "discard and dump";
944 
945  timesliceTX.push_back(*frame);
946 
947  continue;
948  }
949 
950  const JModule& module = moduleRouter->getModule(frame->getModuleID());
951  JSuperFrame2D_t& buffer = JSuperFrame2D_t::demultiplex(*frame, module);
952 
953  // Apply high-rate veto
954 
955  buffer.applyHighRateVeto(parameters.highRateVeto_Hz);
956 
957  // L0
958 
959  timesliceL0.push_back(JSuperFrame1D_t(buffer));
960 
961  // Nano-beacon trigger
962 
964 
965  JSuperFrame2D_t::iterator __end = partition(buffer.begin(), buffer.end(), parameters.triggerNB.pmts);
966 
967  if (buffer.begin() != __end) {
968 
969  timesliceNB.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
970  frame->getModuleIdentifier(),
971  module.getPosition()));
972 
973  (*buildL1)(buffer.begin(), __end , back_inserter(*timesliceNB.rbegin()));
974  }
975  }
976 
977  // L1
978 
979  timesliceL1.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
980  frame->getModuleIdentifier(),
981  module.getPosition()));
982 
983  (*buildL1)(*timesliceL0.rbegin(), back_inserter(*timesliceL1.rbegin()));
984 
985  // L2
986 
987  timesliceL2.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
988  frame->getModuleIdentifier(),
989  module.getPosition()));
990 
991  (*buildL2)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceL2.rbegin()));
992 
993  // SN
994 
995  timesliceSN.push_back(JSuperFrame1D_t(frame->getDAQChronometer(),
996  frame->getModuleIdentifier(),
997  module.getPosition()));
998 
999  (*buildSN)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceSN.rbegin()));
1000 
1001  } else {
1002 
1003  JErrorStream(logErrorDetector) << "No detector information for module " << frame->getModuleID();
1004  }
1005  }
1006 
1007  if (!timesliceTX.empty()) {
1008  this->put(timesliceTX);
1009  }
1010 
1011  // Trigger
1012 
1013  if (parameters.triggerNB.enabled) {
1014 
1015  const JTriggerInput trigger_input(timesliceNB);
1016 
1017  for (JTriggerInput::const_iterator hit = trigger_input.begin(); hit != trigger_input.end(); ++hit) {
1018 
1019  JTriggeredEvent tev(timesliceNB.getDAQChronometer(),
1020  getTriggerMask(triggerNB->getTriggerBit()),
1021  *hit,
1022  *timesliceRouter,
1023  *moduleRouter,
1027 
1028  this->put(tev);
1029  }
1030  }
1031 
1032  JTriggerInput trigger_input(timesliceL2);
1033  JTriggerOutput trigger_output;
1034 
1035  (*trigger3DMuon) (trigger_input, back_inserter(trigger_output));
1036  (*trigger3DShower)(trigger_input, back_inserter(trigger_output));
1037  (*triggerMXShower)(trigger_input, timesliceL0, back_inserter(trigger_output));
1038 
1039  trigger_output.merge(JEventOverlap(parameters.TMaxEvent_ns));
1040 
1041  for (JTriggerOutput::const_iterator event = trigger_output.begin(); event != trigger_output.end(); ++event) {
1042 
1043  const JTriggeredEvent object(*event, *timesliceRouter, *moduleRouter, parameters.TMaxLocal_ns, getTimeRange(parameters));
1044 
1045  if (this->put(object)) {
1046  numberOfEvents += 1;
1047  }
1048  }
1049 
1050  if (parameters.writeL1() || c_buffer.sizeL1 > 0) {
1051 
1052  const JTimesliceL1<JDAQTimesliceL1> object(timesliceL1, *timesliceRouter, *moduleRouter, parameters.TMaxLocal_ns);
1053 
1054  if (parameters.writeL1) { this->put(object); }
1055  if (c_buffer.sizeL1 > 0) { c_buffer.put(object); }
1056  }
1057 
1058  if (parameters.writeL2() || c_buffer.sizeL2 > 0) {
1059 
1060  const JTimesliceL1<JDAQTimesliceL2> object(timesliceL2, *timesliceRouter, *moduleRouter, parameters.L2.TMaxLocal_ns);
1061 
1062  if (parameters.writeL2) { this->put(object); }
1063  if (c_buffer.sizeL2 > 0) { c_buffer.put(object); }
1064  }
1065 
1066  if (parameters.writeSN() || c_buffer.sizeSN > 0) {
1067 
1068  const JTimesliceL1<JDAQTimesliceSN> object(timesliceSN, *timesliceRouter, *moduleRouter, parameters.SN.TMaxLocal_ns);
1069 
1070  if (parameters.writeSN) { this->put(object); }
1071  if (c_buffer.sizeSN > 0) { c_buffer.put(object); }
1072  }
1073 
1074  if (parameters.writeL0() || c_buffer.sizeL0 > 0) {
1075 
1076  if (parameters.writeL0) { this->put(timeslice); }
1077  if (c_buffer.sizeL0 > 0) { c_buffer.put(timeslice); }
1078  }
1079  }
1080 
1081  } catch(const exception& error) {
1082  JErrorStream(logger) << "Error = " << error.what() << ";"
1083  << "run = " << timeslice.getRunNumber() << ";"
1084  << "frame index = " << timeslice.getFrameIndex() << ";"
1085  << "time slice not correctly processed!";
1086  }
1087  }

◆ typeout()

void KM3NETDAQ::JDataFilter::typeout ( )
inline

Report status to message logger.

Definition at line 1093 of file JDataFilter.cc.

1094  {
1095  timer.stop();
1096 
1097  const double T_us = (double) timer.usec_wall;
1098 
1099  JNoticeStream(logger) << "Elapsed real (wall) time [s] " << T_us / 1e6;
1100  JNoticeStream(logger) << "Elapsed user CPU time [s] " << (double) timer.usec_ucpu/ 1e6;
1101  JNoticeStream(logger) << "Elapsed system CPU time [s] " << (double) timer.usec_scpu/ 1e6;
1102  try {
1103  JNoticeStream(logger) << "Elapsed real time per time slice [ms] " << Qt.getMean() * 1.0e-3 << " +/- " << Qt.getDeviation() * 1.0e-3;
1104  }
1105  catch(const std::exception&) {}
1106  JNoticeStream(logger) << "Number of packets received/discarded " << number_of_packets_received << "/" << number_of_packets_discarded;
1107  JNoticeStream(logger) << "Number of events/MB sent " << numberOfEvents << "/" << numberOfBytes/1e6;
1108 
1109  if (number_of_packets_received > 0) {
1110  JNoticeStream(logger) << "Number of reads/packet " << (double) number_of_reads / (double) number_of_packets_received;
1111  }
1112 
1113  JNoticeStream(logger) << "Current queue depth/size " << timeslices.size() << "/" << queueSize;
1114  JNoticeStream(logger) << "Current number of frames per slice expected: " << frames_per_slice;
1115 
1116  JNoticeStream(logger) << "Number of timeslices processed total/incomplete " << numberOfTimeslicesProcessed << "/" << numberOfIncompleteTimeslicesProcessed;
1117 
1118  if (numberOfTimeslicesProcessed > 0) {
1119  JNoticeStream(logger) << "Real time per timeslice [ms] " << timer.usec_wall / 1000 / numberOfTimeslicesProcessed;
1120  JNoticeStream(logger) << "User CPU time per timeslice [ms] " << timer.usec_ucpu / 1000 / numberOfTimeslicesProcessed;
1121  JNoticeStream(logger) << "System CPU time per timeslice [ms] " << timer.usec_scpu / 1000 / numberOfTimeslicesProcessed;
1122  }
1123 
1124  const double processedSlicesTime_us = numberOfTimeslicesProcessed * getFrameTime() / 1000;
1125  const double processedDetectorTime_us = (maxFrameNumber - minFrameNumber) * getFrameTime() / 1000;
1126 
1127  if (processedSlicesTime_us > 0) {
1128  JNoticeStream(logger) << "Performance factor (inaccurate estimate): " << T_us / processedSlicesTime_us;
1129  }
1130  if (processedDetectorTime_us > 0) {
1131  JNoticeStream(logger) << "Performance factor whole detector (inaccurate estimate): " << T_us / processedDetectorTime_us;
1132  }
1133 
1134  timer.start();
1135  }

◆ actionTagged()

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

Tagged action to handle alerts.

Parameters
tagtag
lengthnumber of characters
buffermessage

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 1145 of file JDataFilter.cc.

1146  {
1147  using namespace std;
1148 
1149  JDebugStream(logger) << "Received message <" << tag.toString() << "> \"" << string(buffer, length) << "\"";
1150 
1151  if (tag == RC_ALERT) {
1152 
1153  if (c_buffer.is_open()) {
1154 
1155  JNoticeStream(logger) << "Close circular buffer " << c_buffer;
1156 
1157  c_buffer.close();
1158  }
1159 
1160  if (c_buffer.is_enabled()) {
1161 
1163 
1164  if (c_buffer.is_open()) {
1165 
1166  JNoticeStream(logger) << "Created circular buffer " << c_buffer;
1167 
1169 
1170  } else {
1171 
1172  JErrorStream (logger) << "Failed to create circular buffer in directory <" << path << ">; disable functionality.";
1173 
1174  c_buffer.disable();
1175  }
1176  }
1177 
1178  } else {
1179 
1180  JWarningStream(logger) << "Tag <" << tag.toString() << "> not implemented";
1181  }
1182  }

◆ put()

template<class T >
bool KM3NETDAQ::JDataFilter::put ( const T &  object)
inlineprivate

Auxiliary method to send object to data server.

Parameters
objectobject to be sent
Returns
true if sent; else false

Definition at line 1201 of file JDataFilter.cc.

1202  {
1203  try {
1204 
1205  datawriter->put(object);
1206 
1207  numberOfBytes += object.getSize();
1208 
1209  return true;
1210  }
1211  catch(const std::exception& error) {
1212  JErrorStream(logger) << error.what();
1213  }
1214 
1215  return false;
1216  }

◆ enter() [1/2]

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
argsarray of command line arguments
Returns
true if okay; else false

Definition at line 363 of file JDAQClient.hh.

364  {
365  using namespace std;
366 
367  string server;
368  string logger;
369  int level;
370  bool use_cout;
371 
372  try {
373 
374  parser['H'] = make_field(server) = "localhost";
375  parser['M'] = make_field(logger) = "localhost";
376  parser['d'] = make_field(level) = 0;
377  parser['c'] = make_field(use_cout);
378 
379  if (parser.read(args) != 0) {
380  return false;
381  }
382  }
383  catch(const exception &error) {
384  cerr << error.what() << endl;
385  return false;
386  }
387 
388  try {
389 
390  JLogger* out = NULL;
391 
392  if (use_cout)
393  out = new JStreamLogger(cout);
394  else
395  out = new JControlHostLogger(logger);
396 
397  this->logger = JMessageLogger(out, getName(), level);
398 
399  this->server.reset(new JControlHost(server));
400 
401  return enter();
402  }
403  catch(const JControlHostException& error) {
404  cerr << error << endl;
405  return false;
406  }
407  }

◆ enter() [2/2]

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.

Returns
true if okay; else false

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 418 of file JDAQClient.hh.

419  {
420  using namespace std;
421  using namespace JPP;
422 
423  if (server.is_valid() && logger.is_valid()) {
424 
425  const JSubscriptionList buffer = getSubscription(eventTable) + subscription;
426 
427  try {
428 
429  server->Subscribe(buffer);
430  server->SendMeAlways();
431  server->MyId(getFullName());
432 
433  JNoticeStream(logger) << "Nick name \"" << getFullName() << "\" subscription: " << buffer.toString();
434 
435  return CHSM::machine::enter();
436  }
437  catch(const JControlHostException& error) {
438  JErrorStream(logger) << error;
439  }
440 
441  } else {
442  cerr << "Message server or logger not properly initialised." << endl;
443  }
444 
445  return false;
446  }

◆ exit()

virtual bool KM3NETDAQ::JDAQClient::exit ( )
inlinevirtualinherited

Exit the state machine.

This method releases the various resources.

Returns
true if okay; else false

Definition at line 456 of file JDAQClient.hh.

457  {
458  try {
459  if (server.is_valid()) { server.reset(NULL); }
460  }
461  catch(const JControlHostException& error) {
462  }
463 
464  try {
465  if (logger.is_valid()) { logger.reset(NULL); }
466  }
467  catch(const JControlHostException& error) {
468  }
469 
470  return CHSM::machine::exit();
471  }

◆ isRunning()

bool KM3NETDAQ::JDAQClient::isRunning ( ) const
inlineinherited

Check if this client is in runnig state.

Returns
true if running; else false

Definition at line 479 of file JDAQClient.hh.

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

◆ replaceEvent()

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

Replace tag of given event in event table.

Parameters
oldTagold tag
newTagnew tag
eventevent

Definition at line 492 of file JDAQClient.hh.

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

◆ findEvent()

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

Find event in event table.

Parameters
tagtag
event_nameevent name
Returns
pointer to event or NULL

Definition at line 507 of file JDAQClient.hh.

508  {
509  JEventTable::const_iterator i = eventTable.find(tag, event_name);
510 
511  if (i != eventTable.end())
512  return i->second;
513  else
514  return NULL;
515  }

◆ addSubscription()

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

Add custom subscription.

Parameters
subscriptionsubscription

Definition at line 523 of file JDAQClient.hh.

524  {
526  }

◆ addParameter() [1/2]

template<class T >
void KM3NETDAQ::JDAQClient::addParameter ( const char  option,
T &  parameter 
)
inlineinherited

Add parameter to parser used in method enter().

Parameters
optionoption
parameterparameter

Definition at line 536 of file JDAQClient.hh.

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

◆ addParameter() [2/2]

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
optionoption
parameterparameter
valuedefault value

Definition at line 550 of file JDAQClient.hh.

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

◆ setSelect() [2/2]

void KM3NETDAQ::JDAQClient::setSelect ( )
inlineinherited

Set the file descriptor mask for the select call.

Definition at line 559 of file JDAQClient.hh.

560  {
561  select.reset();
562 
564 
566  }

◆ actionInput()

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

This method is called at ev_input.

Parameters
lengthlength of data
bufferpointer to data

Reimplemented from JDAQCHSM.

Reimplemented in KM3NETDAQ::DataQueue, and AcousticDataFilter.

Definition at line 606 of file JDAQClient.hh.

607  {
608  using namespace std;
609 
610  JProperties properties(JEquationParameters("=", ";", "", ""), 1);
611 
612  int level = this->logger.getLevel();
613 
614  properties["debug"] = level;
615 
616  properties.read(string(buffer, length));
617 
618  this->logger.setLevel(level);
619  }

◆ filter()

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
tagtag
lengthnumber of characters
buffermessage
Returns
skip message or not

Definition at line 633 of file JDAQClient.hh.

634  {
635  return false;
636  }

◆ run() [1/3]

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

662  {
663  using namespace std;
664 
665  while (active()) {
666 
667  try {
668 
669  setSelect();
670 
671  if (select(JTimeval(TIMEOUT_S,0)) > 0) {
672 
673  if (select.hasReaderMask(*server)) {
674  update();
675  }
676 
678 
679  } else {
680 
681  continue;
682  }
683 
684 
685  if (isRunning() && clock.getInterval() != 0LL) {
686 
687  long long int numberOfCalls = 0;
688 
689  clock.reset();
690 
691  do {
692 
693  ++numberOfCalls;
694 
695  setSelect();
696 
697  if (clock.wait(select.getReaderMask())) {
698 
699  if (select.hasReaderMask(*server)) {
700  update();
701  }
702 
704 
705  } else {
706 
707  try {
708  actionRunning();
709  }
710  catch(const exception& error) {
711  logger.error(error.what());
712  }
713  }
714 
715  } while (isRunning());
716 
717  if (numberOfCalls != 0) {
718  JNoticeStream(logger) << "Delay per call " << clock.getDelay() / numberOfCalls / 1000 << " ms";
719  }
720  }
721  }
722  catch(const exception& error) {
723  JErrorStream(logger) << "method run(): " << error.what();
724  }
725  }
726  }

◆ run() [2/3]

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
portport number

Definition at line 741 of file JDAQClient.hh.

742  {
743  JControlHostServer local_server(port);
744 
745  for ( ; ; ) {
746 
747  JControlHost* ps = local_server.AcceptClient();
748 
749  ps->Connected();
750 
751  JNET::JPrefix prefix;
752 
753  ps->WaitHead(prefix);
754 
755  const int length = prefix.getSize();
756 
757  char* buffer = new char[length];
758 
759  ps->GetFullData(buffer, length);
760  ps->PutFullData(prefix.toString(), buffer, length);
761 
762  delete ps;
763 
764  enter(JArgs(std::string(buffer, length)));
765 
766  delete [] buffer;
767 
768  run();
769 
770  exit();
771  }
772  }

◆ run() [3/3]

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
ininput stream

Definition at line 786 of file JDAQClient.hh.

787  {
788  using namespace std;
789 
790  string tag;
791  string buffer;
792 
793  while (in >> tag && in >> skipws && getline(in, buffer, ';')) {
794  update(tag, buffer.length(), buffer.data());
795  }
796  }

◆ update() [1/2]

void KM3NETDAQ::JDAQClient::update ( )
inlineprivateinherited

Update state machine.

This method waits for a message from JNET::JControlHost server.

Definition at line 808 of file JDAQClient.hh.

809  {
810  JNET::JPrefix prefix;
811 
812  server->WaitHead(prefix);
813 
814  const int length = prefix.getSize();
815 
816  char* buffer = new char[length];
817 
818  server->GetFullData(buffer, length);
819 
820  update(prefix.getTag(), length, buffer);
821 
822  delete [] buffer;
823  }

◆ update() [2/2]

void KM3NETDAQ::JDAQClient::update ( const JTag tag,
int  length,
const char *  buffer 
)
inlineprivateinherited

Update state machine.

Parameters
tagtag
lengthnumber of characters
buffermessage

Definition at line 833 of file JDAQClient.hh.

834  {
835  using namespace std;
836  using namespace JPP;
837 
838  if (filter(tag, length, buffer)) {
839  return;
840  }
841 
842  if (getSubscription(eventTable)->count(JSubscriptionAny(tag)) == 0 &&
843  getSubscription(eventTable)->count(JSubscriptionAll(tag)) == 0) {
844 
845  actionTagged(tag, length, buffer);
846 
847  return;
848  }
849 
850 
851  string::size_type pos = 0;
852 
853  while (pos != (string::size_type) length && TOKEN_DELIMETER.find(*(buffer + pos)) == string::npos) {
854  ++pos;
855  }
856 
857  const JEvent_t event = JEvent_t::toValue(string(buffer, pos));
858 
859  setEventNumber(event.getNumber());
860 
861  while (pos != (string::size_type) length && TOKEN_DELIMETER.find(*(buffer + pos)) != string::npos) {
862  ++pos;
863  }
864 
865 
866  JEventTable::const_iterator i = eventTable.find(tag, event.getName());
867 
868  if (i != eventTable.end()) {
869 
870  const CHSM::state* const s0 = getState();
871 
872  if (!i->second->active()) {
873 
874  JWarningStream(logger) << "Event " << i->second->name() << " not active (" << (s0 != NULL ? s0->name() : "") << ")";
875 
876  if (server.is_valid() && s0 != NULL) {
877  server->PutFullString(RC_FAIL, getMessage(*s0, *i->second));
878  }
879  }
880 
881  // redirect all I/O
882 
883  {
885  JErrorStream error(logger);
886 
887  JRedirectStream redirect[] = { JRedirectStream(cin, JLANG::null),
888  JRedirectStream(cout, debug),
889  JRedirectStream(cerr, error) };
890 
891  if (redirect[0] &&
892  redirect[1] &&
893  redirect[2]) {
894 
895  (*(i->second))(length - pos, buffer + pos);
896  }
897  }
898 
899  const CHSM::state* const s1 = getState();
900 
901  JStatusStream(logger) << "Transition "
902  << (s0 != NULL ? s0->name() : "")
903  << "->(" << i->second->name() << ")->"
904  << (s1 != NULL ? s1->name() : "");
905  } else {
906 
907  JErrorStream(logger) << "Unknown key <" << tag << "," << event.getName() << ">";
908  }
909  }

◆ configure()

void KM3NETDAQ::JDAQClient::configure ( )
inlineprivateinherited

Configure client.

This method is used to setup the event table.

Definition at line 916 of file JDAQClient.hh.

917  {
918  }

◆ getMessage()

std::string KM3NETDAQ::JDAQClient::getMessage ( const CHSM::state &  state,
const CHSM::event &  event 
) const
inlineprivateinherited

Get event message.

Parameters
statestate
eventevent
Returns
message

Definition at line 928 of file JDAQClient.hh.

929  {
930  std::ostringstream os;
931 
932  os << getFullName()
933  << getTokenDelimeter()
934  << JEvent_t(event.name(), event_number)
935  << getTokenDelimeter()
936  << getStateName(state.name());
937 
938  return os.str();
939  }

◆ enterState()

virtual void KM3NETDAQ::JDAQClient::enterState ( const CHSM::state &  state,
const CHSM::event &  event 
)
inlineprivatevirtualinherited

Action when entering state.

This method provides for the hand shaking with the run control program.

Parameters
stateentered state
eventevent that triggered transition

Implements JDAQCHSM.

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 949 of file JDAQClient.hh.

950  {
951  if (server.is_valid()) {
952  server->PutFullString(RC_REPLY, getMessage(state, event));
953  }
954  }

◆ actionCheck()

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

This method is called at ev_check and reports a system check by mimicing an enter state action.

Parameters
lengthnumber of characters
buffermessage

Reimplemented from JDAQCHSM.

Definition at line 963 of file JDAQClient.hh.

964  {
965  if (Main.RunControl.Error.active()) {
966 
968 
969  } else {
970 
971  for (CHSM::parent::iterator state = Main.RunControl.Operational.begin(); state != Main.RunControl.Operational.end(); ++state) {
972 
973  if (state->active()) {
974 
975  // mimic enter state
976 
977  enterState(*state, ev_check);
978  }
979  }
980  }
981  }

◆ execute()

void KM3NETDAQ::JDAQClient::execute ( action  __action,
const CHSM::event &  __event 
)
inlineprivatevirtualinherited

The method to execute the action.

Parameters
__actionpointer to action method
__eventevent that triggered the action

Implements JDAQCHSM.

Definition at line 990 of file JDAQClient.hh.

991  {
992  try {
993 
994  const JDAQStateMachine::ev_daq_event& event = dynamic_cast<const JDAQStateMachine::ev_daq_event&>(__event);
995 
996  (this->*__action)(event->length, event->buffer);
997  }
998  catch(const std::exception& error) {
999  JErrorStream(logger) << "Error at event " << __event.name() << " \"" << error.what() << "\"; trigger ev_error.";
1000  ev_error();
1001  }
1002  }

◆ getState()

const CHSM::state* KM3NETDAQ::JDAQClient::getState ( ) const
inlineprivateinherited

Get current state.

Returns
state

Definition at line 1010 of file JDAQClient.hh.

1011  {
1012  for (CHSM::parent::const_iterator state = Main.RunControl.Operational.begin(); state != Main.RunControl.Operational.end(); ++state) {
1013  if (state->active()) {
1014  return &(*state);
1015  }
1016  }
1017 
1018  if (Main.RunControl.Error.active()) {
1019  return &Main.RunControl.Error;
1020  }
1021 
1022  return NULL;
1023  }

◆ A1()

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

Definition at line 344 of file JDAQCHSM.cc.

344 { actionError(); }

◆ A2()

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

Definition at line 346 of file JDAQCHSM.cc.

◆ A3()

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

Definition at line 348 of file JDAQCHSM.cc.

348 { JDAQCHSM::exit(); }

◆ A4()

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

Definition at line 350 of file JDAQCHSM.cc.

◆ A5()

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

Definition at line 352 of file JDAQCHSM.cc.

◆ A6()

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

Definition at line 354 of file JDAQCHSM.cc.

354  {
355 
356  std::istringstream is(std::string(ev_start->buffer, ev_start->length));
357 
358  is >> run_number >> detector_id;
359 
361 
362  }

◆ A7()

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

Definition at line 364 of file JDAQCHSM.cc.

◆ A8()

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

Definition at line 366 of file JDAQCHSM.cc.

◆ A9()

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

Definition at line 368 of file JDAQCHSM.cc.

◆ A10()

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

Definition at line 370 of file JDAQCHSM.cc.

◆ A11()

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

Definition at line 372 of file JDAQCHSM.cc.

◆ A12()

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

Definition at line 374 of file JDAQCHSM.cc.

374 { JDAQCHSM::exit(); }

◆ A13()

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

Definition at line 376 of file JDAQCHSM.cc.

◆ A14()

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

Definition at line 378 of file JDAQCHSM.cc.

◆ EAM4root()

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.

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

◆ XAM4root()

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.

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

◆ getName()

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

Get name of state machine.

Returns
name

Definition at line 89 of file JDAQCHSM.hh.

90  {
91  return name;
92  }

◆ getDetectorID()

int JDAQCHSM::getDetectorID ( ) const
inlineinherited

Get detector identifier.

Returns
detector identifier.

Definition at line 100 of file JDAQCHSM.hh.

101  {
102  return detector_id;
103  }

◆ getRunNumber()

int JDAQCHSM::getRunNumber ( ) const
inlineinherited

Get run number.

Returns
run number

Definition at line 111 of file JDAQCHSM.hh.

112  {
113  return run_number;
114  }

◆ actionError()

virtual void JDAQCHSM::actionError ( )
inlinevirtualinherited

Definition at line 135 of file JDAQCHSM.hh.

135 {}

◆ actionRecover()

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

Definition at line 136 of file JDAQCHSM.hh.

136 {}

◆ getHostname()

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

Get hostname.

Returns
host name

Definition at line 108 of file JDAQClient.hh.

109  {
110  return hostname;
111  }

◆ getFullName()

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

Get full name of this run control client.

Returns
full name

Definition at line 119 of file JDAQClient.hh.

120  {
121  return fullname;
122  }

◆ getUniqueTag()

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

Get unique tag of this run control client.

Returns
unique tag

Definition at line 130 of file JDAQClient.hh.

131  {
132  return unique_tag;
133  }

◆ getClockDelay()

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

Get total delay time.

Returns
delay time [us]

Definition at line 141 of file JDAQClient.hh.

142  {
143  return clock.getDelay();
144  }

◆ getClockInterval()

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

Get interval time.

Returns
interval time [us]

Definition at line 153 of file JDAQClient.hh.

154  {
155  return clock.getInterval();
156  }

◆ setClockInterval()

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

Set interval time.

Parameters
interval_usinterval time [us]

Definition at line 164 of file JDAQClient.hh.

165  {
166  clock.setInterval(interval_us);
167  }

◆ resetClock()

void KM3NETDAQ::JDAQClient_t::resetClock ( )
inlineinherited

Reset clock.

Definition at line 173 of file JDAQClient.hh.

174  {
175  clock.reset();
176  }

◆ getEventNumber()

int KM3NETDAQ::JDAQClient_t::getEventNumber ( ) const
inlineinherited

Get last event number.

Returns
event number

Definition at line 184 of file JDAQClient.hh.

185  {
186  return event_number;
187  }

◆ setEventNumber()

void KM3NETDAQ::JDAQClient_t::setEventNumber ( const int  event_number)
inlineinherited

Set last event number.

Parameters
event_numberevent number

Definition at line 195 of file JDAQClient.hh.

196  {
197  this->event_number = event_number;
198  }

Member Data Documentation

◆ meta

JMeta KM3NETDAQ::JDataFilter::meta

meta data

Definition at line 1184 of file JDataFilter.cc.

◆ MAXIMUM_FILE_NUMBER

const int KM3NETDAQ::JDataFilter::MAXIMUM_FILE_NUMBER = 100
static

maximum file number for overwrite protection.

Definition at line 1186 of file JDataFilter.cc.

◆ datawriter

JSinglePointer<JControlHost_t> KM3NETDAQ::JDataFilter::datawriter
private

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

Definition at line 1191 of file JDataFilter.cc.

◆ hostname

std::string KM3NETDAQ::JDataFilter::hostname
private

host name of data server

Definition at line 1192 of file JDataFilter.cc.

◆ port

int KM3NETDAQ::JDataFilter::port
private

server socket port

Definition at line 1219 of file JDataFilter.cc.

◆ backlog

int KM3NETDAQ::JDataFilter::backlog
private

Definition at line 1220 of file JDataFilter.cc.

◆ buffer_size

int KM3NETDAQ::JDataFilter::buffer_size
private

Definition at line 1221 of file JDataFilter.cc.

◆ serversocket

JSinglePointer<JServerSocket> KM3NETDAQ::JDataFilter::serversocket
private

server for data queue connections

Definition at line 1223 of file JDataFilter.cc.

◆ channelList

JChannelList_t KM3NETDAQ::JDataFilter::channelList
private

connections to data queue

Definition at line 1224 of file JDataFilter.cc.

◆ timer

JTimer KM3NETDAQ::JDataFilter::timer
private

Definition at line 1226 of file JDataFilter.cc.

◆ Qt

JQuantile KM3NETDAQ::JDataFilter::Qt
private

Definition at line 1227 of file JDataFilter.cc.

◆ timeslices

std::list<JDAQTimesliceL0> KM3NETDAQ::JDataFilter::timeslices
private

buffer with pending time slice data

Definition at line 1229 of file JDataFilter.cc.

◆ current_slice_index

int KM3NETDAQ::JDataFilter::current_slice_index
private

Definition at line 1230 of file JDataFilter.cc.

◆ frames_per_slice

unsigned int KM3NETDAQ::JDataFilter::frames_per_slice
private

Definition at line 1231 of file JDataFilter.cc.

◆ maximum_frames_per_slice

unsigned int KM3NETDAQ::JDataFilter::maximum_frames_per_slice
private

Definition at line 1232 of file JDataFilter.cc.

◆ maximal_frame_index

int KM3NETDAQ::JDataFilter::maximal_frame_index
private

Definition at line 1233 of file JDataFilter.cc.

◆ parameters

JTriggerParameters KM3NETDAQ::JDataFilter::parameters
private

Definition at line 1237 of file JDataFilter.cc.

◆ timesliceRouter

JSinglePointer<JTimesliceRouter> KM3NETDAQ::JDataFilter::timesliceRouter
private

Definition at line 1238 of file JDataFilter.cc.

◆ detector

JDetector KM3NETDAQ::JDataFilter::detector
private

Definition at line 1240 of file JDataFilter.cc.

◆ moduleRouter

JSinglePointer<JModuleRouter> KM3NETDAQ::JDataFilter::moduleRouter
private

Definition at line 1241 of file JDataFilter.cc.

◆ buildL1

JSinglePointer<JBuildL1_t> KM3NETDAQ::JDataFilter::buildL1
private

Definition at line 1242 of file JDataFilter.cc.

◆ buildL2

JSinglePointer<JBuildL2_t> KM3NETDAQ::JDataFilter::buildL2
private

Definition at line 1243 of file JDataFilter.cc.

◆ buildSN

JSinglePointer<JBuildL2_t> KM3NETDAQ::JDataFilter::buildSN
private

Definition at line 1244 of file JDataFilter.cc.

◆ triggerNB

JSinglePointer<JTriggerNB> KM3NETDAQ::JDataFilter::triggerNB
private

Definition at line 1246 of file JDataFilter.cc.

◆ trigger3DMuon

JSinglePointer<JTrigger3DMuon> KM3NETDAQ::JDataFilter::trigger3DMuon
private

Definition at line 1247 of file JDataFilter.cc.

◆ trigger3DShower

JSinglePointer<JTrigger3DShower> KM3NETDAQ::JDataFilter::trigger3DShower
private

Definition at line 1248 of file JDataFilter.cc.

◆ triggerMXShower

JSinglePointer<JTriggerMXShower> KM3NETDAQ::JDataFilter::triggerMXShower
private

Definition at line 1249 of file JDataFilter.cc.

◆ logErrorRun

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorRun
private

Definition at line 1251 of file JDataFilter.cc.

◆ logErrorDetector

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorDetector
private

Definition at line 1252 of file JDataFilter.cc.

◆ logErrorIndex

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorIndex
private

Definition at line 1253 of file JDataFilter.cc.

◆ logErrorIncomplete

JMessageScheduler KM3NETDAQ::JDataFilter::logErrorIncomplete
private

Definition at line 1254 of file JDataFilter.cc.

◆ dataFilters

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

Definition at line 1258 of file JDataFilter.cc.

◆ dataQueues

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

Definition at line 1259 of file JDataFilter.cc.

◆ totalCPURAM

long long int KM3NETDAQ::JDataFilter::totalCPURAM
private

Definition at line 1263 of file JDataFilter.cc.

◆ maxQueueDepth

unsigned int KM3NETDAQ::JDataFilter::maxQueueDepth
private

Definition at line 1264 of file JDataFilter.cc.

◆ maxQueueSize

long long int KM3NETDAQ::JDataFilter::maxQueueSize
private

Definition at line 1265 of file JDataFilter.cc.

◆ queueSize

long long int KM3NETDAQ::JDataFilter::queueSize
private

Definition at line 1266 of file JDataFilter.cc.

◆ reporting

bool KM3NETDAQ::JDataFilter::reporting
private

Definition at line 1270 of file JDataFilter.cc.

◆ numberOfEvents

long long int KM3NETDAQ::JDataFilter::numberOfEvents
private

Definition at line 1272 of file JDataFilter.cc.

◆ numberOfBytes

long long int KM3NETDAQ::JDataFilter::numberOfBytes
private

Definition at line 1273 of file JDataFilter.cc.

◆ numberOfTimeslicesProcessed

long long int KM3NETDAQ::JDataFilter::numberOfTimeslicesProcessed
private

Definition at line 1274 of file JDataFilter.cc.

◆ numberOfIncompleteTimeslicesProcessed

long long int KM3NETDAQ::JDataFilter::numberOfIncompleteTimeslicesProcessed
private

Definition at line 1275 of file JDataFilter.cc.

◆ minFrameNumber

int KM3NETDAQ::JDataFilter::minFrameNumber
private

Definition at line 1277 of file JDataFilter.cc.

◆ maxFrameNumber

int KM3NETDAQ::JDataFilter::maxFrameNumber
private

Definition at line 1278 of file JDataFilter.cc.

◆ number_of_packets_received

long long int KM3NETDAQ::JDataFilter::number_of_packets_received
private

Definition at line 1282 of file JDataFilter.cc.

◆ number_of_packets_discarded

long long int KM3NETDAQ::JDataFilter::number_of_packets_discarded
private

Definition at line 1283 of file JDataFilter.cc.

◆ number_of_reads

long long int KM3NETDAQ::JDataFilter::number_of_reads
private

Definition at line 1284 of file JDataFilter.cc.

◆ number_of_bytes_received

long long int KM3NETDAQ::JDataFilter::number_of_bytes_received
private

Definition at line 1285 of file JDataFilter.cc.

◆ c_buffer

JCircularBuffer_t KM3NETDAQ::JDataFilter::c_buffer
private

Definition at line 1289 of file JDataFilter.cc.

◆ path

std::string KM3NETDAQ::JDataFilter::path
private

directory for writing circular buffer

Definition at line 1290 of file JDataFilter.cc.

◆ server

JSharedPointer<JControlHost> KM3NETDAQ::JDAQClient::server
protectedinherited

message server

Definition at line 800 of file JDAQClient.hh.

◆ logger

JMessageLogger KM3NETDAQ::JDAQClient::logger
protectedinherited

message logger

Definition at line 801 of file JDAQClient.hh.

◆ select

JSelectReader KM3NETDAQ::JDAQClient::select
privateinherited

select call

Definition at line 1026 of file JDAQClient.hh.

◆ parser

JParser KM3NETDAQ::JDAQClient::parser
privateinherited

parser method enter()

Definition at line 1027 of file JDAQClient.hh.

◆ subscription

JSubscriptionList KM3NETDAQ::JDAQClient::subscription
privateinherited

custom subscription

Definition at line 1028 of file JDAQClient.hh.

◆ root

JDAQStateMachine::state_root JDAQStateMachine::root
inherited

◆ Main

JDAQStateMachine::state_Main JDAQStateMachine::Main
inherited

◆ ev_daq_transitions

const int JDAQStateMachine::ev_daq_transitions
staticprivateinherited
Initial value:
= {
-1
}

Definition at line 216 of file JDAQCHSM.hh.

◆ ev_daq

JDAQStateMachine::ev_daq_event JDAQStateMachine::ev_daq
inherited

◆ ev_daq_param_block

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

Definition at line 238 of file JDAQCHSM.hh.

◆ ev_init_transitions

const int JDAQStateMachine::ev_init_transitions
staticprivateinherited
Initial value:
= {
1, -1
}

Definition at line 240 of file JDAQCHSM.hh.

◆ ev_init

JDAQStateMachine::ev_init_event JDAQStateMachine::ev_init
inherited

◆ ev_init_param_block

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

Definition at line 258 of file JDAQCHSM.hh.

◆ ev_configure_transitions

const int JDAQStateMachine::ev_configure_transitions
staticprivateinherited
Initial value:
= {
3, -1
}

Definition at line 260 of file JDAQCHSM.hh.

◆ ev_configure

JDAQStateMachine::ev_configure_event JDAQStateMachine::ev_configure
inherited

◆ ev_configure_param_block

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

Definition at line 278 of file JDAQCHSM.hh.

◆ ev_start_transitions

const int JDAQStateMachine::ev_start_transitions
staticprivateinherited
Initial value:
= {
5, -1
}

Definition at line 280 of file JDAQCHSM.hh.

◆ ev_start

JDAQStateMachine::ev_start_event JDAQStateMachine::ev_start
inherited

◆ ev_start_param_block

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

Definition at line 298 of file JDAQCHSM.hh.

◆ ev_pause_transitions

const int JDAQStateMachine::ev_pause_transitions
staticprivateinherited
Initial value:
= {
9, -1
}

Definition at line 300 of file JDAQCHSM.hh.

◆ ev_pause

JDAQStateMachine::ev_pause_event JDAQStateMachine::ev_pause
inherited

◆ ev_pause_param_block

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

Definition at line 318 of file JDAQCHSM.hh.

◆ ev_continue_transitions

const int JDAQStateMachine::ev_continue_transitions
staticprivateinherited
Initial value:
= {
7, -1
}

Definition at line 320 of file JDAQCHSM.hh.

◆ ev_continue

JDAQStateMachine::ev_continue_event JDAQStateMachine::ev_continue
inherited

◆ ev_continue_param_block

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

Definition at line 338 of file JDAQCHSM.hh.

◆ ev_stop_transitions

const int JDAQStateMachine::ev_stop_transitions
staticprivateinherited
Initial value:
= {
8, -1
}

Definition at line 340 of file JDAQCHSM.hh.

◆ ev_stop

JDAQStateMachine::ev_stop_event JDAQStateMachine::ev_stop
inherited

◆ ev_stop_param_block

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

Definition at line 358 of file JDAQCHSM.hh.

◆ ev_reset_transitions

const int JDAQStateMachine::ev_reset_transitions
staticprivateinherited
Initial value:
= {
4, -1
}

Definition at line 360 of file JDAQCHSM.hh.

◆ ev_reset

JDAQStateMachine::ev_reset_event JDAQStateMachine::ev_reset
inherited

◆ ev_reset_param_block

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

Definition at line 378 of file JDAQCHSM.hh.

◆ ev_quit_transitions

const int JDAQStateMachine::ev_quit_transitions
staticprivateinherited
Initial value:
= {
6, -1
}

Definition at line 380 of file JDAQCHSM.hh.

◆ ev_quit

JDAQStateMachine::ev_quit_event JDAQStateMachine::ev_quit
inherited

◆ ev_quit_param_block

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

Definition at line 398 of file JDAQCHSM.hh.

◆ ev_off_transitions

const int JDAQStateMachine::ev_off_transitions
staticprivateinherited
Initial value:
= {
2, 11, -1
}

Definition at line 400 of file JDAQCHSM.hh.

◆ ev_off

JDAQStateMachine::ev_off_event JDAQStateMachine::ev_off
inherited

◆ ev_off_param_block

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

Definition at line 418 of file JDAQCHSM.hh.

◆ ev_check_transitions

const int JDAQStateMachine::ev_check_transitions
staticprivateinherited
Initial value:
= {
12, -1
}

Definition at line 420 of file JDAQCHSM.hh.

◆ ev_check

JDAQStateMachine::ev_check_event JDAQStateMachine::ev_check
inherited

◆ ev_check_param_block

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

Definition at line 438 of file JDAQCHSM.hh.

◆ ev_input_transitions

const int JDAQStateMachine::ev_input_transitions
staticprivateinherited
Initial value:
= {
13, -1
}

Definition at line 440 of file JDAQCHSM.hh.

◆ ev_input

JDAQStateMachine::ev_input_event JDAQStateMachine::ev_input
inherited

◆ ev_input_param_block

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

Definition at line 458 of file JDAQCHSM.hh.

◆ ev_recover_transitions

const int JDAQStateMachine::ev_recover_transitions
staticprivateinherited
Initial value:
= {
10, -1
}

Definition at line 460 of file JDAQCHSM.hh.

◆ ev_recover

JDAQStateMachine::ev_recover_event JDAQStateMachine::ev_recover
inherited

◆ ev_recover_param_block

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

Definition at line 478 of file JDAQCHSM.hh.

◆ ev_error_transitions

const int JDAQStateMachine::ev_error_transitions
staticprivateinherited
Initial value:
= {
0, -1
}

Definition at line 480 of file JDAQCHSM.hh.

◆ ev_error

JDAQStateMachine::ev_error_event JDAQStateMachine::ev_error
inherited

◆ ev_error_param_block

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

Definition at line 495 of file JDAQCHSM.hh.

◆ state_

CHSM_ns_alias::state* JDAQStateMachine::state_[11]
privateinherited

Definition at line 522 of file JDAQCHSM.hh.

◆ transition_

const CHSM_ns_alias::transition JDAQStateMachine::transition_
staticprivateinherited
Initial value:
= {
{ 0, 2, 8, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A1 },
{ 0, 3, 4, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A2 },
{ 0, 3, -1, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A3 },
{ 0, 4, 5, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A4 },
{ 0, 4, 3, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A5 },
{ 0, 5, 7, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A6 },
{ 0, 5, 4, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A7 },
{ 0, 6, 7, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A8 },
{ 0, 6, 4, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A9 },
{ 0, 7, 6, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A10 },
{ 0, 8, 2, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A11 },
{ 0, 8, -1, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A12 },
{ 0, 9, -1, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A13 },
{ 0, 9, -1, 0, (CHSM_ns_alias::transition::action)&JDAQStateMachine::A14 },
0
}

Definition at line 523 of file JDAQCHSM.hh.

◆ taken_

const CHSM_ns_alias::event* JDAQStateMachine::taken_[14]
privateinherited

Definition at line 524 of file JDAQCHSM.hh.

◆ target_

CHSM_ns_alias::state* JDAQStateMachine::target_[14]
privateinherited

Definition at line 525 of file JDAQCHSM.hh.

◆ name

std::string JDAQCHSM::name
protectedinherited

Definition at line 165 of file JDAQCHSM.hh.

◆ detector_id

int JDAQCHSM::detector_id
protectedinherited

Definition at line 166 of file JDAQCHSM.hh.

◆ run_number

int JDAQCHSM::run_number
protectedinherited

Definition at line 167 of file JDAQCHSM.hh.

◆ TIMEOUT_S

const int KM3NETDAQ::JDAQClient_t::TIMEOUT_S = 1
staticinherited

time out of update [s]

Definition at line 61 of file JDAQClient.hh.

◆ eventTable

JEventTable KM3NETDAQ::JDAQClient_t::eventTable
protectedinherited

event table

Definition at line 202 of file JDAQClient.hh.

◆ fullname

std::string KM3NETDAQ::JDAQClient_t::fullname
protectedinherited

Definition at line 204 of file JDAQClient.hh.

◆ unique_tag

JTag KM3NETDAQ::JDAQClient_t::unique_tag
protectedinherited

Definition at line 205 of file JDAQClient.hh.

◆ clock

JTimekeeper KM3NETDAQ::JDAQClient_t::clock
protectedinherited

central clock

Definition at line 206 of file JDAQClient.hh.

◆ event_number

int KM3NETDAQ::JDAQClient_t::event_number
protectedinherited

number of last event

Definition at line 207 of file JDAQClient.hh.


The documentation for this class was generated from the following file:
JDAQCHSM::actionStart
virtual void actionStart(int, const char *)
Definition: JDAQCHSM.hh:125
JLOGGER::JDebugStream
Level specific message streamers.
Definition: JMessageStream.hh:113
JLOGGER::JLogger
Interface for logging messages.
Definition: JLogger.hh:22
KM3NETDAQ::JDataFilter::hostname
std::string hostname
host name of data server
Definition: JDataFilter.cc:1192
JTRIGGER::JTriggerNB_t::JParameters::enabled
bool enabled
enabled status of trigger
Definition: JTriggerNB_t.hh:81
JLOGGER::JNoticeStream
Definition: JMessageStream.hh:116
KM3NETDAQ::JDataFilter::maxQueueSize
long long int maxQueueSize
Definition: JDataFilter.cc:1265
JLOGGER::JMessageLogger
Message logger.
Definition: JMessageLogger.hh:53
KM3NETDAQ::RC_FAIL
static const JNET::JTag RC_FAIL
Definition: JDAQTags.hh:46
JEEP::JTimer::usec_scpu
unsigned long long usec_scpu
Definition: JTimer.hh:226
KM3NETDAQ::JDataFilter::path
std::string path
directory for writing circular buffer
Definition: JDataFilter.cc:1290
KM3NETDAQ::JDataFilter::parameters
JTriggerParameters parameters
Definition: JDataFilter.cc:1237
KM3NETDAQ::TOKEN_DELIMETER
static const std::string TOKEN_DELIMETER
Definition: JDAQTags.hh:36
KM3NETDAQ::JDataFilter::channelList
JChannelList_t channelList
connections to data queue
Definition: JDataFilter.cc:1224
KM3NETDAQ::JDataFilter::number_of_reads
long long int number_of_reads
Definition: JDataFilter.cc:1284
JTRIGGER::JTriggerParameters::numberOfBins
int numberOfBins
number of bins for lookup table of timeslice
Definition: JTriggerParameters.hh:324
KM3NETDAQ::JDAQClient::setSelect
void setSelect()
Set the file descriptor mask for the select call.
Definition: JDAQClient.hh:559
JDAQCHSM::actionEnter
virtual void actionEnter()
Interface methods for actions corresponding to state transitions.
Definition: JDAQCHSM.hh:120
JTRIGGER::JPrescaler::prescale
long long int prescale
Definition: JPrescaler.hh:96
KM3NETDAQ::JDataFilter::maximum_frames_per_slice
unsigned int maximum_frames_per_slice
Definition: JDataFilter.cc:1232
KM3NETDAQ::JDAQClient::getState
const CHSM::state * getState() const
Get current state.
Definition: JDAQClient.hh:1010
KM3NETDAQ::JDataFilter::JCircularBuffer_t::sizeL2
Long64_t sizeL2
Number of L2 time slices.
Definition: JDataFilter.cc:258
JEEP::JTimer::reset
void reset()
Reset timer.
Definition: JTimer.hh:76
JDAQCHSM::actionContinue
virtual void actionContinue(int, const char *)
Definition: JDAQCHSM.hh:127
JDETECTOR::getMaximalDistance
double getMaximalDistance(const JDetector &detector)
Get maximal distance between modules in detector.
Definition: JDetectorToolkit.hh:76
JLANG::JPointer::get
virtual JClass_t * get() const
Get pointer.
Definition: JPointer.hh:64
JEEP::JArgs
Data structure to store command line arguments.
Definition: JArgs.hh:24
KM3NETDAQ::JDataFilter::JSuperFrame1D_t
JSuperFrame1D< hit_type > JSuperFrame1D_t
Definition: JDataFilter.cc:154
JDAQCHSM::execute
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
KM3NETDAQ::JDataFilter::JCircularBuffer_t::open
void open(const std::string &path, const JTag &tag)
Open file.
Definition: JDataFilter.cc:182
KM3NETDAQ::JDataFilter::numberOfBytes
long long int numberOfBytes
Definition: JDataFilter.cc:1273
JDAQStateMachine::A5
void A5(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:352
JAANET::getTimeRange
JTimeRange getTimeRange(const Evt &event)
Get time range (i.e.
Definition: JAAnetToolkit.hh:134
JTRIGGER::JTriggerNB_t::JParameters::pmts
JPMTSelector pmts
PMT selection.
Definition: JTriggerNB_t.hh:82
KM3NETDAQ::JDAQClient::enterState
virtual void enterState(const CHSM::state &state, const CHSM::event &event)
Action when entering state.
Definition: JDAQClient.hh:949
KM3NETDAQ::JDataFilter::maximal_frame_index
int maximal_frame_index
Definition: JDataFilter.cc:1233
JDAQCHSM::actionRecover
virtual void actionRecover(int, const char *)
Definition: JDAQCHSM.hh:136
JDAQCHSM::actionReset
virtual void actionReset(int, const char *)
Definition: JDAQCHSM.hh:129
JDAQCHSM::getRunNumber
int getRunNumber() const
Get run number.
Definition: JDAQCHSM.hh:111
KM3NETDAQ::JDataFilter::timesliceRouter
JSinglePointer< JTimesliceRouter > timesliceRouter
Definition: JDataFilter.cc:1238
JTRIGGER::JTriggerParameters::set
void set(const double DMax_m=0.0)
Set dependent trigger parameters.
Definition: JTriggerParameters.hh:141
KM3NETDAQ::JDataFilter::c_buffer
JCircularBuffer_t c_buffer
Definition: JDataFilter.cc:1289
KM3NETDAQ::JDataFilter::meta
JMeta meta
meta data
Definition: JDataFilter.cc:1184
KM3NETDAQ::JDataFilter::trigger3DShower
JSinglePointer< JTrigger3DShower > trigger3DShower
Definition: JDataFilter.cc:1248
JNET::JPrefix
ControlHost prefix.
Definition: JPrefix.hh:31
KM3NETDAQ::JDAQClient::parser
JParser parser
parser method enter()
Definition: JDAQClient.hh:1027
JEEP::JTimekeeper::wait
void wait() const
Wait until the number of time intervals has elapsed since the last call to the reset method.
Definition: JTimekeeper.hh:145
JTRIGGER::JTriggerParameters::TMaxLocal_ns
double TMaxLocal_ns
maximal time difference between L0 hits for L1
Definition: JTriggerParameters.hh:322
KM3NETDAQ::JDAQClient_t::TIMEOUT_S
static const int TIMEOUT_S
time out of update [s]
Definition: JDAQClient.hh:61
JLOGGER::JMessageScheduler::reset
void reset()
Reset.
Definition: JMessageScheduler.hh:94
JDAQStateMachine::A3
void A3(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:348
JLOGGER::JErrorStream
Definition: JMessageStream.hh:115
KM3NETDAQ::JDataFilter::triggerNB
JSinglePointer< JTriggerNB > triggerNB
Definition: JDataFilter.cc:1246
KM3NETDAQ::JDataFilter::numberOfEvents
long long int numberOfEvents
Definition: JDataFilter.cc:1272
JDAQStateMachine::ev_check
JDAQStateMachine::ev_check_event ev_check
JNET::JSelectReader::getReaderMask
JFileDescriptorMask & getReaderMask()
Get reader mask.
Definition: JSelectReader.hh:46
JEEP::JTimer::start
void start()
Start timer.
Definition: JTimer.hh:89
KM3NETDAQ::JDataFilter::logErrorRun
JMessageScheduler logErrorRun
Definition: JDataFilter.cc:1251
JTRIGGER::JTriggerParameters::triggerNB
JTriggerNB_t::JParameters triggerNB
Definition: JTriggerParameters.hh:314
JEEP::JTimer::usec_wall
unsigned long long usec_wall
Definition: JTimer.hh:224
KM3NETDAQ::JDataFilter::number_of_packets_discarded
long long int number_of_packets_discarded
Definition: JDataFilter.cc:1283
JTRIGGER::JTriggerParameters::TMaxEvent_ns
double TMaxEvent_ns
maximal time before and after event for snapshot
Definition: JTriggerParameters.hh:323
KM3NETDAQ::JDataFilter::minFrameNumber
int minFrameNumber
Definition: JDataFilter.cc:1277
KM3NETDAQ::JDataFilter::JBuildL1_t
JBuildL1< hit_type > JBuildL1_t
Definition: JDataFilter.cc:157
KM3NETDAQ::JDAQClient::run
void run()
Run as run control client following command messages via JNET::JControlHost.
Definition: JDAQClient.hh:661
JTOOLS::GIGABYTE
static const long long int GIGABYTE
Number of bytes in a megabyte.
Definition: JConstants.hh:81
JDAQStateMachine::ev_daq_event::param_block::length
int length
Definition: JDAQCHSM.hh:222
KM3NETDAQ::RC_REPLY
static const JNET::JTag RC_REPLY
Definition: JDAQTags.hh:45
JTRIGGER::JTriggerParameters::triggerMXShower
JTriggerMXShower_t::JParameters triggerMXShower
Definition: JTriggerParameters.hh:312
JNET::JTag::getTag
const JTag & getTag() const
Get tag.
Definition: JTag.hh:82
std::vector
Definition: JSTDTypes.hh:12
JTOOLS::JQuantile::getDeviation
double getDeviation(const bool relative=true) const
Get maximal deviation from average.
Definition: JQuantile.hh:260
KM3NETDAQ::JDataFilter::port
int port
server socket port
Definition: JDataFilter.cc:1219
KM3NETDAQ::JDAQChronometer::getFrameIndex
int getFrameIndex() const
Get frame index.
Definition: JDAQChronometer.hh:132
event
Structure to store the ToT mean and standard deviation of the hits produced by a nanobeacon in a sour...
Definition: JVoltageOptimizer_utils.hh:26
JTRIGGER::JSuperFrame2D::demultiplex
static JSuperFrame2D< JElement_t, JAllocator_t > demultiplex
Demultiplexer.
Definition: JSuperFrame2D.hh:161
JDAQCHSM::getName
const std::string & getName() const
Get name of state machine.
Definition: JDAQCHSM.hh:89
KM3NETDAQ::JDataFilter::timeslices
std::list< JDAQTimesliceL0 > timeslices
buffer with pending time slice data
Definition: JDataFilter.cc:1229
JLANG::null
static JNullStream null
Null I/O stream.
Definition: JNullStream.hh:51
JLANG::JAccessible::is_open
virtual bool is_open() const =0
Check is device is open.
KM3NETDAQ::JDAQTimeslice
Data time slice.
Definition: JDAQTimeslice.hh:36
KM3NETDAQ::JDataFilter::JCircularBuffer_t::disable
void disable()
Disable writing.
Definition: JDataFilter.cc:213
KM3NETDAQ::JDataFilter::buildL1
JSinglePointer< JBuildL1_t > buildL1
Definition: JDataFilter.cc:1242
KM3NETDAQ::JDataFilter::timer
JTimer timer
Definition: JDataFilter.cc:1226
JLOGGER::JMessageLogger::getLevel
JLevel_t getLevel()
Get debug level.
Definition: JMessageLogger.hh:117
JDAQStateMachine::state_Main::state_RunControl::Error
JDAQState Error
Definition: JDAQCHSM.hh:202
KM3NETDAQ::JDataFilter::trigger3DMuon
JSinglePointer< JTrigger3DMuon > trigger3DMuon
Definition: JDataFilter.cc:1247
JDAQStateMachine::A6
void A6(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:354
KM3NETDAQ::JDAQClient_t::eventTable
JEventTable eventTable
event table
Definition: JDAQClient.hh:202
KM3NETDAQ::JDAQTimeslice::getSize
virtual int getSize() const
Get size of object.
Definition: JDAQTimeslice.hh:260
KM3NETDAQ::JDAQClient::server
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
KM3NETDAQ::JDataFilter::reporting
bool reporting
Definition: JDataFilter.cc:1270
KM3NETDAQ::JDataFilter::JCircularBuffer_t::sizeL1
Long64_t sizeL1
Number of L1 time slices.
Definition: JDataFilter.cc:257
JTRIGGER::JTriggerParameters::trigger3DShower
JTrigger3DShower_t::JParameters trigger3DShower
Definition: JTriggerParameters.hh:311
JNET::JSelectReader::reset
void reset()
Reset.
Definition: JSelectReader.hh:78
JROOT::putObject
bool putObject(TDirectory *dir, const T &object)
Write object to ROOT directory.
Definition: JRootFileWriter.hh:38
KM3NETDAQ::JEventTable::find
const_iterator find(const JTag &tag, const std::string &event_name) const
Find entry.
Definition: JEventTable.hh:116
KM3NETDAQ::JDataFilter::backlog
int backlog
Definition: JDataFilter.cc:1220
KM3NETDAQ::JDAQClient::filter
virtual bool filter(const JTag &tag, int length, const char *buffer)
Filter message.
Definition: JDAQClient.hh:633
JLOGGER::JMessageLogger::setLevel
void setLevel(const int __level)
Set debug level.
Definition: JMessageLogger.hh:128
KM3NETDAQ::JDAQClient::select
JSelectReader select
select call
Definition: JDAQClient.hh:1026
JTRIGGER::JTriggerParameters::L2
JL2Parameters L2
L2 processing.
Definition: JTriggerParameters.hh:327
KM3NETDAQ::JDataFilter::buildL2
JSinglePointer< JBuildL2_t > buildL2
Definition: JDataFilter.cc:1243
KM3NETDAQ::JDAQClient::actionRunning
virtual void actionRunning()
This method is repeatedly called when this client machine is in state Running and the clock interval ...
Definition: JDAQClient.hh:596
JLOGGER::JMessageLogger::error
void error(const JMessage_t &message)
Definition: JMessageLogger.hh:184
JEEP::JTimekeeper::reset
void reset(const long long int t0)
Reset time.
Definition: JTimekeeper.hh:100
JTRIGGER::JTriggerNB_t::JParameters::DMax_m
double DMax_m
maximal distance between PMTs [m]
Definition: JTriggerNB_t.hh:83
KM3NETDAQ::getFrameTime
double getFrameTime()
Get frame time duration.
Definition: JDAQClock.hh:162
JROOT::JRootFile::getFile
TFile * getFile() const
Get file.
Definition: JRootFile.hh:65
JPP
This name space includes all other name spaces (except KM3NETDAQ, KM3NET and ANTARES).
Definition: JAAnetToolkit.hh:37
JDAQStateMachine::state_Main::state_RunControl::state_Operational::Running
JDAQState Running
Definition: JDAQCHSM.hh:196
KM3NETDAQ::JEvent_t::toValue
static JEvent_t toValue(const std::string &buffer)
Convert string to event.
Definition: JRuncontrolToolkit.hh:116
KM3NETDAQ::JDAQClient::replaceEvent
void replaceEvent(const JTag &oldTag, const JTag &newTag, JDAQEvent_t &event)
Replace tag of given event in event table.
Definition: JDAQClient.hh:492
KM3NETDAQ::JDataFilter::buffer_size
int buffer_size
Definition: JDataFilter.cc:1221
JDAQStateMachine::A8
void A8(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:366
JDAQStateMachine::ev_start
JDAQStateMachine::ev_start_event ev_start
KM3NETDAQ::JDataFilter::JTimeslice_t
JTimeslice< hit_type > JTimeslice_t
Definition: JDataFilter.cc:156
JTRIGGER::JTriggerParameters::writeL2
JPrescaler writeL2
write JDAQTimeslice with L2 data
Definition: JTriggerParameters.hh:334
KM3NETDAQ::JDataFilter::JCircularBuffer_t::is_enabled
bool is_enabled() const
Check whether writing of data is enabled.
Definition: JDataFilter.cc:226
JDAQCHSM::actionPause
virtual void actionPause(int, const char *)
Definition: JDAQCHSM.hh:126
JTOOLS::JQuantile::put
void put(const double x, const double w=1.0)
Put value.
Definition: JQuantile.hh:123
KM3NETDAQ::JDataFilter::JCircularBuffer_t::sizeSN
Long64_t sizeSN
Number of SN time slices.
Definition: JDataFilter.cc:259
KM3NETDAQ::JDataFilter::datawriter
JSinglePointer< JControlHost_t > datawriter
controlhost of data server (to which data writer should be connected)
Definition: JDataFilter.cc:1191
debug
int debug
debug level
Definition: JSirene.cc:59
KM3NETDAQ::getTriggerMask
JTriggerMask_t getTriggerMask(const unsigned int bit)
Convert trigger bit to trigger mask.
Definition: JDAQTriggerMask.hh:40
KM3NETDAQ::JDataFilter::logErrorIncomplete
JMessageScheduler logErrorIncomplete
Definition: JDataFilter.cc:1254
KM3NETDAQ::JDataFilter::moduleRouter
JSinglePointer< JModuleRouter > moduleRouter
Definition: JDataFilter.cc:1241
KM3NETDAQ::JDAQClient_t::fullname
std::string fullname
Definition: JDAQClient.hh:204
JROOT::JTreeWriterObjectOutput::put
virtual bool put(const T &object)
Object output.
Definition: JTreeWriterObjectOutput.hh:88
JDAQStateMachine::A2
void A2(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:346
KM3NETDAQ::JDAQClient::actionTagged
virtual void actionTagged(const JTag &tag, int length, const char *buffer)
This method is called when a custom tag is encountered.
Definition: JDAQClient.hh:646
JDAQCHSM::detector_id
int detector_id
Definition: JDAQCHSM.hh:166
JNET::JSelectReader::hasReaderMask
bool hasReaderMask(const JAbstractFile &file) const
Has reader file.
Definition: JSelectReader.hh:69
KM3NETDAQ::JDataFilter::dataFilters
std::vector< JDAQProcess > dataFilters
Definition: JDataFilter.cc:1258
KM3NETDAQ::JDataFilter::serversocket
JSinglePointer< JServerSocket > serversocket
server for data queue connections
Definition: JDataFilter.cc:1223
KM3NETDAQ::JDataFilter::maxQueueDepth
unsigned int maxQueueDepth
Definition: JDataFilter.cc:1264
JSYSTEM::getLocalTime
static const JLocalTime getLocalTime
Function object to get local time in micro seconds.
Definition: JSystem/JTime.hh:61
JLOGGER::JWarningStream
Definition: JMessageStream.hh:114
KM3NETDAQ::JDataFilter::JControlHost_t
JControlHostObjectOutput< JDAQTypes_t > JControlHost_t
Definition: JDataFilter.cc:1190
KM3NETDAQ::JDAQTimesliceL0
Timeslice data structure for L0 data.
Definition: JDAQTimeslice.hh:313
JLOGGER::JStatusStream
Definition: JMessageStream.hh:117
KM3NETDAQ::JDAQClient_t::hostname
std::string hostname
Definition: JDAQClient.hh:203
JLOGGER::JStreamLogger
Message logging based on std::ostream.
Definition: JStreamLogger.hh:22
KM3NETDAQ::JDAQSummaryslice
Data summary slice.
Definition: JDAQSummaryslice.hh:31
KM3NETDAQ::JDAQClient::exit
virtual bool exit()
Exit the state machine.
Definition: JDAQClient.hh:456
JDAQStateMachine::A12
void A12(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:374
JEEP::JTimekeeper::setInterval
void setInterval(const long long int interval_us)
Set interval time.
Definition: JTimekeeper.hh:89
KM3NETDAQ::JDAQClient::enter
virtual bool enter()
Enter the state machine.
Definition: JDAQClient.hh:418
KM3NETDAQ::JDataFilter::Qt
JQuantile Qt
Definition: JDataFilter.cc:1227
JNET::JSubscriptionList::add
JSubscriptionList & add(const JSubscription &subscription)
Add subscription.
Definition: JControlHost.hh:174
KM3NETDAQ::JDataFilter::maxFrameNumber
int maxFrameNumber
Definition: JDataFilter.cc:1278
KM3NETDAQ::JDAQSuperFrameHeader
DAQ super frame header.
Definition: JDAQSuperFrameHeader.hh:25
JDAQCHSM::actionConfigure
virtual void actionConfigure(int, const char *)
Definition: JDAQCHSM.hh:124
JEEP::JTimer::usec_ucpu
unsigned long long usec_ucpu
Definition: JTimer.hh:225
KM3NETDAQ::JDAQClient::isRunning
bool isRunning() const
Check if this client is in runnig state.
Definition: JDAQClient.hh:479
KM3NETDAQ::JDAQClient::update
void update()
Update state machine.
Definition: JDAQClient.hh:808
KM3NETDAQ::JDataFilter::logErrorDetector
JMessageScheduler logErrorDetector
Definition: JDataFilter.cc:1252
JLOGGER::JMessageLogger::is_valid
bool is_valid() const
Check validity of logger object.
Definition: JMessageLogger.hh:161
JDAQCHSM::actionQuit
virtual void actionQuit(int, const char *)
Definition: JDAQCHSM.hh:130
KM3NETDAQ::RC_ALERT
static const JNET::JTag RC_ALERT
Definition: JDAQTags.hh:57
JSYSTEM::localtime_t
long long int localtime_t
Type definition of local time.
Definition: JSystem/JTime.hh:21
KM3NETDAQ::JDataFilter::detector
JDetector detector
Definition: JDataFilter.cc:1240
JDAQStateMachine::A14
void A14(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:378
JTOOLS::JQuantile::getMean
double getMean() const
Get mean value.
Definition: JQuantile.hh:217
KM3NETDAQ::JDAQClient_t::unique_tag
JTag unique_tag
Definition: JDAQClient.hh:205
JTRIGGER::checksum
static const JChecksum checksum
Function object to perform check-sum of raw data.
Definition: JChecksum.hh:161
JLOGGER::JControlHostLogger
Message logging based on ControlHost.
Definition: JControlHostLogger.hh:26
JTRIGGER::JTrigger3DMuon_t::JParameters::enabled
bool enabled
enabled status of trigger
Definition: JTrigger3DMuon_t.hh:113
KM3NETDAQ::JEventTable::replace
void replace(const JTag &oldTag, const JTag &newTag, JDAQEvent_t &event)
Replace entry in table.
Definition: JEventTable.hh:96
JLOGGER::JMessageLogger::reset
void reset(JLogger *__logger=NULL)
Reset logger.
Definition: JMessageLogger.hh:106
JDAQStateMachine::state_Main::RunControl
JDAQStateMachine::state_Main::state_RunControl RunControl
JDAQStateMachine::A4
void A4(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:350
KM3NETDAQ::JDataFilter::frames_per_slice
unsigned int frames_per_slice
Definition: JDataFilter.cc:1231
JDAQStateMachine::ev_error
JDAQStateMachine::ev_error_event ev_error
KM3NETDAQ::JDAQClient_t::getUniqueTag
const JTag & getUniqueTag() const
Get unique tag of this run control client.
Definition: JDAQClient.hh:130
JDAQStateMachine::ev_daq_event
Definition: JDAQCHSM.hh:217
JTRIGGER::JTriggerParameters::SN
JL2Parameters SN
Supernova trigger.
Definition: JTriggerParameters.hh:328
KM3NETDAQ::IO_TRIGGER_PARAMETERS
static const JNET::JTag IO_TRIGGER_PARAMETERS
Definition: JDAQTags.hh:68
KM3NETDAQ::JDAQClient::subscription
JSubscriptionList subscription
custom subscription
Definition: JDAQClient.hh:1028
KM3NETDAQ::JDAQClient::logger
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
KM3NETDAQ::JDataFilter::number_of_bytes_received
long long int number_of_bytes_received
Definition: JDataFilter.cc:1285
KM3NETDAQ::JDAQChronometer::getRunNumber
int getRunNumber() const
Get run number.
Definition: JDAQChronometer.hh:121
KM3NETDAQ::JDataFilter::number_of_packets_received
long long int number_of_packets_received
Definition: JDataFilter.cc:1282
JDAQStateMachine::state_Main::state_RunControl::Operational
JDAQStateMachine::state_Main::state_RunControl::state_Operational Operational
JLANG::JEquationParameters
Simple data structure to support I/O of equations (see class JLANG::JEquation).
Definition: JEquationParameters.hh:20
JDAQCHSM::actionCheck
virtual void actionCheck(int, const char *)
Definition: JDAQCHSM.hh:132
JTRIGGER::JTriggerParameters::writeSummary
JPrescaler writeSummary
write JDAQSummaryslice
Definition: JTriggerParameters.hh:331
KM3NETDAQ::JDataFilter::processIndexSorter
static bool processIndexSorter(const JDAQProcess &first, const JDAQProcess &second)
Sort DAQ process by index.
Definition: JDataFilter.cc:270
JTRIGGER::JTriggerParameters::highRateVeto_Hz
double highRateVeto_Hz
high-rate veto [Hz]
Definition: JTriggerParameters.hh:319
JDAQStateMachine::A1
void A1(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:344
make_field
#define make_field(A,...)
macro to convert parameter to JParserTemplateElement object
Definition: JParser.hh:1954
JEEP::JTimekeeper::getInterval
long long int getInterval() const
Get interval time.
Definition: JTimekeeper.hh:67
KM3NETDAQ::JDataFilter::current_slice_index
int current_slice_index
Definition: JDataFilter.cc:1230
KM3NETDAQ::JDataFilter::processTimeSlice
void processTimeSlice(const JDAQTimesliceL0 &timeslice)
Process time slice.
Definition: JDataFilter.cc:904
KM3NETDAQ::JDAQClient_t::getFullName
const std::string & getFullName() const
Get full name of this run control client.
Definition: JDAQClient.hh:119
JDAQCHSM::actionError
virtual void actionError()
Definition: JDAQCHSM.hh:135
JNET::JSelectReader::setReaderMask
void setReaderMask(const JAbstractFile &file)
Set reader mask.
Definition: JSelectReader.hh:57
KM3NETDAQ::JDataFilter::JCircularBuffer_t::sizeL0
Long64_t sizeL0
Number of L0 time slices.
Definition: JDataFilter.cc:256
JTOOLS::JQuantile::reset
void reset()
Reset.
Definition: JQuantile.hh:104
JEEP::JProperties
Utility class to parse parameter values.
Definition: JProperties.hh:496
JDAQStateMachine::ev_configure
JDAQStateMachine::ev_configure_event ev_configure
KM3NETDAQ::getStateName
std::string getStateName(const std::string &name)
Get name of state.
Definition: JRuncontrolToolkit.hh:591
JNET::JControlHostObjectOutput::put
virtual bool put(const T &object)
Object output.
Definition: JControlHostObjectOutput.hh:89
KM3NETDAQ::JDAQChronometer::getDAQChronometer
const JDAQChronometer & getDAQChronometer() const
Get DAQ chronometer.
Definition: JDAQChronometer.hh:88
JTRIGGER::JTriggerMXShower_t::JParameters::enabled
bool enabled
enabled status of trigger
Definition: JTriggerMXShower_t.hh:103
KM3NETDAQ::JDataFilter::typeout
void typeout()
Report status to message logger.
Definition: JDataFilter.cc:1093
std
Definition: jaanetDictionary.h:36
KM3NETDAQ::JDataFilter::put
bool put(const T &object)
Auxiliary method to send object to data server.
Definition: JDataFilter.cc:1201
KM3NETDAQ::getSubscription
JSubscriptionList getSubscription(const JEventTable &event_table)
Convert event table to ControlHost subscription.
Definition: JEventTable.hh:129
JDAQStateMachine::ev_daq_event::param_block::buffer
const char * buffer
Definition: JDAQCHSM.hh:224
JDAQStateMachine::A13
void A13(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:376
KM3NETDAQ::JDataFilter::numberOfIncompleteTimeslicesProcessed
long long int numberOfIncompleteTimeslicesProcessed
Definition: JDataFilter.cc:1275
JTRIGGER::JTriggerParameters::writeSN
JPrescaler writeSN
write JDAQTimeslice with SN data
Definition: JTriggerParameters.hh:335
JDAQStateMachine::A7
void A7(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:364
KM3NETDAQ::JDAQClient::getMessage
std::string getMessage(const CHSM::state &state, const CHSM::event &event) const
Get event message.
Definition: JDAQClient.hh:928
KM3NETDAQ::JDAQSuperFrame
Data frame of one optical module.
Definition: JDAQSuperFrame.hh:27
KM3NETDAQ::RC_CMD
static const JNET::JTag RC_CMD
Definition: JDAQTags.hh:44
JEEP::JTimer::stop
void stop()
Stop timer.
Definition: JTimer.hh:113
JDAQCHSM::actionStop
virtual void actionStop(int, const char *)
Definition: JDAQCHSM.hh:128
JDAQCHSM::actionExit
virtual void actionExit()
Definition: JDAQCHSM.hh:121
JTRIGGER::JTriggerParameters::trigger3DMuon
JTrigger3DMuon_t::JParameters trigger3DMuon
Definition: JTriggerParameters.hh:313
JTRIGGER::JSuperFrame2D::iterator
std::vector< value_type >::iterator iterator
Definition: JSuperFrame2D.hh:50
KM3NETDAQ::JDataFilter::JBuildL2_t
JBuildL2< hit_type > JBuildL2_t
Definition: JDataFilter.cc:158
KM3NETDAQ::JDAQClient_t::setClockInterval
void setClockInterval(const long long int interval_us)
Set interval time.
Definition: JDAQClient.hh:164
KM3NETDAQ::JDAQClient_t::event_number
int event_number
number of last event
Definition: JDAQClient.hh:207
JSYSTEM::getRAM
unsigned long long int getRAM()
Get RAM of this CPU.
Definition: JSystemToolkit.hh:254
JDAQCHSM::run_number
int run_number
Definition: JDAQCHSM.hh:167
JDAQStateMachine::Main
JDAQStateMachine::state_Main Main
JTRIGGER::JTriggerParameters::writeL1
JPrescaler writeL1
write JDAQTimeslice with L1 data
Definition: JTriggerParameters.hh:333
KM3NETDAQ::getTokenDelimeter
char getTokenDelimeter()
Get the token delimeter for command messages.
Definition: JRuncontrolToolkit.hh:56
JNET::JTag::toString
std::string toString() const
Convert tag to string.
Definition: JTag.hh:167
KM3NETDAQ::JDAQClient::JDAQClient
JDAQClient(const std::string &name, const std::string &server, JLogger *logger, const int level)
Constructor.
Definition: JDAQClient.hh:290
KM3NETDAQ::JDataFilter::buildSN
JSinglePointer< JBuildL2_t > buildSN
Definition: JDataFilter.cc:1244
KM3NETDAQ::JDataFilter::logErrorIndex
JMessageScheduler logErrorIndex
Definition: JDataFilter.cc:1253
KM3NETDAQ::JDataFilter::triggerMXShower
JSinglePointer< JTriggerMXShower > triggerMXShower
Definition: JDataFilter.cc:1249
JTRIGGER::JTriggerParameters::reset
void reset()
Reset trigger parameters.
Definition: JTriggerParameters.hh:164
std::list
Definition: JSTDTypes.hh:24
JDAQCHSM::actionInit
virtual void actionInit(int, const char *)
Definition: JDAQCHSM.hh:123
JTRIGGER::JTriggerParameters::writeL0
JPrescaler writeL0
write JDAQTimeslice with L0 data
Definition: JTriggerParameters.hh:332
KM3NETDAQ::JDataFilter::dataQueues
std::vector< JDAQProcess > dataQueues
Definition: JDataFilter.cc:1259
JLANG::trim
std::string trim(const std::string &buffer)
Trim string.
Definition: JLangToolkit.hh:79
JLANG::JStorage::reset
virtual void reset()
Reset pointer.
Definition: JStorage.hh:42
KM3NETDAQ::JDAQProcess::index
std::string index
index in process list
Definition: JRuncontrolToolkit.hh:580
JSUPPORT::JTreeRecorder::close
virtual void close()
Close file.
Definition: JTreeRecorder.hh:70
JNET::JPrefix::getSize
int getSize() const
Get size.
Definition: JPrefix.hh:62
KM3NETDAQ::JDAQClient_t::getClockInterval
long long int getClockInterval() const
Get interval time.
Definition: JDAQClient.hh:153
JDAQCHSM::actionInput
virtual void actionInput(int, const char *)
Definition: JDAQCHSM.hh:133
KM3NETDAQ::JDataFilter::updateFrameQueue
void updateFrameQueue(const JChannelList_t::const_iterator channel)
Update queue with data frames.
Definition: JDataFilter.cc:809
JLANG::getline
std::istream & getline(std::istream &in, JString &object)
Read string from input stream until end of line.
Definition: JString.hh:468
JSYSTEM::getListOfIPaddresses
std::vector< std::string > getListOfIPaddresses()
Get list of IP address (decimal-dot notation).
Definition: JNetwork.hh:216
KM3NETDAQ::JDAQTriggerCounter::reset
static void reset()
Reset counter of unique instance of this class object.
Definition: JDAQTriggerCounter.hh:87
JDAQStateMachine::A11
void A11(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:372
JTRIGGER::JL2Parameters::TMaxLocal_ns
double TMaxLocal_ns
maximal time difference [ns]
Definition: JTriggerParameters.hh:108
JEEP::JTimekeeper::getDelay
long long int getDelay() const
Get total delay time.
Definition: JTimekeeper.hh:78
KM3NETDAQ::JDataFilter::JSuperFrame2D_t
JSuperFrame2D< hit_type > JSuperFrame2D_t
Definition: JDataFilter.cc:155
KM3NETDAQ::RC_DFILTER
static const JNET::JTag RC_DFILTER
Definition: JDAQTags.hh:51
JDAQStateMachine::A10
void A10(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:370
KM3NETDAQ::JDAQClient_t::clock
JTimekeeper clock
central clock
Definition: JDAQClient.hh:206
KM3NETDAQ::JDataFilter::JSocketInputChannel_t
JSocketInputChannel< JDAQAbstractPreamble > JSocketInputChannel_t
Definition: JDataFilter.cc:150
KM3NETDAQ::JDataFilter::queueSize
long long int queueSize
Definition: JDataFilter.cc:1266
JDAQCHSM::name
std::string name
Definition: JDAQCHSM.hh:165
KM3NETDAQ::JDataFilter::numberOfTimeslicesProcessed
long long int numberOfTimeslicesProcessed
Definition: JDataFilter.cc:1274
KM3NETDAQ::JDAQPreamble
DAQ preamble.
Definition: JDAQPreamble.hh:39
KM3NETDAQ::JDAQClient::actionSelect
virtual void actionSelect(const JFileDescriptorMask &mask)
Action method following last select call.
Definition: JDAQClient.hh:585
JTRIGGER::JTrigger3DShower_t::JParameters::enabled
bool enabled
enabled status of trigger
Definition: JTrigger3DShower_t.hh:102
JPARSER::JParser::read
int read(const int argc, const char *const argv[])
Parse the program's command line options.
Definition: JParser.hh:1791
JLANG::JAbstractPointer::is_valid
bool is_valid() const
Check validity of pointer.
Definition: JAbstractPointer.hh:83
KM3NETDAQ::JDAQClient_t::setEventNumber
void setEventNumber(const int event_number)
Set last event number.
Definition: JDAQClient.hh:195
KM3NETDAQ::JDAQClient::addSubscription
void addSubscription(const JSubscription &subscription)
Add custom subscription.
Definition: JDAQClient.hh:523
KM3NETDAQ::JDataFilter::totalCPURAM
long long int totalCPURAM
Definition: JDataFilter.cc:1263
JDAQStateMachine::A9
void A9(CHSM_ns_alias::event const &)
Definition: JDAQCHSM.cc:368