Commit d6e1e47b authored by jplindst@t41.(none)'s avatar jplindst@t41.(none)

Added function innobase_store_binlog_offset_and_flush_log requested by Guilhem

to ha_innodb.cc and ha_innodb.h
parent 500874b5
...@@ -78,6 +78,7 @@ jcole@sarvik.tfr.cafe.ee ...@@ -78,6 +78,7 @@ jcole@sarvik.tfr.cafe.ee
jcole@tetra.spaceapes.com jcole@tetra.spaceapes.com
joreland@mysql.com joreland@mysql.com
jorge@linux.jorge.mysql.com jorge@linux.jorge.mysql.com
jplindst@t41.(none)
kaj@work.mysql.com kaj@work.mysql.com
konstantin@mysql.com konstantin@mysql.com
kostja@oak.local kostja@oak.local
......
...@@ -66,6 +66,7 @@ extern "C" { ...@@ -66,6 +66,7 @@ extern "C" {
#include "../innobase/include/trx0roll.h" #include "../innobase/include/trx0roll.h"
#include "../innobase/include/trx0trx.h" #include "../innobase/include/trx0trx.h"
#include "../innobase/include/trx0sys.h" #include "../innobase/include/trx0sys.h"
#include "../innobase/include/mtr0mtr.h"
#include "../innobase/include/row0ins.h" #include "../innobase/include/row0ins.h"
#include "../innobase/include/row0mysql.h" #include "../innobase/include/row0mysql.h"
#include "../innobase/include/row0sel.h" #include "../innobase/include/row0sel.h"
...@@ -5182,4 +5183,36 @@ ha_innobase::get_auto_increment() ...@@ -5182,4 +5183,36 @@ ha_innobase::get_auto_increment()
return(nr); return(nr);
} }
/***********************************************************************
This function stores binlog offset and flushes logs */
void
innobase_store_binlog_offset_and_flush_log(
/*=============================*/
char *binlog_name, /* in: binlog name */
longlong offset /* in: binlog offset */
)
{
mtr_t mtr;
assert(binlog_name != NULL);
/* Start a mini-transaction */
mtr_start_noninline(&mtr);
/* Update the latest MySQL binlog name and offset info
in trx sys header */
trx_sys_update_mysql_binlog_offset(
binlog_name,
offset,
TRX_SYS_MYSQL_LOG_INFO, &mtr);
/* Commits the mini-transaction */
mtr_commit(&mtr);
/* Syncronous flush of the log buffer to disk */
log_buffer_flush_to_disk();
}
#endif /* HAVE_INNOBASE_DB */ #endif /* HAVE_INNOBASE_DB */
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment