certifier.h File Reference

#include <assert.h>
#include <mysql/group_replication_priv.h>
#include <atomic>
#include <list>
#include <map>
#include <string>
#include <unordered_map>
#include <vector>
#include "my_inttypes.h"
#include "plugin/group_replication/include/certification/certified_gtid.h"
#include "plugin/group_replication/include/certification/gtid_generator.h"
#include "plugin/group_replication/include/certification_result.h"
#include "plugin/group_replication/include/certifier_stats_interface.h"
#include "plugin/group_replication/include/gcs_plugin_messages.h"
#include "plugin/group_replication/include/gr_compression.h"
#include "plugin/group_replication/include/gr_decompression.h"
#include "plugin/group_replication/include/member_info.h"
#include "plugin/group_replication/include/pipeline_interfaces.h"
#include "plugin/group_replication/include/plugin_messages/recovery_metadata_message.h"
#include "plugin/group_replication/include/plugin_utils.h"
#include "plugin/group_replication/libmysqlgcs/include/mysql/gcs/gcs_communication_interface.h"
#include "plugin/group_replication/libmysqlgcs/include/mysql/gcs/gcs_control_interface.h"
#include "plugin/group_replication/generated/protobuf_lite/replication_group_recovery_metadata.pb.h"
#include "mysql/utils/return_status.h"

Go to the source code of this file.

Classes
class	Gtid_set_ref
	This class extends Gtid_set to include a reference counter. More...
class	Certifier_broadcast_thread
	This class is a core component of the database state machine replication protocol. More...
class	Certifier_interface
class	Certifier
class	Gtid_Executed_Message

Macros
#define	MAX_COMPRESSED_PACKET_SIZE   10485760
	While sending Recovery Metadata the Certification Information is divided into several small packets of MAX_COMPRESSED_PACKET_SIZE before sending it to group for Recovery. More...

Macro Definition Documentation

MAX_COMPRESSED_PACKET_SIZE

#define MAX_COMPRESSED_PACKET_SIZE   10485760

While sending Recovery Metadata the Certification Information is divided into several small packets of MAX_COMPRESSED_PACKET_SIZE before sending it to group for Recovery.

The compressed packet size is choosen as 10MB so that multiple threads can process (serialize and compress or unserialize and decompress) packets simultaneously without consuming too much memory.