#include <AcousticDataFilter.h>

Inheritance diagram for AcousticDataFilter:

Public Member Functions
	AcousticDataFilter (const std::string &address, const std::string &port, const std::string &name, const std::string &server, const std::string &wisdom, const std::string &output, const std::string &raw, JLOGGER::JLogger *logger, const int level)

virtual	~AcousticDataFilter ()

void	Send_toa_async (ToA_Packet packet)

virtual void	actionEnter ()

virtual void	actionExit ()

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

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

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

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

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

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

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

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

virtual void	actionInput (int length, const char *buffer)
	This method is called at `ev_input`. 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 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...

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

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

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

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

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

JDAQEvent_t *	findEvent (const JNET::JTag &tag, const std::string &event_name)
	Find event in event table. 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...

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

const std::string &	getHostname () const
	Get hostname. 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...

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 bool	filter (const std::string &tag, int length, const char *buffer)
	Filter message. More...

void	run ()
	Run as run control client following command messages via JNET::JControlHost. More...

void	run (const int port)
	Run for ever. More...

void	run (std::istream &in)
	Run client with commands from input stream (e.g for debugging). More...

Static Public Attributes
static const int	DEBUG_LEVEL =1

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

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

JMessageLogger	logger
	message logger More...

Private Member Functions
const JNET::JTag &	clientTag () const

void	Create_probes (std::vector< std::string > probes, std::size_t window)

void	Create_DOMs (std::vector< std::string > doms, std::string &debug_file_path, std::size_t window, std::size_t overlap)

void	Start_accept ()

void	Accept_completed (pLink link, const boost::system::error_code &error)

void	Start ()

void	Stop ()

void	Open_toa_file ()

void	Send_toa (ToA_Packet packet)

Private Attributes
boost::atomic< bool >	exit_

boost::atomic< bool >	running_

std::string	address_

std::string	port_

std::map< std::size_t, pProbe >	probes_

std::map< std::size_t, pDOM >	doms_

std::vector< pLink >	links_

boost::thread_group	server_threads_

boost::asio::io_service	server_io_service_

boost::asio::io_service::work *	server_work_

boost::asio::ip::tcp::acceptor	server_acceptor_

boost::thread_group	trigger_threads_

boost::asio::io_service	trigger_io_service_

boost::asio::io_service::work *	trigger_work_

boost::asio::io_service::strand	strand_

std::string	debug_file_path_

std::string	toa_file_path_

std::ofstream	toa_file_

std::string	wisdom_file_

Detailed Description

Definition at line 46 of file AcousticDataFilter.h.

Constructor & Destructor Documentation

AcousticDataFilter::AcousticDataFilter	(	const std::string &	address,
		const std::string &	port,
		const std::string &	name,
		const std::string &	server,
		const std::string &	wisdom,
		const std::string &	output,
		const std::string &	raw,
		JLOGGER::JLogger *	logger,
		const int	level
	)

Definition at line 53 of file AcousticDataFilter.cpp.

                                                                                              :  KM3NETDAQ::JDAQClient(name,server,logger,level),\
 																	strand_(trigger_io_service_),\
 																	server_acceptor_(server_io_service_)
 {
         DEBUG_MSG("Constructor",0);
         
         replaceEvent(KM3NETDAQ::RC_CMD, clientTag(), ev_configure);
         
         address_=address;
         port_=port;
         exit_=false;
         running_=false;
         wisdom_file_=wisdom;
         toa_file_path_=output;
         debug_file_path_=raw;
 
 }

AcousticDataFilter::~AcousticDataFilter ( )

virtual

Definition at line 79 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("Destructor",0);
         Stop();
 }

Member Function Documentation

void AcousticDataFilter::Send_toa_async ( ToA_Packet packet )

inline

Definition at line 62 of file AcousticDataFilter.h.

62 {strand_.post(boost::bind(&AcousticDataFilter::Send_toa,this,packet));};

AcousticDataFilter::strand_

boost::asio::io_service::strand strand_

Definition: AcousticDataFilter.h:106

AcousticDataFilter::Send_toa

void Send_toa(ToA_Packet packet)

Definition: AcousticDataFilter.cpp:301

virtual void AcousticDataFilter::actionEnter ( )

inlinevirtual

Definition at line 64 of file AcousticDataFilter.h.

64 {};

virtual void AcousticDataFilter::actionExit ( )

inlinevirtual

Definition at line 65 of file AcousticDataFilter.h.

65 {exit_=true;};

AcousticDataFilter::exit_

boost::atomic< bool > exit_

Definition: AcousticDataFilter.h:90

void AcousticDataFilter::actionInit	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 147 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("SM:Init",2);
         FILE* pfile;
         pfile=fopen(wisdom_file_.c_str(),"r");
         if (pfile!=NULL) 
         {
                 if (fftwf_import_wisdom_from_file(pfile)==1)
                 {
                         DEBUG_MSG("SM:Init wisdom imported",2);
                 }
                 fclose(pfile);
         }
 }

void AcousticDataFilter::actionConfigure	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 175 of file AcousticDataFilter.cpp.

 {
 
         DEBUG_MSG("SM:Configure",2); 
         Parser dummy(std::string(buffer, length),';');
         DEBUG_MSG("SM:Cerco",2);
 
         std::string l_debug_file_path;
         std::string l_window;
         std::string l_overlap;
         std::vector<std::string> l_toa_path;
         std::vector<std::string> l_dbg_path;
         std::vector<std::string> l_probes;
         std::vector<std::string> l_dom_configuration;
 
         l_window=dummy.Find("ADF_analysis_window_size")[0];
         l_overlap=dummy.Find("ADF_analysis_window_overlap")[0];
         l_probes=dummy.Find("ADF_waveform");
         l_dom_configuration=dummy.Find("ADF_DOM_configuration");
 
         l_toa_path=dummy.Find("ADF_TOA_path");
         if (l_toa_path.size()!=0) toa_file_path_=l_toa_path[0];
         l_dbg_path=dummy.Find("ADF_DBG_path");
         if (l_dbg_path.size()!=0) debug_file_path_=l_dbg_path[0];
 
         DEBUG_MSG("SM:Configure. win="<<l_window,2);
         DEBUG_MSG("SM:Configure. ovr="<<l_overlap,2);
         DEBUG_MSG("SM:Configure. TOA_path="<<toa_file_path_,2);
         DEBUG_MSG("SM:Configure. DBG_path="<<debug_file_path_,2);
 
         DEBUG_MSG("SM:Configure. n dom="<<l_dom_configuration.size(),2);
         DEBUG_MSG("SM:Configure. n pro="<<l_probes.size(),2);
         
         Create_probes(l_probes,atoi(l_window.c_str()));
         Create_DOMs(l_dom_configuration,debug_file_path_,atoi(l_window.c_str()),atoi(l_overlap.c_str()));
         
         Start();
 
 }

void AcousticDataFilter::actionStart	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 215 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("SM start",2);
         running_=true;
         strand_.post(boost::bind(&AcousticDataFilter::Start_accept,this));
 }

void AcousticDataFilter::actionPause	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 329 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("SM: pause",2);
         running_=false;
 }

void AcousticDataFilter::actionContinue	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 335 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("SM: continue",2);
         running_=true;
 }

void AcousticDataFilter::actionStop	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 341 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("SM:Stop",2); 
         Stop();
 }

void AcousticDataFilter::actionReset	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 162 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("SM:Reset",2);
     FILE* pfile;
     pfile=fopen(wisdom_file_.c_str(),"w");
     if (pfile!=NULL)
     {
 DEBUG_MSG("SM:Reset wisdom saved",2);
                 fftwf_export_wisdom_to_file(pfile);
                 fclose(pfile);
         }
 }

void AcousticDataFilter::actionQuit	(	int	length,
		const char *	buffer
	)

virtual

Definition at line 347 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("SM:Quit",2); 
         Stop();
 }

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

inlinevirtual

This method is called at ev_input.

Parameters

length	length of data
buffer	pointer to data

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 74 of file AcousticDataFilter.h.

74 {};

virtual void AcousticDataFilter::actionRunning ( )

inlinevirtual

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

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

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 75 of file AcousticDataFilter.h.

75 {};

const JNET::JTag& AcousticDataFilter::clientTag ( ) const

inlineprivate

Definition at line 79 of file AcousticDataFilter.h.

79 { return KM3NETDAQ::RC_AFILTER; };

KM3NETDAQ::RC_AFILTER

static const JNET::JTag RC_AFILTER

Definition: JDAQTags.hh:55

void AcousticDataFilter::Create_probes	(	std::vector< std::string >	probes,
		std::size_t	window
	)

private

Definition at line 222 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("Create probes",1);
 
         for(int t=0;t<probes.size();++t)
         {
                 std::istringstream l_iss(probes.at(t));
                 std::string l_line;
                 uint32_t l_id;
                 uint32_t l_samples;
                 real_type* l_buffer;
         
                 std::getline(l_iss, l_line,' ');
                 l_id=atoi(l_line.c_str());
                 DEBUG_MSG("id probe="<<l_id,1);
                 std::getline(l_iss, l_line,' ');
                 l_samples=atoi(l_line.c_str());
                 DEBUG_MSG("n samples="<<l_samples,1);
                 l_buffer=(real_type*)malloc(l_samples*sizeof(real_type));
                 for (uint32_t i=0; i<l_samples; ++i)
                 {
                         std::getline(l_iss, l_line,' ');
                         real_type l_dummy=atof(l_line.c_str());
                         DEBUG_MSG("sample="<<l_dummy,0);
                         l_buffer[i]=l_dummy;
                 }
                 DEBUG_MSG("creating probes",1);
                 pProbe l_probe = boost::make_shared<KM3::TOALIB::CTOAFinder::probeSignalT>(*(new KM3::TOALIB::CTOAFinder::probeSignalT(window)));
                 DEBUG_MSG("copying data",1);
                 l_probe->copyFromBuffer(l_buffer,l_samples);
                 DEBUG_MSG("insert probe",1);
                 probes_.insert(probe_entry(l_id,l_probe));      
         }       
         DEBUG_MSG("Probes creation finished",1);
 }

void AcousticDataFilter::Create_DOMs	(	std::vector< std::string >	doms,
		std::string &	debug_file_path,
		std::size_t	window,
		std::size_t	overlap
	)

private

Definition at line 258 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("Create DOM",1);
 
         for(int t=0;t<dom_configuration.size();++t)
         {
                 std::istringstream l_iss(dom_configuration.at(t));
                 std::string l_line;
                 uint32_t l_dom_id;
                 uint32_t l_probe_id;
                 uint32_t l_threshold;
                 uint32_t l_waveforms;
                 uint32_t l_test;
         
                 std::getline(l_iss, l_line,' ');
                 l_dom_id=atoi(l_line.c_str());
                 DEBUG_MSG("DOM id="<<l_dom_id,1);
                 pDOM l_dom = boost::make_shared<KM3NeT_DOM>(*(new KM3NeT_DOM(   trigger_io_service_,\
                                                                                                                                                 boost::bind(&AcousticDataFilter::Send_toa_async, this, _1),\
                                                                                                                                                 debug_file_path,\
                                                                                                                                                 window,\
                                                                                                                                                 overlap)));
                 doms_.insert(dom_entry(l_dom_id,l_dom));        
                 std::getline(l_iss, l_line,' ');
                 l_waveforms=atoi(l_line.c_str());
                 DEBUG_MSG("n waveforms="<<l_waveforms,1);
                 for (uint32_t i=0; i<l_waveforms; ++i)
                 {
                         std::getline(l_iss, l_line,' ');
                         l_probe_id=atoi(l_line.c_str());
                         std::getline(l_iss, l_line,' ');
                         l_threshold=atoi(l_line.c_str());
                         DEBUG_MSG("adding probe "<<l_probe_id<<" with threshold "<<l_threshold<<" to DOM "<<l_dom_id,1);
                         l_dom->Add_probe(probes_.find(l_probe_id)->second,l_probe_id,l_threshold);
                 }
         std::getline(l_iss, l_line,' ');
         l_test=atoi(l_line.c_str());
                 DEBUG_MSG("setting test id="<<l_test,1);
                 l_dom->Set_test(l_test);
         }
         DEBUG_MSG("DOMs creation finished",1);
 }

void AcousticDataFilter::Start_accept ( )

private

Definition at line 128 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("Start accept",2);
         pLink l_link=pLink(new KM3NeT_Acoustic_Link(server_io_service_,doms_));
         links_.push_back(l_link);
         server_acceptor_.async_accept(l_link->Socket(), boost::bind(&AcousticDataFilter::Accept_completed, this, l_link, boost::asio::placeholders::error));
 }

void AcousticDataFilter::Accept_completed	(	pLink	link,
		const boost::system::error_code &	error
	)

private

Definition at line 136 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("Accept completed",2);
 
         if (!error)     
         {
                 link->Start_reading();
                 strand_.post(boost::bind(&AcousticDataFilter::Start_accept,this));
         }
 }

void AcousticDataFilter::Start ( )

private

Definition at line 85 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("Start",2);
         server_work_ = new boost::asio::io_service::work(server_io_service_);
     trigger_work_ = new boost::asio::io_service::work(trigger_io_service_);
 
         boost::asio::ip::tcp::resolver l_resolver(server_io_service_);
         boost::asio::ip::tcp::resolver::query l_query(address_,port_);
         boost::asio::ip::tcp::endpoint l_endpoint = *l_resolver.resolve(l_query);
         server_acceptor_.open(l_endpoint.protocol());
         server_acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true));
         server_acceptor_.bind(l_endpoint);
         server_acceptor_.listen();
 
     for (std::size_t i=0; i<SERVER_THREAD_POOL; ++i)    {       server_threads_.create_thread(boost::bind(&boost::asio::io_service::run,&server_io_service_));  }
     for (std::size_t i=0; i<TRIGGER_THREAD_POOL; ++i)   {       trigger_threads_.create_thread(boost::bind(&boost::asio::io_service::run,&trigger_io_service_));        }
 }

void AcousticDataFilter::Stop ( )

private

Definition at line 103 of file AcousticDataFilter.cpp.

 {
         DEBUG_MSG("Stop",2);
 
         server_acceptor_.close();
         delete server_work_;
 
         std::vector<pLink>::iterator i;
         for (i=links_.begin(); i!=links_.end(); ++i){ (*i)->Disconnect(); }
         server_io_service_.stop();
         server_threads_.join_all();
         server_io_service_.reset();
 
         delete trigger_work_;
         trigger_io_service_.stop();
         trigger_threads_.join_all();
         trigger_io_service_.reset();
         
         links_.clear();
         doms_.clear();
         probes_.clear();
         
         if (toa_file_.is_open()) toa_file_.close();
 }

void AcousticDataFilter::Open_toa_file ( )

private

Definition at line 320 of file AcousticDataFilter.cpp.

 {
         std::string l_file=toa_file_path_;
         std::time_t seconds = std::time(0);
         l_file+="TOA_"+std::to_string((long long unsigned int)seconds)+".bin";
         toa_file_.open(l_file.c_str(),std::ofstream::binary);
     DEBUG_MSG("Toa file opened at "<<seconds,1);
 }

void AcousticDataFilter::Send_toa ( ToA_Packet packet )

private

Definition at line 301 of file AcousticDataFilter.cpp.

 {
         if (!running_) return;
  
     DEBUG_MSG("Sent toa from ID="<<packet.Header.DOM_Identifier,3);
         
         if (!toa_file_.is_open()) Open_toa_file();
 
         if (toa_file_.tellp()>MAX_TOA_SIZE)
         {
                 DEBUG_MSG("Toa file closed",1);
                 toa_file_.close();
                 Open_toa_file();
         }
 
         if (toa_file_.is_open()) toa_file_.write((char*)&packet,sizeof(ToA_Packet));
         
 }

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

Definition at line 143 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.

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 195 of file JDAQClient.hh.

     {
       using namespace std;
 
       if (server.is_valid() && logger.is_valid()) {
 
         try {
           
           server->Subscribe(getSubscription(eventTable));
           server->SendMeAlways();
           server->MyId(getFullName());
           
           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.

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

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

inlineinherited

Get full name of this run control client.

Returns: full name

Definition at line 248 of file JDAQClient.hh.

     {
       return full_name;
     }

const JNET::JTag& KM3NETDAQ::JDAQClient::getUniqueTag ( ) const

inlineinherited

Get unique tag of this run control client.

Returns: unique tag

Definition at line 259 of file JDAQClient.hh.

     {
       return unique_tag;
     }

int KM3NETDAQ::JDAQClient::getEventNumber ( ) const

inlineinherited

Get last event number.

Returns: event number

Definition at line 270 of file JDAQClient.hh.

     {
       return event_number;
     }

bool KM3NETDAQ::JDAQClient::isRunning ( ) const

inlineinherited

Check if this client is in runnig state.

Returns: true if running; else false

Definition at line 281 of file JDAQClient.hh.

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

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

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

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

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

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

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

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

inlineinherited

Get total delay time.

Returns: delay time [us]

Definition at line 352 of file JDAQClient.hh.

     {
       return clock.getDelay();
     }

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

inlineinherited

Get hostname.

Returns: host name

Definition at line 363 of file JDAQClient.hh.

     {
       return hostname;
     }

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

inlineinherited

Get interval time.

Returns: interval time [us]

Definition at line 374 of file JDAQClient.hh.

     {
       return clock.getInterval();
     }

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

inlineinherited

Set interval time.

Parameters

interval_us interval time [us]

Definition at line 385 of file JDAQClient.hh.

     {
       clock.setInterval(interval_us);
     }

void KM3NETDAQ::JDAQClient::resetClock ( )

inlineinherited

Reset clock.

Definition at line 394 of file JDAQClient.hh.

     {
       clock.reset();
     }

void KM3NETDAQ::JDAQClient::setSelect ( )

inlineinherited

Set the file descriptor mask for the select call.

Definition at line 403 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::JDataWriter, and KM3NETDAQ::MonitorRouter.

Definition at line 419 of file JDAQClient.hh.

420 {}

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::DataQueue, KM3NETDAQ::JDataWriter, and KM3NETDAQ::MonitorRouter.

Definition at line 429 of file JDAQClient.hh.

430 {}

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

inlinevirtualinherited

Filter message.

The filter method can be overloaded 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 477 of file JDAQClient.hh.

     {
       return false;
     }

void KM3NETDAQ::JDAQClient::run ( )

inlineinherited

Run as run control client following command messages via JNET::JControlHost.

This method can be called once the state machine is entered. It returns when the state machine is exited. If the clock interval is non-zero, the method actionRunning() is repeatedly called when this client machine is in state Running. The file descriptor mask can be set to interrupt the timeout of the select call and clock method wait() in this calling sequence (see methods setSelect() and actionSelect()).

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

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

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

Member Data Documentation

const int AcousticDataFilter::DEBUG_LEVEL =1

static

Definition at line 49 of file AcousticDataFilter.h.

boost::atomic<bool> AcousticDataFilter::exit_

private

Definition at line 90 of file AcousticDataFilter.h.

boost::atomic<bool> AcousticDataFilter::running_

private

Definition at line 91 of file AcousticDataFilter.h.

std::string AcousticDataFilter::address_

private

Definition at line 92 of file AcousticDataFilter.h.

std::string AcousticDataFilter::port_

private

Definition at line 93 of file AcousticDataFilter.h.

std::map<std::size_t,pProbe> AcousticDataFilter::probes_

private

Definition at line 95 of file AcousticDataFilter.h.

std::map<std::size_t,pDOM> AcousticDataFilter::doms_

private

Definition at line 96 of file AcousticDataFilter.h.

std::vector<pLink> AcousticDataFilter::links_

private

Definition at line 97 of file AcousticDataFilter.h.

boost::thread_group AcousticDataFilter::server_threads_

private

Definition at line 99 of file AcousticDataFilter.h.

boost::asio::io_service AcousticDataFilter::server_io_service_

private

Definition at line 100 of file AcousticDataFilter.h.

boost::asio::io_service::work* AcousticDataFilter::server_work_

private

Definition at line 101 of file AcousticDataFilter.h.

boost::asio::ip::tcp::acceptor AcousticDataFilter::server_acceptor_

private

Definition at line 102 of file AcousticDataFilter.h.

boost::thread_group AcousticDataFilter::trigger_threads_

private

Definition at line 103 of file AcousticDataFilter.h.

boost::asio::io_service AcousticDataFilter::trigger_io_service_

private

Definition at line 104 of file AcousticDataFilter.h.

boost::asio::io_service::work* AcousticDataFilter::trigger_work_

private

Definition at line 105 of file AcousticDataFilter.h.

boost::asio::io_service::strand AcousticDataFilter::strand_

private

Definition at line 106 of file AcousticDataFilter.h.

std::string AcousticDataFilter::debug_file_path_

private

Definition at line 108 of file AcousticDataFilter.h.

std::string AcousticDataFilter::toa_file_path_

private

Definition at line 109 of file AcousticDataFilter.h.

std::ofstream AcousticDataFilter::toa_file_

private

Definition at line 110 of file AcousticDataFilter.h.

std::string AcousticDataFilter::wisdom_file_

private

Definition at line 111 of file AcousticDataFilter.h.

const int KM3NETDAQ::JDAQClient::TIMEOUT_S = 1

staticinherited

time out of update [s]

Definition at line 631 of file JDAQClient.hh.

JSharedPointer<JControlHost> KM3NETDAQ::JDAQClient::server

protectedinherited

message server

Definition at line 635 of file JDAQClient.hh.

JMessageLogger KM3NETDAQ::JDAQClient::logger

protectedinherited

message logger

Definition at line 636 of file JDAQClient.hh.

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

Public Member Functions

Static Public Attributes

Protected Attributes

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation