Transports::Evologics::Listener Class Reference

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)

Constructor & Destructor Documentation

Transports::Evologics::Listener::Listener ( DUNE::Network::TCPSocket *  sock )

inline

References DUNE::Network::TCPSocket::addToPoll().

Transports::Evologics::Listener::~Listener ( void  )

inline

References clearReplyQueue().

Member Function Documentation

void Transports::Evologics::Listener::clearCommandQueue ( void  )

inline

Referenced by queueInstantMessage(), and queueMessage().

void Transports::Evologics::Listener::clearReplyQueue ( void  )

inline

Referenced by queueInstantMessage(), queueMessage(), and ~Listener().

Reply* Transports::Evologics::Listener::dequeueInstantMessage ( void  )

inline

Referenced by Transports::Evologics::Task::onMain().

Reply* Transports::Evologics::Listener::dequeueMessage ( void  )

inline

Referenced by Transports::Evologics::Task::onMain().

Reply* Transports::Evologics::Listener::dequeueReply ( void  )

inline

bool Transports::Evologics::Listener::queueInstantMessage ( unsigned  address, const char *  data, unsigned  data_size  )

inline

References clearCommandQueue(), clearReplyQueue(), DUNE::Utils::String::str(), and writeString().

Referenced by Transports::Evologics::Task::consume().

bool Transports::Evologics::Listener::queueMessage ( unsigned  address, const char *  data, unsigned  data_size  )

inline

References clearCommandQueue(), clearReplyQueue(), DUNE::Utils::String::str(), and writeString().

Referenced by Transports::Evologics::Task::consume().

void Transports::Evologics::Listener::run ( void  )

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.

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

inline

References Transports::Evologics::printHex(), and DUNE::Network::TCPSocket::write().

Referenced by queueInstantMessage(), and queueMessage().

Collaboration diagram for Transports::Evologics::Listener: