Runcontrol client to simulate data queue. More...

Inheritance diagram for KM3NETDAQ::JDQSimulator:

Classes
class	JData

Public Member Functions
	JDQSimulator (const std::string &name, const std::string &server, JLogger *logger, const int level)
	Constructor. More...

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

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

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

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

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

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

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	setSelect (JFileDescriptorMask &mask) const
	Set the file descriptor mask for the select call. More...

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

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

virtual bool	filter (const 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. for debugging). More...

void	A1 (CHSM_ns_alias::event const &)

void	A2 (CHSM_ns_alias::event const &)

void	A3 (CHSM_ns_alias::event const &)

void	A4 (CHSM_ns_alias::event const &)

void	A5 (CHSM_ns_alias::event const &)

void	A6 (CHSM_ns_alias::event const &)

void	A7 (CHSM_ns_alias::event const &)

void	A8 (CHSM_ns_alias::event const &)

void	A9 (CHSM_ns_alias::event const &)

void	A10 (CHSM_ns_alias::event const &)

void	A11 (CHSM_ns_alias::event const &)

void	A12 (CHSM_ns_alias::event const &)

void	A13 (CHSM_ns_alias::event const &)

void	A14 (CHSM_ns_alias::event const &)

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

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

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

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

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

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

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

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

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

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

virtual void	actionExit ()

virtual void	actionExit ()

virtual void	actionInit (int, const char *)

virtual void	actionInit (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	actionError ()

virtual void	actionError ()

virtual void	actionRecover (int, const char *)

virtual void	actionRecover (int, const char *)

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

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

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

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

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

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

void	resetClock ()
	Reset clock. More...

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

void	setEventNumber (const int event_number)
	Set last event number. More...

Public Attributes
JDAQStateMachine::state_root	root

JDAQStateMachine::state_Main	Main

JDAQStateMachine::ev_daq_event	ev_daq

char	ev_daq_param_block [sizeof(ev_daq_event::param_block)]

JDAQStateMachine::ev_init_event	ev_init

char	ev_init_param_block [sizeof(ev_init_event::param_block)]

JDAQStateMachine::ev_configure_event	ev_configure

char	ev_configure_param_block [sizeof(ev_configure_event::param_block)]

JDAQStateMachine::ev_start_event	ev_start

char	ev_start_param_block [sizeof(ev_start_event::param_block)]

JDAQStateMachine::ev_pause_event	ev_pause

char	ev_pause_param_block [sizeof(ev_pause_event::param_block)]

JDAQStateMachine::ev_continue_event	ev_continue

char	ev_continue_param_block [sizeof(ev_continue_event::param_block)]

JDAQStateMachine::ev_stop_event	ev_stop

char	ev_stop_param_block [sizeof(ev_stop_event::param_block)]

JDAQStateMachine::ev_reset_event	ev_reset

char	ev_reset_param_block [sizeof(ev_reset_event::param_block)]

JDAQStateMachine::ev_quit_event	ev_quit

char	ev_quit_param_block [sizeof(ev_quit_event::param_block)]

JDAQStateMachine::ev_off_event	ev_off

char	ev_off_param_block [sizeof(ev_off_event::param_block)]

JDAQStateMachine::ev_check_event	ev_check

char	ev_check_param_block [sizeof(ev_check_event::param_block)]

JDAQStateMachine::ev_input_event	ev_input

char	ev_input_param_block [sizeof(ev_input_event::param_block)]

JDAQStateMachine::ev_recover_event	ev_recover

char	ev_recover_param_block [sizeof(ev_recover_event::param_block)]

JDAQStateMachine::ev_error_event	ev_error

char	ev_error_param_block [sizeof(ev_error_event::param_block)]

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

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

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

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

JMessageLogger	logger
	message logger More...

std::string	name

int	detector_id

int	run_number

JEventTable	eventTable
	event table More...

std::string	hostname

std::string	fullname

JTag	unique_tag

JTimekeeper	clock
	central clock More...

int	event_number
	number of last event More...

Private Types
typedef JIO::JByteArrayWriter	JFrame
	Memory management for sending of raw data. More...

typedef std::vector< JFrame >	JTimeslice

Private Attributes
std::vector< JSource >	source

std::vector< JTarget >	target

JData	data

long long int	numberOfSlices

long long int	numberOfBytes

JEEP::JTimer	timer

Detailed Description

Runcontrol client to simulate data queue.

In state running, this application will send raw data to the data filters in a round robin way, based on the frame index.

Definition at line 163 of file JDQSimulator.cc.

Member Typedef Documentation

typedef JIO::JByteArrayWriter KM3NETDAQ::JDQSimulator::JFrame

private

Memory management for sending of raw data.

Definition at line 357 of file JDQSimulator.cc.

typedef std::vector<JFrame> KM3NETDAQ::JDQSimulator::JTimeslice

private

Definition at line 358 of file JDQSimulator.cc.

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

protectedinherited

Type definition of action method.

Definition at line 141 of file JDAQCHSM.chsm.

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

protectedinherited

Type definition of action method.

Definition at line 152 of file JDAQCHSM.hh.

Constructor & Destructor Documentation

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

inline

Constructor.

Parameters

name	name of client
server	name of command message server
logger	pointer to logger
level	debug level

Definition at line 175 of file JDQSimulator.cc.

                                            :
       JDAQClient(name, server, logger, level)
     {
       replaceEvent(RC_CMD, RC_DQSIMULATOR, ev_configure);
     }

Member Function Documentation

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 185 of file JDQSimulator.cc.

     {
       using namespace std;
       using namespace KM3NETDAQ;
       using namespace JPP;
 
 
       JMultipleFileScanner<JDAQTimesliceL0> inputFile;
       Long64_t        numberOfEvents = 1;
       int             numberOfFrames = numeric_limits<int>::max();
       double          P              = 0.0;
 
       JProperties properties(JEquationParameters("=", ";", "", ""));
 
       properties["source"]         = source;
       properties["target"]         = target;
       properties["inputFile"]      = inputFile;
       properties["numberOfEvents"] = numberOfEvents;
       properties["numberOfFrames"] = numberOfFrames;
       properties["probability"]    = P;
       
       properties.read(string(buffer, length));
 
 
       for (vector<JTarget>::iterator i = target.begin(); i != target.end(); ) {
         if (i->is_open())
           ++i;
         else
           i = target.erase(i);
       }
 
       if (inputFile.empty()) { JErrorStream(logger) << "No input files"; }
       if (target   .empty()) { JErrorStream(logger) << "No targets"; }
 
       const unsigned int index = distance(source.begin(), find(source.begin(), source.end(), getName()));
 
       int number_of_hits   = 0;
       int number_of_errors = 0;
 
       if (index < source.size()) {
       
         while (inputFile.hasNext()) {
 
           JDAQTimeslice* timeslice = inputFile.next();
 
           int i1 = (timeslice->size() * (index + 0)) / source.size();
           int i2 = (timeslice->size() * (index + 1)) / source.size();
 
           if (i2 - i1 > numberOfFrames) {
             i2 = i1 + numberOfFrames;
           }
 
           for (int i = i1; i != i2; ++i) {
 
             JDAQSuperFrame& frame = timeslice->at(i);
 
             for (JDAQSuperFrame::iterator hit = frame.begin(); hit != frame.end(); ++hit) {
 
               ++number_of_hits;
 
               if (gRandom->Rndm() <= P) {
 
                 *hit = JDAQHit(hit->getPMT(), getRandom<JDAQHit::JTDC_t>(), hit->getToT());
 
                 ++number_of_errors;
               }
             }
           }
 
           JDebugStream(logger) << "Processing timeslice: " << inputFile.getCounter() << " [" << i1 << "," << i2 << "]";
             
           data.push_back(JTimeslice(i2 - i1));
           
           for (int i = i1; i != i2; ++i) {
             data.rbegin()->at(i - i1) << timeslice->at(i);
           }
         }
 
         JNoticeStream(logger) << "Number of errors / hits " << number_of_errors << " / " << number_of_hits << " for P = " << P;
 
       } else {
 
         JErrorStream(logger) << "Source not found in configuration data: " << getName();
       }
 
       setClockInterval((long long int) (1e-3 * getFrameTime()));
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 274 of file JDQSimulator.cc.

     {
       for (std::vector<JTarget>::iterator i = target.begin(); i != target.end(); ++i) {
         i->close();
       }
 
       target.clear();
       source.clear();
       data  .clear();
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 286 of file JDQSimulator.cc.

     {
       actionReset(0, NULL);
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 292 of file JDQSimulator.cc.

     {
       numberOfSlices = 0;
       numberOfBytes  = 0;
 
       data.setRunNumber(getRunNumber());
       data.reset();
 
       timer.reset();
 
       resetClock();
     }

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

inlineoverridevirtual

Reimplemented from JDAQCHSM.

Definition at line 306 of file JDQSimulator.cc.

     {
       if (timer.usec_wall > 0) { JNoticeStream(logger) << "I/O "         << (int) (numberOfBytes   / timer.usec_wall) << " MB/s"; }
       if (numberOfSlices  > 0) { JNoticeStream(logger) << "Delay/slice " << (int) (getClockDelay() / numberOfSlices)  << " us"; }
     }

virtual void KM3NETDAQ::JDQSimulator::actionRunning ( )

inlineoverridevirtual

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

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

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 313 of file JDQSimulator.cc.

     {
       if (!data.empty() && !target.empty()) {
 
         timer.start();
 
         try {
           
           JDAQPreamble         preamble;
           JDAQSuperFrameHeader header;
           
           for (JTimeslice::const_iterator frame = data->begin(); frame != data->end(); ++frame) {
             
             JIO::JByteArrayReader in(frame->data(), getSizeof<JDAQPreamble>() + getSizeof<JDAQSuperFrameHeader>());
               
             in >> preamble;
             in >> header;
             
             JSocketBlocking& socket = target[header.getFrameIndex() % target.size()];
             
             socket.write(frame->data(), frame->size());
             
             numberOfBytes += frame->size();
           }
           
           numberOfSlices += 1;
         }
         catch(const JException& exception) {
           JErrorStream(logger) << exception;
         }
         
         data.next();
 
         timer.stop();
       }
     }

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

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

virtual bool KM3NETDAQ::JDAQClient::enter ( )

inlinevirtualinherited

Enter the state machine.

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

Returns: true if okay; else false

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 419 of file JDAQClient.hh.

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

virtual bool KM3NETDAQ::JDAQClient::exit ( )

inlinevirtualinherited

Exit the state machine.

This method releases the various resources.

Returns: true if okay; else false

Definition at line 457 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();
     }

bool KM3NETDAQ::JDAQClient::isRunning ( ) const

inlineinherited

Check if this client is in runnig state.

Returns: true if running; else false

Definition at line 480 of file JDAQClient.hh.

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

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

inlineinherited

Replace tag of given event in event table.

Parameters

oldTag	old tag
newTag	new tag
event	event

Definition at line 493 of file JDAQClient.hh.

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

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

inlineinherited

Find event in event table.

Parameters

tag	tag
event_name	event name

Returns: pointer to event or NULL

Definition at line 508 of file JDAQClient.hh.

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

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

inlineinherited

Add custom subscription.

Parameters

subscription subscription

Definition at line 524 of file JDAQClient.hh.

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

template<class T >

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

inlineinherited

Add parameter to parser used in method enter().

Parameters

option	option
parameter	parameter

Definition at line 537 of file JDAQClient.hh.

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

template<class T >

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

inlineinherited

Add parameter to parser used in method enter().

Parameters

option	option
parameter	parameter
value	default value

Definition at line 551 of file JDAQClient.hh.

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

void KM3NETDAQ::JDAQClient::setSelect ( )

inlineinherited

Set the file descriptor mask for the select call.

Definition at line 560 of file JDAQClient.hh.

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

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

inlinevirtualinherited

Set the file descriptor mask for the select call.

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

Parameters

mask	file descriptor mask

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

Definition at line 576 of file JDAQClient.hh.

577 {}

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

inlinevirtualinherited

Action method following last select call.

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

Parameters

mask	file descriptor mask

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

Definition at line 586 of file JDAQClient.hh.

587 {}

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

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

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

inlinevirtualinherited

Filter message.

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

Parameters

tag	tag
length	number of characters
buffer	message

Returns: skip message or not

Definition at line 634 of file JDAQClient.hh.

     {
       return false;
     }

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

648 {

649 }

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

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

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

inlineinherited

Run for ever.

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

Parameters

port	port number

Definition at line 742 of file JDAQClient.hh.

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

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

inlineinherited

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

Example input format:

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

Parameters

in	input stream

Definition at line 787 of file JDAQClient.hh.

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

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

inherited

Definition at line 344 of file JDAQCHSM.cc.

344 { actionError(); }

JDAQCHSM::actionError

virtual void actionError()

Definition: JDAQCHSM.chsm:124

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

inherited

Definition at line 346 of file JDAQCHSM.cc.

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

JDAQCHSM::actionInit

virtual void actionInit(int, const char *)

Definition: JDAQCHSM.chsm:112

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 348 of file JDAQCHSM.cc.

348 { JDAQCHSM::exit(); }

exit

Definition: JPizza.sh:36

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

inherited

Definition at line 350 of file JDAQCHSM.cc.

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

JDAQCHSM::execute

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

The method to execute the action.

JDAQCHSM::actionConfigure

virtual void actionConfigure(int, const char *)

Definition: JDAQCHSM.chsm:113

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

inherited

Definition at line 352 of file JDAQCHSM.cc.

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

JDAQCHSM::actionReset

virtual void actionReset(int, const char *)

Definition: JDAQCHSM.chsm:118

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 354 of file JDAQCHSM.cc.

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

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

inherited

Definition at line 364 of file JDAQCHSM.cc.

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

JDAQCHSM::actionQuit

virtual void actionQuit(int, const char *)

Definition: JDAQCHSM.chsm:119

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 366 of file JDAQCHSM.cc.

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

JDAQCHSM::execute

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

The method to execute the action.

JDAQCHSM::actionContinue

virtual void actionContinue(int, const char *)

Definition: JDAQCHSM.chsm:116

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

inherited

Definition at line 368 of file JDAQCHSM.cc.

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

JDAQCHSM::actionStop

virtual void actionStop(int, const char *)

Definition: JDAQCHSM.chsm:117

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 370 of file JDAQCHSM.cc.

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

JDAQCHSM::actionPause

virtual void actionPause(int, const char *)

Definition: JDAQCHSM.chsm:115

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 372 of file JDAQCHSM.cc.

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

JDAQCHSM::actionRecover

virtual void actionRecover(int, const char *)

Definition: JDAQCHSM.chsm:125

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 374 of file JDAQCHSM.cc.

374 { JDAQCHSM::exit(); }

exit

Definition: JPizza.sh:36

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

inherited

Definition at line 376 of file JDAQCHSM.cc.

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

JDAQCHSM::actionCheck

virtual void actionCheck(int, const char *)

Definition: JDAQCHSM.chsm:121

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 378 of file JDAQCHSM.cc.

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

JDAQCHSM::actionInput

virtual void actionInput(int, const char *)

Definition: JDAQCHSM.chsm:122

JDAQCHSM::execute

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

The method to execute the action.

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

inherited

Definition at line 337 of file JDAQCHSM.cc.

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

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

inherited

Definition at line 340 of file JDAQCHSM.cc.

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

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

inlineinherited

Get name of state machine.

Returns: name

Definition at line 78 of file JDAQCHSM.chsm.

   {
     return name;
   }

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

inlineinherited

Get name of state machine.

Returns: name

Definition at line 89 of file JDAQCHSM.hh.

   {
     return name;
   }

int JDAQCHSM::getDetectorID ( ) const

inlineinherited

Get detector identifier.

Returns: detector identifier.

Definition at line 89 of file JDAQCHSM.chsm.

   { 
     return detector_id; 
   }

int JDAQCHSM::getDetectorID ( ) const

inlineinherited

Get detector identifier.

Returns: detector identifier.

Definition at line 100 of file JDAQCHSM.hh.

   { 
     return detector_id; 
   }

int JDAQCHSM::getRunNumber ( ) const

inlineinherited

Get run number.

Returns: run number

Definition at line 100 of file JDAQCHSM.chsm.

   { 
     return run_number; 
   }

int JDAQCHSM::getRunNumber ( ) const

inlineinherited

Get run number.

Returns: run number

Definition at line 111 of file JDAQCHSM.hh.

   { 
     return run_number; 
   }

virtual void JDAQCHSM::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::actionExit ( )

inlinevirtualinherited

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

Definition at line 110 of file JDAQCHSM.chsm.

110 {}

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.

121 {}

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

inlinevirtualinherited

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

Definition at line 112 of file JDAQCHSM.chsm.

112 {}

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

inlinevirtualinherited

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

Definition at line 123 of file JDAQCHSM.hh.

123 {}

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

inlinevirtualinherited

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

Definition at line 115 of file JDAQCHSM.chsm.

115 {}

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.

126 {}

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

inlinevirtualinherited

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

Definition at line 116 of file JDAQCHSM.chsm.

116 {}

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.

127 {}

virtual void JDAQCHSM::actionError ( )

inlinevirtualinherited

Definition at line 124 of file JDAQCHSM.chsm.

124 {}

virtual void JDAQCHSM::actionError ( )

inlinevirtualinherited

Definition at line 135 of file JDAQCHSM.hh.

135 {}

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

inlinevirtualinherited

Definition at line 125 of file JDAQCHSM.chsm.

125 {}

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

inlinevirtualinherited

Definition at line 136 of file JDAQCHSM.hh.

136 {}

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

inlineinherited

Get hostname.

Returns: host name

Definition at line 109 of file JDAQClient.hh.

     {
       return hostname;
     }

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

inlineinherited

Get full name of this run control client.

Returns: full name

Definition at line 120 of file JDAQClient.hh.

     {
       return fullname;
     }

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

inlineinherited

Get unique tag of this run control client.

Returns: unique tag

Definition at line 131 of file JDAQClient.hh.

     {
       return unique_tag;
     }

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

inlineinherited

Get total delay time.

Returns: delay time [us]

Definition at line 142 of file JDAQClient.hh.

     {
       return clock.getDelay();
     }

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

inlineinherited

Get interval time.

Returns: interval time [us]

Definition at line 154 of file JDAQClient.hh.

     {
       return clock.getInterval();
     }

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

inlineinherited

Set interval time.

Parameters

interval_us interval time [us]

Definition at line 165 of file JDAQClient.hh.

     {
       clock.setInterval(interval_us);
     }

void KM3NETDAQ::JDAQClient_t::resetClock ( )

inlineinherited

Reset clock.

Definition at line 174 of file JDAQClient.hh.

     {
       clock.reset();
     }

int KM3NETDAQ::JDAQClient_t::getEventNumber ( ) const

inlineinherited

Get last event number.

Returns: event number

Definition at line 185 of file JDAQClient.hh.

     {
       return event_number;
     }

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

inlineinherited

Set last event number.

Parameters

event_number event number

Definition at line 196 of file JDAQClient.hh.

     {
       this->event_number = event_number;
     }

Member Data Documentation

std::vector<JSource> KM3NETDAQ::JDQSimulator::source

private

Definition at line 351 of file JDQSimulator.cc.

std::vector<JTarget> KM3NETDAQ::JDQSimulator::target

private

Definition at line 352 of file JDQSimulator.cc.

JData KM3NETDAQ::JDQSimulator::data

private

Definition at line 461 of file JDQSimulator.cc.

long long int KM3NETDAQ::JDQSimulator::numberOfSlices

private

Definition at line 463 of file JDQSimulator.cc.

long long int KM3NETDAQ::JDQSimulator::numberOfBytes

private

Definition at line 464 of file JDQSimulator.cc.

JEEP::JTimer KM3NETDAQ::JDQSimulator::timer

private

Definition at line 466 of file JDQSimulator.cc.

JSharedPointer<JControlHost> KM3NETDAQ::JDAQClient::server

protectedinherited

message server

Definition at line 801 of file JDAQClient.hh.

JMessageLogger KM3NETDAQ::JDAQClient::logger

protectedinherited

message logger

Definition at line 802 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 62 of file JDAQClient.hh.

JEventTable KM3NETDAQ::JDAQClient_t::eventTable

protectedinherited

event table

Definition at line 203 of file JDAQClient.hh.

std::string KM3NETDAQ::JDAQClient_t::hostname

protectedinherited

Definition at line 204 of file JDAQClient.hh.

std::string KM3NETDAQ::JDAQClient_t::fullname

protectedinherited

Definition at line 205 of file JDAQClient.hh.

JTag KM3NETDAQ::JDAQClient_t::unique_tag

protectedinherited

Definition at line 206 of file JDAQClient.hh.

JTimekeeper KM3NETDAQ::JDAQClient_t::clock

protectedinherited

central clock

Definition at line 207 of file JDAQClient.hh.

int KM3NETDAQ::JDAQClient_t::event_number

protectedinherited

number of last event

Definition at line 208 of file JDAQClient.hh.

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

JDQSimulator.cc

Classes

Public Member Functions

Public Attributes

Static Public Attributes

Protected Types

Protected Attributes

Private Types

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation