From 639fc60c100204c87b93112516cf3b3117cfff0d Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Fri, 5 Dec 2014 01:02:51 +0100
Subject: Return false on error during read.

---
 store/database.cpp | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

(limited to 'store/database.cpp')

diff --git a/store/database.cpp b/store/database.cpp
index 0c4fd18..c4dfbd6 100644
--- a/store/database.cpp
+++ b/store/database.cpp
@@ -187,9 +187,9 @@ bool Database::write(const std::string &sKey, const std::string &sValue)
     return !rc;
 }
 
-void Database::read(const std::string &sKey, const std::function<void(const std::string &value)> &resultHandler)
+bool Database::read(const std::string &sKey, const std::function<void(const std::string &value)> &resultHandler)
 {
-    read(sKey,
+    return read(sKey,
          [&](void *ptr, int size) {
             const std::string resultValue(static_cast<char*>(ptr), size);
             resultHandler(resultValue);
@@ -197,10 +197,10 @@ void Database::read(const std::string &sKey, const std::function<void(const std:
 // std::cout << "key: " << resultKey << " data: " << resultValue << std::endl;
 }
 
-void Database::read(const std::string &sKey, const std::function<void(void *ptr, int size)> &resultHandler)
+bool Database::read(const std::string &sKey, const std::function<void(void *ptr, int size)> &resultHandler)
 {
     if (!d->env) {
-        return;
+        return false;
     }
 
     int rc;
@@ -215,14 +215,14 @@ void Database::read(const std::string &sKey, const std::function<void(void *ptr,
     if (implicitTransaction) {
         // TODO: if this fails, still try the write below?
         if (!startTransaction(ReadOnly)) {
-            return;
+            return false;
         }
     }
 
     rc = mdb_cursor_open(d->transaction, d->dbi, &cursor);
     if (rc) {
         std::cerr << "mdb_cursor_get: " << rc << " " << mdb_strerror(rc) << std::endl;
-        return;
+        return false;
     }
 
     if (sKey.empty()) {
@@ -246,6 +246,7 @@ void Database::read(const std::string &sKey, const std::function<void(void *ptr,
 
     if (rc) {
         std::cerr << "mdb_cursor_get: " << rc << " " << mdb_strerror(rc) << std::endl;
+        return false;
     }
 
     mdb_cursor_close(cursor);
@@ -256,6 +257,7 @@ void Database::read(const std::string &sKey, const std::function<void(void *ptr,
         abortTransaction();
     }
     */
+    return true;
 }
 
 qint64 Database::diskUsage() const
-- 
cgit v1.2.3