mirror of
https://github.com/MariaDB/server.git
synced 2025-01-16 12:02:42 +01:00
370 lines
12 KiB
C++
370 lines
12 KiB
C++
/* Copyright (c) 2009, 2010, Oracle and/or its affiliates.
|
|
Copyright (c) 2012, 2020, MariaDB Corporation.
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1335 USA */
|
|
|
|
/* support for Services */
|
|
#include <service_versions.h>
|
|
#include <mysql/service_wsrep.h>
|
|
#include <mysql/service_thd_mdl.h>
|
|
#include <mysql/service_print_check_msg.h>
|
|
|
|
struct st_service_ref {
|
|
const char *name;
|
|
uint version;
|
|
void *service;
|
|
};
|
|
|
|
static struct my_snprintf_service_st my_snprintf_handler = {
|
|
my_snprintf,
|
|
my_vsnprintf
|
|
};
|
|
|
|
static struct thd_alloc_service_st thd_alloc_handler= {
|
|
thd_alloc,
|
|
thd_calloc,
|
|
thd_strdup,
|
|
thd_strmake,
|
|
thd_memdup,
|
|
thd_make_lex_string
|
|
};
|
|
|
|
static struct thd_wait_service_st thd_wait_handler= {
|
|
thd_wait_begin,
|
|
thd_wait_end
|
|
};
|
|
|
|
static struct progress_report_service_st progress_report_handler= {
|
|
thd_progress_init,
|
|
thd_progress_report,
|
|
thd_progress_next_stage,
|
|
thd_progress_end,
|
|
set_thd_proc_info
|
|
};
|
|
|
|
static struct kill_statement_service_st thd_kill_statement_handler= {
|
|
thd_kill_level
|
|
};
|
|
|
|
static struct thd_timezone_service_st thd_timezone_handler= {
|
|
thd_TIME_to_gmt_sec,
|
|
thd_gmt_sec_to_TIME
|
|
};
|
|
|
|
static struct my_sha2_service_st my_sha2_handler = {
|
|
my_sha224,
|
|
my_sha224_multi,
|
|
my_sha224_context_size,
|
|
my_sha224_init,
|
|
my_sha224_input,
|
|
my_sha224_result,
|
|
my_sha256,
|
|
my_sha256_multi,
|
|
my_sha256_context_size,
|
|
my_sha256_init,
|
|
my_sha256_input,
|
|
my_sha256_result,
|
|
my_sha384,
|
|
my_sha384_multi,
|
|
my_sha384_context_size,
|
|
my_sha384_init,
|
|
my_sha384_input,
|
|
my_sha384_result,
|
|
my_sha512,
|
|
my_sha512_multi,
|
|
my_sha512_context_size,
|
|
my_sha512_init,
|
|
my_sha512_input,
|
|
my_sha512_result,
|
|
};
|
|
|
|
static struct my_sha1_service_st my_sha1_handler = {
|
|
my_sha1,
|
|
my_sha1_multi,
|
|
my_sha1_context_size,
|
|
my_sha1_init,
|
|
my_sha1_input,
|
|
my_sha1_result
|
|
};
|
|
|
|
static struct my_md5_service_st my_md5_handler = {
|
|
my_md5,
|
|
my_md5_multi,
|
|
my_md5_context_size,
|
|
my_md5_init,
|
|
my_md5_input,
|
|
my_md5_result
|
|
};
|
|
|
|
static struct logger_service_st logger_service_handler= {
|
|
logger_init_mutexes,
|
|
logger_open,
|
|
logger_close,
|
|
logger_vprintf,
|
|
logger_printf,
|
|
logger_write,
|
|
logger_rotate
|
|
};
|
|
|
|
static struct thd_autoinc_service_st thd_autoinc_handler= {
|
|
thd_get_autoinc
|
|
};
|
|
|
|
static struct thd_rnd_service_st thd_rnd_handler= {
|
|
thd_rnd,
|
|
thd_create_random_password
|
|
};
|
|
|
|
static struct base64_service_st base64_handler= {
|
|
my_base64_needed_encoded_length,
|
|
my_base64_encode_max_arg_length,
|
|
my_base64_needed_decoded_length,
|
|
my_base64_decode_max_arg_length,
|
|
my_base64_encode,
|
|
my_base64_decode
|
|
};
|
|
|
|
static struct thd_error_context_service_st thd_error_context_handler= {
|
|
thd_get_error_message,
|
|
thd_get_error_number,
|
|
thd_get_error_row,
|
|
thd_inc_error_row,
|
|
thd_get_error_context_description
|
|
};
|
|
|
|
static struct wsrep_service_st wsrep_handler = {
|
|
get_wsrep_recovery,
|
|
wsrep_consistency_check,
|
|
wsrep_is_wsrep_xid,
|
|
wsrep_xid_seqno,
|
|
wsrep_xid_uuid,
|
|
wsrep_on,
|
|
wsrep_prepare_key_for_innodb,
|
|
wsrep_thd_LOCK,
|
|
wsrep_thd_TRYLOCK,
|
|
wsrep_thd_UNLOCK,
|
|
wsrep_thd_query,
|
|
wsrep_thd_retry_counter,
|
|
wsrep_thd_ignore_table,
|
|
wsrep_thd_trx_seqno,
|
|
wsrep_thd_is_aborting,
|
|
wsrep_set_data_home_dir,
|
|
wsrep_thd_is_BF,
|
|
wsrep_thd_is_local,
|
|
wsrep_thd_self_abort,
|
|
wsrep_thd_append_key,
|
|
wsrep_thd_append_table_key,
|
|
wsrep_thd_is_local_transaction,
|
|
wsrep_thd_client_state_str,
|
|
wsrep_thd_client_mode_str,
|
|
wsrep_thd_transaction_state_str,
|
|
wsrep_thd_transaction_id,
|
|
wsrep_thd_bf_abort,
|
|
wsrep_thd_order_before,
|
|
wsrep_handle_SR_rollback,
|
|
wsrep_thd_skip_locking,
|
|
wsrep_get_sr_table_name,
|
|
wsrep_get_debug,
|
|
wsrep_commit_ordered,
|
|
wsrep_thd_is_applying,
|
|
wsrep_OSU_method_get,
|
|
wsrep_thd_has_ignored_error,
|
|
wsrep_thd_set_ignored_error,
|
|
wsrep_report_bf_lock_wait,
|
|
wsrep_thd_kill_LOCK,
|
|
wsrep_thd_kill_UNLOCK,
|
|
wsrep_thd_set_PA_unsafe,
|
|
wsrep_get_domain_id
|
|
};
|
|
|
|
static struct thd_specifics_service_st thd_specifics_handler=
|
|
{
|
|
thd_key_create,
|
|
thd_key_delete,
|
|
thd_getspecific,
|
|
thd_setspecific
|
|
};
|
|
|
|
static struct encryption_scheme_service_st encryption_scheme_handler=
|
|
{
|
|
encryption_scheme_encrypt,
|
|
encryption_scheme_decrypt
|
|
};
|
|
|
|
static struct my_crypt_service_st crypt_handler=
|
|
{
|
|
my_aes_crypt_init,
|
|
my_aes_crypt_update,
|
|
my_aes_crypt_finish,
|
|
my_aes_crypt,
|
|
my_aes_get_size,
|
|
my_aes_ctx_size,
|
|
my_random_bytes
|
|
};
|
|
|
|
static struct my_print_error_service_st my_print_error_handler=
|
|
{
|
|
my_error,
|
|
my_printf_error,
|
|
my_printv_error
|
|
};
|
|
|
|
static struct print_check_msg_service_st print_check_msg_handler=
|
|
{
|
|
print_check_msg
|
|
};
|
|
|
|
static struct json_service_st json_handler=
|
|
{
|
|
json_type,
|
|
json_get_array_item,
|
|
json_get_object_key,
|
|
json_get_object_nkey,
|
|
json_escape_string,
|
|
json_unescape_json
|
|
};
|
|
|
|
struct sql_service_st sql_service_handler=
|
|
{
|
|
mysql_init,
|
|
mysql_real_connect_local,
|
|
mysql_real_connect,
|
|
mysql_errno,
|
|
mysql_error,
|
|
mysql_real_query,
|
|
mysql_affected_rows,
|
|
mysql_num_rows,
|
|
mysql_store_result,
|
|
mysql_free_result,
|
|
mysql_fetch_row,
|
|
mysql_close,
|
|
mysql_options,
|
|
mysql_fetch_lengths,
|
|
mysql_set_character_set,
|
|
mysql_num_fields,
|
|
mysql_select_db,
|
|
mysql_use_result,
|
|
mysql_fetch_fields,
|
|
mysql_real_escape_string,
|
|
mysql_ssl_set
|
|
};
|
|
|
|
static struct thd_mdl_service_st thd_mdl_handler=
|
|
{
|
|
thd_mdl_context
|
|
};
|
|
|
|
#define DEFINE_warning_function(name, ret) { \
|
|
static query_id_t last_query_id= -1; \
|
|
THD *thd= current_thd; \
|
|
if((thd ? thd->query_id : 0) != last_query_id) \
|
|
{ \
|
|
my_error(ER_PROVIDER_NOT_LOADED, MYF(ME_ERROR_LOG|ME_WARNING), name); \
|
|
last_query_id= thd ? thd->query_id : 0; \
|
|
} \
|
|
return ret; \
|
|
}
|
|
|
|
#include <providers/lzma.h>
|
|
static struct provider_service_lzma_st provider_handler_lzma=
|
|
{
|
|
DEFINE_lzma_stream_buffer_decode([]) DEFINE_warning_function("LZMA compression", LZMA_PROG_ERROR),
|
|
DEFINE_lzma_easy_buffer_encode([]) DEFINE_warning_function("LZMA compression", LZMA_PROG_ERROR),
|
|
|
|
false // .is_loaded
|
|
};
|
|
struct provider_service_lzma_st *provider_service_lzma= &provider_handler_lzma;
|
|
|
|
#include <providers/lzo/lzo1x.h>
|
|
static struct provider_service_lzo_st provider_handler_lzo=
|
|
{
|
|
DEFINE_lzo1x_1_15_compress([]) DEFINE_warning_function("LZO compression", LZO_E_INTERNAL_ERROR),
|
|
DEFINE_lzo1x_decompress_safe([]) DEFINE_warning_function("LZO compression", LZO_E_INTERNAL_ERROR),
|
|
|
|
false // .is_loaded
|
|
};
|
|
struct provider_service_lzo_st *provider_service_lzo= &provider_handler_lzo;
|
|
|
|
#include <providers/bzlib.h>
|
|
static struct provider_service_bzip2_st provider_handler_bzip2=
|
|
{
|
|
DEFINE_BZ2_bzBuffToBuffCompress([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
DEFINE_BZ2_bzBuffToBuffDecompress([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
DEFINE_BZ2_bzCompress([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
DEFINE_BZ2_bzCompressEnd([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
DEFINE_BZ2_bzCompressInit([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
DEFINE_BZ2_bzDecompress([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
DEFINE_BZ2_bzDecompressEnd([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
DEFINE_BZ2_bzDecompressInit([]) DEFINE_warning_function("BZip2 compression", -1),
|
|
|
|
false // .is_loaded
|
|
};
|
|
struct provider_service_bzip2_st *provider_service_bzip2= &provider_handler_bzip2;
|
|
|
|
#include <providers/snappy-c.h>
|
|
static struct provider_service_snappy_st provider_handler_snappy=
|
|
{
|
|
DEFINE_snappy_max_compressed_length([]) -> size_t DEFINE_warning_function("Snappy compression", 0),
|
|
DEFINE_snappy_compress([]) DEFINE_warning_function("Snappy compression", SNAPPY_INVALID_INPUT),
|
|
DEFINE_snappy_uncompressed_length([]) DEFINE_warning_function("Snappy compression", SNAPPY_INVALID_INPUT),
|
|
DEFINE_snappy_uncompress([]) DEFINE_warning_function("Snappy compression", SNAPPY_INVALID_INPUT),
|
|
|
|
false // .is_loaded
|
|
};
|
|
struct provider_service_snappy_st *provider_service_snappy= &provider_handler_snappy;
|
|
|
|
#include <providers/lz4.h>
|
|
static struct provider_service_lz4_st provider_handler_lz4=
|
|
{
|
|
DEFINE_LZ4_compressBound([]) DEFINE_warning_function("LZ4 compression", 0),
|
|
DEFINE_LZ4_compress_default([]) DEFINE_warning_function("LZ4 compression", 0),
|
|
DEFINE_LZ4_decompress_safe([]) DEFINE_warning_function("LZ4 compression", -1),
|
|
|
|
false // .is_loaded
|
|
};
|
|
struct provider_service_lz4_st *provider_service_lz4= &provider_handler_lz4;
|
|
|
|
static struct st_service_ref list_of_services[]=
|
|
{
|
|
{ "base64_service", VERSION_base64, &base64_handler },
|
|
{ "debug_sync_service", VERSION_debug_sync, 0 }, // updated in plugin_init()
|
|
{ "encryption_scheme_service", VERSION_encryption_scheme, &encryption_scheme_handler },
|
|
{ "encryption_service", VERSION_encryption, &encryption_handler },
|
|
{ "logger_service", VERSION_logger, &logger_service_handler },
|
|
{ "my_crypt_service", VERSION_my_crypt, &crypt_handler},
|
|
{ "my_md5_service", VERSION_my_md5, &my_md5_handler},
|
|
{ "my_print_error_service", VERSION_my_print_error, &my_print_error_handler},
|
|
{ "print_check_msg_service", VERSION_print_check_msg, &print_check_msg_handler},
|
|
{ "my_sha1_service", VERSION_my_sha1, &my_sha1_handler},
|
|
{ "my_sha2_service", VERSION_my_sha2, &my_sha2_handler},
|
|
{ "my_snprintf_service", VERSION_my_snprintf, &my_snprintf_handler },
|
|
{ "progress_report_service", VERSION_progress_report, &progress_report_handler },
|
|
{ "thd_alloc_service", VERSION_thd_alloc, &thd_alloc_handler },
|
|
{ "thd_autoinc_service", VERSION_thd_autoinc, &thd_autoinc_handler },
|
|
{ "thd_error_context_service", VERSION_thd_error_context, &thd_error_context_handler },
|
|
{ "thd_kill_statement_service", VERSION_kill_statement, &thd_kill_statement_handler },
|
|
{ "thd_rnd_service", VERSION_thd_rnd, &thd_rnd_handler },
|
|
{ "thd_specifics_service", VERSION_thd_specifics, &thd_specifics_handler },
|
|
{ "thd_timezone_service", VERSION_thd_timezone, &thd_timezone_handler },
|
|
{ "thd_wait_service", VERSION_thd_wait, &thd_wait_handler },
|
|
{ "wsrep_service", VERSION_wsrep, &wsrep_handler },
|
|
{ "json_service", VERSION_json, &json_handler },
|
|
{ "sql_service", VERSION_sql_service, &sql_service_handler },
|
|
{ "thd_mdl_service", VERSION_thd_mdl, &thd_mdl_handler },
|
|
{ "provider_service_bzip2", VERSION_provider_bzip2, &provider_handler_bzip2 },
|
|
{ "provider_service_lz4", VERSION_provider_lz4, &provider_handler_lz4 },
|
|
{ "provider_service_lzma", VERSION_provider_lzma, &provider_handler_lzma },
|
|
{ "provider_service_lzo", VERSION_provider_lzo, &provider_handler_lzo },
|
|
{ "provider_service_snappy", VERSION_provider_snappy, &provider_handler_snappy }
|
|
};
|