Gcs_message_stage_split_v3 Class Reference

#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