Avoid unnecessary commits

1 files changed, 5 insertions, 0 deletions

diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index 9813f60..f9e82b7 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -120,6 +120,11 @@ void Pipeline::commit()
     // for (auto processor : d->processors[bufferType]) {
     //     processor->finalize();
     // }
+    if (!d->revisionChanged) {
+        d->transaction.abort();
+        d->transaction = Storage::Transaction();
+        return;
+    }
     const auto revision = Storage::maxRevision(d->transaction);
     const auto elapsed = d->transactionTime.elapsed();
     Log() << "Committing revision: " << revision << ":" << d->transactionItemCount << " items in: " << Log::TraceTime(elapsed) << " "