Message_service_handler Class Reference

Handles the deliver of recv service messages to subscribed modules. More...

#include <message_service.h>

Public Member Functions
	Message_service_handler ()
	Create a message service handler to deliver messages to recv subscribers. More...
virtual	~Message_service_handler ()
int	initialize ()
	Initialize thread that will deliver messages. More...
void	dispatcher ()
	Main loop that checks message availability. More...
int	terminate ()
	Terminate delivering message thread. More...
void	add (Group_service_message *message)
	Add to queue a new message to be deliver to recv service subscribers. More...
bool	notify_message_service_recv (Group_service_message *service_message)
	It will notify recv subscribers with a service message. More...

Private Attributes
bool	m_aborted
	Thread was terminated. More...
my_thread_handle	m_message_service_pthd
	The current phase. More...
mysql_mutex_t	m_message_service_run_lock
	The thread lock to control access. More...
mysql_cond_t	m_message_service_run_cond
	The thread signal mechanism to be terminated. More...
thread_state	m_message_service_thd_state
	The state of the thread. More...
Abortable_synchronized_queue< Group_service_message * > *	m_incoming
	Queue with service message to be delivered. More...

Detailed Description

Handles the deliver of recv service messages to subscribed modules.

Constructor & Destructor Documentation

Message_service_handler()

Message_service_handler::Message_service_handler

(

)

Create a message service handler to deliver messages to recv subscribers.

~Message_service_handler()

Message_service_handler::~Message_service_handler ( )

virtual

Member Function Documentation

add()

void Message_service_handler::add

(

Group_service_message *

message

)

Add to queue a new message to be deliver to recv service subscribers.

Parameters

[in]

message

message to be delivered

dispatcher()

void Message_service_handler::dispatcher

(

)

Main loop that checks message availability.

initialize()

int Message_service_handler::initialize

(

)

Initialize thread that will deliver messages.

Returns

returns 0 if succeeds, error otherwise

notify_message_service_recv()

bool Message_service_handler::notify_message_service_recv

(

Group_service_message *

service_message

)

It will notify recv subscribers with a service message.

Parameters

[in]

service_message

message to process

Returns

false if message is delivered, true otherwise

terminate()

int Message_service_handler::terminate

(

)

Terminate delivering message thread.

Returns

returns 0 if succeeds, error otherwise

Member Data Documentation

m_aborted

bool Message_service_handler::m_aborted

private

Thread was terminated.

m_incoming

Abortable_synchronized_queue<Group_service_message *>* Message_service_handler::m_incoming

private

Queue with service message to be delivered.

m_message_service_pthd

my_thread_handle Message_service_handler::m_message_service_pthd

private

The current phase.

m_message_service_run_cond

mysql_cond_t Message_service_handler::m_message_service_run_cond

private

The thread signal mechanism to be terminated.

m_message_service_run_lock

mysql_mutex_t Message_service_handler::m_message_service_run_lock

private

The thread lock to control access.

m_message_service_thd_state

thread_state Message_service_handler::m_message_service_thd_state

private

The state of the thread.

---

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

• plugin/group_replication/include/services/message_service/message_service.h
• plugin/group_replication/src/services/message_service/message_service.cc