diff options
| author | Seppo Jaakola <seppo.jaakola@codership.com> | 2013-05-21 00:10:35 +0300 |
|---|---|---|
| committer | Seppo Jaakola <seppo.jaakola@codership.com> | 2013-05-21 00:10:35 +0300 |
| commit | e95fdb74ab85bf24b805c1d4ead8c3d3a791b79a (patch) | |
| tree | 5c13acfc631a6de475dc46d54f651460c92d091e /sql/wsrep_hton.cc | |
| parent | 3e841b77e0b683bcf16546eeef8c286150ed2b6f (diff) | |
| download | mariadb-git-e95fdb74ab85bf24b805c1d4ead8c3d3a791b79a.tar.gz | |
merged in revisions 3853..3857 from lp:codership-mysql/5.5-23
Diffstat (limited to 'sql/wsrep_hton.cc')
| -rw-r--r-- | sql/wsrep_hton.cc | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/sql/wsrep_hton.cc b/sql/wsrep_hton.cc index 0e013556f45..576e6b8ad47 100644 --- a/sql/wsrep_hton.cc +++ b/sql/wsrep_hton.cc @@ -178,6 +178,7 @@ int wsrep_commit(handlerton *hton, THD *thd, bool all) extern Rpl_filter* binlog_filter; extern my_bool opt_log_slave_updates; +extern void wsrep_write_rbr_buf(THD *thd, const void* rbr_buf, size_t buf_len); enum wsrep_trx_status wsrep_run_wsrep_commit( THD *thd, handlerton *hton, bool all) @@ -337,6 +338,10 @@ wsrep_run_wsrep_commit( (thd->wsrep_PA_safe) ? WSREP_FLAG_PA_SAFE : 0ULL, &thd->wsrep_trx_seqno); if (rcode == WSREP_TRX_MISSING) { + WSREP_WARN("Transaction missing in provider, thd: %ld, SQL: %s", + thd->thread_id, thd->query()); + wsrep_write_rbr_buf(thd, rbr_data, data_len); + rcode = WSREP_OK; } else if (rcode == WSREP_BF_ABORT) { mysql_mutex_lock(&thd->LOCK_wsrep_thd); |