+ log_item->log_size = header->size1;
+
+ bluesky_string_unref(log_item->data);
+ log_item->data = bluesky_string_new(g_memdup(buf + offset + sizeof(struct log_header), GUINT32_FROM_LE(header->size1)), GUINT32_FROM_LE(header->size1));
+
+ /* For any inodes which were read from the journal, deserialize the
+ * inode information, overwriting any old inode data. */
+ if (header->type - '0' == LOGTYPE_INODE) {
+ uint64_t inum = GUINT64_FROM_LE(header->inum);
+ BlueSkyInode *inode;
+ g_mutex_lock(fs->lock);
+ inode = (BlueSkyInode *)g_hash_table_lookup(fs->inodes, &inum);
+ if (inode == NULL) {
+ inode = bluesky_new_inode(inum, fs, BLUESKY_PENDING);
+ inode->change_count = 0;
+ bluesky_insert_inode(fs, inode);
+ }
+ g_mutex_lock(inode->lock);
+ bluesky_inode_free_resources(inode);
+ if (!bluesky_deserialize_inode(inode, log_item))
+ g_print("Error deserializing inode %"PRIu64"\n", inum);
+ fs->next_inum = MAX(fs->next_inum, inum + 1);
+ bluesky_list_unlink(&fs->accessed_list, inode->accessed_list);
+ inode->accessed_list = bluesky_list_prepend(&fs->accessed_list, inode);
+ bluesky_list_unlink(&fs->dirty_list, inode->dirty_list);
+ inode->dirty_list = bluesky_list_prepend(&fs->dirty_list, inode);
+ bluesky_list_unlink(&fs->unlogged_list, inode->unlogged_list);
+ inode->unlogged_list = NULL;
+ inode->change_cloud = inode->change_commit;
+ bluesky_cloudlog_ref(log_item);
+ bluesky_cloudlog_unref(inode->committed_item);
+ inode->committed_item = log_item;
+ g_mutex_unlock(inode->lock);
+ g_mutex_unlock(fs->lock);
+ }
+ bluesky_string_unref(log_item->data);
+ log_item->data = NULL;