udf_write_concurrency.cc File Reference

#include "plugin/group_replication/include/udf/udf_write_concurrency.h"
#include <cinttypes>
#include "mysql/plugin.h"
#include "plugin/group_replication/include/plugin.h"
#include "plugin/group_replication/include/udf/udf_utils.h"

Functions
static bool	group_replication_get_write_concurrency_init (UDF_INIT *, UDF_ARGS *args, char *message)
static void	group_replication_get_write_concurrency_deinit (UDF_INIT *)
static long long	group_replication_get_write_concurrency (UDF_INIT *, UDF_ARGS *, unsigned char *is_null, unsigned char *error)
udf_descriptor	get_write_concurrency_udf ()
	Returns the descriptor of the "group_replication_get_write_concurrency" UDF. More...
static bool	group_replication_set_write_concurrency_init (UDF_INIT *initid, UDF_ARGS *args, char *message)
static void	group_replication_set_write_concurrency_deinit (UDF_INIT *)
static char *	group_replication_set_write_concurrency (UDF_INIT *, UDF_ARGS *args, char *result, unsigned long *length, unsigned char *is_null, unsigned char *error)
udf_descriptor	set_write_concurrency_udf ()
	Returns the descriptor of the "group_replication_set_write_concurrency" UDF. More...

Variables
const char *const	wrong_nr_args_str = "UDF takes one integer argument."
const char *const	value_outside_domain_str

Function Documentation

get_write_concurrency_udf()

udf_descriptor get_write_concurrency_udf

(

)

Returns the descriptor of the "group_replication_get_write_concurrency" UDF.

Returns

the descriptor of the "group_replication_get_write_concurrency" UDF

group_replication_get_write_concurrency()

static long long group_replication_get_write_concurrency ( UDF_INIT *  , UDF_ARGS *  , unsigned char *  is_null, unsigned char *  error  )

static

group_replication_get_write_concurrency_deinit()

static void group_replication_get_write_concurrency_deinit ( UDF_INIT *  )

static

group_replication_get_write_concurrency_init()

static bool group_replication_get_write_concurrency_init ( UDF_INIT *  , UDF_ARGS *  args, char *  message  )

static

group_replication_set_write_concurrency()

static char * group_replication_set_write_concurrency ( UDF_INIT *  , UDF_ARGS *  args, char *  result, unsigned long *  length, unsigned char *  is_null, unsigned char *  error  )

static

group_replication_set_write_concurrency_deinit()

static void group_replication_set_write_concurrency_deinit ( UDF_INIT *  )

static

group_replication_set_write_concurrency_init()

static bool group_replication_set_write_concurrency_init ( UDF_INIT *  initid, UDF_ARGS *  args, char *  message  )

static

set_write_concurrency_udf()

udf_descriptor set_write_concurrency_udf

(

)

Returns the descriptor of the "group_replication_set_write_concurrency" UDF.

Returns

the descriptor of the "group_replication_set_write_concurrency" UDF

Variable Documentation

value_outside_domain_str

const char* const value_outside_domain_str

Initial value:

=
    "Argument must be between %" PRIu32 " and %" PRIu32 "."

wrong_nr_args_str

const char* const wrong_nr_args_str = "UDF takes one integer argument."