msg_queue_processor Class Reference

class inherits thread processor class More...

#include <msg_que.h>

Inheritance diagram for msg_queue_processor:

List of all members.

Public Member Functions
	msg_queue_processor (msg_communicator *communicator)
	constructor
	~msg_queue_processor ()
	destructor
Protected Member Functions
virtual bool	v_has_job (size_t ident, void *user_data)
	checks queue
virtual void	v_on ()
	action on turning on
virtual void	v_off ()
	action on turning off

---

Detailed Description

class inherits thread processor class

Definition at line 229 of file msg_que.h.

---

Constructor & Destructor Documentation

BEGIN_TERIMBER_NAMESPACE msg_queue_processor::msg_queue_processor

(

msg_communicator *

communicator

)

constructor

Parameters:

communicator

pointer to communicator

Definition at line 36 of file msg_que.cpp.

msg_queue_processor::~msg_queue_processor

(

)

destructor

Definition at line 40 of file msg_que.cpp.

---

Member Function Documentation

bool msg_queue_processor::v_has_job	(	size_t	ident,
		void *	user_data
	)			[protected, virtual]

checks queue

Parameters:

ident	thread ident
user_data	user defined data

Implements terimber_thread_employer.

Reimplemented in msg_sock_connection, and msg_user_connection.

Definition at line 63 of file msg_que.cpp.

References msg_queue< 3 >::is_block(), and msg_queue< 3 >::peek().

Referenced by msg_user_connection::v_has_job(), and msg_sock_connection::v_has_job().

void msg_queue_processor::v_on

(

)

[protected, virtual]

action on turning on

Reimplemented from msg_base.

Reimplemented in msg_communicator.

Definition at line 47 of file msg_que.cpp.

References msg_base::v_on(), and msg_queue< 3 >::wakeup().

Referenced by msg_sock_connection::accept(), and msg_communicator::v_on().

void msg_queue_processor::v_off

(

)

[protected, virtual]

action on turning off

Reimplemented from msg_base.

Reimplemented in msg_communicator, and msg_user_connection.

Definition at line 55 of file msg_que.cpp.

References msg_base::_communicator, msg_communicator::get_thread_manager(), threadpool::revoke_client(), and msg_base::v_off().

Referenced by msg_user_connection::v_off(), and msg_communicator::v_off().

---

The documentation for this class was generated from the following files:

• msg_que.h
• msg_que.cpp