Variable moved
Variable moved
This commit is contained in:
@ -1697,7 +1697,6 @@ uint8_t *ptr;
|
|||||||
int len, rval, binlognamelen;
|
int len, rval, binlognamelen;
|
||||||
REP_HEADER hdr;
|
REP_HEADER hdr;
|
||||||
uint32_t chksum;
|
uint32_t chksum;
|
||||||
bool force_disconnect = false;
|
|
||||||
|
|
||||||
ptr = GWBUF_DATA(queue);
|
ptr = GWBUF_DATA(queue);
|
||||||
len = extract_field(ptr, 24);
|
len = extract_field(ptr, 24);
|
||||||
@ -1731,6 +1730,8 @@ bool force_disconnect = false;
|
|||||||
* Force slave disconnection if requested position is unsafe.
|
* Force slave disconnection if requested position is unsafe.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
bool force_disconnect = false;
|
||||||
|
|
||||||
spinlock_acquire(&router->binlog_lock);
|
spinlock_acquire(&router->binlog_lock);
|
||||||
if (router->pending_transaction && strcmp(router->binlog_name, slave->binlogfile) == 0 &&
|
if (router->pending_transaction && strcmp(router->binlog_name, slave->binlogfile) == 0 &&
|
||||||
(slave->binlog_pos > router->binlog_position) && !router->rotating)
|
(slave->binlog_pos > router->binlog_position) && !router->rotating)
|
||||||
|
Reference in New Issue
Block a user