Spinlock added for slave state set
Spinlock added for slave state set
This commit is contained in:
@ -2261,8 +2261,11 @@ ROUTER_INSTANCE *router = slave->router;
|
|||||||
slave->binlogfile,
|
slave->binlogfile,
|
||||||
(unsigned long)slave->binlog_pos)));
|
(unsigned long)slave->binlog_pos)));
|
||||||
|
|
||||||
|
spinlock_acquire(&slave->catch_lock);
|
||||||
slave->cstate |= CS_EXPECTCB;
|
slave->cstate |= CS_EXPECTCB;
|
||||||
|
spinlock_release(&slave->catch_lock);
|
||||||
poll_fake_write_event(slave->dcb);
|
poll_fake_write_event(slave->dcb);
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user