lib/wsrep-lib
1
0
Fork 0
mirror of https://github.com/codership/wsrep-lib.git synced 2025-07-28 20:02:00 +03:00
Code Activity

removing bytes_certified

Browse Source
This commit is contained in:
Leandro Pacheco
2019-03-12 11:37:45 +01:00
committed by Daniele Sciascia
parent d9ada0226f
commit 98af85498b
2 changed files with 3 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
include/wsrep/streaming_context.hpp
View File

@ -45,7 +45,6 @@ namespace wsrep
, rollback_replicated_for_() , rollback_replicated_for_()
, fragment_unit_() , fragment_unit_()
, fragment_size_() , fragment_size_()
, bytes_certified_()
, unit_counter_() , unit_counter_()
, log_position_() , log_position_()
{ } { }
@ -102,10 +101,9 @@ namespace wsrep
fragment_size_ = 0; fragment_size_ = 0;
} }
void certified(size_t bytes) void certified()
{ {
++fragments_certified_; ++fragments_certified_;
bytes_certified_ += bytes;
} }
size_t fragments_certified() const size_t fragments_certified() const
@ -131,11 +129,6 @@ namespace wsrep
fragments_.push_back(seqno); fragments_.push_back(seqno);
} }
size_t bytes_certified() const
{
return bytes_certified_;
}
void rolled_back(wsrep::transaction_id id) void rolled_back(wsrep::transaction_id id)
{ {
assert(rollback_replicated_for_ == wsrep::transaction_id::undefined()); assert(rollback_replicated_for_ == wsrep::transaction_id::undefined());
@ -193,7 +186,6 @@ namespace wsrep
fragments_certified_ = 0; fragments_certified_ = 0;
fragments_.clear(); fragments_.clear();
rollback_replicated_for_ = wsrep::transaction_id::undefined(); rollback_replicated_for_ = wsrep::transaction_id::undefined();
bytes_certified_ = 0;
unit_counter_ = 0; unit_counter_ = 0;
log_position_ = 0; log_position_ = 0;
} }
@ -210,7 +202,6 @@ namespace wsrep
wsrep::transaction_id rollback_replicated_for_; wsrep::transaction_id rollback_replicated_for_;
enum fragment_unit fragment_unit_; enum fragment_unit fragment_unit_;
size_t fragment_size_; size_t fragment_size_;
size_t bytes_certified_;
size_t unit_counter_; size_t unit_counter_;
size_t log_position_; size_t log_position_;
}; };

5
src/transaction.cpp
View File

@ -1292,7 +1292,7 @@ int wsrep::transaction::certify_fragment(
case wsrep::provider::success: case wsrep::provider::success:
++fragments_certified_for_statement_; ++fragments_certified_for_statement_;
assert(sr_ws_meta.seqno().is_undefined() == false); assert(sr_ws_meta.seqno().is_undefined() == false);
streaming_context_.certified(data.size()); streaming_context_.certified();
if (storage_service.update_fragment_meta(sr_ws_meta)) if (storage_service.update_fragment_meta(sr_ws_meta))
{ {
storage_service.rollback(wsrep::ws_handle(), storage_service.rollback(wsrep::ws_handle(),
@ -1332,7 +1332,7 @@ int wsrep::transaction::certify_fragment(
// we take a risk of sending one rollback fragment for nothing. // we take a risk of sending one rollback fragment for nothing.
storage_service.rollback(wsrep::ws_handle(), storage_service.rollback(wsrep::ws_handle(),
wsrep::ws_meta()); wsrep::ws_meta());
streaming_context_.certified(data.size()); streaming_context_.certified();
ret = 1; ret = 1;
error = wsrep::e_deadlock_error; error = wsrep::e_deadlock_error;
break; break;
@ -1700,7 +1700,6 @@ void wsrep::transaction::debug_log_state(
<< ", 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() << ", log_pos: " << streaming_context_.log_position()
<< ", 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())
<< " thread_id: " << client_state_.owning_thread_id_ << " thread_id: " << client_state_.owning_thread_id_