#include <gcs_message_stage_split.h>

Inheritance diagram for Gcs_message_stage_split_v3:

Public Member Functions
	Gcs_message_stage_split_v3 (bool enabled, unsigned long long split_threshold)
	Creates an instance of the stage. More...

	~Gcs_message_stage_split_v3 () override

Stage_code	get_stage_code () const override
	Return the stage code. More...

Public Member Functions inherited from Gcs_message_stage_split_v2
Gcs_message_stage::stage_status	skip_apply (uint64_t const &original_payload_size) const override
	Check if the apply operation which affects outgoing packets should be executed (i.e. More...

std::unique_ptr< Gcs_stage_metadata >	get_stage_header () override

	Gcs_message_stage_split_v2 (bool enabled, unsigned long long split_threshold)
	Creates an instance of the stage. More...

	~Gcs_message_stage_split_v2 () override

bool	update_members_information (const Gcs_member_identifier &me, const Gcs_xcom_nodes &xcom_nodes) override
	Update the list of members in the group as this is required to process split messages. More...

void	set_threshold (unsigned long long split_threshold)
	Sets the threshold in bytes after which messages are split. More...

Public Member Functions inherited from Gcs_message_stage
	Gcs_message_stage ()

	Gcs_message_stage (bool enabled)

virtual	~Gcs_message_stage ()=default

std::pair< bool, std::vector< Gcs_packet > >	apply (Gcs_packet &&packet)
	Apply some transformation to the outgoing packet, and return a set of one, or more, transformed packets. More...

std::pair< Gcs_pipeline_incoming_result, Gcs_packet >	revert (Gcs_packet &&packet)
	Revert some transformation from the incoming packet, and return one, or none, transformed packet. More...

bool	is_enabled () const
	Return whether the message stage is enabled or not. More...

void	set_enabled (bool is_enabled)
	Enable or disable the message stage. More...

Additional Inherited Members
Public Types inherited from Gcs_message_stage
enum class	stage_status : unsigned int { apply , skip , abort }

Static Public Attributes inherited from Gcs_message_stage_split_v2
static constexpr unsigned long long	DEFAULT_THRESHOLD = 1048576
	Default split threshold. More...

Protected Member Functions inherited from Gcs_message_stage_split_v2
std::pair< bool, std::vector< Gcs_packet > >	apply_transformation (Gcs_packet &&packet) override
	Implements the logic of this stage's transformation to the packet, and returns a set of one, or more, transformed packets. More...

std::pair< Gcs_pipeline_incoming_result, Gcs_packet >	revert_transformation (Gcs_packet &&packet) override
	Implements the logic to revert this stage's transformation to the packet, and returns one, or none, transformed packet. More...

Gcs_message_stage::stage_status	skip_revert (const Gcs_packet &packet) const override
	Check if the revert operation which affects incoming packets should be executed (i.e. More...

Protected Member Functions inherited from Gcs_message_stage
void	encode (unsigned char *header, unsigned short header_length, unsigned long long old_payload_length)
	Encode the fixed part of the associated dynamic header information into the header buffer. More...

void	decode (const unsigned char header, unsigned short header_length, unsigned long long *old_payload_length)
	Decode the fixed part of the associated dynamic header information from the header buffer. More...

Constructor & Destructor Documentation

◆ Gcs_message_stage_split_v3()

Gcs_message_stage_split_v3::Gcs_message_stage_split_v3	(	bool	enabled,
		unsigned long long	split_threshold
	)

inlineexplicit

Creates an instance of the stage.

Parameters

enabled	enables this message stage
split_threshold	messages with the payload larger than split_threshold in bytes are split.

◆ ~Gcs_message_stage_split_v3()

Gcs_message_stage_split_v3::~Gcs_message_stage_split_v3 ( )

inlineoverride

Member Function Documentation

◆ get_stage_code()

Stage_code Gcs_message_stage_split_v3::get_stage_code ( ) const

inlineoverridevirtual

Return the stage code.

Reimplemented from Gcs_message_stage_split_v2.

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

plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_message_stage_split.h

Public Member Functions

Additional Inherited Members

Constructor & Destructor Documentation

◆ Gcs_message_stage_split_v3()

◆ ~Gcs_message_stage_split_v3()

Member Function Documentation

◆ get_stage_code()