Transports::Evologics::Task Struct Reference

Public Member Functions
	Task (const std::string &name, Tasks::Context &ctx)
	~Task (void)
void	onResourceAcquisition (void)
void	onResourceRelease (void)
std::string	readString (double timeout=2.0)
bool	waitReply (const char *reply, const char *alt_reply, double timeout=2.0)
void	writeString (const std::string &str)
void	onResourceInitialization (void)
void	consume (const IMC::AcousticOperation *msg)
void	openFile (const char *data, unsigned data_size)
void	handleInstantMessage (Reply *msg)
void	handleMessage (Reply *msg)
void	onMain (void)

Public Attributes
EvologicsMap	m_modem_addrs
AddressMap	m_modem_to_imc_table
AddressMap	m_imc_to_modem_table
TCPSocket *	m_sock
IOMultiplexing *	m_iom
unsigned	m_address
Listener *	m_listener
Arguments	m_args
std::ofstream	m_file
unsigned	m_file_frames
unsigned	m_file_frames_now

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::low_gain, m_address, m_args, m_imc_to_modem_table, m_modem_addrs, m_modem_to_imc_table, Transports::Evologics::Arguments::pool_size, Transports::Evologics::Arguments::port, and Transports::Evologics::Arguments::source_level.

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

inline

References onResourceRelease().

Member Function Documentation

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

inline

References m_listener, Transports::Evologics::Listener::queueInstantMessage(), and Transports::Evologics::Listener::queueMessage().

void Transports::Evologics::Task::handleInstantMessage ( Reply *  msg )

inline

References Transports::Evologics::Reply::Data::data, Transports::Evologics::Reply::data, and Transports::Evologics::Reply::Data::recv.

Referenced by onMain().

void Transports::Evologics::Task::handleMessage ( Reply *  msg )

inline

References Transports::Evologics::Reply::Data::data, Transports::Evologics::Reply::data, Transports::Evologics::Reply::Data::data_size, m_file, m_file_frames, m_file_frames_now, openFile(), and Transports::Evologics::Reply::Data::recv.

Referenced by onMain().

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

inline

References Transports::Evologics::Listener::dequeueInstantMessage(), Transports::Evologics::Listener::dequeueMessage(), handleInstantMessage(), handleMessage(), m_listener, m_sock, and DUNE::Concurrency::Runnable::start().

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

inline

References Transports::Evologics::Arguments::address, m_args, m_iom, 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::low_gain, m_address, m_args, m_iom, m_sock, Transports::Evologics::Arguments::source_level, waitReply(), and writeString().

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

inline

References m_iom, m_listener, m_sock, and DUNE::Concurrency::Runnable::stopAndJoin().

Referenced by ~Task().

void Transports::Evologics::Task::openFile ( const char *  data, unsigned  data_size  )

inline

References m_file, m_file_frames, and m_file_frames_now.

Referenced by handleMessage().

std::string Transports::Evologics::Task::readString ( double  timeout = 2.0 )

inline

References m_iom, and m_sock.

Referenced by waitReply().

bool Transports::Evologics::Task::waitReply ( const char *  reply, const char *  alt_reply, double  timeout = 2.0  )

inline

References readString().

Referenced by onResourceInitialization().

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

inline

References m_sock.

Referenced by onResourceInitialization().

Member Data Documentation

unsigned Transports::Evologics::Task::m_address

Referenced by onResourceInitialization(), and Task().

Arguments Transports::Evologics::Task::m_args

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

std::ofstream Transports::Evologics::Task::m_file

Referenced by handleMessage(), and openFile().

unsigned Transports::Evologics::Task::m_file_frames

Referenced by handleMessage(), and openFile().

unsigned Transports::Evologics::Task::m_file_frames_now

Referenced by handleMessage(), and openFile().

AddressMap Transports::Evologics::Task::m_imc_to_modem_table

Referenced by Task().

IOMultiplexing* Transports::Evologics::Task::m_iom

Referenced by onResourceAcquisition(), onResourceInitialization(), onResourceRelease(), and readString().

Listener* Transports::Evologics::Task::m_listener

Referenced by consume(), onMain(), and onResourceRelease().

EvologicsMap Transports::Evologics::Task::m_modem_addrs

Referenced by Task().

AddressMap Transports::Evologics::Task::m_modem_to_imc_table

Referenced by Task().

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

Referenced by onMain(), onResourceAcquisition(), onResourceInitialization(), onResourceRelease(), readString(), and writeString().

Collaboration diagram for Transports::Evologics::Task: