Transports::Evologics::Task Struct Reference

Public Member Functions
	Task (const std::string &name, Tasks::Context &ctx)
	~Task (void)
void	onEntityResolution (void)
void	onUpdateParameters (void)
void	onResourceAcquisition (void)
void	onResourceRelease (void)
void	onResourceInitialization (void)
unsigned	lookupSystemAddress (const std::string &name)
std::string	lookupSystemName (unsigned addr)
void	consume (const IMC::SoundSpeed *msg)
void	consume (const IMC::DevDataText *msg)
void	clearTicket (IMC::UamTxStatus::ValueEnum reason, const std::string &error="")
void	replaceTicket (const Ticket &ticket)
void	sendTxStatus (const Ticket &ticket, IMC::UamTxStatus::ValueEnum value, const std::string &error="")
void	consume (const IMC::UamTxFrame *msg)
void	handleInstantMessageFailed (const std::string &str)
void	handleInstantMessageDelivered (const std::string &str)
void	handleSendEnd (const std::string &str)
void	handleInstantMessage (const std::string &str)
void	keepAlive (void)
void	onMain (void)

Public Attributes
MapName	m_modem_names
MapAddr	m_modem_addrs
TCPSocket *	m_sock
unsigned	m_address
Driver *	m_driver
double	m_sound_speed
int	m_sound_speed_eid
Ticket *	m_ticket
Counter< double >	m_kalive_counter
Arguments	m_args

Constructor & Destructor Documentation

Transports::Evologics::Task::Task ( const std::string &  name, Tasks::Context &  ctx  )

inline

References Transports::Evologics::Arguments::address, Transports::Evologics::Arguments::con_idle_tout, Transports::Evologics::Arguments::con_retry_count, Transports::Evologics::Arguments::con_retry_tout, Transports::Evologics::Arguments::im_retry_count, Transports::Evologics::Arguments::kalive_tout, Transports::Evologics::Arguments::low_gain, m_address, m_args, m_modem_addrs, m_modem_names, Transports::Evologics::Arguments::pool_size, Transports::Evologics::Arguments::port, Transports::Evologics::Arguments::sound_speed_def, Transports::Evologics::Arguments::sound_speed_elabel, and Transports::Evologics::Arguments::source_level.

Transports::Evologics::Task::~Task ( void  )

inline

References onResourceRelease().

Member Function Documentation

void Transports::Evologics::Task::clearTicket ( IMC::UamTxStatus::ValueEnum  reason, const std::string &  error = ""  )

inline

References m_ticket, and sendTxStatus().

Referenced by handleInstantMessageDelivered(), handleInstantMessageFailed(), handleSendEnd(), onResourceRelease(), and replaceTicket().

void Transports::Evologics::Task::consume ( const IMC::SoundSpeed *  msg )

inline

References m_sound_speed, and m_sound_speed_eid.

void Transports::Evologics::Task::consume ( const IMC::DevDataText *  msg )

inline

References handleInstantMessage(), handleInstantMessageDelivered(), handleInstantMessageFailed(), and handleSendEnd().

void Transports::Evologics::Task::consume ( const IMC::UamTxFrame *  msg )

inline

References Transports::Evologics::Ticket::ack, Transports::Evologics::Ticket::addr, Transports::Evologics::Ticket::imc_eid, Transports::Evologics::Ticket::imc_sid, lookupSystemAddress(), m_driver, m_kalive_counter, replaceTicket(), DUNE::Time::Counter< T >::reset(), Transports::Evologics::Driver::sendIM(), sendTxStatus(), and Transports::Evologics::Ticket::seq.

void Transports::Evologics::Task::handleInstantMessage ( const std::string &  str )

inline

References Transports::Evologics::RecvIM::data, Transports::Evologics::RecvIM::dst, lookupSystemName(), m_address, m_driver, Transports::Evologics::Driver::parse(), and Transports::Evologics::RecvIM::src.

Referenced by consume().

void Transports::Evologics::Task::handleInstantMessageDelivered ( const std::string &  str )

inline

References clearTicket(), Transports::Evologics::Driver::getPropagationTime(), lookupSystemName(), m_driver, m_sound_speed, m_ticket, and Transports::Evologics::Ticket::seq.

Referenced by consume().

void Transports::Evologics::Task::handleInstantMessageFailed ( const std::string &  str )

inline

References clearTicket(), and m_driver.

Referenced by consume().

void Transports::Evologics::Task::handleSendEnd ( const std::string &  str )

inline

References Transports::Evologics::Ticket::ack, clearTicket(), m_driver, and m_ticket.

Referenced by consume().

void Transports::Evologics::Task::keepAlive ( void  )

inline

References Transports::Evologics::Driver::getClock(), m_driver, m_kalive_counter, DUNE::Time::Counter< T >::overflow(), and DUNE::Time::Counter< T >::reset().

Referenced by onMain().

unsigned Transports::Evologics::Task::lookupSystemAddress ( const std::string &  name )

inline

References m_modem_names.

Referenced by consume().

std::string Transports::Evologics::Task::lookupSystemName ( unsigned  addr )

inline

References m_modem_addrs.

Referenced by handleInstantMessage(), and handleInstantMessageDelivered().

void Transports::Evologics::Task::onEntityResolution ( void  )

inline

References m_args, m_sound_speed, m_sound_speed_eid, Transports::Evologics::Arguments::sound_speed_def, and Transports::Evologics::Arguments::sound_speed_elabel.

void Transports::Evologics::Task::onMain ( void  )

inline

References keepAlive().

void Transports::Evologics::Task::onResourceAcquisition ( void  )

inline

References Transports::Evologics::Arguments::address, m_args, m_driver, m_sock, and Transports::Evologics::Arguments::port.

void Transports::Evologics::Task::onResourceInitialization ( void  )

inline

References Transports::Evologics::Arguments::con_idle_tout, Transports::Evologics::Arguments::con_retry_count, Transports::Evologics::Arguments::con_retry_tout, Transports::Evologics::Arguments::im_retry_count, Transports::Evologics::Arguments::kalive_tout, Transports::Evologics::Arguments::low_gain, m_address, m_args, m_driver, m_kalive_counter, Transports::Evologics::Driver::setAddress(), Transports::Evologics::Driver::setExtendedNotifications(), Transports::Evologics::Driver::setIdleTimeout(), Transports::Evologics::Driver::setLowGain(), Transports::Evologics::Driver::setPositionDataOutput(), Transports::Evologics::Driver::setPromiscuous(), Transports::Evologics::Driver::setRetryCount(), Transports::Evologics::Driver::setRetryCountIM(), Transports::Evologics::Driver::setRetryTimeout(), Transports::Evologics::Driver::setSourceLevel(), DUNE::Time::Counter< T >::setTop(), and Transports::Evologics::Arguments::source_level.

void Transports::Evologics::Task::onResourceRelease ( void  )

inline

References clearTicket(), m_driver, and m_sock.

Referenced by ~Task().

void Transports::Evologics::Task::onUpdateParameters ( void  )

inline

References m_args, m_sound_speed, and Transports::Evologics::Arguments::sound_speed_def.

void Transports::Evologics::Task::replaceTicket ( const Ticket &  ticket )

inline

References clearTicket(), and m_ticket.

Referenced by consume().

void Transports::Evologics::Task::sendTxStatus ( const Ticket &  ticket, IMC::UamTxStatus::ValueEnum  value, const std::string &  error = ""  )

inline

References Transports::Evologics::Ticket::imc_eid, Transports::Evologics::Ticket::imc_sid, and Transports::Evologics::Ticket::seq.

Referenced by clearTicket(), and consume().

Member Data Documentation

unsigned Transports::Evologics::Task::m_address

Modem address.

Referenced by handleInstantMessage(), onResourceInitialization(), and Task().

Arguments Transports::Evologics::Task::m_args

Task arguments.

Referenced by onEntityResolution(), onResourceAcquisition(), onResourceInitialization(), onUpdateParameters(), and Task().

Driver* Transports::Evologics::Task::m_driver

Driver.

Referenced by consume(), handleInstantMessage(), handleInstantMessageDelivered(), handleInstantMessageFailed(), handleSendEnd(), keepAlive(), onResourceAcquisition(), onResourceInitialization(), and onResourceRelease().

Counter<double> Transports::Evologics::Task::m_kalive_counter

Keep-alive counter.

Referenced by consume(), keepAlive(), and onResourceInitialization().

MapAddr Transports::Evologics::Task::m_modem_addrs

Map of Evologics modems by address.

Referenced by lookupSystemName(), and Task().

MapName Transports::Evologics::Task::m_modem_names

Map of Evologics modems by name.

Referenced by lookupSystemAddress(), and Task().

TCPSocket* Transports::Evologics::Task::m_sock

TCP socket.

Referenced by onResourceAcquisition(), and onResourceRelease().

double Transports::Evologics::Task::m_sound_speed

Referenced by consume(), handleInstantMessageDelivered(), onEntityResolution(), and onUpdateParameters().

int Transports::Evologics::Task::m_sound_speed_eid

Sound speed entity id.

Referenced by consume(), and onEntityResolution().

Ticket* Transports::Evologics::Task::m_ticket

Current transmission ticket.

Referenced by clearTicket(), handleInstantMessageDelivered(), handleSendEnd(), and replaceTicket().

Collaboration diagram for Transports::Evologics::Task: