binlog::service::iterators::tests Namespace Reference

Classes
struct	Cs_entries_table
struct	Row

Functions
static bool	acquire_service_handles ()
static void	release_service_handles ()
bool	register_pfs_tables ()
bool	unregister_pfs_tables ()
PSI_table_handle *	open_table (PSI_pos **pos)
void	close_table (PSI_table_handle *h)
static Binlog_iterator_service_get_status	dbug_retry_on_eof (Cs_entries_table *handle, Binlog_iterator_service_get_status get_return, uint64_t *bytes_read)
int	rnd_next (PSI_table_handle *h)
int	rnd_init (PSI_table_handle *h, bool scan)
int	read_column_value (PSI_table_handle *h, PSI_field *field, unsigned int index)
unsigned long long	row_count ()
int	delete_all_rows ()
void	init_share (PFS_engine_table_share_proxy *share)
static bool	acquire_service_handles ()
static void	release_service_handles ()
static int	show_count_buffer_reallocations (THD *, SHOW_VAR *var, char *buf)
static int	show_sum_buffer_size_requested (THD *, SHOW_VAR *var, char *buf)
bool	register_status_variables ()
	Registers the status variables. More...
bool	unregister_status_variables ()
	unregisters the status variables. More...

Variables
my_h_service	h_ret_table_svc = nullptr
const mysql_service_pfs_plugin_table_v1_t *	table_srv = nullptr
my_h_service	h_ret_col_string_svc = nullptr
const mysql_service_pfs_plugin_column_string_v2_t *	pc_string_srv = nullptr
my_h_service	h_ret_col_bigint_svc = nullptr
const mysql_service_pfs_plugin_column_bigint_v1_t *	pc_bigint_srv = nullptr
my_h_service	h_ret_col_blob_svc = nullptr
const mysql_service_pfs_plugin_column_blob_v1_t *	pc_blob_srv = nullptr
my_h_service	h_ret_binlog_iterator_svc = nullptr
const mysql_service_binlog_storage_iterator_t *	binlog_iterator_svc = nullptr
my_h_service	h_ret_current_thd_svc = nullptr
const mysql_service_mysql_current_thread_reader_t *	current_thd_srv = nullptr
static const uint64_t	DEFAULT_EXTENT {1024}
static PFS_engine_table_share_proxy	table
static PFS_engine_table_share_proxy *	ptables [] = {nullptr}
const std::string	TABLE_NAME {"binlog_storage_iterator_entries"}
static const uint32_t	MAX_STORAGE_NAME_SIZE {1024}
my_h_service	h_ret_statvar_svc = nullptr
const mysql_service_status_variable_registration_t *	statvar_register_srv = nullptr
std::atomic< uint64_t >	global_status_var_count_buffer_reallocations {0}
	counts the number of reallocations done when the read buffer was not large enough More...
std::atomic< uint64_t >	global_status_var_sum_buffer_size_requested {0}
	the sum of memory allocation requests More...
SHOW_VAR	status_func_var []

Function Documentation

acquire_service_handles() [1/2]

static bool binlog::service::iterators::tests::acquire_service_handles ( )

static

acquire_service_handles() [2/2]

static bool binlog::service::iterators::tests::acquire_service_handles ( )

static

close_table()

void binlog::service::iterators::tests::close_table

(

PSI_table_handle *

h

)

dbug_retry_on_eof()

static Binlog_iterator_service_get_status binlog::service::iterators::tests::dbug_retry_on_eof ( Cs_entries_table *  handle, Binlog_iterator_service_get_status  get_return, uint64_t *  bytes_read  )

static

delete_all_rows()

int binlog::service::iterators::tests::delete_all_rows

(

)

init_share()

void binlog::service::iterators::tests::init_share

(

PFS_engine_table_share_proxy *

share

)

open_table()

PSI_table_handle * binlog::service::iterators::tests::open_table

(

PSI_pos **

pos

)

read_column_value()

int binlog::service::iterators::tests::read_column_value	(	PSI_table_handle *	h,
		PSI_field *	field,
		unsigned int	index
	)

register_pfs_tables()

bool binlog::service::iterators::tests::register_pfs_tables

(

)

register_status_variables()

bool binlog::service::iterators::tests::register_status_variables

(

)

Registers the status variables.

Returns

false on success, true otherwise.

release_service_handles() [1/2]

static void binlog::service::iterators::tests::release_service_handles ( )

static

release_service_handles() [2/2]

static void binlog::service::iterators::tests::release_service_handles ( )

static

rnd_init()

int binlog::service::iterators::tests::rnd_init	(	PSI_table_handle *	h,
		bool	scan
	)

rnd_next()

int binlog::service::iterators::tests::rnd_next

(

PSI_table_handle *

h

)

row_count()

unsigned long long binlog::service::iterators::tests::row_count

(

)

show_count_buffer_reallocations()

static int binlog::service::iterators::tests::show_count_buffer_reallocations ( THD *  , SHOW_VAR *  var, char *  buf  )

static

show_sum_buffer_size_requested()

static int binlog::service::iterators::tests::show_sum_buffer_size_requested ( THD *  , SHOW_VAR *  var, char *  buf  )

static

unregister_pfs_tables()

bool binlog::service::iterators::tests::unregister_pfs_tables

(

)

unregister_status_variables()

bool binlog::service::iterators::tests::unregister_status_variables

(

)

unregisters the status variables.

Returns

false on success, true otherwise.

Variable Documentation

binlog_iterator_svc

const mysql_service_binlog_storage_iterator_t* binlog::service::iterators::tests::binlog_iterator_svc = nullptr

current_thd_srv

const mysql_service_mysql_current_thread_reader_t* binlog::service::iterators::tests::current_thd_srv = nullptr

DEFAULT_EXTENT

const uint64_t binlog::service::iterators::tests::DEFAULT_EXTENT {1024}

static

global_status_var_count_buffer_reallocations

std::atomic< uint64_t > binlog::service::iterators::tests::global_status_var_count_buffer_reallocations {0}

counts the number of reallocations done when the read buffer was not large enough

global_status_var_sum_buffer_size_requested

std::atomic< uint64_t > binlog::service::iterators::tests::global_status_var_sum_buffer_size_requested {0}

the sum of memory allocation requests

h_ret_binlog_iterator_svc

my_h_service binlog::service::iterators::tests::h_ret_binlog_iterator_svc = nullptr

h_ret_col_bigint_svc

my_h_service binlog::service::iterators::tests::h_ret_col_bigint_svc = nullptr

h_ret_col_blob_svc

my_h_service binlog::service::iterators::tests::h_ret_col_blob_svc = nullptr

h_ret_col_string_svc

my_h_service binlog::service::iterators::tests::h_ret_col_string_svc = nullptr

h_ret_current_thd_svc

my_h_service binlog::service::iterators::tests::h_ret_current_thd_svc = nullptr

h_ret_statvar_svc

my_h_service binlog::service::iterators::tests::h_ret_statvar_svc = nullptr

h_ret_table_svc

my_h_service binlog::service::iterators::tests::h_ret_table_svc = nullptr

MAX_STORAGE_NAME_SIZE

const uint32_t binlog::service::iterators::tests::MAX_STORAGE_NAME_SIZE {1024}

static

pc_bigint_srv

const mysql_service_pfs_plugin_column_bigint_v1_t* binlog::service::iterators::tests::pc_bigint_srv = nullptr

pc_blob_srv

const mysql_service_pfs_plugin_column_blob_v1_t* binlog::service::iterators::tests::pc_blob_srv = nullptr

pc_string_srv

const mysql_service_pfs_plugin_column_string_v2_t* binlog::service::iterators::tests::pc_string_srv = nullptr

ptables

PFS_engine_table_share_proxy* binlog::service::iterators::tests::ptables[] = {nullptr}

static

status_func_var

SHOW_VAR binlog::service::iterators::tests::status_func_var[]

Initial value:

= {
    {"test_binlog_storage_iterator.count_buffer_reallocations",
     (char *)show_count_buffer_reallocations, SHOW_FUNC, SHOW_SCOPE_GLOBAL},
    {"test_binlog_storage_iterator.sum_buffer_size_requested",
     (char *)show_sum_buffer_size_requested, SHOW_FUNC, SHOW_SCOPE_GLOBAL},
    {nullptr, nullptr, SHOW_UNDEF,
     SHOW_SCOPE_UNDEF}  
}

statvar_register_srv

const mysql_service_status_variable_registration_t* binlog::service::iterators::tests::statvar_register_srv = nullptr

table

PFS_engine_table_share_proxy binlog::service::iterators::tests::table

static

TABLE_NAME

const std::string binlog::service::iterators::tests::TABLE_NAME {"binlog_storage_iterator_entries"}

table_srv

const mysql_service_pfs_plugin_table_v1_t* binlog::service::iterators::tests::table_srv = nullptr