#212: rbox sync does also wait_for_complete

ceph-dovecot · Nov 22, 2018 · 6fcd90c · 6fcd90c
1 parent 92ac165
commit 6fcd90c
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/storage-rbox/rbox-sync.cpp b/src/storage-rbox/rbox-sync.cpp
@@ -565,7 +565,12 @@ int rbox_sync_finish(struct rbox_sync_context **_ctx, bool success) {
       mail_index_view_close(&ctx->sync_view);
 
       for (std::list<librados::AioCompletion *>::iterator it = completions.begin(); it != completions.end(); ++it) {
-        (*it)->wait_for_complete_and_cb();
+        struct rbox_storage *s = ctx->rbox->storage;
+        if (s->config->is_ceph_aio_wait_for_safe_and_cb()) {
+          (*it)->wait_for_safe_and_cb();
+        } else {
+          (*it)->wait_for_complete_and_cb();
+        }
         (*it)->release();
       }
     }