WL#7491: GTID-based replication applier recovery and positioning

Step 1: Add fields to the master and relay log info classes.

ReviewBoard: 26586

Author: pedrolgomes

sql/rpl_mi.cc

@@ -193,7 +193,9 @@ Master_info::Master_info(
       auto_position(false),
       transaction_parser(
           Transaction_boundary_parser::TRX_BOUNDARY_PARSER_RECEIVER),
-      reset(false) {
+      reset(false),
+      m_gtid_only_mode(false),
+      m_is_receiver_position_info_invalid(false) {
   host[0] = 0;
   user[0] = 0;
   bind_addr[0] = 0;
@@ -785,3 +787,17 @@ void Master_info::get_flushed_relay_log_info(LOG_INFO *linfo) {
           sizeof(linfo->log_file_name) - 1);
   linfo->pos = flushed_relay_log_info.pos;
 }
+
+void Master_info::set_receiver_position_info_invalid(bool invalid) {
+  m_is_receiver_position_info_invalid = invalid;
+}
+
+bool Master_info::is_receiver_position_info_invalid() const {
+  return m_is_receiver_position_info_invalid;
+}
+
+void Master_info::set_gtid_only_mode(bool gtid_only_mode) {
+  m_gtid_only_mode = gtid_only_mode;
+}
+
+bool Master_info::is_gtid_only_mode() const { return m_gtid_only_mode; }

sql/rpl_mi.h

@@ -750,12 +750,55 @@ class Master_info : public Rpl_info {
 
   void get_flushed_relay_log_info(LOG_INFO *linfo);
 
+  /**
+    Marks the receiver position information (master_log_name, master_log_pos)
+    as being invalid or not.
+
+    @param invalid The value to set the status to invalid or valid
+  */
+  void set_receiver_position_info_invalid(bool invalid);
+
+  /**
+    Returns if receiver position information is valid or invalid
+
+    @return true if receiver position information is not reliable,
+            false otherwise.
+  */
+  bool is_receiver_position_info_invalid() const;
+
+  /**
+    Enable or disable the gtid_only mode
+
+    @param gtid_only_mode value to set gtid_only (enable/disable it)
+  */
+  void set_gtid_only_mode(bool gtid_only_mode);
+
+  /**
+    Returns if gtid_only is enabled or not
+
+    @return true if gtid_only mode is active for a channel,
+            false otherwise.
+  */
+  bool is_gtid_only_mode() const;
+
  private:
   /*
     Holds the relay log coordinates (file name and position) of the last master
     coordinates flushed into Master_info repository.
   */
   LOG_INFO flushed_relay_log_info;
+
+  /**
+    Is the replica working in GTID only mode, meaning it does not
+    persist position related information when executing or queing transactions.
+  */
+  bool m_gtid_only_mode;
+
+  /**
+    Are positions invalid. When true this means the values for
+    receiver position related information might be outdated.
+  */
+  bool m_is_receiver_position_info_invalid;
 };
 
 #endif /* RPL_MI_H */

sql/rpl_rli.cc

@@ -146,6 +146,7 @@ Relay_log_info::Relay_log_info(bool is_slave_recovery,
       m_privilege_checks_user_corrupted{false},
       m_require_row_format(false),
       m_require_table_primary_key_check(PK_CHECK_STREAM),
+      m_is_applier_source_position_info_invalid(false),
       is_group_master_log_pos_invalid(false),
       log_space_total(0),
       ignore_log_space_limit(false),
@@ -3243,6 +3244,14 @@ void Relay_log_info::set_require_table_primary_key_check(
   this->m_require_table_primary_key_check = require_pk;
 }
 
+void Relay_log_info::set_applier_source_position_info_invalid(bool invalid) {
+  m_is_applier_source_position_info_invalid = invalid;
+}
+
+bool Relay_log_info::is_applier_source_position_info_invalid() const {
+  return m_is_applier_source_position_info_invalid;
+}
+
 std::string Assign_gtids_to_anonymous_transactions_info::get_value() const {
   return m_value;
 }

sql/rpl_rli.h

@@ -643,6 +643,21 @@ class Relay_log_info : public Rpl_info {
   */
   Replication_transaction_boundary_parser transaction_parser;
 
+  /**
+    Marks the applier position information as being invalid or not.
+
+    @param invalid value to set the position/file info as invalid or not
+  */
+  void set_applier_source_position_info_invalid(bool invalid);
+
+  /**
+    Returns if the applier positions are marked as being invalid or not.
+
+    @return true if applier position information is not reliable,
+            false otherwise.
+  */
+  bool is_applier_source_position_info_invalid() const;
+
   /*
     Let's call a group (of events) :
       - a transaction
@@ -771,6 +786,15 @@ class Relay_log_info : public Rpl_info {
   */
   enum_require_table_primary_key m_require_table_primary_key_check;
 
+  /**
+    Are positions invalid. If true it means the applier related position
+    information (group_master_log_name and group_master_log_pos) might
+    be outdated.
+
+    Check also is_group_master_log_pos_invalid
+  */
+  bool m_is_applier_source_position_info_invalid;
+
  public:
   bool is_relay_log_truncated() { return m_relay_log_truncated; }
 
@@ -826,12 +850,14 @@ class Relay_log_info : public Rpl_info {
   void fill_coord_err_buf(loglevel level, int err_code,
                           const char *buff_coord) const;
 
-  /*
+  /**
     Flag that the group_master_log_pos is invalid. This may occur
     (for example) after CHANGE MASTER TO RELAY_LOG_POS.  This will
     be unset after the first event has been executed and the
     group_master_log_pos is valid again.
-   */
+
+    Check also m_is_applier_position_info_invalid
+  */
   bool is_group_master_log_pos_invalid;
 
   /*