Support for sync operations on an inode.

[bluesky.git] / bluesky / cache.c

diff --git a/bluesky/cache.c b/bluesky/cache.c
index 4fe4671..41348e2 100644 (file)
--- a/bluesky/cache.c
+++ b/bluesky/cache.c
@@ -42,18 +42,24 @@ static void flushd_inode(gpointer key, gpointer value, gpointer user_data)
 
     BlueSkyInode *inode = (BlueSkyInode *)value;
 
-    if (inode->change_count == inode->change_commit)
+    g_mutex_lock(inode->lock);
+
+    if (inode->change_count == inode->change_commit) {
+        g_mutex_unlock(inode->lock);
         return;
+    }
 
     if (inode->change_pending) {
         /* Waiting for an earlier writeback to finish, so don't start a new
          * writeback yet. */
+        g_mutex_unlock(inode->lock);
         return;
     }
 
     uint64_t elapsed = bluesky_get_current_time() - inode->change_time;
     if (elapsed < WRITEBACK_DELAY) {
         /* Give a bit more time before starting writeback. */
+        g_mutex_unlock(inode->lock);
         return;
     }
 
@@ -73,6 +79,8 @@ static void flushd_inode(gpointer key, gpointer value, gpointer user_data)
     bluesky_store_async_add_notifier(barrier, writeback_complete, inode);
     bluesky_store_async_submit(barrier);
     bluesky_store_async_unref(barrier);
+
+    g_mutex_unlock(inode->lock);
 }
 
 /* Scan through the cache for dirty data and start flushing it to stable