X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=bluesky%2Fcache.c;h=c27d39dbdcd8dfc9c73f3ac9c7ac6caa8b5ab931;hb=0a021d1c28cff9cbaa4c127a837816f96dd37a27;hp=454e06f3e962e9f4a6bfec8d27223aab02c402c8;hpb=881bb3ee9aa6088415461f6efdb04c3638af1a22;p=bluesky.git

diff --git a/bluesky/cache.c b/bluesky/cache.c
index 454e06f..c27d39d 100644
--- a/bluesky/cache.c
+++ b/bluesky/cache.c
@@ -114,6 +114,7 @@ static void flushd_cloud(BlueSkyFS *fs)
 
     /* TODO: Locking?  Since we're reading a single variable this is probably
      * atomic but a lock could be safer. */
+    BlueSkyCloudLog *marker = bluesky_log_get_commit_point(fs);
     int journal_seq_start = fs->log->seq_num;
 
     while (1) {
@@ -177,6 +178,8 @@ static void flushd_cloud(BlueSkyFS *fs)
                                  fs->log_state->pending_segments);
     }
 
+    bluesky_log_write_commit_point(fs, marker);
+
     g_print("All segments have been flushed, journal < %d is clean\n",
             journal_seq_start);