Upon the sql command flush logs, we need to ensure that all outstanding
ndb data to be logged has made it to the binary log to get a deterministic behavior on the rotation of the log.
This commit is contained in:
parent
ded39d5a5e
commit
9dfc925db0
@ -683,6 +683,18 @@ static void ndbcluster_reset_slave(THD *thd)
|
|||||||
/*
|
/*
|
||||||
Initialize the binlog part of the ndb handlerton
|
Initialize the binlog part of the ndb handlerton
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
Upon the sql command flush logs, we need to ensure that all outstanding
|
||||||
|
ndb data to be logged has made it to the binary log to get a deterministic
|
||||||
|
behavior on the rotation of the log.
|
||||||
|
*/
|
||||||
|
static bool ndbcluster_flush_logs(handlerton *hton)
|
||||||
|
{
|
||||||
|
ndbcluster_binlog_wait(current_thd);
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
static int ndbcluster_binlog_func(handlerton *hton, THD *thd,
|
static int ndbcluster_binlog_func(handlerton *hton, THD *thd,
|
||||||
enum_binlog_func fn,
|
enum_binlog_func fn,
|
||||||
void *arg)
|
void *arg)
|
||||||
@ -711,6 +723,7 @@ static int ndbcluster_binlog_func(handlerton *hton, THD *thd,
|
|||||||
void ndbcluster_binlog_init_handlerton()
|
void ndbcluster_binlog_init_handlerton()
|
||||||
{
|
{
|
||||||
handlerton *h= ndbcluster_hton;
|
handlerton *h= ndbcluster_hton;
|
||||||
|
h->flush_logs= ndbcluster_flush_logs;
|
||||||
h->binlog_func= ndbcluster_binlog_func;
|
h->binlog_func= ndbcluster_binlog_func;
|
||||||
h->binlog_log_query= ndbcluster_binlog_log_query;
|
h->binlog_log_query= ndbcluster_binlog_log_query;
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user