Skip to content

Commit

Permalink
fix a merge error
Browse files Browse the repository at this point in the history
  • Loading branch information
vuvova committed May 13, 2022
1 parent da18a5d commit 6d51b5d
Showing 1 changed file with 2 additions and 27 deletions.
29 changes: 2 additions & 27 deletions sql/slave.cc
Original file line number Diff line number Diff line change
Expand Up @@ -7189,33 +7189,8 @@ static int queue_event(Master_info* mi, const uchar *buf, ulong event_len)
mi->gtid_current_pos.update(&mi->last_queued_gtid);
mi->events_queued_since_last_gtid= 0;

if (unlikely(gtid_skip_enqueue))
{
error= ER_SLAVE_RELAY_LOG_WRITE_FAILURE;
sql_print_error("Recieved a group closing %s event "
"at %llu position in the group while there are "
"still %llu events to skip upon reconnecting; "
"the last seen GTID is %u-%u-%llu",
Log_event::get_type_str((Log_event_type) (uchar)
buf[EVENT_TYPE_OFFSET]),
(mi->events_queued_since_last_gtid -
mi->gtid_reconnect_event_skip_count),
mi->events_queued_since_last_gtid,
mi->last_queued_gtid);
goto err;
}
else
{
/*
The whole of the current event group is queued. So in case of
reconnect we can start from after the current GTID.
*/
mi->gtid_current_pos.update(&mi->last_queued_gtid);
mi->events_queued_since_last_gtid= 0;

/* Reset the domain_id_filter flag. */
mi->domain_id_filter.reset_filter();
}
/* Reset the domain_id_filter flag. */
mi->domain_id_filter.reset_filter();
}

skip_relay_logging:
Expand Down

0 comments on commit 6d51b5d

Please sign in to comment.