X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=bluesky%2Finode.c;h=f3b804dc4e7f5378b08227b8ad22d8a7a5545f64;hb=ddaec40a37a5e65e53546b14632b1b0b35613264;hp=9d72f4d9c66141f1035f8a7289de5700f2bfad42;hpb=8ec7f79f834ff8c3493b1bbdd63314d276786aa4;p=bluesky.git diff --git a/bluesky/inode.c b/bluesky/inode.c index 9d72f4d..f3b804d 100644 --- a/bluesky/inode.c +++ b/bluesky/inode.c @@ -173,8 +173,8 @@ void bluesky_inode_unref(BlueSkyInode *inode) if (b->type == BLUESKY_BLOCK_DIRTY) { g_error("Deleting an inode with dirty file data!"); } - bluesky_cloudlog_unref(b->cloudref); - bluesky_string_unref(b->data); + bluesky_cloudlog_unref(b->ref); + bluesky_string_unref(b->dirty); } g_array_unref(inode->blocks); break; @@ -292,46 +292,29 @@ void bluesky_insert_inode(BlueSkyFS *fs, BlueSkyInode *inode) void bluesky_inode_start_sync(BlueSkyInode *inode) { GList *log_items = NULL; - BlueSkyFS *fs = inode->fs; if (inode->type == BLUESKY_REGULAR) bluesky_file_flush(inode, &log_items); - GString *buf = g_string_new(""); - bluesky_serialize_inode(buf, inode); - BlueSkyRCStr *data = bluesky_string_new_from_gstring(buf); + BlueSkyCloudLog *cloudlog = bluesky_serialize_inode(inode); - char key[64]; - sprintf(key, "inode-%016"PRIx64, inode->inum); - - BlueSkyCloudLog *cloudlog = bluesky_cloudlog_new(fs); - cloudlog->type = LOGTYPE_INODE; - cloudlog->inum = inode->inum; - cloudlog->data = data; - bluesky_string_ref(data); - - if (inode->type == BLUESKY_REGULAR) { - for (int i = 0; i < inode->blocks->len; i++) { - BlueSkyBlock *b = &g_array_index(inode->blocks, BlueSkyBlock, i); - if (b->type == BLUESKY_BLOCK_CACHED - || b->type == BLUESKY_BLOCK_REF) - { - BlueSkyCloudID id = b->cloudref->id; - g_array_append_val(cloudlog->pointers, id); - } - } - } - - if (inode->committed_item != NULL) - bluesky_cloudlog_unref(inode->committed_item); + bluesky_cloudlog_unref(inode->committed_item); inode->committed_item = cloudlog; bluesky_cloudlog_sync(cloudlog); + bluesky_cloudlog_ref(cloudlog); log_items = g_list_prepend(log_items, cloudlog); - bluesky_cloudlog_insert(cloudlog); /* Wait for all log items to be committed to disk. */ bluesky_log_finish_all(log_items); + + /* Mark the inode as clean */ + inode->change_commit = inode->change_count; + inode->change_time = 0; + g_mutex_lock(inode->fs->lock); + bluesky_list_unlink(&inode->fs->unlogged_list, inode->unlogged_list); + inode->unlogged_list = NULL; + g_mutex_unlock(inode->fs->lock); } /* Write back an inode and all associated data and wait for completion. Inode