Fixed event position updating
The position of the next event to be written was used as the position of the current event. This caused the checks for the position of the current safe event to fail and the non-transaction safe version was used. This only happened with events that are not done inside a transaction i.e. DDL statements.
This commit is contained in:
@ -1466,9 +1466,8 @@ blr_handle_binlog_record(ROUTER_INSTANCE *router, GWBUF *pkt)
|
||||
|
||||
if (router->trx_safe == 0 || (router->trx_safe && router->pending_transaction == 0))
|
||||
{
|
||||
|
||||
router->binlog_position = router->current_pos;
|
||||
router->current_safe_event = router->current_pos;
|
||||
router->current_safe_event = router->last_event_pos;
|
||||
|
||||
spinlock_release(&router->binlog_lock);
|
||||
|
||||
|
Reference in New Issue
Block a user