From b3948590f8f042e577e7b412c543a94b9294fbba Mon Sep 17 00:00:00 2001 From: CJ Cobb Date: Fri, 4 Mar 2022 10:00:45 -0500 Subject: [PATCH] fix sync interval failover bug --- src/backend/CassandraBackend.h | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/backend/CassandraBackend.h b/src/backend/CassandraBackend.h index 4030a899..0ecf7937 100644 --- a/src/backend/CassandraBackend.h +++ b/src/backend/CassandraBackend.h @@ -695,7 +695,7 @@ public: doFinishWrites() override { if (!range || lastSync_ == 0 || - ledgerSequence_ - syncInterval_ == lastSync_) + ledgerSequence_ - syncInterval_ >= lastSync_) { // wait for all other writes to finish sync(); @@ -726,6 +726,14 @@ public: << std::to_string(ledgerSequence_); lastSync_ = ledgerSequence_; } + else + { + BOOST_LOG_TRIVIAL(info) + << __func__ << " Skipping commit. sync interval is " + << std::to_string(syncInterval_) << " - last sync is " + << std::to_string(lastSync_) << " - ledger sequence is " + << std::to_string(ledgerSequence_); + } return true; } void