message_service.cc File Reference

#include "plugin/group_replication/include/services/message_service/message_service.h"
#include <mysql/components/my_service.h>
#include <mysql/components/services/group_replication_message_service.h>
#include <mysql/components/services/registry.h>
#include "plugin/group_replication/include/leave_group_on_failure.h"
#include "plugin/group_replication/include/plugin.h"
#include "string_with_len.h"

Functions
mysql_service_status_t	send (const char *tag, const unsigned char *data, const size_t data_length) noexcept
bool	register_gr_message_service_send ()
	Register default send message service. More...
bool	unregister_gr_message_service_send ()
	Unregister default send message service. More...
static void *	launch_message_service_handler_thread (void *arg)

Variables
const mysql_service_group_replication_message_service_send_t	imp_group_replication_group_replication_message_service_send

Function Documentation

launch_message_service_handler_thread()

static void * launch_message_service_handler_thread ( void *  arg )

static

register_gr_message_service_send()

bool register_gr_message_service_send

(

)

Register default send message service.

send()

mysql_service_status_t send ( const char *  tag, const unsigned char *  data, const size_t  data_length  )

noexcept

unregister_gr_message_service_send()

bool unregister_gr_message_service_send

(

)

Unregister default send message service.

Variable Documentation

imp_group_replication_group_replication_message_service_send

const mysql_service_group_replication_message_service_send_t imp_group_replication_group_replication_message_service_send

Initial value:

= {
send, }