Commit 77a8ae07 authored by Nirbhay Choubey's avatar Nirbhay Choubey

Cleanup around wsrep system variables.

parent 355bf4fb
...@@ -18,8 +18,6 @@ ...@@ -18,8 +18,6 @@
#include "sys_vars_shared.h" #include "sys_vars_shared.h"
#include "wsrep.h" #include "wsrep.h"
#include "wsrep_sst.h" #include "wsrep_sst.h"
//#include <sql_class.h>
//#include "wsrep_mysqld.h"
extern char *my_bind_addr_str; extern char *my_bind_addr_str;
......
...@@ -52,49 +52,64 @@ rpl_sidno wsrep_sidno= -1; ...@@ -52,49 +52,64 @@ rpl_sidno wsrep_sidno= -1;
my_bool wsrep_preordered_opt= FALSE; my_bool wsrep_preordered_opt= FALSE;
/* /*
* Begin configuration options and their default values * Begin configuration options
*/ */
extern my_bool plugins_are_initialized; extern my_bool plugins_are_initialized;
extern uint kill_cached_threads; extern uint kill_cached_threads;
extern mysql_cond_t COND_thread_cache; extern mysql_cond_t COND_thread_cache;
const char* wsrep_data_home_dir = NULL; /* System variables. */
const char* wsrep_dbug_option = ""; const char *wsrep_provider;
const char *wsrep_provider_options;
long wsrep_slave_threads = 1; // # of slave action appliers wanted const char *wsrep_cluster_address;
int wsrep_slave_count_change = 0; // # of appliers to stop or start const char *wsrep_cluster_name;
my_bool wsrep_debug = 0; // enable debug level logging const char *wsrep_node_name;
my_bool wsrep_convert_LOCK_to_trx = 1; // convert locking sessions to trx const char *wsrep_node_address;
ulong wsrep_retry_autocommit = 5; // retry aborted autocommit trx const char *wsrep_node_incoming_address;
my_bool wsrep_auto_increment_control = 1; // control auto increment variables const char *wsrep_start_position;
my_bool wsrep_drupal_282555_workaround = 1; // retry autoinc insert after dupkey const char *wsrep_data_home_dir;
my_bool wsrep_incremental_data_collection = 0; // incremental data collection const char *wsrep_dbug_option;
ulong wsrep_max_ws_size = 1073741824UL;//max ws (RBR buffer) size const char *wsrep_notify_cmd;
ulong wsrep_max_ws_rows = 65536; // max number of rows in ws const char *wsrep_sst_method;
int wsrep_to_isolation = 0; // # of active TO isolation threads const char *wsrep_sst_receive_address;
my_bool wsrep_certify_nonPK = 1; // certify, even when no primary key const char *wsrep_sst_donor;
long wsrep_max_protocol_version = 3; // maximum protocol version to use const char *wsrep_sst_auth;
ulong wsrep_forced_binlog_format = BINLOG_FORMAT_UNSPEC; my_bool wsrep_debug; // Enable debug level logging
my_bool wsrep_recovery = 0; // recovery my_bool wsrep_convert_LOCK_to_trx; // Convert locking sessions to trx
my_bool wsrep_replicate_myisam = 0; // enable myisam replication my_bool wsrep_auto_increment_control; // Control auto increment variables
my_bool wsrep_log_conflicts = 0; my_bool wsrep_drupal_282555_workaround; // Retry autoinc insert after dupkey
ulong wsrep_mysql_replication_bundle = 0; my_bool wsrep_certify_nonPK; // Certify, even when no primary key
my_bool wsrep_desync = 0; // desynchronize the node from the my_bool wsrep_recovery; // Recovery
// cluster my_bool wsrep_replicate_myisam; // Enable MyISAM replication
my_bool wsrep_load_data_splitting = 1; // commit load data every 10K intervals my_bool wsrep_log_conflicts;
my_bool wsrep_restart_slave = 0; // should mysql slave thread be my_bool wsrep_load_data_splitting; // Commit load data every 10K intervals
// restarted, if node joins back my_bool wsrep_slave_UK_checks; // Slave thread does UK checks
my_bool wsrep_restart_slave_activated = 0; // node has dropped, and slave my_bool wsrep_slave_FK_checks; // Slave thread does FK checks
// restart will be needed my_bool wsrep_sst_donor_rejects_queries;
my_bool wsrep_slave_UK_checks = 0; // slave thread does UK checks my_bool wsrep_restart_slave; // Should mysql slave thread be
my_bool wsrep_slave_FK_checks = 0; // slave thread does FK checks // restarted, when node joins back?
bool wsrep_new_cluster = false; // Bootstrap the cluster ? my_bool wsrep_desync; // De(re)synchronize the node from the
// cluster
// Use wsrep_gtid_domain_id for galera transactions? long wsrep_slave_threads; // No. of slave appliers threads
bool wsrep_gtid_mode = 0; ulong wsrep_retry_autocommit; // Retry aborted autocommit trx
// gtid_domain_id for galera transactions. ulong wsrep_max_ws_size; // Max allowed ws (RBR buffer) size
uint32 wsrep_gtid_domain_id = 0; ulong wsrep_max_ws_rows; // Max number of rows in ws
ulong wsrep_forced_binlog_format;
ulong wsrep_mysql_replication_bundle;
bool wsrep_gtid_mode; // Use wsrep_gtid_domain_id
// for galera transactions?
uint32 wsrep_gtid_domain_id; // gtid_domain_id for galera
// transactions
/* Other configuration variables and their default values. */
my_bool wsrep_incremental_data_collection= 0; // Incremental data collection
my_bool wsrep_restart_slave_activated= 0; // Node has dropped, and slave
// restart will be needed
bool wsrep_new_cluster= false; // Bootstrap the cluster?
int wsrep_slave_count_change= 0; // No. of appliers to stop/start
int wsrep_to_isolation= 0; // No. of active TO isolation threads
long wsrep_max_protocol_version= 3; // Maximum protocol version to use
/* /*
* End configuration options * End configuration options
......
...@@ -17,7 +17,6 @@ ...@@ -17,7 +17,6 @@
#include "wsrep_priv.h" #include "wsrep_priv.h"
#include "wsrep_utils.h" #include "wsrep_utils.h"
const char* wsrep_notify_cmd="";
static const char* _status_str(wsrep_member_status_t status) static const char* _status_str(wsrep_member_status_t status)
{ {
......
...@@ -34,14 +34,8 @@ char wsrep_defaults_file[FN_REFLEN * 2 + 10 + ...@@ -34,14 +34,8 @@ char wsrep_defaults_file[FN_REFLEN * 2 + 10 +
sizeof(WSREP_SST_OPT_CONF) + sizeof(WSREP_SST_OPT_CONF) +
sizeof(WSREP_SST_OPT_EXTRA_CONF)] = {0}; sizeof(WSREP_SST_OPT_EXTRA_CONF)] = {0};
const char* wsrep_sst_method = WSREP_SST_DEFAULT;
const char* wsrep_sst_receive_address = WSREP_SST_ADDRESS_AUTO;
const char* wsrep_sst_donor = "";
char* wsrep_sst_auth = NULL;
// container for real auth string // container for real auth string
static const char* sst_auth_real = NULL; static const char* sst_auth_real = NULL;
my_bool wsrep_sst_donor_rejects_queries = FALSE;
bool wsrep_sst_method_check (sys_var *self, THD* thd, set_var* var) bool wsrep_sst_method_check (sys_var *self, THD* thd, set_var* var)
{ {
......
...@@ -55,8 +55,8 @@ ...@@ -55,8 +55,8 @@
extern const char* wsrep_sst_method; extern const char* wsrep_sst_method;
extern const char* wsrep_sst_receive_address; extern const char* wsrep_sst_receive_address;
extern const char* wsrep_sst_donor; extern const char* wsrep_sst_donor;
extern char* wsrep_sst_auth; extern const char* wsrep_sst_auth;
extern my_bool wsrep_sst_donor_rejects_queries; extern my_bool wsrep_sst_donor_rejects_queries;
/*! Synchronizes applier thread start with init thread */ /*! Synchronizes applier thread start with init thread */
extern void wsrep_sst_grab(); extern void wsrep_sst_grab();
......
...@@ -26,14 +26,6 @@ ...@@ -26,14 +26,6 @@
#include <cstdio> #include <cstdio>
#include <cstdlib> #include <cstdlib>
const char* wsrep_provider = 0;
const char* wsrep_provider_options = 0;
const char* wsrep_cluster_address = 0;
const char* wsrep_cluster_name = 0;
const char* wsrep_node_name = 0;
const char* wsrep_node_address = 0;
const char* wsrep_node_incoming_address = 0;
const char* wsrep_start_position = 0;
int wsrep_init_vars() int wsrep_init_vars()
{ {
...@@ -45,8 +37,6 @@ int wsrep_init_vars() ...@@ -45,8 +37,6 @@ int wsrep_init_vars()
wsrep_node_address = my_strdup("", MYF(MY_WME)); wsrep_node_address = my_strdup("", MYF(MY_WME));
wsrep_node_incoming_address= my_strdup(WSREP_NODE_INCOMING_AUTO, MYF(MY_WME)); wsrep_node_incoming_address= my_strdup(WSREP_NODE_INCOMING_AUTO, MYF(MY_WME));
wsrep_start_position = my_strdup(WSREP_START_POSITION_ZERO, MYF(MY_WME)); wsrep_start_position = my_strdup(WSREP_START_POSITION_ZERO, MYF(MY_WME));
global_system_variables.binlog_format=BINLOG_FORMAT_ROW;
return 0; return 0;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment