diff --git a/dbsim/db_client_service.hpp b/dbsim/db_client_service.hpp index fdcbb52..fe9d632 100644 --- a/dbsim/db_client_service.hpp +++ b/dbsim/db_client_service.hpp @@ -60,7 +60,8 @@ namespace db { return true; } - int prepare_fragment_for_replication(wsrep::mutable_buffer&) override + int prepare_fragment_for_replication(wsrep::mutable_buffer&, + size_t& position) override { return 0; } diff --git a/test/mock_client_state.hpp b/test/mock_client_state.hpp index 7e8308e..df2c858 100644 --- a/test/mock_client_state.hpp +++ b/test/mock_client_state.hpp @@ -146,7 +146,7 @@ namespace wsrep bool statement_allowed_for_streaming() const WSREP_OVERRIDE { return true; } - int prepare_fragment_for_replication(wsrep::mutable_buffer& buffer) + int prepare_fragment_for_replication(wsrep::mutable_buffer& buffer, size_t& position) WSREP_OVERRIDE { if (error_during_prepare_data_) @@ -156,6 +156,7 @@ namespace wsrep static const char buf[1] = { 1 }; buffer.push_back(&buf[0], &buf[1]); wsrep::const_buffer data(buffer.data(), buffer.size()); + position = buffer.size(); return client_state_.append_data(data); }