diff options
author | Sergei Golubchik <serg@mariadb.org> | 2015-08-30 15:03:55 +0200 |
---|---|---|
committer | Sergei Golubchik <serg@mariadb.org> | 2015-09-04 10:33:52 +0200 |
commit | 2d2286faf3085160dbe345fe403c11c712a358ff (patch) | |
tree | f69bbeda6f3fe6bb26a2d132500d973f41f5881b /sql | |
parent | 86b06a0e52b7583858df81fec8bd57cfe02b9999 (diff) | |
download | mariadb-git-2d2286faf3085160dbe345fe403c11c712a358ff.tar.gz |
cleanup: use enum_binlog_checksum_alg, not uint8
* fix unireg.h includes
* use enum_binlog_checksum_alg for binlog checksum variables,
not uint8
Diffstat (limited to 'sql')
-rw-r--r-- | sql/hostname.cc | 2 | ||||
-rw-r--r-- | sql/log.cc | 12 | ||||
-rw-r--r-- | sql/log.h | 6 | ||||
-rw-r--r-- | sql/log_event.cc | 56 | ||||
-rw-r--r-- | sql/log_event.h | 29 | ||||
-rw-r--r-- | sql/rpl_constants.h | 9 | ||||
-rw-r--r-- | sql/rpl_mi.h | 2 | ||||
-rw-r--r-- | sql/rpl_utility.cc | 2 | ||||
-rw-r--r-- | sql/slave.cc | 10 | ||||
-rw-r--r-- | sql/sql_repl.cc | 29 | ||||
-rw-r--r-- | sql/wsrep_mysqld.cc | 2 |
11 files changed, 77 insertions, 82 deletions
diff --git a/sql/hostname.cc b/sql/hostname.cc index 1879d056623..656663a9692 100644 --- a/sql/hostname.cc +++ b/sql/hostname.cc @@ -27,7 +27,7 @@ #include <my_global.h> #include "sql_priv.h" #include "hostname.h" -#include "my_global.h" +#include "unireg.h" #ifndef __WIN__ #include <netdb.h> // getservbyname, servent #endif diff --git a/sql/log.cc b/sql/log.cc index 6cf10a72ddf..8989ffa8e55 100644 --- a/sql/log.cc +++ b/sql/log.cc @@ -3450,12 +3450,12 @@ bool MYSQL_BIN_LOG::open(const char *log_name, { if (relay_log_checksum_alg == BINLOG_CHECKSUM_ALG_UNDEF) relay_log_checksum_alg= - opt_slave_sql_verify_checksum ? (uint8) binlog_checksum_options - : (uint8) BINLOG_CHECKSUM_ALG_OFF; + opt_slave_sql_verify_checksum ? (enum_binlog_checksum_alg) binlog_checksum_options + : BINLOG_CHECKSUM_ALG_OFF; s.checksum_alg= relay_log_checksum_alg; } else - s.checksum_alg= (uint8) binlog_checksum_options; + s.checksum_alg= (enum_binlog_checksum_alg)binlog_checksum_options; DBUG_ASSERT(s.checksum_alg != BINLOG_CHECKSUM_ALG_UNDEF); if (!s.is_valid()) @@ -8068,8 +8068,8 @@ void MYSQL_BIN_LOG::close(uint exiting) { Stop_log_event s; // the checksumming rule for relay-log case is similar to Rotate - s.checksum_alg= is_relay_log ? - (uint8) relay_log_checksum_alg : (uint8) binlog_checksum_options; + s.checksum_alg= is_relay_log ? relay_log_checksum_alg + : (enum_binlog_checksum_alg)binlog_checksum_options; DBUG_ASSERT(!is_relay_log || relay_log_checksum_alg != BINLOG_CHECKSUM_ALG_UNDEF); s.write(&log_file); @@ -10007,7 +10007,7 @@ binlog_checksum_update(MYSQL_THD thd, struct st_mysql_sys_var *var, { prev_binlog_id= mysql_bin_log.current_binlog_id; if (binlog_checksum_options != value) - mysql_bin_log.checksum_alg_reset= (uint8) value; + mysql_bin_log.checksum_alg_reset= (enum_binlog_checksum_alg)value; if (mysql_bin_log.rotate(true, &check_purge)) check_purge= false; } diff --git a/sql/log.h b/sql/log.h index 73faf8cfce9..fcec606443f 100644 --- a/sql/log.h +++ b/sql/log.h @@ -17,10 +17,10 @@ #ifndef LOG_H #define LOG_H -#include "unireg.h" // REQUIRED: for other includes #include "handler.h" /* my_xid */ #include "wsrep.h" #include "wsrep_mysqld.h" +#include "rpl_constants.h" class Relay_log_info; @@ -591,7 +591,7 @@ public: /* This is relay log */ bool is_relay_log; ulong signal_cnt; // update of the counter is checked by heartbeat - uint8 checksum_alg_reset; // to contain a new value when binlog is rotated + enum enum_binlog_checksum_alg checksum_alg_reset; // to contain a new value when binlog is rotated /* Holds the last seen in Relay-Log FD's checksum alg value. The initial value comes from the slave's local FD that heads @@ -625,7 +625,7 @@ public: (A) - checksum algorithm descriptor value FD.(A) - the value of (A) in FD */ - uint8 relay_log_checksum_alg; + enum enum_binlog_checksum_alg relay_log_checksum_alg; /* These describe the log's format. This is used only for relay logs. _for_exec is used by the SQL thread, _for_queue by the I/O thread. It's diff --git a/sql/log_event.cc b/sql/log_event.cc index 831e632d207..1341aa975e0 100644 --- a/sql/log_event.cc +++ b/sql/log_event.cc @@ -1091,20 +1091,12 @@ my_bool Log_event::need_checksum() provides their checksum alg preference through Log_event::checksum_alg. */ if (checksum_alg != BINLOG_CHECKSUM_ALG_UNDEF) - ret= (checksum_alg != BINLOG_CHECKSUM_ALG_OFF); + ret= checksum_alg != BINLOG_CHECKSUM_ALG_OFF; else { - if (binlog_checksum_options != BINLOG_CHECKSUM_ALG_OFF && - cache_type == Log_event::EVENT_NO_CACHE) - { - checksum_alg= binlog_checksum_options; - ret= MY_TEST(binlog_checksum_options); - } - else - { - ret= FALSE; - checksum_alg= (uint8) BINLOG_CHECKSUM_ALG_OFF; - } + ret= binlog_checksum_options && cache_type == Log_event::EVENT_NO_CACHE; + checksum_alg= ret ? (enum_binlog_checksum_alg)binlog_checksum_options + : BINLOG_CHECKSUM_ALG_OFF; } /* FD calls the methods before data_written has been calculated. @@ -1269,7 +1261,7 @@ bool Log_event::write_header(IO_CACHE* file, ulong event_data_length) */ int Log_event::read_log_event(IO_CACHE* file, String* packet, - uint8 checksum_alg_arg) + enum enum_binlog_checksum_alg checksum_alg_arg) { ulong data_len; char buf[LOG_EVENT_MINIMAL_HEADER_LEN]; @@ -1367,7 +1359,7 @@ Log_event* Log_event::read_log_event(IO_CACHE* file, if (log_lock) mysql_mutex_lock(log_lock); - switch (read_log_event(file, &event, (uint8)BINLOG_CHECKSUM_ALG_OFF)) + switch (read_log_event(file, &event, BINLOG_CHECKSUM_ALG_OFF)) { case 0: break; @@ -1437,7 +1429,7 @@ Log_event* Log_event::read_log_event(const char* buf, uint event_len, my_bool crc_check) { Log_event* ev; - uint8 alg; + enum enum_binlog_checksum_alg alg; DBUG_ENTER("Log_event::read_log_event(char*,...)"); DBUG_ASSERT(description_event != 0); DBUG_PRINT("info", ("binlog_version: %d", description_event->binlog_version)); @@ -3589,7 +3581,7 @@ Query_log_event::Query_log_event(const char* buf, uint event_len, */ int Query_log_event::dummy_event(String *packet, ulong ev_offset, - uint8 checksum_alg) + enum enum_binlog_checksum_alg checksum_alg) { uchar *p= (uchar *)packet->ptr() + ev_offset; size_t data_len= packet->length() - ev_offset; @@ -3681,7 +3673,7 @@ Query_log_event::dummy_event(String *packet, ulong ev_offset, */ int Query_log_event::begin_event(String *packet, ulong ev_offset, - uint8 checksum_alg) + enum enum_binlog_checksum_alg checksum_alg) { uchar *p= (uchar *)packet->ptr() + ev_offset; uchar *q= p + LOG_EVENT_HEADER_LEN; @@ -4470,7 +4462,8 @@ Query_log_event::do_shall_skip(rpl_group_info *rgi) bool Query_log_event::peek_is_commit_rollback(const char *event_start, - size_t event_len, uint8 checksum_alg) + size_t event_len, + enum enum_binlog_checksum_alg checksum_alg) { if (checksum_alg == BINLOG_CHECKSUM_ALG_CRC32) { @@ -4864,7 +4857,7 @@ Format_description_log_event(uint8 binlog_ver, const char* server_ver) break; } calc_server_version_split(); - checksum_alg= (uint8) BINLOG_CHECKSUM_ALG_UNDEF; + checksum_alg= BINLOG_CHECKSUM_ALG_UNDEF; } @@ -4916,11 +4909,11 @@ Format_description_log_event(const char* buf, { /* the last bytes are the checksum alg desc and value (or value's room) */ number_of_event_types -= BINLOG_CHECKSUM_ALG_DESC_LEN; - checksum_alg= post_header_len[number_of_event_types]; + checksum_alg= (enum_binlog_checksum_alg)post_header_len[number_of_event_types]; } else { - checksum_alg= (uint8) BINLOG_CHECKSUM_ALG_UNDEF; + checksum_alg= BINLOG_CHECKSUM_ALG_UNDEF; } DBUG_VOID_RETURN; @@ -4956,8 +4949,8 @@ bool Format_description_log_event::write(IO_CACHE* file) #ifndef DBUG_OFF data_written= 0; // to prepare for need_checksum assert #endif - uchar checksum_byte= need_checksum() ? - checksum_alg : (uint8) BINLOG_CHECKSUM_ALG_OFF; + uint8 checksum_byte= (uint8) + (need_checksum() ? checksum_alg : BINLOG_CHECKSUM_ALG_OFF); /* FD of checksum-aware server is always checksum-equipped, (V) is in, regardless of @@global.binlog_checksum policy. @@ -5162,9 +5155,9 @@ Format_description_log_event::is_version_before_checksum(const master_version_sp checksum-unaware (effectively no checksum) and the actuall [1-254] range alg descriptor. */ -uint8 get_checksum_alg(const char* buf, ulong len) +enum enum_binlog_checksum_alg get_checksum_alg(const char* buf, ulong len) { - uint8 ret; + enum enum_binlog_checksum_alg ret; char version[ST_SERVER_VER_LEN]; Format_description_log_event::master_version_split version_split; @@ -5177,9 +5170,9 @@ uint8 get_checksum_alg(const char* buf, ulong len) version[ST_SERVER_VER_LEN - 1]= 0; do_server_version_split(version, &version_split); - ret= Format_description_log_event::is_version_before_checksum(&version_split) ? - (uint8) BINLOG_CHECKSUM_ALG_UNDEF : - * (uint8*) (buf + len - BINLOG_CHECKSUM_LEN - BINLOG_CHECKSUM_ALG_DESC_LEN); + ret= Format_description_log_event::is_version_before_checksum(&version_split) + ? BINLOG_CHECKSUM_ALG_UNDEF + : (enum_binlog_checksum_alg)buf[len - BINLOG_CHECKSUM_LEN - BINLOG_CHECKSUM_ALG_DESC_LEN]; DBUG_ASSERT(ret == BINLOG_CHECKSUM_ALG_OFF || ret == BINLOG_CHECKSUM_ALG_UNDEF || ret == BINLOG_CHECKSUM_ALG_CRC32); @@ -6358,7 +6351,7 @@ Gtid_log_event::Gtid_log_event(THD *thd_arg, uint64 seq_no_arg, */ bool Gtid_log_event::peek(const char *event_start, size_t event_len, - uint8 checksum_alg, + enum enum_binlog_checksum_alg checksum_alg, uint32 *domain_id, uint32 *server_id, uint64 *seq_no, uchar *flags2, const Format_description_log_event *fdev) { @@ -6424,7 +6417,8 @@ Gtid_log_event::write(IO_CACHE *file) */ int Gtid_log_event::make_compatible_event(String *packet, bool *need_dummy_event, - ulong ev_offset, uint8 checksum_alg) + ulong ev_offset, + enum enum_binlog_checksum_alg checksum_alg) { uchar flags2; if (packet->length() - ev_offset < LOG_EVENT_HEADER_LEN + GTID_HEADER_LEN) @@ -6879,7 +6873,7 @@ Gtid_list_log_event::print(FILE *file, PRINT_EVENT_INFO *print_event_info) */ bool Gtid_list_log_event::peek(const char *event_start, uint32 event_len, - uint8 checksum_alg, + enum enum_binlog_checksum_alg checksum_alg, rpl_gtid **out_gtid_list, uint32 *out_list_len, const Format_description_log_event *fdev) { diff --git a/sql/log_event.h b/sql/log_event.h index 4866eb5f83b..9aa661f8cb2 100644 --- a/sql/log_event.h +++ b/sql/log_event.h @@ -566,15 +566,6 @@ struct sql_ex_info #endif #undef EXPECTED_OPTIONS /* You shouldn't use this one */ -enum enum_binlog_checksum_alg { - BINLOG_CHECKSUM_ALG_OFF= 0, // Events are without checksum though its generator - // is checksum-capable New Master (NM). - BINLOG_CHECKSUM_ALG_CRC32= 1, // CRC32 of zlib algorithm. - BINLOG_CHECKSUM_ALG_ENUM_END, // the cut line: valid alg range is [1, 0x7f]. - BINLOG_CHECKSUM_ALG_UNDEF= 255 // special value to tag undetermined yet checksum - // or events from checksum-unaware servers -}; - #define CHECKSUM_CRC32_SIGNATURE_LEN 4 /** defined statically while there is just one alg implemented @@ -1201,7 +1192,7 @@ public: @retval LOG_READ_TOO_LARGE event too large */ static int read_log_event(IO_CACHE* file, String* packet, - uint8 checksum_alg_arg); + enum enum_binlog_checksum_alg checksum_alg_arg); /* The value is set by caller of FD constructor and Log_event::write_header() for the rest. @@ -1210,7 +1201,7 @@ public: On the slave side the value is assigned from post_header_len[last] of the last seen FD event. */ - uint8 checksum_alg; + enum enum_binlog_checksum_alg checksum_alg; static void *operator new(size_t size) { @@ -1995,8 +1986,8 @@ public: my_free(data_buf); } Log_event_type get_type_code() { return QUERY_EVENT; } - static int dummy_event(String *packet, ulong ev_offset, uint8 checksum_alg); - static int begin_event(String *packet, ulong ev_offset, uint8 checksum_alg); + static int dummy_event(String *packet, ulong ev_offset, enum enum_binlog_checksum_alg checksum_alg); + static int begin_event(String *packet, ulong ev_offset, enum enum_binlog_checksum_alg checksum_alg); #ifdef MYSQL_SERVER bool write(IO_CACHE* file); virtual bool write_post_header_for_derived(IO_CACHE* file) { return FALSE; } @@ -2019,7 +2010,7 @@ public: /* !!! Public in this patch to allow old usage */ const char *query_arg, uint32 q_len_arg); static bool peek_is_commit_rollback(const char *event_start, - size_t event_len, uint8 checksum_alg); + size_t event_len, enum enum_binlog_checksum_alg checksum_alg); #endif /* HAVE_REPLICATION */ /* If true, the event always be applied by slave SQL thread or be printed by @@ -3206,9 +3197,9 @@ public: #ifdef MYSQL_SERVER bool write(IO_CACHE *file); static int make_compatible_event(String *packet, bool *need_dummy_event, - ulong ev_offset, uint8 checksum_alg); + ulong ev_offset, enum enum_binlog_checksum_alg checksum_alg); static bool peek(const char *event_start, size_t event_len, - uint8 checksum_alg, + enum enum_binlog_checksum_alg checksum_alg, uint32 *domain_id, uint32 *server_id, uint64 *seq_no, uchar *flags2, const Format_description_log_event *fdev); #endif @@ -3324,7 +3315,7 @@ public: enum_skip_reason do_shall_skip(rpl_group_info *rgi); #endif static bool peek(const char *event_start, uint32 event_len, - uint8 checksum_alg, + enum enum_binlog_checksum_alg checksum_alg, rpl_gtid **out_gtid_list, uint32 *out_list_len, const Format_description_log_event *fdev); }; @@ -4864,8 +4855,8 @@ bool rpl_get_position_info(const char **log_file_name, ulonglong *log_pos, const char **group_relay_log_name, ulonglong *relay_log_pos); -bool event_checksum_test(uchar *buf, ulong event_len, uint8 alg); -uint8 get_checksum_alg(const char* buf, ulong len); +bool event_checksum_test(uchar *buf, ulong event_len, enum_binlog_checksum_alg alg); +enum enum_binlog_checksum_alg get_checksum_alg(const char* buf, ulong len); extern TYPELIB binlog_checksum_typelib; /** diff --git a/sql/rpl_constants.h b/sql/rpl_constants.h index cc6fb8145ad..b1f1286184e 100644 --- a/sql/rpl_constants.h +++ b/sql/rpl_constants.h @@ -69,4 +69,13 @@ enum ExtraRowInfoFormat { #define EXTRA_ROW_INFO_HDR_BYTES 2 #define EXTRA_ROW_INFO_MAX_PAYLOAD (255 - EXTRA_ROW_INFO_HDR_BYTES) +enum enum_binlog_checksum_alg { + BINLOG_CHECKSUM_ALG_OFF= 0, // Events are without checksum though its generator + // is checksum-capable New Master (NM). + BINLOG_CHECKSUM_ALG_CRC32= 1, // CRC32 of zlib algorithm. + BINLOG_CHECKSUM_ALG_ENUM_END, // the cut line: valid alg range is [1, 0x7f]. + BINLOG_CHECKSUM_ALG_UNDEF= 255 // special value to tag undetermined yet checksum + // or events from checksum-unaware servers +}; + #endif /* RPL_CONSTANTS_H */ diff --git a/sql/rpl_mi.h b/sql/rpl_mi.h index 7ba64a9dc92..69d602c1dcb 100644 --- a/sql/rpl_mi.h +++ b/sql/rpl_mi.h @@ -218,7 +218,7 @@ class Master_info : public Slave_reporting_capability Initialized to novalue, then set to the queried from master @@global.binlog_checksum and deactivated once FD has been received. */ - uint8 checksum_alg_before_fd; + enum enum_binlog_checksum_alg checksum_alg_before_fd; uint connect_retry; #ifndef DBUG_OFF int events_till_disconnect; diff --git a/sql/rpl_utility.cc b/sql/rpl_utility.cc index 0f244267563..d1dd0298a1f 100644 --- a/sql/rpl_utility.cc +++ b/sql/rpl_utility.cc @@ -1158,7 +1158,7 @@ table_def::~table_def() @return TRUE if test fails FALSE as success */ -bool event_checksum_test(uchar *event_buf, ulong event_len, uint8 alg) +bool event_checksum_test(uchar *event_buf, ulong event_len, enum enum_binlog_checksum_alg alg) { bool res= FALSE; uint16 flags= 0; // to store in FD's buffer flags orig value diff --git a/sql/slave.cc b/sql/slave.cc index 659f3a90574..63fc2fe4155 100644 --- a/sql/slave.cc +++ b/sql/slave.cc @@ -1881,8 +1881,8 @@ when it try to get the value of TIME_ZONE global variable from master."; (master_row= mysql_fetch_row(master_res)) && (master_row[0] != NULL)) { - mi->checksum_alg_before_fd= (uint8) - find_type(master_row[0], &binlog_checksum_typelib, 1) - 1; + mi->checksum_alg_before_fd= (enum_binlog_checksum_alg) + (find_type(master_row[0], &binlog_checksum_typelib, 1) - 1); // valid outcome is either of DBUG_ASSERT(mi->checksum_alg_before_fd == BINLOG_CHECKSUM_ALG_OFF || mi->checksum_alg_before_fd == BINLOG_CHECKSUM_ALG_CRC32); @@ -5408,9 +5408,9 @@ static int queue_event(Master_info* mi,const char* buf, ulong event_len) Show-up of FD:s affects checksum_alg at once because that changes FD_queue. */ - uint8 checksum_alg= mi->checksum_alg_before_fd != BINLOG_CHECKSUM_ALG_UNDEF ? - mi->checksum_alg_before_fd : - mi->rli.relay_log.relay_log_checksum_alg; + enum enum_binlog_checksum_alg checksum_alg= + mi->checksum_alg_before_fd != BINLOG_CHECKSUM_ALG_UNDEF ? + mi->checksum_alg_before_fd : mi->rli.relay_log.relay_log_checksum_alg; char *save_buf= NULL; // needed for checksumming the fake Rotate event char rot_buf[LOG_EVENT_HEADER_LEN + ROTATE_HEADER_LEN + FN_REFLEN]; diff --git a/sql/sql_repl.cc b/sql/sql_repl.cc index 52e94ec27f8..9bf7c7c9416 100644 --- a/sql/sql_repl.cc +++ b/sql/sql_repl.cc @@ -51,7 +51,7 @@ extern TYPELIB binlog_checksum_typelib; static int fake_event_header(String* packet, Log_event_type event_type, ulong extra_len, my_bool *do_checksum, ha_checksum *crc, const char** errmsg, - uint8 checksum_alg_arg, uint32 end_pos) + enum enum_binlog_checksum_alg checksum_alg_arg, uint32 end_pos) { char header[LOG_EVENT_HEADER_LEN]; ulong event_len; @@ -132,7 +132,7 @@ struct binlog_send_info { enum_gtid_skip_type gtid_skip_group; enum_gtid_until_state gtid_until_group; ushort flags; - uint8 current_checksum_alg; + enum enum_binlog_checksum_alg current_checksum_alg; bool slave_gtid_strict_mode; bool send_fake_gtid_list; bool slave_gtid_ignore_duplicates; @@ -208,7 +208,7 @@ static int reset_transmit_packet(struct binlog_send_info *info, ushort flags, */ static int fake_rotate_event(binlog_send_info *info, ulonglong position, - const char** errmsg, uint8 checksum_alg_arg) + const char** errmsg, enum enum_binlog_checksum_alg checksum_alg_arg) { DBUG_ENTER("fake_rotate_event"); ulong ev_offset; @@ -453,9 +453,9 @@ static bool is_slave_checksum_aware(THD * thd) @c enum enum_binlog_checksum_alg */ -static uint8 get_binlog_checksum_value_at_connect(THD * thd) +static enum enum_binlog_checksum_alg get_binlog_checksum_value_at_connect(THD * thd) { - uint8 ret; + enum enum_binlog_checksum_alg ret; DBUG_ENTER("get_binlog_checksum_value_at_connect"); user_var_entry *entry= get_binlog_checksum_uservar(thd); @@ -470,7 +470,8 @@ static uint8 get_binlog_checksum_value_at_connect(THD * thd) uint dummy_errors; str.copy(entry->value, entry->length, &my_charset_bin, &my_charset_bin, &dummy_errors); - ret= (uint8) find_type ((char*) str.ptr(), &binlog_checksum_typelib, 1) - 1; + ret= (enum_binlog_checksum_alg) + (find_type ((char*) str.ptr(), &binlog_checksum_typelib, 1) - 1); DBUG_ASSERT(ret <= BINLOG_CHECKSUM_ALG_CRC32); // while it's just on CRC32 alg } DBUG_RETURN(ret); @@ -774,7 +775,7 @@ get_slave_until_gtid(THD *thd, String *out_str) static int send_heartbeat_event(binlog_send_info *info, NET* net, String* packet, const struct event_coordinates *coord, - uint8 checksum_alg_arg) + enum enum_binlog_checksum_alg checksum_alg_arg) { DBUG_ENTER("send_heartbeat_event"); @@ -1394,7 +1395,7 @@ gtid_state_from_pos(const char *name, uint32 offset, bool found_gtid_list_event= false; bool found_format_description_event= false; bool valid_pos= false; - uint8 current_checksum_alg= BINLOG_CHECKSUM_ALG_UNDEF; + enum enum_binlog_checksum_alg current_checksum_alg= BINLOG_CHECKSUM_ALG_UNDEF; int err; String packet; Format_description_log_event *fdev= NULL; @@ -1437,8 +1438,8 @@ gtid_state_from_pos(const char *name, uint32 offset, packet.length(0); err= Log_event::read_log_event(&cache, &packet, - opt_master_verify_checksum - ? current_checksum_alg : 0); + opt_master_verify_checksum ? current_checksum_alg + : BINLOG_CHECKSUM_ALG_OFF); if (err) { errormsg= "Could not read binlog while searching for slave start " @@ -1646,7 +1647,7 @@ send_event_to_slave(binlog_send_info *info, Log_event_type event_type, String* const packet= info->packet; size_t len= packet->length(); int mariadb_slave_capability= info->mariadb_slave_capability; - uint8 current_checksum_alg= info->current_checksum_alg; + enum enum_binlog_checksum_alg current_checksum_alg= info->current_checksum_alg; slave_connection_state *gtid_state= &info->gtid_state; slave_connection_state *until_gtid_state= info->until_gtid_state; @@ -2229,7 +2230,7 @@ static int send_format_descriptor_event(binlog_send_info *info, IO_CACHE *log, info->last_pos= my_b_tell(log); error= Log_event::read_log_event(log, packet, opt_master_verify_checksum - ? info->current_checksum_alg : 0); + ? info->current_checksum_alg : BINLOG_CHECKSUM_ALG_OFF); linfo->pos= my_b_tell(log); if (error) @@ -2559,8 +2560,8 @@ static int send_events(binlog_send_info *info, IO_CACHE* log, LOG_INFO* linfo, info->last_pos= linfo->pos; error= Log_event::read_log_event(log, packet, - opt_master_verify_checksum - ? info->current_checksum_alg : 0); + opt_master_verify_checksum ? info->current_checksum_alg + : BINLOG_CHECKSUM_ALG_OFF); linfo->pos= my_b_tell(log); if (error) diff --git a/sql/wsrep_mysqld.cc b/sql/wsrep_mysqld.cc index e74c898dd95..0a44dd278ac 100644 --- a/sql/wsrep_mysqld.cc +++ b/sql/wsrep_mysqld.cc @@ -1221,7 +1221,7 @@ int wsrep_to_buf_helper( int ret(0); Format_description_log_event *tmp_fd= new Format_description_log_event(4); - tmp_fd->checksum_alg= binlog_checksum_options; + tmp_fd->checksum_alg= (enum_binlog_checksum_alg)binlog_checksum_options; tmp_fd->write(&tmp_io_cache); delete tmp_fd; |