Transports::FTP::Task Struct Reference

Public Member Functions
	Task (const std::string &name, Tasks::Context &ctx)
	~Task (void)
TCPSocket *	createSocket (Address addr, uint16_t &port)
void	onResourceAcquisition (void)
void	onResourceRelease (void)
void	acceptNewClient (TCPSocket *sock, const Address &local_addr)
void	cleanBusyList (void)
void	onMain (void)

Public Attributes
Arguments	m_args
std::list< TCPSocket * >	m_sockets
IOMultiplexing	m_iom
std::list< Session * >	m_busy_list
Mutex	m_busy_list_lock

Static Public Attributes
static const int	c_port_retries

Constructor & Destructor Documentation

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

inline

References Transports::FTP::Arguments::control_port, Transports::FTP::Arguments::data_port, m_args, and Transports::FTP::Arguments::session_tout.

Transports::FTP::Task::~Task ( void  )

inline

References onResourceRelease().

Member Function Documentation

void Transports::FTP::Task::acceptNewClient ( TCPSocket *  sock, const Address &  local_addr  )

inline

References m_args, m_busy_list, and Transports::FTP::Arguments::session_tout.

Referenced by onMain().

void Transports::FTP::Task::cleanBusyList ( void  )

inline

References m_busy_list.

Referenced by onMain().

TCPSocket* Transports::FTP::Task::createSocket ( Address  addr, uint16_t &  port  )

inline

Referenced by onResourceAcquisition().

void Transports::FTP::Task::onMain ( void  )

inline

References acceptNewClient(), cleanBusyList(), m_iom, and m_sockets.

void Transports::FTP::Task::onResourceAcquisition ( void  )

inline

References Transports::FTP::Arguments::control_port, createSocket(), m_args, m_iom, and m_sockets.

void Transports::FTP::Task::onResourceRelease ( void  )

inline

References m_busy_list, m_sockets, and DUNE::Concurrency::Runnable::stopAndJoin().

Referenced by ~Task().

Member Data Documentation

const int Transports::FTP::Task::c_port_retries

static

Port bind retries.

Arguments Transports::FTP::Task::m_args

Arguments.

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

std::list<Session*> Transports::FTP::Task::m_busy_list

List of busy sessions.

Referenced by acceptNewClient(), cleanBusyList(), and onResourceRelease().

Mutex Transports::FTP::Task::m_busy_list_lock

Concurrency lock for list of busy sessions.

IOMultiplexing Transports::FTP::Task::m_iom

IO selector.

Referenced by onMain(), and onResourceAcquisition().

std::list<TCPSocket*> Transports::FTP::Task::m_sockets

Control sockets.

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

Collaboration diagram for Transports::FTP::Task: