DUNE: Uniform Navigational Environment
2.3.1
|
Public Member Functions | |
Listener (DUNE::Network::TCPSocket *sock) | |
~Listener (void) | |
void | writeString (const std::string &str) |
void | clearCommandQueue (void) |
bool | queueMessage (unsigned address, const char *data, unsigned data_size) |
bool | queueInstantMessage (unsigned address, const char *data, unsigned data_size) |
void | clearReplyQueue (void) |
Reply * | dequeueReply (void) |
Reply * | dequeueMessage (void) |
Reply * | dequeueInstantMessage (void) |
void | run (void) |
Public Member Functions inherited from DUNE::Concurrency::Thread | |
Thread (void) | |
virtual | ~Thread (void) |
Public Member Functions inherited from DUNE::Concurrency::Runnable | |
Runnable (void) | |
virtual | ~Runnable (void) |
void | start (void) |
void | stop (void) |
void | join (void) |
void | stopAndJoin (void) |
void | setPriority (Scheduler::Policy policy, unsigned priority) |
State | getState (void) |
bool | isCreated (void) |
bool | isStopping (void) |
bool | isRunning (void) |
bool | isStarting (void) |
bool | isDead (void) |
Additional Inherited Members | |
Public Types inherited from DUNE::Concurrency::Runnable | |
enum | State { StateStarting, StateRunning, StateStopping, StateDead, StateUnknown } |
Static Public Member Functions inherited from DUNE::Concurrency::Thread | |
static unsigned | native (void) |
Protected Member Functions inherited from DUNE::Concurrency::Thread | |
void | startImpl (void) |
void | stopImpl (void) |
void | joinImpl (void) |
void | setPriorityImpl (Scheduler::Policy policy, unsigned priority) |
|
inline |
References DUNE::Network::TCPSocket::addToPoll().
|
inline |
References clearReplyQueue().
|
inline |
Referenced by queueInstantMessage(), and queueMessage().
|
inline |
Referenced by queueInstantMessage(), queueMessage(), and ~Listener().
|
inline |
Referenced by Transports::Evologics::Task::onMain().
|
inline |
Referenced by Transports::Evologics::Task::onMain().
|
inline |
|
inline |
References clearCommandQueue(), clearReplyQueue(), DUNE::Utils::String::str(), and writeString().
Referenced by Transports::Evologics::Task::consume().
|
inline |
References clearCommandQueue(), clearReplyQueue(), DUNE::Utils::String::str(), and writeString().
Referenced by Transports::Evologics::Task::consume().
|
inlinevirtual |
Implements DUNE::Concurrency::Runnable.
References DUNE::Concurrency::Runnable::isStopping(), Transports::Evologics::Parser::parse(), DUNE::System::IOMultiplexing::poll(), Transports::Evologics::printHex(), DUNE::Network::TCPSocket::read(), Transports::Evologics::Reply::RPL_RECV, Transports::Evologics::Reply::RPL_RECVIM, and Transports::Evologics::Reply::type.
|
inline |
References Transports::Evologics::printHex(), and DUNE::Network::TCPSocket::write().
Referenced by queueInstantMessage(), and queueMessage().