Jpp  16.0.0-rc.2
the software that should make you happy
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Public Attributes | Static Public Attributes | Protected Types | Static Protected Member Functions | Protected Attributes | List of all members
KM3NETDAQ::JDAQDriver Class Reference

Simple driver for run control clients. More...

#include <JDAQDriver.hh>

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

Public Member Functions

 JDAQDriver (const std::string &name, const std::string &server, JLogger *logger, const int level, const int timeout_s)
 Constructor. More...
 
virtual bool enter () override
 Enter the state machine. More...
 
void actionExit ()
 Exit the state machine. More...
 
virtual void enterState (const CHSM::state &state, const CHSM::event &event) override
 Action when entering state. More...
 
bool update (const bool no_wait)
 Update client list with incoming ControlHost message. More...
 
virtual void actionStart (int, const char *) override
 
virtual void actionStop (int, const char *) override
 
void run ()
 Run driver with user input. More...
 
void run (std::istream &in)
 Run driver. More...
 
void update ()
 Update client list with incoming ControlHost messages until the client list is synchronised with the current state or until the timeout. More...
 
void synchronise ()
 Synchronise clients. More...
 
void filter (const std::string &target="")
 Filter client list by putting failing clients to sleep. More...
 
virtual bool enter (const JArgs &args)
 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 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...
 
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 (const int port)
 Run for ever. More...
 
void A1 (CHSM_ns_alias::event const &)
 
void A2 (CHSM_ns_alias::event const &)
 
void A3 (CHSM_ns_alias::event const &)
 
void A4 (CHSM_ns_alias::event const &)
 
void A5 (CHSM_ns_alias::event const &)
 
void A6 (CHSM_ns_alias::event const &)
 
void A7 (CHSM_ns_alias::event const &)
 
void A8 (CHSM_ns_alias::event const &)
 
void A9 (CHSM_ns_alias::event const &)
 
void A10 (CHSM_ns_alias::event const &)
 
void A11 (CHSM_ns_alias::event const &)
 
void A12 (CHSM_ns_alias::event const &)
 
void A13 (CHSM_ns_alias::event const &)
 
void A14 (CHSM_ns_alias::event const &)
 
void EAM4root (CHSM_ns_alias::state const &, CHSM_ns_alias::event const &)
 
void XAM4root (CHSM_ns_alias::state const &, CHSM_ns_alias::event const &)
 
const std::string & getName () const
 Get name of state machine. More...
 
const std::string & getName () const
 Get name of state machine. More...
 
int getDetectorID () const
 Get detector identifier. More...
 
int getDetectorID () const
 Get detector identifier. More...
 
int getRunNumber () const
 Get run number. More...
 
int getRunNumber () const
 Get run number. More...
 
virtual void actionEnter ()
 Interface methods for actions corresponding to state transitions. More...
 
virtual void actionEnter ()
 Interface methods for actions corresponding to state transitions. More...
 
virtual void actionInit (int, const char *)
 
virtual void actionInit (int, const char *)
 
virtual void actionConfigure (int, const char *)
 
virtual void actionConfigure (int, const char *)
 
virtual void actionPause (int, const char *)
 
virtual void actionPause (int, const char *)
 
virtual void actionContinue (int, const char *)
 
virtual void actionContinue (int, const char *)
 
virtual void actionReset (int, const char *)
 
virtual void actionReset (int, const char *)
 
virtual void actionQuit (int, const char *)
 
virtual void actionQuit (int, const char *)
 
virtual void actionError ()
 
virtual void actionError ()
 
virtual void actionRecover (int, const char *)
 
virtual void actionRecover (int, const char *)
 
const std::string & getHostname () const
 Get hostname. More...
 
const std::string & getFullName () const
 Get full name of this run control client. More...
 
const 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...
 

Public Attributes

int timeout_s
 timeout of state transitions [s] More...
 
JDAQStateMachine::state_root root
 
JDAQStateMachine::state_Main Main
 
JDAQStateMachine::ev_daq_event ev_daq
 
char ev_daq_param_block [sizeof(ev_daq_event::param_block)]
 
JDAQStateMachine::ev_init_event ev_init
 
char ev_init_param_block [sizeof(ev_init_event::param_block)]
 
JDAQStateMachine::ev_configure_event ev_configure
 
char ev_configure_param_block [sizeof(ev_configure_event::param_block)]
 
JDAQStateMachine::ev_start_event ev_start
 
char ev_start_param_block [sizeof(ev_start_event::param_block)]
 
JDAQStateMachine::ev_pause_event ev_pause
 
char ev_pause_param_block [sizeof(ev_pause_event::param_block)]
 
JDAQStateMachine::ev_continue_event ev_continue
 
char ev_continue_param_block [sizeof(ev_continue_event::param_block)]
 
JDAQStateMachine::ev_stop_event ev_stop
 
char ev_stop_param_block [sizeof(ev_stop_event::param_block)]
 
JDAQStateMachine::ev_reset_event ev_reset
 
char ev_reset_param_block [sizeof(ev_reset_event::param_block)]
 
JDAQStateMachine::ev_quit_event ev_quit
 
char ev_quit_param_block [sizeof(ev_quit_event::param_block)]
 
JDAQStateMachine::ev_off_event ev_off
 
char ev_off_param_block [sizeof(ev_off_event::param_block)]
 
JDAQStateMachine::ev_check_event ev_check
 
char ev_check_param_block [sizeof(ev_check_event::param_block)]
 
JDAQStateMachine::ev_input_event ev_input
 
char ev_input_param_block [sizeof(ev_input_event::param_block)]
 
JDAQStateMachine::ev_recover_event ev_recover
 
char ev_recover_param_block [sizeof(ev_recover_event::param_block)]
 
JDAQStateMachine::ev_error_event ev_error
 
char ev_error_param_block [sizeof(ev_error_event::param_block)]
 

Static Public Attributes

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

Protected Types

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

Static Protected Member Functions

static void copy (std::istream &in, std::ostream &out, const char eol= '\n')
 Copy data from input to output stream. More...
 

Protected Attributes

JClientList clientList
 
bool is_alive
 
std::string rc_log
 
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 hostname
 
std::string fullname
 
JTag unique_tag
 
JTimekeeper clock
 central clock More...
 
int event_number
 number of last event More...
 

Detailed Description

Simple driver for run control clients.

This class can be used to start a set of run control clients, trigger events and eventually stop the clients.

Definition at line 35 of file JDAQDriver.hh.

Member Typedef Documentation

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

Type definition of action method.

Definition at line 141 of file JDAQCHSM.chsm.

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

Type definition of action method.

Definition at line 152 of file JDAQCHSM.hh.

Constructor & Destructor Documentation

KM3NETDAQ::JDAQDriver::JDAQDriver ( const std::string &  name,
const std::string &  server,
JLogger logger,
const int  level,
const int  timeout_s 
)
inline

Constructor.

Parameters
namename of driver
servername of command message server
loggerlogger
leveldebug level
timeout_stimeout_s [s]

Definition at line 48 of file JDAQDriver.hh.

52  :
53  JDAQClient(name, server, logger, level),
55  is_alive (false)
56  {}
int timeout_s
timeout of state transitions [s]
Definition: JDAQDriver.hh:620
std::string name
Definition: JDAQCHSM.chsm:154
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
JDAQClient(const std::string &name, const std::string &server, JLogger *logger, const int level)
Constructor.
Definition: JDAQClient.hh:290
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801

Member Function Documentation

virtual bool KM3NETDAQ::JDAQDriver::enter ( )
inlineoverridevirtual

Enter the state machine.

The driver will subscribe to the ControlHost tags corresponding to born, died and reply messages of the clients instead of the standard tags for run control commands. The clients are started after the driver is ready to receive ControlHost messages. In case of an error, a message is printed on the terminal and the state machine is not entered.

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 67 of file JDAQDriver.hh.

68  {
69  using namespace std;
70  using namespace JLANG;
71  using namespace JNET;
72 
73  if (server.is_valid() && logger.is_valid()) {
74 
75  try {
76 
77  server->Subscribe(JSubscriptionAll(RC_REPLY) +
81  server->SendMeAlways();
82  server->MyId(getFullName());
83 
84  // check alive of this driver
85 
86  for (int i = 0; i != timeout_s && !is_alive; ) {
87  if (!update(true)) {
88  sleep(1);
89  ++i;
90  }
91  }
92 
93  if (is_alive) {
94 
95  {
96  clientList.start();
97 
98  for (int i = 0; i != timeout_s; ++i) {
99 
100  while (update(true)) {}
101 
102  if (clientList.count() >= clientList.count(JClient::ACTIVE))
103  break;
104  else
105  sleep(1);
106  }
107  }
108 
109  if (clientList.count() != clientList.count(JClient::ACTIVE)) {
110  for (JClientList::const_iterator i = clientList.begin(); i != clientList.end(); ++i) {
111  if (i->isActive() && i->getBorn() <= i->getDied()) {
112  JWarningStream(logger) << "client " << i->getFullName() << " did not start.";
113  }
114  }
115  }
116 
117  return CHSM::machine::enter();
118 
119  } else {
120  cerr << "Timeout at subscription." << endl;
121  }
122  }
123  catch(const JControlHostException& error) {
124  cerr << error << endl;
125  }
126 
127  } else {
128  cerr << "Message server or logger not properly initialised." << endl;
129  }
130 
131  return false;
132  }
int timeout_s
timeout of state transitions [s]
Definition: JDAQDriver.hh:620
static const JTag DISPTAG_Died("Died")
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
static const JNET::JTag RC_LOG
Definition: JDAQTags.hh:50
static const JNET::JTag RC_REPLY
Definition: JDAQTags.hh:45
Exception for ControlHost.
Definition: JException.hh:468
Auxiliary class for all subscription.
Definition: JControlHost.hh:97
JClientList clientList
Definition: JDAQDriver.hh:624
static const JTag DISPTAG_Born("Born")
bool is_valid() const
Check validity of logger object.
const std::string & getFullName() const
Get full name of this run control client.
Definition: JDAQClient.hh:119
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
void update()
Update client list with incoming ControlHost messages until the client list is synchronised with the ...
Definition: JDAQDriver.hh:506
void KM3NETDAQ::JDAQDriver::actionExit ( )
inlinevirtual

Exit the state machine.

This method waits for the clients to terminate using the died message generated by ControlHost. In case of a timeout, the process is terminated by calling the method stop() of the corresponding client.

Reimplemented from JDAQCHSM.

Definition at line 141 of file JDAQDriver.hh.

142  {
143  using namespace std;
144  using namespace JLANG;
145 
146  for (int i = 0; i != timeout_s; ++i) {
147 
148  while (update(true)) {}
149 
150  if (clientList.count() == 0)
151  break;
152  else
153  sleep(1);
154  }
155 
156  if (clientList.count() != 0) {
157  JWarningStream(logger) << "Timeout at transition " << "exit(); forced stop.";
158  }
159 
160  clientList.stop();
161  }
int timeout_s
timeout of state transitions [s]
Definition: JDAQDriver.hh:620
JClientList clientList
Definition: JDAQDriver.hh:624
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
void update()
Update client list with incoming ControlHost messages until the client list is synchronised with the ...
Definition: JDAQDriver.hh:506
virtual void KM3NETDAQ::JDAQDriver::enterState ( const CHSM::state &  state,
const CHSM::event &  event 
)
inlineoverridevirtual

Action when entering state.

This method waits for all clients to produce the enter state message. In case of a timeout, no specific action is taken but an error message is logged.

Parameters
stateentered state
eventevent that triggered transition

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 172 of file JDAQDriver.hh.

173  {
174  for (int i = 0; i != timeout_s && clientList.count(state) < clientList.count(JClient::ACTIVE) && clientList.count() != 0; ) {
175  if (!update(true)) {
176  sleep(1);
177  ++i;
178  }
179  }
180 
181  if (clientList.count(state) < clientList.count(JClient::ACTIVE)) {
182  JWarningStream(logger) << "Timeout at transition " << event.name() << " to state " << state.name();
183  }
184  }
int timeout_s
timeout of state transitions [s]
Definition: JDAQDriver.hh:620
JClientList clientList
Definition: JDAQDriver.hh:624
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
void update()
Update client list with incoming ControlHost messages until the client list is synchronised with the ...
Definition: JDAQDriver.hh:506
bool KM3NETDAQ::JDAQDriver::update ( const bool  no_wait)
inline

Update client list with incoming ControlHost message.

This method receives and processes a message. The client list is updated accordingly. If the no-wait option is set to true, it returns in the absence of a pending message immediately. The return value is then false. If the no-wait option is set to false, it waits until the next message is received.

Parameters
no_waitwait option
Returns
true if message received; else false

Definition at line 198 of file JDAQDriver.hh.

199  {
200  using namespace std;
201  using namespace JNET;
203 
204  try {
205 
206  string tag;
207  long long int length = 0;
208 
209  if ( no_wait && server->CheckHead(tag, length) <= 0) { return false; }
210  if (!no_wait && server->WaitHead (tag, length) < 0) { return false; }
211 
212  char* data= new char[length];
213 
214  server->GetFullData(data, length);
215 
216  const string buffer(data, length);
217 
218  delete [] data;
219 
220  JDebugStream(logger) << "Got message " << tag << ' ' << buffer;
221 
222  if (tag == RC_LOG) {
223 
224  rc_log = buffer;
225 
226  } else if (buffer.find(getFullName()) != string::npos) {
227 
228  if (tag == DISPTAG_Born)
229  is_alive = true;
230  else if (tag == DISPTAG_Died)
231  is_alive = false;
232 
233  } else {
234 
235  JClientList::iterator i = clientList.find(buffer);
236 
237  if (i != clientList.end()) {
238 
239  i->update(tag, buffer);
240 
241  } else {
242 
243  JErrorStream(logger) << "Message fom illegal client " << buffer;
244 
245  try {
246 
247  if (tag == DISPTAG_Born ||
248  tag == DISPTAG_Died ||
249  tag == RC_REPLY) {
250 
251  string key, hostname, name;
252 
253  istringstream is(buffer);
254 
255  const locale loc(is.getloc(), new JWhiteSpacesFacet(is.getloc(), TOKEN_DELIMETER));
256 
257  is.imbue(loc);
258 
259  if (is >> key >> hostname >> name && key == RUN_CONTROL_CLIENT) {
260 
261  JClient client(name, hostname);
262 
263  client.update(tag, buffer);
264  client.setMode(JClient::ILLEGAL);
265 
266  clientList.insert(client);
267 
268  JWarningStream(logger) << "Added illegal client " << client.getFullName();
269 
270  } else {
271  throw JIOException("JClient: Error reading " + buffer);
272  }
273  }
274  }
275  catch(const JException& error) {
276  JErrorStream(logger) << error;
277  }
278  }
279  }
280 
281  return true;
282  }
283  catch(const JControlHostException& error) {
284  JErrorStream(logger) << error;
285  }
286 
287  return false;
288  }
General exception.
Definition: JException.hh:23
static const JTag DISPTAG_Died("Died")
ControlHost client manager.
Definition: JLigier.cc:243
std::string name
Definition: JDAQCHSM.chsm:154
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
static const std::string TOKEN_DELIMETER
Definition: JDAQTags.hh:36
is
Definition: JDAQCHSM.chsm:167
static const std::string RUN_CONTROL_CLIENT
Definition: JDAQTags.hh:22
static const JNET::JTag RC_LOG
Definition: JDAQTags.hh:50
static const JNET::JTag RC_REPLY
Definition: JDAQTags.hh:45
then echo Test string reversed by client(hit< return > to continue)." $DIR/JProcess -c "$DIR/JEcho-r" -C fi if (( 1 ))
Exception for ControlHost.
Definition: JException.hh:468
JClientList clientList
Definition: JDAQDriver.hh:624
static const JTag DISPTAG_Born("Born")
Auxiliary class to specify white space character(s) in currect locale.
const std::string & getFullName() const
Get full name of this run control client.
Definition: JDAQClient.hh:119
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
char * loc(char *orig)
Exception for I/O.
Definition: JException.hh:324
virtual void KM3NETDAQ::JDAQDriver::actionStart ( int  ,
const char *   
)
inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 290 of file JDAQDriver.hh.

291  {
292  rc_log = "";
293  }
virtual void KM3NETDAQ::JDAQDriver::actionStop ( int  ,
const char *   
)
inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 295 of file JDAQDriver.hh.

296  {
297  if (rc_log != "")
298  JNoticeStream(logger) << rc_log;
299  else
300  JErrorStream (logger) << "Missing message from JDataWriter with tag " << RC_LOG;
301  }
static const JNET::JTag RC_LOG
Definition: JDAQTags.hh:50
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
void KM3NETDAQ::JDAQDriver::run ( )
inline

Run driver with user input.

Definition at line 306 of file JDAQDriver.hh.

307  {
308  run(std::cin);
309  }
void run()
Run driver with user input.
Definition: JDAQDriver.hh:306
void KM3NETDAQ::JDAQDriver::run ( std::istream &  in)
inline

Run driver.

Example input format:

# comment line.
process <process name> <host name> [<start command>];
# The following tokens in <start command> will be substituted: 
#   $HOST$    by  <host name>;
#   $NAME$    by  <process name>;
#   $SERVER$  by  JClient::SERVER;
#   $LOGGER$  by  JClient::LOGGER;
#   $ARGS$    by  part following '/' in <process name>;
# enter state machine.
enter
# trigger event
# data can be provided online and mixed with data from a separate file (optional).
# multiple tags should be separated by a new line.
event <event name> {
  [<tag 1> [data]]
  [<tag 2> [data][%<file name>%][data]]
}
# optionally quit before end of input
[quit]
# optionally kill processes that did not properly terminate.
[exit]
Parameters
ininput stream

Definition at line 350 of file JDAQDriver.hh.

351  {
352  using namespace std;
353 
354  for (string key; in >> key; ) {
355 
356  if (key[0] == '#') {
357 
358  in.ignore(numeric_limits<streamsize>::max(), '\n');
359 
360  } else if (key == "enter") {
361 
362  enter();
363 
364  if (!active()) {
365  cerr << "State machine not entered; abort." << endl;
366  return;
367  }
368 
369  } else if (key == "exit") {
370 
371  timeout_s = 0;
372  exit();
373 
374  } else if (key == "quit") {
375 
376  break;
377 
378  } else if (key == "sleep") {
379 
380  int sec;
381 
382  if (in >> sec) {
383  sleep(sec);
384  }
385 
386  } else if (key == "process") {
387 
388  string buffer;
389 
390  getline(in, buffer, ';');
391 
392  istringstream is(buffer);
393 
394  JClient client;
395 
396  if (is >> client) {
397 
398  client.setMode(JClient::ACTIVE);
399 
400  if (!clientList.insert(client).second) {
401  JWarningStream(logger) << "Process already exists " << client;
402  }
403 
404  } else {
405  JErrorStream(logger) << "Error reading key word process.";
406  }
407 
408  } else if (key == "event" || key == "event*") {
409 
410  JEvent_t event;
411  char c;
412  string buffer;
413  const char eol = '\n';
414 
415  if (in >> event >> c && c == '{' && getline(in, buffer, '}')) {
416 
417  if (clientList.count() != 0) {
418 
419  JDAQEvent_t* pev = findEvent(RC_CMD, event.getName());
420 
421  if (pev != NULL) {
422 
423  if (pev->active() || key == "event*") {
424 
425  istringstream is(buffer);
426 
427  for (string tag; is >> tag; ) {
428 
429  ostringstream os;
430 
431  os << event << getTokenDelimeter();
432 
433  copy(is, os, eol);
434 
435  server->PutFullString(tag, os.str());
436  }
437 
438  if (key != "event*") {
439  (*pev)(0, NULL); // trigger driver
440  }
441 
442  } else {
443  JErrorStream(logger) << "Inactive event " << event;
444  }
445 
446  } else {
447  JErrorStream(logger) << "Unknown event " << event;
448  }
449 
450  } else {
451  JErrorStream(logger) << "No active client to trigger event.";
452  }
453 
454  } else {
455  JErrorStream(logger) << "Error reading key word event.";
456  }
457 
458  } else if (key == "message") {
459 
460  string tag;
461  string buffer;
462 
463  if (in >> tag && getline(in, buffer, ';'))
464  server->PutFullString(tag, buffer);
465  else
466  JErrorStream(logger) << "Invalid message: <" << tag << "> \"" << buffer << "\"";
467 
468  } else if (key == "print") {
469 
470  for (JClientList::const_iterator i = clientList.begin(); i != clientList.end(); ++i) {
471  JNoticeStream(logger) << i->getFullName() << ' '
472  << i->getStartCommand() << ' '
473  << i->getAlive() << ' '
474  << i->getStatename();
475  }
476 
477  } else if (key == "filter") {
478 
479  string client;
480  string buffer;
481 
482  getline(in, buffer, ';');
483 
484  for (istringstream is(buffer); is >> client; ) {
485  filter(client);
486  }
487 
488  } else if (key == "sync") {
489 
490  synchronise();
491 
492  } else {
493 
494  JErrorStream(logger) << "Unknown key: " << key;
495 
496  in.ignore(numeric_limits<streamsize>::max(), '\n');
497  }
498  }
499  }
int timeout_s
timeout of state transitions [s]
Definition: JDAQDriver.hh:620
JDAQEvent_t * findEvent(const JTag &tag, const std::string &event_name)
Find event in event table.
Definition: JDAQClient.hh:507
ControlHost client manager.
Definition: JLigier.cc:243
static void copy(std::istream &in, std::ostream &out, const char eol= '\n')
Copy data from input to output stream.
Definition: JDAQDriver.hh:636
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
is
Definition: JDAQCHSM.chsm:167
void synchronise()
Synchronise clients.
Definition: JDAQDriver.hh:529
then echo Test string reversed by client(hit< return > to continue)." $DIR/JProcess -c "$DIR/JEcho-r" -C fi if (( 1 ))
std::istream & getline(std::istream &in, JString &object)
Read string from input stream until end of line.
Definition: JString.hh:478
virtual bool exit()
Exit the state machine.
Definition: JDAQClient.hh:456
char getTokenDelimeter()
Get the token delimeter for command messages.
JClientList clientList
Definition: JDAQDriver.hh:624
void filter(const std::string &target="")
Filter client list by putting failing clients to sleep.
Definition: JDAQDriver.hh:596
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
static const JNET::JTag RC_CMD
Definition: JDAQTags.hh:44
$WORKDIR ev_configure_domsimulator txt echo process $DOM_SIMULATOR $i $SOURCE_HOST[$index] csh c(setenv ROOTSYS $ROOTSYS &&source $JPP_DIR/setenv.csh $JPP_DIR &&($DOM_SIMULATOR\-u\$NAME\$\-H\$SERVER\$\-M\$LOGGER\$\-d $DEBUG</dev/null > &/dev/null &))'
JDAQStateMachine::ev_daq_event JDAQEvent_t
Type definition of a DAQ event.
Definition: JEventTable.hh:25
then fatal Wrong number of arguments fi set_variable DETECTOR $argv[1] set_variable INPUT_FILE $argv[2] eval JPrintDetector a $DETECTOR O IDENTIFIER eval JPrintDetector a $DETECTOR O SUMMARY source JAcoustics sh $DETECTOR_ID CHECK_EXIT_CODE typeset A TRIPODS get_tripods $WORKDIR tripod txt TRIPODS for EMITTER in
Definition: JCanberra.sh:42
virtual bool enter() override
Enter the state machine.
Definition: JDAQDriver.hh:67
void KM3NETDAQ::JDAQDriver::update ( )
inline

Update client list with incoming ControlHost messages until the client list is synchronised with the current state or until the timeout.

Definition at line 506 of file JDAQDriver.hh.

507  {
508  using namespace std;
509 
510  const CHSM::parent& parent = static_cast<const CHSM::parent&>(Main.RunControl);
511 
512  for (CHSM::parent::const_iterator state = parent.begin(); state != parent.end(); ++state) {
513 
514  if (state->active()) {
515  for (int i = 0; i != timeout_s && clientList.count(*state) < clientList.count(JClient::ACTIVE); ) {
516  if (!update(true)) {
517  sleep(1);
518  ++i;
519  }
520  }
521  }
522  }
523  }
int timeout_s
timeout of state transitions [s]
Definition: JDAQDriver.hh:620
JDAQStateMachine::state_Main Main
JClientList clientList
Definition: JDAQDriver.hh:624
JDAQStateMachine::state_Main::state_RunControl RunControl
void update()
Update client list with incoming ControlHost messages until the client list is synchronised with the ...
Definition: JDAQDriver.hh:506
void KM3NETDAQ::JDAQDriver::synchronise ( )
inline

Synchronise clients.

Definition at line 529 of file JDAQDriver.hh.

530  {
531  using namespace std;
532 
533  const CHSM::parent& parent = static_cast<const CHSM::parent&>(Main.RunControl);
534 
535  for (CHSM::parent::const_iterator state = parent.begin(); state != parent.end(); ++state) {
536 
537  if (state->active()) {
538 
539  if (clientList.count(*state) < clientList.count(JClient::ACTIVE)) {
540 
541  JDebugStream(logger) << "Synchronising " << state->name();
542 
543  for (JClientList::iterator i = clientList.begin(); i != clientList.end(); ++i) {
544 
545  if (i->getMode() == JClient::ACTIVE) {
546 
547  if (!i->getAlive()) {
548 
549  try {
550 
551  string buffer;
552 
553  if (JControlHost::WhereIs(JClient::SERVER, i->getFullName(), buffer) > 0) {
554 
555  i->setAlive(true);
556 
557  if (buffer.find(i->getHostname()) == string::npos) {
558  JErrorStream(logger) << i->getFullName() << " running on " << buffer << " but not alive.";
559  }
560  }
561  }
562  catch(const JControlHostException& error) {
563  JErrorStream(logger) << error;
564  }
565  }
566 
567  if (i->getAlive() && i->getStatename() != state->name()) {
568  server->PutFullString(KM3NETDAQ::getUniqueTag(i->getHostname(), i->getName()), ev_check.name());
569  }
570  }
571  }
572 
573 
574  for (int i = 0; i != timeout_s && clientList.count(*state) < clientList.count(JClient::ACTIVE); ) {
575  if (!update(true)) {
576  sleep(1);
577  ++i;
578  }
579  }
580 
581  if (clientList.count(*state) < clientList.count(JClient::ACTIVE)) {
582  JWarningStream(logger) << "Timeout at synchronisation.";
583  }
584  }
585  }
586  }
587  }
int timeout_s
timeout of state transitions [s]
Definition: JDAQDriver.hh:620
JDAQStateMachine::state_Main Main
JTag getUniqueTag(const std::string &hostname, const std::string &name)
Get unique tag of run control client.
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
Exception for ControlHost.
Definition: JException.hh:468
JClientList clientList
Definition: JDAQDriver.hh:624
JDAQStateMachine::ev_check_event ev_check
&set_variable SERVER
Definition: JStopDAQ.sh:29
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
static int WhereIs(const std::string &host_name, const std::string &nick_name, std::string &answer)
Locate ControlHost client(s).
JDAQStateMachine::state_Main::state_RunControl RunControl
void update()
Update client list with incoming ControlHost messages until the client list is synchronised with the ...
Definition: JDAQDriver.hh:506
void KM3NETDAQ::JDAQDriver::filter ( const std::string &  target = "")
inline

Filter client list by putting failing clients to sleep.

In this, only clients with names that contain the given character sequence are considered.

Parameters
targettarget name of client(s)

Definition at line 596 of file JDAQDriver.hh.

597  {
598  const CHSM::parent& parent = static_cast<const CHSM::parent&>(Main.RunControl);
599 
600  for (CHSM::parent::const_iterator state = parent.begin(); state != parent.end(); ++state) {
601 
602  if (state->active()) {
603 
604  for (JClientList::iterator i = clientList.begin(); i != clientList.end(); ++i) {
605 
606  if (target == "" || i->getName().find(target) != std::string::npos) {
607 
608  if (!i->getAlive() || i->getStatename() != state->name()) {
609 
610  JNoticeStream(logger) << "Put to sleep " << i->getFullName();
611 
612  i->setMode(JClient::SLEEP);
613  }
614  }
615  }
616  }
617  }
618  }
JDAQStateMachine::state_Main Main
JClientList clientList
Definition: JDAQDriver.hh:624
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
JDAQStateMachine::state_Main::state_RunControl RunControl
static void KM3NETDAQ::JDAQDriver::copy ( std::istream &  in,
std::ostream &  out,
const char  eol = '\n' 
)
inlinestaticprotected

Copy data from input to output stream.

Tagged file names are recursively expanded.

Parameters
ininput stream
outoutput stream
eolend of line

Definition at line 636 of file JDAQDriver.hh.

637  {
638  using namespace std;
639 
640  string buffer;
641 
642  if (getline(in, buffer, eol)) {
643 
644  for (string::size_type pos = 0; pos < buffer.length(); ) {
645 
646  string::size_type lpos = buffer.substr(pos).find(FILENAME_PREFIX);
647  string::size_type rpos = buffer.substr(pos).find(FILENAME_POSTFIX);
648 
649  if (lpos != string::npos &&
650  rpos != string::npos) {
651 
652  out << buffer.substr(pos, lpos);
653 
654  lpos += FILENAME_PREFIX.length();
655  pos += lpos;
656 
657  ifstream file(buffer.substr(pos, rpos - lpos).c_str());
658 
659  copy(file, out, '\0');
660 
661  rpos += FILENAME_POSTFIX.length();
662  pos += rpos - lpos;
663 
664  } else {
665 
666  out << buffer.substr(pos);
667 
668  pos += buffer.substr(pos).length();
669  }
670  }
671  }
672  }
static const std::string FILENAME_PREFIX
Definition: JDAQTags.hh:38
static const std::string FILENAME_POSTFIX
Definition: JDAQTags.hh:39
then set_variable PMT_FILE set_variable DAQ_FILE set_variable OUTPUT_FILE set_variable DETECTOR else fatal Wrong number of arguments fi set_variable RUNBYRUN file
static void copy(std::istream &in, std::ostream &out, const char eol= '\n')
Copy data from input to output stream.
Definition: JDAQDriver.hh:636
std::istream & getline(std::istream &in, JString &object)
Read string from input stream until end of line.
Definition: JString.hh:478
then fatal Wrong number of arguments fi set_variable DETECTOR $argv[1] set_variable INPUT_FILE $argv[2] eval JPrintDetector a $DETECTOR O IDENTIFIER eval JPrintDetector a $DETECTOR O SUMMARY source JAcoustics sh $DETECTOR_ID CHECK_EXIT_CODE typeset A TRIPODS get_tripods $WORKDIR tripod txt TRIPODS for EMITTER in
Definition: JCanberra.sh:42
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  }
JParser parser
parser method enter()
Definition: JDAQClient.hh:1027
Message logging based on std::ostream.
Interface for logging messages.
Definition: JLogger.hh:22
Message logging based on ControlHost.
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
#define make_field(A,...)
macro to convert parameter to JParserTemplateElement object
Definition: JParser.hh:1961
virtual bool enter()
Enter the state machine.
Definition: JDAQClient.hh:418
int read(const int argc, const char *const argv[])
Parse the program&#39;s command line options.
Definition: JParser.hh:1798
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
const std::string & getName() const
Get name of state machine.
Definition: JDAQCHSM.chsm:78
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  }
void reset(JLogger *__logger=NULL)
Reset logger.
exit
Definition: JPizza.sh:36
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
bool is_valid() const
Check validity of logger object.
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
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  }
JDAQStateMachine::state_Main Main
JDAQStateMachine::state_Main::state_RunControl::state_Operational Operational
JDAQStateMachine::state_Main::state_RunControl RunControl
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  }
void replace(const JTag &oldTag, const JTag &newTag, JDAQEvent_t &event)
Replace entry in table.
Definition: JEventTable.hh:96
JEventTable eventTable
event table
Definition: JDAQClient.hh:202
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  }
JEventTable eventTable
event table
Definition: JDAQClient.hh:202
const_iterator find(const JTag &tag, const std::string &event_name) const
Find entry.
Definition: JEventTable.hh:116
void KM3NETDAQ::JDAQClient::addSubscription ( const JSubscription subscription)
inlineinherited

Add custom subscription.

Parameters
subscriptionsubscription

Definition at line 523 of file JDAQClient.hh.

524  {
526  }
JSubscriptionList & add(const JSubscription &subscription)
Add subscription.
JSubscriptionList subscription
custom subscription
Definition: JDAQClient.hh:1028
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  }
JParser parser
parser method enter()
Definition: JDAQClient.hh:1027
#define make_field(A,...)
macro to convert parameter to JParserTemplateElement object
Definition: JParser.hh:1961
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  }
JParser parser
parser method enter()
Definition: JDAQClient.hh:1027
#define make_field(A,...)
macro to convert parameter to JParserTemplateElement object
Definition: JParser.hh:1961
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  }
JSelectReader select
select call
Definition: JDAQClient.hh:1026
JSharedPointer< JControlHost > server
message server
Definition: JDAQClient.hh:800
JFileDescriptorMask & getReaderMask()
Get reader mask.
void setReaderMask(const JAbstractFile &file)
Set reader mask.
void reset()
Reset.
void setSelect()
Set the file descriptor mask for the select call.
Definition: JDAQClient.hh:559
virtual void KM3NETDAQ::JDAQClient::setSelect ( JFileDescriptorMask mask) const
inlinevirtualinherited

Set the file descriptor mask for the select call.

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

Parameters
maskfile descriptor mask

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

Definition at line 575 of file JDAQClient.hh.

576  {}
virtual void KM3NETDAQ::JDAQClient::actionSelect ( const JFileDescriptorMask mask)
inlinevirtualinherited

Action method following last select call.

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

Parameters
maskfile descriptor mask

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

Definition at line 585 of file JDAQClient.hh.

586  {}
virtual void KM3NETDAQ::JDAQClient::actionRunning ( )
inlinevirtualinherited

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 in KM3NETDAQ::JDataFilter, KM3NETDAQ::JDataWriter, KM3NETDAQ::JDOMSimulator, KM3NETDAQ::DataQueue, KM3NETDAQ::JEventGenerator, KM3NETDAQ::MonitorRouter, and AcousticDataFilter.

Definition at line 596 of file JDAQClient.hh.

597  {}
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  }
Utility class to parse parameter values.
Definition: JProperties.hh:496
Simple data structure to support I/O of equations (see class JLANG::JEquation).
JMessageLogger logger
message logger
Definition: JDAQClient.hh:801
void setLevel(const int __level)
Set debug level.
JLevel_t getLevel()
Get debug level.
virtual bool KM3NETDAQ::JDAQClient::filter ( const JTag tag,
int  length,
const char *  buffer 
)
inlinevirtualinherited

Filter message.

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

Parameters
tagtag
lengthnumber of characters
buffermessage
Returns
skip message or not

Definition at line 633 of file JDAQClient.hh.

634  {
635  return false;
636  }
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
tagtag
lengthlength of data
bufferpointer to data

Reimplemented in KM3NETDAQ::JDataFilter.

Definition at line 646 of file JDAQClient.hh.

647  {
648  }
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  }
ControlHost prefix.
Definition: JPrefix.hh:31
void run()
Run as run control client following command messages via JNET::JControlHost.
Definition: JDAQClient.hh:661
int getSize() const
Get size.
Definition: JPrefix.hh:62
virtual bool enter()
Enter the state machine.
Definition: JDAQClient.hh:418
virtual bool exit()
Exit the state machine.
Definition: JDAQClient.hh:456
std::string toString() const
Convert tag to string.
Definition: JTag.hh:171
void JDAQStateMachine::A1 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 344 of file JDAQCHSM.cc.

344 { actionError(); }
virtual void actionError()
Definition: JDAQCHSM.chsm:124
void JDAQStateMachine::A2 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 346 of file JDAQCHSM.cc.

346 { execute(&JDAQCHSM::actionInit, event); }
virtual void actionInit(int, const char *)
Definition: JDAQCHSM.chsm:112
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::A3 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 348 of file JDAQCHSM.cc.

348 { JDAQCHSM::exit(); }
exit
Definition: JPizza.sh:36
void JDAQStateMachine::A4 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 350 of file JDAQCHSM.cc.

virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
virtual void actionConfigure(int, const char *)
Definition: JDAQCHSM.chsm:113
void JDAQStateMachine::A5 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 352 of file JDAQCHSM.cc.

352 { execute(&JDAQCHSM::actionReset, event); }
virtual void actionReset(int, const char *)
Definition: JDAQCHSM.chsm:118
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::A6 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 354 of file JDAQCHSM.cc.

354  {
355 
356  std::istringstream is(std::string(ev_start->buffer, ev_start->length));
357 
358  is >> run_number >> detector_id;
359 
361 
362  }
JDAQStateMachine::ev_start_event ev_start
int run_number
Definition: JDAQCHSM.chsm:156
is
Definition: JDAQCHSM.chsm:167
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
virtual void actionStart(int, const char *)
Definition: JDAQCHSM.chsm:114
int detector_id
Definition: JDAQCHSM.chsm:155
void JDAQStateMachine::A7 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 364 of file JDAQCHSM.cc.

364 { execute(&JDAQCHSM::actionQuit, event); }
virtual void actionQuit(int, const char *)
Definition: JDAQCHSM.chsm:119
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::A8 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 366 of file JDAQCHSM.cc.

366 { execute(&JDAQCHSM::actionContinue, event); }
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
virtual void actionContinue(int, const char *)
Definition: JDAQCHSM.chsm:116
void JDAQStateMachine::A9 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 368 of file JDAQCHSM.cc.

368 { execute(&JDAQCHSM::actionStop, event); }
virtual void actionStop(int, const char *)
Definition: JDAQCHSM.chsm:117
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::A10 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 370 of file JDAQCHSM.cc.

370 { execute(&JDAQCHSM::actionPause, event); }
virtual void actionPause(int, const char *)
Definition: JDAQCHSM.chsm:115
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::A11 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 372 of file JDAQCHSM.cc.

372 { execute(&JDAQCHSM::actionRecover, event); }
virtual void actionRecover(int, const char *)
Definition: JDAQCHSM.chsm:125
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::A12 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 374 of file JDAQCHSM.cc.

374 { JDAQCHSM::exit(); }
exit
Definition: JPizza.sh:36
void JDAQStateMachine::A13 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 376 of file JDAQCHSM.cc.

376 { execute(&JDAQCHSM::actionCheck, event); }
virtual void actionCheck(int, const char *)
Definition: JDAQCHSM.chsm:121
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::A14 ( CHSM_ns_alias::event const &  event)
inherited

Definition at line 378 of file JDAQCHSM.cc.

378 { execute(&JDAQCHSM::actionInput, event); }
virtual void actionInput(int, const char *)
Definition: JDAQCHSM.chsm:122
virtual void execute(action __action, const CHSM::event &__event)=0
The method to execute the action.
void JDAQStateMachine::EAM4root ( CHSM_ns_alias::state const &  chsm_state_,
CHSM_ns_alias::event const &  event 
)
inherited

Definition at line 337 of file JDAQCHSM.cc.

337  {
338 #line 164 "JDAQCHSM.chsm"
339  CHSM_ns_alias::cluster const &state = (CHSM_ns_alias::cluster const&)chsm_state_; actionEnter(); }
virtual void actionEnter()
Interface methods for actions corresponding to state transitions.
Definition: JDAQCHSM.chsm:109
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(); }
virtual void actionExit()
Definition: JDAQCHSM.chsm:110
const std::string& JDAQCHSM::getName ( ) const
inlineinherited

Get name of state machine.

Returns
name

Definition at line 78 of file JDAQCHSM.chsm.

79  {
80  return name;
81  }
std::string name
Definition: JDAQCHSM.chsm:154
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  }
std::string name
Definition: JDAQCHSM.chsm:154
int JDAQCHSM::getDetectorID ( ) const
inlineinherited

Get detector identifier.

Returns
detector identifier.

Definition at line 89 of file JDAQCHSM.chsm.

90  {
91  return detector_id;
92  }
int detector_id
Definition: JDAQCHSM.chsm:155
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  }
int detector_id
Definition: JDAQCHSM.chsm:155
int JDAQCHSM::getRunNumber ( ) const
inlineinherited

Get run number.

Returns
run number

Definition at line 100 of file JDAQCHSM.chsm.

101  {
102  return run_number;
103  }
int run_number
Definition: JDAQCHSM.chsm:156
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  }
int run_number
Definition: JDAQCHSM.chsm:156
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 109 of file JDAQCHSM.chsm.

109 {}
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.

120 {}
virtual void JDAQCHSM::actionInit ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionInit ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionConfigure ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionConfigure ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionPause ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionPause ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionContinue ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionContinue ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionReset ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionReset ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionQuit ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionQuit ( int  ,
const char *   
)
inlinevirtualinherited
virtual void JDAQCHSM::actionError ( )
inlinevirtualinherited

Definition at line 124 of file JDAQCHSM.chsm.

124 {}
virtual void JDAQCHSM::actionError ( )
inlinevirtualinherited

Definition at line 135 of file JDAQCHSM.hh.

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

Definition at line 125 of file JDAQCHSM.chsm.

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

Definition at line 136 of file JDAQCHSM.hh.

136 {}
const std::string& KM3NETDAQ::JDAQClient_t::getHostname ( ) const
inlineinherited

Get hostname.

Returns
host name

Definition at line 108 of file JDAQClient.hh.

109  {
110  return hostname;
111  }
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  }
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  }
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  }
long long int getDelay() const
Get total delay time.
Definition: JTimekeeper.hh:78
JTimekeeper clock
central clock
Definition: JDAQClient.hh:206
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  }
JTimekeeper clock
central clock
Definition: JDAQClient.hh:206
long long int getInterval() const
Get interval time.
Definition: JTimekeeper.hh:67
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  }
JTimekeeper clock
central clock
Definition: JDAQClient.hh:206
void setInterval(const long long int interval_us)
Set interval time.
Definition: JTimekeeper.hh:89
void KM3NETDAQ::JDAQClient_t::resetClock ( )
inlineinherited

Reset clock.

Definition at line 173 of file JDAQClient.hh.

174  {
175  clock.reset();
176  }
JTimekeeper clock
central clock
Definition: JDAQClient.hh:206
void reset(const long long int t0)
Reset time.
Definition: JTimekeeper.hh:100
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  }
int event_number
number of last event
Definition: JDAQClient.hh:207
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  }
int event_number
number of last event
Definition: JDAQClient.hh:207

Member Data Documentation

int KM3NETDAQ::JDAQDriver::timeout_s

timeout of state transitions [s]

Definition at line 620 of file JDAQDriver.hh.

JClientList KM3NETDAQ::JDAQDriver::clientList
protected

Definition at line 624 of file JDAQDriver.hh.

bool KM3NETDAQ::JDAQDriver::is_alive
protected

Definition at line 625 of file JDAQDriver.hh.

std::string KM3NETDAQ::JDAQDriver::rc_log
protected

Definition at line 626 of file JDAQDriver.hh.

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

message server

Definition at line 800 of file JDAQClient.hh.

JMessageLogger KM3NETDAQ::JDAQClient::logger
protectedinherited

message logger

Definition at line 801 of file JDAQClient.hh.

JDAQStateMachine::state_root JDAQStateMachine::root
inherited
JDAQStateMachine::state_Main JDAQStateMachine::Main
inherited
JDAQStateMachine::ev_daq_event JDAQStateMachine::ev_daq
inherited
char JDAQStateMachine::ev_daq_param_block[sizeof(ev_daq_event::param_block)]
inherited

Definition at line 238 of file JDAQCHSM.hh.

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

Definition at line 258 of file JDAQCHSM.hh.

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

Definition at line 278 of file JDAQCHSM.hh.

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

Definition at line 298 of file JDAQCHSM.hh.

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

Definition at line 318 of file JDAQCHSM.hh.

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

Definition at line 338 of file JDAQCHSM.hh.

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

Definition at line 358 of file JDAQCHSM.hh.

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

Definition at line 378 of file JDAQCHSM.hh.

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

Definition at line 398 of file JDAQCHSM.hh.

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

Definition at line 418 of file JDAQCHSM.hh.

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

Definition at line 438 of file JDAQCHSM.hh.

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

Definition at line 458 of file JDAQCHSM.hh.

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

Definition at line 478 of file JDAQCHSM.hh.

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

Definition at line 495 of file JDAQCHSM.hh.

std::string JDAQCHSM::name
protectedinherited

Definition at line 154 of file JDAQCHSM.chsm.

int JDAQCHSM::detector_id
protectedinherited

Definition at line 155 of file JDAQCHSM.chsm.

int JDAQCHSM::run_number
protectedinherited

Definition at line 156 of file JDAQCHSM.chsm.

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

time out of update [s]

Definition at line 61 of file JDAQClient.hh.

JEventTable KM3NETDAQ::JDAQClient_t::eventTable
protectedinherited

event table

Definition at line 202 of file JDAQClient.hh.

std::string KM3NETDAQ::JDAQClient_t::hostname
protectedinherited

Definition at line 203 of file JDAQClient.hh.

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

Definition at line 204 of file JDAQClient.hh.

JTag KM3NETDAQ::JDAQClient_t::unique_tag
protectedinherited

Definition at line 205 of file JDAQClient.hh.

JTimekeeper KM3NETDAQ::JDAQClient_t::clock
protectedinherited

central clock

Definition at line 206 of file JDAQClient.hh.

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: