1 files changed, 10 insertions, 0 deletions

diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index f9e82b7..7a89492 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -111,6 +111,16 @@ void Pipeline::startTransaction()
     d->transaction = std::move(storage().createTransaction(Storage::ReadWrite, [](const Sink::Storage::Error &error) {
         Warning() << error.message;
     }));
+
+    //FIXME this is a temporary measure to recover from a failure to open the named databases correctly.
+    //Once the actual problem is fixed it will be enough to simply crash if we open the wrong database (which we check in openDatabase already).
+    //It seems like the validateNamedDatabase calls actually stops the mdb_put failures during sync...
+    while (!d->transaction.validateNamedDatabases()) {
+        Warning() << "Opened an invalid transaction!!!!!!";
+        d->transaction = std::move(storage().createTransaction(Storage::ReadWrite, [](const Sink::Storage::Error &error) {
+        Warning() << error.message;
+    }));
+    }
 }
 
 void Pipeline::commit()