DUNE: Uniform Navigational Environment
2017.01.0
|
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 |
Poll | m_poll |
std::list< Session * > | m_busy_list |
Mutex | m_busy_list_lock |
Static Public Attributes | |
static const int | c_port_retries |
|
inline |
|
inline |
References onResourceRelease().
|
inline |
References m_args, m_busy_list, and Transports::FTP::Arguments::session_tout.
Referenced by onMain().
|
inline |
References m_busy_list.
Referenced by onMain().
|
inline |
Referenced by onResourceAcquisition().
|
inline |
References acceptNewClient(), cleanBusyList(), m_poll, and m_sockets.
|
inline |
References Transports::FTP::Arguments::control_port, createSocket(), m_args, m_poll, and m_sockets.
|
inline |
References m_busy_list, m_sockets, and DUNE::Concurrency::Runnable::stopAndJoin().
Referenced by ~Task().
|
static |
Port bind retries.
Arguments Transports::FTP::Task::m_args |
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.
Poll Transports::FTP::Task::m_poll |
I/O selector.
Referenced by onMain(), and onResourceAcquisition().
std::list<TCPSocket*> Transports::FTP::Task::m_sockets |
Control sockets.
Referenced by onMain(), onResourceAcquisition(), and onResourceRelease().