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)
std::string	safeLookup (unsigned addr)
void	consume (const IMC::GpsFix *msg)
void	consume (const IMC::SoundSpeed *msg)
void	consume (const IMC::VehicleMedium *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	transmitData (const uint8_t *data, unsigned data_size, Ticket &ticket)
void	handleMessageFailed (const std::string &str)
void	handleMessageDelivered (const std::string &str)
void	handleSendEnd (const std::string &str)
void	handleInstantMessage (const std::string &str, bool piggyback)
void	handleBurstMessage (const std::string &str)
void	handleUsblPosition (const std::string &str)
void	handleUsblAngles (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
bool	m_declination
Ticket *	m_ticket
Counter< double >	m_kalive_counter
IMC::VehicleMedium	m_medium
Arguments	m_args

Constructor & Destructor Documentation

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

inline

References Transports::Evologics::Arguments::addr_section, 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::highest_addr, Transports::Evologics::Arguments::im_retry_count, Transports::Evologics::Arguments::kalive_tout, Transports::Evologics::Arguments::low_gain, m_args, m_medium, Transports::Evologics::Arguments::pool_size, Transports::Evologics::Arguments::port, Transports::Evologics::Arguments::sound_speed_def, Transports::Evologics::Arguments::sound_speed_elabel, Transports::Evologics::Arguments::source_level, Transports::Evologics::Arguments::src_level_control, Transports::Evologics::Arguments::src_level_underwater, Transports::Evologics::Arguments::src_level_unknown, and Transports::Evologics::Arguments::src_level_water.

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 handleMessageDelivered(), handleMessageFailed(), handleSendEnd(), onResourceRelease(), and replaceTicket().

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

inline

References m_declination, m_driver, and Transports::Evologics::Driver::setDeclination().

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::VehicleMedium *  msg )

inline

References m_args, m_driver, m_medium, Transports::Evologics::Driver::setSourceLevel(), Transports::Evologics::Arguments::src_level_control, Transports::Evologics::Arguments::src_level_underwater, Transports::Evologics::Arguments::src_level_unknown, and Transports::Evologics::Arguments::src_level_water.

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

inline

References handleBurstMessage(), handleInstantMessage(), handleMessageDelivered(), handleMessageFailed(), handleSendEnd(), handleUsblAngles(), and handleUsblPosition().

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, Transports::Evologics::Ticket::pbm, replaceTicket(), DUNE::Time::Counter< T >::reset(), sendTxStatus(), Transports::Evologics::Ticket::seq, and transmitData().

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

inline

References Transports::Evologics::RecvIM::data, Transports::Evologics::RecvIM::dst, Transports::Evologics::Driver::getMultipathStructure(), Transports::Evologics::RecvIM::integrity, m_driver, Transports::Evologics::Driver::parseReceivedBurst(), Transports::Evologics::RecvIM::rssi, safeLookup(), and Transports::Evologics::RecvIM::src.

Referenced by consume().

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

inline

References Transports::Evologics::RecvIM::data, Transports::Evologics::RecvIM::dst, Transports::Evologics::Driver::getMultipathStructure(), Transports::Evologics::RecvIM::integrity, m_address, m_driver, Transports::Evologics::Driver::parse(), Transports::Evologics::RecvIM::rssi, safeLookup(), and Transports::Evologics::RecvIM::src.

Referenced by consume().

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

inline

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

Referenced by consume().

void Transports::Evologics::Task::handleMessageFailed ( 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::handleUsblAngles ( const std::string &  str )

inline

References Transports::Evologics::RecvUsblAng::addr, Transports::Evologics::RecvUsblAng::fill(), m_driver, Transports::Evologics::Driver::parseUsblAngles(), and safeLookup().

Referenced by consume().

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

inline

References Transports::Evologics::RecvUsblPos::addr, Transports::Evologics::RecvUsblPos::fill(), m_driver, Transports::Evologics::Driver::parseUsblPosition(), and safeLookup().

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 handleMessageDelivered(), and safeLookup().

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::addr_section, Transports::Evologics::Arguments::con_idle_tout, Transports::Evologics::Arguments::con_retry_count, Transports::Evologics::Arguments::con_retry_tout, Transports::Evologics::Arguments::highest_addr, 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, m_modem_addrs, m_modem_names, Transports::Evologics::Driver::setAddress(), Transports::Evologics::Driver::setControl(), Transports::Evologics::Driver::setExtendedNotifications(), Transports::Evologics::Driver::setHighestAddress(), 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().

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

inline

References lookupSystemName().

Referenced by handleBurstMessage(), handleInstantMessage(), handleUsblAngles(), and handleUsblPosition().

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().

void Transports::Evologics::Task::transmitData ( const uint8_t *  data, unsigned  data_size, Ticket &  ticket  )

inline

References Transports::Evologics::Ticket::ack, Transports::Evologics::Ticket::addr, m_driver, Transports::Evologics::Ticket::pbm, Transports::Evologics::Driver::sendBurst(), Transports::Evologics::Driver::sendIM(), and Transports::Evologics::Driver::sendPBM().

Referenced by consume().

Member Data Documentation

unsigned Transports::Evologics::Task::m_address

Modem address.

Referenced by handleInstantMessage(), and onResourceInitialization().

Arguments Transports::Evologics::Task::m_args

Task arguments.

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

bool Transports::Evologics::Task::m_declination

Declination flag;.

Referenced by consume().

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

Driver.

Referenced by consume(), handleBurstMessage(), handleInstantMessage(), handleMessageDelivered(), handleMessageFailed(), handleSendEnd(), handleUsblAngles(), handleUsblPosition(), keepAlive(), onResourceAcquisition(), onResourceInitialization(), onResourceRelease(), and transmitData().

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

Keep-alive counter.

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

IMC::VehicleMedium Transports::Evologics::Task::m_medium

Medium.

Referenced by consume(), and Task().

MapAddr Transports::Evologics::Task::m_modem_addrs

Map of Evologics modems by address.

Referenced by lookupSystemName(), and onResourceInitialization().

MapName Transports::Evologics::Task::m_modem_names

Map of Evologics modems by name.

Referenced by lookupSystemAddress(), and onResourceInitialization().

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

TCP socket.

Referenced by onResourceAcquisition(), and onResourceRelease().

double Transports::Evologics::Task::m_sound_speed

Referenced by consume(), handleMessageDelivered(), 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(), handleMessageDelivered(), handleSendEnd(), and replaceTicket().

Collaboration diagram for Transports::Evologics::Task: