lib/wsrep-lib
1
0
Fork 0
mirror of https://github.com/codership/wsrep-lib.git synced 2025-07-25 21:41:56 +03:00
Code Activity

use log_position when calculating bytes_to_replicate

Browse Source 
`bytes_certified` includes XA events which are not written to the
binlog. Thus, we need to use `log_position` instead.
This commit is contained in:
Leandro Pacheco
2019-03-11 14:49:01 +01:00
committed by Daniele Sciascia
parent a9987aa970
commit d9ada0226f
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/transaction.cpp
View File

@ -1150,7 +1150,7 @@ int wsrep::transaction::streaming_step(wsrep::unique_lock<wsrep::mutex>& lock)
int ret(0); int ret(0);
const size_t bytes_to_replicate(client_service_.bytes_generated() - const size_t bytes_to_replicate(client_service_.bytes_generated() -
streaming_context_.bytes_certified()); streaming_context_.log_position());
switch (streaming_context_.fragment_unit()) switch (streaming_context_.fragment_unit())
{ {
@ -1699,6 +1699,7 @@ void wsrep::transaction::debug_log_state(
<< ", unit: " << streaming_context_.fragment_unit() << ", unit: " << streaming_context_.fragment_unit()
<< ", size: " << streaming_context_.fragment_size() << ", size: " << streaming_context_.fragment_size()
<< ", counter: " << streaming_context_.unit_counter() << ", counter: " << streaming_context_.unit_counter()
<< ", log_pos: " << streaming_context_.log_position()
<< ", bytes: " << streaming_context_.bytes_certified() << ", bytes: " << streaming_context_.bytes_certified()
<< ", sr_rb: " << streaming_context_.rolled_back() << ", sr_rb: " << streaming_context_.rolled_back()
<< "\n own: " << (client_state_.owning_thread_id_ == wsrep::this_thread::get_id()) << "\n own: " << (client_state_.owning_thread_id_ == wsrep::this_thread::get_id())

2
wsrep-API/v26

Submodule wsrep-API/v26 updated: 12a50c43b1...75a5f452f2