KM3NETDAQ::JDataWriter Class Reference

Runcontrol client to write data to disk. More...

Inheritance diagram for KM3NETDAQ::JDataWriter:

Classes
struct	JRunDB
	Map run number to trigger parameters. More...
struct	JValue_t
	Auxiliary data structure for I/O of trigger parameters. More...

Public Member Functions
	JDataWriter (const std::string &name, const std::string &server, const std::string &hostname, JLogger *logger, const int level, const std::string &path)
	Constructor. More...
virtual void	actionInit (int length, const char *buffer)
virtual void	actionConfigure (int length, const char *buffer)
virtual void	actionReset (int length, const char *buffer)
virtual void	actionQuit (int length, const char *buffer)
virtual void	actionStart (int length, const char *buffer)
virtual void	actionStop (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	typeout ()
	Report status of data writing. 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_t *	findEvent (const JTag &tag, const std::string &event_name)
	Find event in event table. More...
void	addSubscription (const JSubscription &subscription)
	Add custom subscription. More...
template<class T >
void	addParameter (const char option, T &parameter)
	Add parameter to parser used in method enter(). More...
template<class T >
void	addParameter (const char option, T &parameter, const T &value)
	Add parameter to parser used in method enter(). More...
void	setSelect ()
	Set the file descriptor mask for the select call. More...
virtual void	actionInput (int length, const char *buffer)
	This method is called at ev_input. More...
virtual bool	filter (const JTag &tag, int length, const char *buffer)
	Filter message. More...
virtual void	actionTagged (const JTag &tag, int length, const char *buffer)
	This method is called when a custom tag is encountered. 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	actionEnter ()
	Interface methods for actions corresponding to state transitions. More...
virtual void	actionExit ()
virtual void	actionPause (int, const char *)
virtual void	actionContinue (int, const char *)
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 JTag &	getUniqueTag () const
	Get unique tag of this run control client. More...
long long int	getClockDelay () const
	Get total delay time. More...
long long int	getClockInterval () const
	Get interval time. More...
void	setClockInterval (const long long int interval_us)
	Set interval time. More...
void	resetClock ()
	Reset clock. More...
int	getEventNumber () const
	Get last event number. More...
void	setEventNumber (const int event_number)
	Set last event number. 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< JControlHost >	server
	message server More...
JMessageLogger	logger
	message logger More...
std::string	name
int	detector_id
int	run_number
JEventTable	eventTable
	event table More...
std::string	fullname
JTag	unique_tag
JTimekeeper	clock
	central clock More...
int	event_number
	number of last event More...

Private Member Functions
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
JLANG::JSharedPointer< JControlHost >	datawriter
std::string	path
JEEP::JTimer	timer
Long64_t	numberOfEvents
long long int	numberOfBytes
JMessageScheduler	logErrorRun
JMessageScheduler	logErrorFile
JMessageScheduler	logErrorTag
JMessageScheduler	logErrorState
std::string	hostname
	host name of data server More...
JTreeWriter_t	writer
	TTree writer. More...
std::vector< char >	buffer
	internal buffer for incoming data More...
JRunDB	run_db
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

Runcontrol client to write data to disk.

In state running, this application will write ROOT formatted data from the data filters to disk.

Definition at line 61 of file JDataWriter.cc.

Member Typedef Documentation

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

JDataWriter()

KM3NETDAQ::JDataWriter::JDataWriter ( const std::string &  name, const std::string &  server, const std::string &  hostname, JLogger *  logger, const int  level, const std::string &  path  )

inline

Constructor.

Parameters

name	name of client
server	name of command message server
hostname	name of data server
logger	pointer to logger
level	debug level
path	default path

Definition at line 75 of file JDataWriter.cc.

                                       :
      JDAQClient(name, server, logger, level),
      datawriter(),
      path      (path),
      hostname  (hostname)
    {
      replaceEvent(RC_CMD, RC_DWRITER, ev_configure);
 
      JControlHost::Throw(true);
 
      // map ControlHost tag to TTree writer.
 
      writer.insert<JDAQTypes_t>();
    }

Member Function Documentation

actionInit()

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

inlinevirtual

Reimplemented from JDAQCHSM.

Definition at line 96 of file JDataWriter.cc.

    {
      using namespace std;
      using namespace JPP;
 
      // start server
 
      try {
 
        datawriter.reset(new JControlHost(hostname));
 
        JSubscriptionList buffer;
 
        for (JTreeWriter_t::iterator i = writer.begin(); i != writer.end(); ++i) {
          buffer.add(JSubscriptionAll(i->first));
        }
        
        buffer.add(JSubscriptionAll(IO_TRIGGER_PARAMETERS));
 
        datawriter->Subscribe(buffer);
        datawriter->SendMeAlways();
 
        JNoticeStream(logger) << "Established connection to " << hostname;
      }
      catch(const JControlHostException& exception) {
        JErrorStream(logger) << exception;
      }
    }

actionConfigure()

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

inlinevirtual

Reimplemented from JDAQCHSM.

Definition at line 126 of file JDataWriter.cc.

    {
      using namespace std;
 
      long long int update_s = 10;
      long long int logger_s =  5;
 
      JProperties properties(JEquationParameters("=", ";", "", ""));
 
      properties["path"]     = path;
      properties["update_s"] = update_s;
      properties["logger_s"] = logger_s;
      
      properties.read(string(buffer, length));
      
      if (update_s <=  0) { update_s = 1; }
      if (logger_s <=  0) { logger_s = 1; }
 
      setClockInterval(update_s * 1000000LL);
 
      JDebugStream(logger) << "Path <" << path << ">";
      JDebugStream(logger) << "Update period [s] " << update_s;
 
      logErrorRun   = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
      logErrorFile  = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
      logErrorTag   = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
      logErrorState = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
 
      numberOfEvents = 0;
      numberOfBytes  = 0;
    }

actionReset()

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

inlinevirtual

Reimplemented from JDAQCHSM.

Definition at line 159 of file JDataWriter.cc.

    {
      datawriter.reset();
    }

actionQuit()

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

inlinevirtual

Reimplemented from JDAQCHSM.

Definition at line 165 of file JDataWriter.cc.

    {}

actionStart()

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

inlinevirtual

Reimplemented from JDAQCHSM.

Definition at line 169 of file JDataWriter.cc.

    {
      using namespace std;
      using namespace JPP;
 
      JNoticeStream(logger) << string(buffer, length);
 
      ostringstream os;
 
      for (int i = 0; !writer.is_open() && i != MAXIMUM_FILE_NUMBER; ++i) {
 
        os.str("");
 
        os << getFullPath(path) 
           << "KM3NeT" 
           << "_"  << FILL(8,'0') << getDetectorID() 
           << "_"  << FILL(8,'0') << getRunNumber();
 
        if (i != 0) {
          os << "_" << i;
        }
 
        os << ".root";
 
        try {
          writer.open(os.str().c_str());
        }
        catch(JException& exception) {
          JErrorStream(logger) << exception;
        }
      }
 
      if (writer.is_open())
        JNoticeStream(logger) << "Output file "     << os.str();
      else
        JErrorStream (logger) << "File not opened " << os.str();
 
      numberOfEvents = 0;
      numberOfBytes  = 0;
 
      putObject(writer.getFile(), meta);
 
      timer.reset();
 
      logErrorRun  .reset();
      logErrorFile .reset();
      logErrorTag  .reset();
      logErrorState.reset();
 
      run_db.reset(getRunNumber());
    }

actionStop()

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

inlinevirtual

Reimplemented from JDAQCHSM.

Definition at line 222 of file JDataWriter.cc.

    {
      typeout();
 
      if (timer.usec_wall > 0) {
        JNoticeStream(logger) << "I/O "  << (int) (numberOfBytes / timer.usec_wall) << " MB/s";
      }
 
      if (!run_db.is_written(getRunNumber())) {
        JErrorStream(logger) << "No trigger parameters written for run " << getRunNumber();
      }
        
      writer.close();
 
      // Release resources.
      
      std::vector<char> null;
 
      this->buffer.swap(null);
    }

setSelect() [1/2]

virtual void KM3NETDAQ::JDataWriter::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

mask	file descriptor mask

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 244 of file JDataWriter.cc.

    {
      if (datawriter.is_valid()) {
        mask.set(*datawriter);
      }
    }

actionSelect()

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

inlinevirtual

Action method following last select call.

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

Parameters

mask	file descriptor mask

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 252 of file JDataWriter.cc.

    {
      using namespace std;
      using namespace JPP;
 
      if (datawriter.is_valid() && mask.has(*datawriter)) {
              
        try {
          
          JPrefix prefix;
          
          datawriter->WaitHead(prefix);
          
          timer.start();
          
          buffer.resize(prefix.getSize());
          
          datawriter->GetFullData(buffer.data(), buffer.size());
 
          
          if (prefix.getTag() == IO_TRIGGER_PARAMETERS) {
 
            const string __str__(buffer.data(), buffer.size());
            
            istringstream in(__str__);
 
            if (!run_db.read(in)) {
 
              JErrorStream(logger) << "Fatal error reading trigger parameters " << __str__;
 
              ev_error();
            }
          }
 
          
          if (isRunning()) {
 
            // Write trigger parameters for current run if not yet done
            
            run_db.write(getRunNumber(), writer.getFile());
 
            JTreeWriter_t::iterator i = writer.find(prefix.toString());
            
            if (i != writer.end()) {
              
              TFile* out = i->second->GetCurrentFile();
              
              if (out != NULL && out->IsOpen()) {
                
                JDAQPreamble preamble;
                JDAQHeader   header;
              
                JByteArrayReader in(buffer.data(), buffer.size());
                
                in >> preamble >> header;
                
                in.seekg(0);   // rewind
                
                if (header.getRunNumber() == getRunNumber()) {
                  
                  const Int_t nb = i->second->copy(in);
 
                  if (nb < (int) buffer.size() || in.tellg() != (int) buffer.size()) {
                    JWarningStream(logger) << "Inconsistency at copy of " 
                                           << prefix.toString() << ' ' 
                                           << buffer.size()     << ' ' 
                                           << in.tellg()        << ' ' 
                                           << nb;
                  }
 
                  if (prefix.getTag() == IO_EVENT)
                    numberOfEvents += 1;
                  numberOfBytes    += buffer.size();
                
                  if (prefix.getTag() == IO_EVENT && numberOfEvents == 1) {
                    typeout();
                  }
                  
                } else {
                  JErrorStream(logErrorRun) << "Inconsistent run number " 
                                            << header.getRunNumber() 
                                            << " != " 
                                            << getRunNumber();
                }
              } else {
                JErrorStream(logErrorFile) << "Output file not open";
              }
            } else {
              if (prefix.getTag() != IO_TRIGGER_PARAMETERS) {
                JErrorStream(logErrorTag) << "Unknown tag <" << prefix.toString() << ">, no data written";
              }
            }       
          } else {
            JWarningStream(logErrorState) << "Not in running state <" << prefix.toString() << ">, no data written";
          }
 
          timer.stop();
        }
        catch(const JControlHostException& exception) {
          JErrorStream(logger) << exception;
        }
      }
    }

actionRunning()

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

    {
      typeout();
    }

typeout()

void KM3NETDAQ::JDataWriter::typeout ( )

inline

Report status of data writing.

Definition at line 366 of file JDataWriter.cc.

    {
      std::ostringstream message;
 
      message << getFullName()  << KM3NETDAQ::getTokenDelimeter() << numberOfBytes  << ' ' << numberOfEvents;
      
      logger.typeout(RC_LOG, message.str());
      logger.status(message.str());
    }

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

args	array of command line arguments

Returns

true if okay; else false

Definition at line 363 of file JDAQClient.hh.

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

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.

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

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.

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

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.

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

replaceEvent()

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

inlineinherited

Replace tag of given event in event table.

Parameters

oldTag	old tag
newTag	new tag
event	event

Definition at line 492 of file JDAQClient.hh.

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

findEvent()

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

inlineinherited

Find event in event table.

Parameters

tag	tag
event_name	event name

Returns

pointer to event or NULL

Definition at line 507 of file JDAQClient.hh.

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

addSubscription()

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

inlineinherited

Add custom subscription.

Parameters

subscription

subscription

Definition at line 523 of file JDAQClient.hh.

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

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

option	option
parameter	parameter

Definition at line 536 of file JDAQClient.hh.

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

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

option	option
parameter	parameter
value	default value

Definition at line 550 of file JDAQClient.hh.

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

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.

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

actionInput()

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

inlinevirtualinherited

This method is called at ev_input.

Parameters

length	length of data
buffer	pointer to data

Reimplemented from JDAQCHSM.

Reimplemented in KM3NETDAQ::DataQueue, and AcousticDataFilter.

Definition at line 606 of file JDAQClient.hh.

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

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

tag	tag
length	number of characters
buffer	message

Returns

skip message or not

Definition at line 633 of file JDAQClient.hh.

    {
      return false;
    }

actionTagged()

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

inlinevirtualinherited

This method is called when a custom tag is encountered.

Parameters

tag	tag
length	length of data
buffer	pointer to data

Reimplemented in KM3NETDAQ::JDataFilter.

Definition at line 646 of file JDAQClient.hh.

    {
    }

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.

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

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

port	port number

Definition at line 741 of file JDAQClient.hh.

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

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

in	input stream

Definition at line 786 of file JDAQClient.hh.

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

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.

    {
      JNET::JPrefix prefix;
      
      server->WaitHead(prefix);
      
      const int length = prefix.getSize();
      
      char* buffer = new char[length];
      
      server->GetFullData(buffer, length);
      
      update(prefix.getTag(), length, buffer);
 
      delete [] buffer;
    }

update() [2/2]

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

inlineprivateinherited

Update state machine.

Parameters

tag	tag
length	number of characters
buffer	message

Definition at line 833 of file JDAQClient.hh.

    {
      using namespace std;
      using namespace JPP;
 
      if (filter(tag, length, buffer)) {
        return;
      }
 
      if (getSubscription(eventTable)->count(JSubscriptionAny(tag)) == 0 &&
          getSubscription(eventTable)->count(JSubscriptionAll(tag)) == 0) {
 
        actionTagged(tag, length, buffer);
 
        return;
      }
 
 
      string::size_type pos = 0;
 
      while (pos != (string::size_type) length && TOKEN_DELIMETER.find(*(buffer + pos)) == string::npos) {
        ++pos;
      }
 
      const JEvent_t event = JEvent_t::toValue(string(buffer, pos));
 
      setEventNumber(event.getNumber());
 
      while (pos != (string::size_type) length && TOKEN_DELIMETER.find(*(buffer + pos)) != string::npos) {
        ++pos;
      }
 
 
      JEventTable::const_iterator i = eventTable.find(tag, event.getName());
      
      if (i != eventTable.end()) {
 
        const CHSM::state* const s0 = getState();
 
        if (!i->second->active()) {
 
          JWarningStream(logger) << "Event " << i->second->name() << " not active (" << (s0 != NULL ? s0->name() : "") << ")";
 
          if (server.is_valid() && s0 != NULL) {
            server->PutFullString(RC_FAIL, getMessage(*s0, *i->second));
          }
        }
 
        // redirect all I/O
 
        {
          JDebugStream    debug(logger);
          JErrorStream    error(logger);
 
          JRedirectStream redirect[] = { JRedirectStream(cin,  JLANG::null),
                                         JRedirectStream(cout, debug), 
                                         JRedirectStream(cerr, error) };
 
          if (redirect[0] &&
              redirect[1] &&
              redirect[2]) {
 
            (*(i->second))(length - pos, buffer + pos);
          }
        }
 
        const CHSM::state* const s1 = getState();
 
        JStatusStream(logger) << "Transition " 
                              << (s0 != NULL ? s0->name() : "") 
                              << "->(" << i->second->name() << ")->" 
                              << (s1 != NULL ? s1->name() : "");
      } else {
 
        JErrorStream(logger) << "Unknown key <" << tag << "," << event.getName() << ">";
      }
    }

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.

    {
    }

getMessage()

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

inlineprivateinherited

Get event message.

Parameters

state	state
event	event

Returns

message

Definition at line 928 of file JDAQClient.hh.

    {
      std::ostringstream os;
      
      os << getFullName()
         << getTokenDelimeter() 
         << JEvent_t(event.name(), event_number)
         << getTokenDelimeter() 
         << getStateName(state.name());
 
      return os.str();
    }

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

state	entered state
event	event that triggered transition

Implements JDAQCHSM.

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 949 of file JDAQClient.hh.

    {
      if (server.is_valid()) {
        server->PutFullString(RC_REPLY, getMessage(state, event));
      }
    }

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

length	number of characters
buffer	message

Reimplemented from JDAQCHSM.

Definition at line 963 of file JDAQClient.hh.

    {
      if (Main.RunControl.Error.active()) {
 
        enterState(Main.RunControl.Error, ev_check);
 
      } else {
        
        for (CHSM::parent::iterator state = Main.RunControl.Operational.begin(); state != Main.RunControl.Operational.end(); ++state) {
 
          if (state->active()) {
 
            // mimic enter state
 
            enterState(*state, ev_check);
          }
        }
      }
    }

execute()

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

inlineprivatevirtualinherited

The method to execute the action.

Parameters

__action	pointer to action method
__event	event that triggered the action

Implements JDAQCHSM.

Definition at line 990 of file JDAQClient.hh.

    {
      try {
 
        const JDAQStateMachine::ev_daq_event& event = dynamic_cast<const JDAQStateMachine::ev_daq_event&>(__event);
 
        (this->*__action)(event->length, event->buffer);
      }
      catch(const std::exception& error) {
        JErrorStream(logger) << "Error at event " << __event.name() << " \"" << error.what() << "\"; trigger ev_error.";
        ev_error();
      }
    }

getState()

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

inlineprivateinherited

Get current state.

Returns

state

Definition at line 1010 of file JDAQClient.hh.

    {
      for (CHSM::parent::const_iterator state = Main.RunControl.Operational.begin(); state != Main.RunControl.Operational.end(); ++state) {
        if (state->active()) {
          return &(*state);
        }
      }
 
      if (Main.RunControl.Error.active()) {
        return &Main.RunControl.Error;
      }
 
      return NULL;
    }

A1()

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

inherited

Definition at line 344 of file JDAQCHSM.cc.

{ actionError(); }

A2()

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

inherited

Definition at line 346 of file JDAQCHSM.cc.

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

A3()

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

inherited

Definition at line 348 of file JDAQCHSM.cc.

{ JDAQCHSM::exit(); }

A4()

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

inherited

Definition at line 350 of file JDAQCHSM.cc.

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

A5()

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

inherited

Definition at line 352 of file JDAQCHSM.cc.

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

A6()

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

inherited

Definition at line 354 of file JDAQCHSM.cc.

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

A7()

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

inherited

Definition at line 364 of file JDAQCHSM.cc.

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

A8()

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

inherited

Definition at line 366 of file JDAQCHSM.cc.

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

A9()

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

inherited

Definition at line 368 of file JDAQCHSM.cc.

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

A10()

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

inherited

Definition at line 370 of file JDAQCHSM.cc.

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

A11()

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

inherited

Definition at line 372 of file JDAQCHSM.cc.

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

A12()

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

inherited

Definition at line 374 of file JDAQCHSM.cc.

{ JDAQCHSM::exit(); }

A13()

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

inherited

Definition at line 376 of file JDAQCHSM.cc.

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

A14()

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

inherited

Definition at line 378 of file JDAQCHSM.cc.

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

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.

                                                                                                        {
#line 164 "JDAQCHSM.chsm"
        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.

                                                                                                        {
#line 165 "JDAQCHSM.chsm"
        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.

  {
    return name;
  }

getDetectorID()

int JDAQCHSM::getDetectorID ( ) const

inlineinherited

Get detector identifier.

Returns

detector identifier.

Definition at line 100 of file JDAQCHSM.hh.

  { 
    return detector_id; 
  }

getRunNumber()

int JDAQCHSM::getRunNumber ( ) const

inlineinherited

Get run number.

Returns

run number

Definition at line 111 of file JDAQCHSM.hh.

  { 
    return run_number; 
  }

actionEnter()

virtual void JDAQCHSM::actionEnter ( )

inlinevirtualinherited

Interface methods for actions corresponding to state transitions.

Reimplemented in KM3NETDAQ::JDataFilter, KM3NETDAQ::DataQueue, JDAQDemoClient, AcousticDataFilter, and KM3NETDAQ::MonitorRouter.

Definition at line 120 of file JDAQCHSM.hh.

{}

actionExit()

virtual void JDAQCHSM::actionExit ( )

inlinevirtualinherited

Reimplemented in KM3NETDAQ::JDataFilter, KM3NETDAQ::JDAQDriver, KM3NETDAQ::DataQueue, JDAQDemoClient, AcousticDataFilter, and KM3NETDAQ::MonitorRouter.

Definition at line 121 of file JDAQCHSM.hh.

{}

actionPause()

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

inlinevirtualinherited

Reimplemented in KM3NETDAQ::JDataFilter, KM3NETDAQ::DataQueue, JDAQDemoClient, KM3NETDAQ::MonitorRouter, and AcousticDataFilter.

Definition at line 126 of file JDAQCHSM.hh.

{}

actionContinue()

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

inlinevirtualinherited

Reimplemented in KM3NETDAQ::JDataFilter, KM3NETDAQ::DataQueue, JDAQDemoClient, KM3NETDAQ::MonitorRouter, and AcousticDataFilter.

Definition at line 127 of file JDAQCHSM.hh.

{}

actionError()

virtual void JDAQCHSM::actionError ( )

inlinevirtualinherited

Definition at line 135 of file JDAQCHSM.hh.

{}

actionRecover()

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

inlinevirtualinherited

Definition at line 136 of file JDAQCHSM.hh.

{}

getHostname()

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

inlineinherited

Get hostname.

Returns

host name

Definition at line 108 of file JDAQClient.hh.

    {
      return hostname;
    }

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.

    {
      return fullname;
    }

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.

    {
      return unique_tag;
    }

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.

    {
      return clock.getDelay();
    }

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.

    {
      return clock.getInterval();
    }

setClockInterval()

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

inlineinherited

Set interval time.

Parameters

interval_us

interval time [us]

Definition at line 164 of file JDAQClient.hh.

    {
      clock.setInterval(interval_us);
    }

resetClock()

void KM3NETDAQ::JDAQClient_t::resetClock ( )

inlineinherited

Reset clock.

Definition at line 173 of file JDAQClient.hh.

    {
      clock.reset();
    }

getEventNumber()

int KM3NETDAQ::JDAQClient_t::getEventNumber ( ) const

inlineinherited

Get last event number.

Returns

event number

Definition at line 184 of file JDAQClient.hh.

    {
      return event_number;
    }

setEventNumber()

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

inlineinherited

Set last event number.

Parameters

event_number

event number

Definition at line 195 of file JDAQClient.hh.

    {
      this->event_number = event_number;
    }

Member Data Documentation

meta

JMeta KM3NETDAQ::JDataWriter::meta

meta data

Definition at line 376 of file JDataWriter.cc.

MAXIMUM_FILE_NUMBER

const int KM3NETDAQ::JDataWriter::MAXIMUM_FILE_NUMBER = 100

static

maximum file number for overwrite protection.

Definition at line 378 of file JDataWriter.cc.

datawriter

JLANG::JSharedPointer<JControlHost> KM3NETDAQ::JDataWriter::datawriter

private

Definition at line 382 of file JDataWriter.cc.

path

std::string KM3NETDAQ::JDataWriter::path

private

Definition at line 383 of file JDataWriter.cc.

timer

JEEP::JTimer KM3NETDAQ::JDataWriter::timer

private

Definition at line 385 of file JDataWriter.cc.

numberOfEvents

Long64_t KM3NETDAQ::JDataWriter::numberOfEvents

private

Definition at line 386 of file JDataWriter.cc.

numberOfBytes

long long int KM3NETDAQ::JDataWriter::numberOfBytes

private

Definition at line 387 of file JDataWriter.cc.

logErrorRun

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorRun

private

Definition at line 389 of file JDataWriter.cc.

logErrorFile

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorFile

private

Definition at line 390 of file JDataWriter.cc.

logErrorTag

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorTag

private

Definition at line 391 of file JDataWriter.cc.

logErrorState

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorState

private

Definition at line 392 of file JDataWriter.cc.

hostname

std::string KM3NETDAQ::JDataWriter::hostname

private

host name of data server

Definition at line 394 of file JDataWriter.cc.

writer

JTreeWriter_t KM3NETDAQ::JDataWriter::writer

private

TTree writer.

Definition at line 395 of file JDataWriter.cc.

buffer

std::vector<char> KM3NETDAQ::JDataWriter::buffer

private

internal buffer for incoming data

Definition at line 396 of file JDataWriter.cc.

run_db

JRunDB KM3NETDAQ::JDataWriter::run_db

private

Definition at line 501 of file JDataWriter.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:

• JDataWriter.cc