]> git.notmuchmail.org Git - notmuch/commitdiff
lib: add _notmuch_database_reopen
authorDavid Bremner <david@tethera.net>
Fri, 24 Feb 2017 01:38:24 +0000 (21:38 -0400)
committerDavid Bremner <david@tethera.net>
Sun, 26 Feb 2017 01:09:17 +0000 (21:09 -0400)
The main expected use is to recover from a Xapian::DatabaseChanged
exception.

lib/database-private.h
lib/database.cc
lib/notmuch-private.h

index 2fb60f5ef3ac9e941ebf3112cae997872f143a47..06882439fc580f88b827b6648b267855b7e5abd4 100644 (file)
@@ -207,6 +207,10 @@ struct _notmuch_database {
     unsigned long revision;
     const char *uuid;
 
+    /* Keep track of the number of times the database has been re-opened
+     * (or other global invalidations of notmuch's caching)
+     */
+    unsigned long view;
     Xapian::QueryParser *query_parser;
     Xapian::TermGenerator *term_gen;
     Xapian::ValueRangeProcessor *value_range_processor;
index 386dcd17adc4d0a91ab5eb10479907b254d32187..ba440d4db87e4608b043167860cc09e911f4aeda 100644 (file)
@@ -951,6 +951,7 @@ notmuch_database_open_verbose (const char *path,
 
     notmuch->mode = mode;
     notmuch->atomic_nesting = 0;
+    notmuch->view = 1;
     try {
        string last_thread_id;
        string last_mod;
@@ -1133,6 +1134,28 @@ notmuch_database_close (notmuch_database_t *notmuch)
     return status;
 }
 
+notmuch_status_t
+_notmuch_database_reopen (notmuch_database_t *notmuch)
+{
+    if (notmuch->mode != NOTMUCH_DATABASE_MODE_READ_ONLY)
+       return NOTMUCH_STATUS_UNSUPPORTED_OPERATION;
+
+    try {
+       notmuch->xapian_db->reopen ();
+    } catch (const Xapian::Error &error) {
+       if (! notmuch->exception_reported) {
+           _notmuch_database_log (notmuch, "Error: A Xapian exception reopening database: %s\n",
+                                  error.get_msg ().c_str ());
+           notmuch->exception_reported = TRUE;
+       }
+       return NOTMUCH_STATUS_XAPIAN_EXCEPTION;
+    }
+
+    notmuch->view++;
+
+    return NOTMUCH_STATUS_SUCCESS;
+}
+
 static int
 unlink_cb (const char *path,
           unused (const struct stat *sb),
index 7b35fc5b0ca8bc4656841a14c6212814f05d2fbc..8587e86ca57ad6697c4966f8fcf8ee9fc677c941 100644 (file)
@@ -192,6 +192,9 @@ _notmuch_message_id_compressed (void *ctx, const char *message_id);
 notmuch_status_t
 _notmuch_database_ensure_writable (notmuch_database_t *notmuch);
 
+notmuch_status_t
+_notmuch_database_reopen (notmuch_database_t *notmuch);
+
 void
 _notmuch_database_log (notmuch_database_t *notmuch,
                       const char *format, ...);