From 31ae386a96e61c4382aa15c13d9b23cdb158353d Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Mon, 20 Jun 2016 18:21:25 +0200 Subject: Avoid unnecessary commits --- common/pipeline.cpp | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'common/pipeline.cpp') 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) << " " -- cgit v1.2.3