+BlueSkyFS *bluesky_init_fs(gchar *name, BlueSkyStore *store,
+ const gchar *master_key)
+{
+ BlueSkyFS *fs = bluesky_new_fs(name);
+ fs->master_key = g_strdup(master_key);
+ fs->keys = g_new(BlueSkyCryptKeys, 1);
+ bluesky_crypt_derive_keys(fs->keys, master_key);
+ fs->store = store;
+ fs->log = bluesky_log_new("journal");
+ fs->log->fs = fs;
+
+ if (bluesky_checkpoint_load(fs)) {
+ g_print("Filesystem checkpoint loaded, starting journal replay...\n");
+ bluesky_replay(fs);
+ g_print("Journal replay complete, filesystem ready.\n");
+ } else {
+ /* Initialize a fresh filesystem */
+ g_print("Initializing new filesystem...\n");
+ BlueSkyInode *root = bluesky_new_inode(BLUESKY_ROOT_INUM, fs,
+ BLUESKY_DIRECTORY);
+ root->nlink = 1;
+ root->mode = 0755;
+ bluesky_insert_inode(fs, root);
+ bluesky_inode_update_ctime(root, TRUE);
+ bluesky_inode_do_sync(root);
+ }
+
+ bluesky_cleaner_thread_launch(fs);
+
+ return fs;
+}
+
+/* Inode reference counting. */
+void bluesky_inode_ref(BlueSkyInode *inode)
+{
+ g_atomic_int_inc(&inode->refcount);
+}
+
+/* Free most of the resources used by an inode structure, but do not free the
+ * inode itself. Can be used if the inode data will be reloaded from
+ * serialized form to clear out old information first. */
+void bluesky_inode_free_resources(BlueSkyInode *inode)
+{
+ switch (inode->type) {
+ case BLUESKY_REGULAR:
+ if (inode->blocks != NULL) {
+ for (int i = 0; i < inode->blocks->len; i++) {
+ BlueSkyBlock *b = &g_array_index(inode->blocks,
+ BlueSkyBlock, i);
+ if (b->type == BLUESKY_BLOCK_DIRTY) {
+ g_error("Deleting an inode with dirty file data!");
+ }
+ bluesky_cloudlog_unref(b->ref);
+ bluesky_string_unref(b->dirty);
+ }
+ g_array_unref(inode->blocks);
+ inode->blocks = NULL;
+ }
+ break;
+
+ case BLUESKY_DIRECTORY:
+ if (inode->dirhash != NULL)
+ g_hash_table_destroy(inode->dirhash);
+ inode->dirhash = NULL;
+ if (inode->dirhash_folded != NULL)
+ g_hash_table_destroy(inode->dirhash_folded);
+ inode->dirhash_folded = NULL;
+ if (inode->dirents != NULL)
+ g_sequence_free(inode->dirents);
+ inode->dirents = NULL;
+ break;
+
+ case BLUESKY_SYMLINK:
+ g_free(inode->symlink_contents);
+ inode->symlink_contents = NULL;
+ break;
+
+ default:
+ break;
+ }
+}
+
+void bluesky_inode_unref(BlueSkyInode *inode)
+{
+ if (g_atomic_int_dec_and_test(&inode->refcount)) {
+ if (bluesky_verbose) {
+ g_log("bluesky/inode", G_LOG_LEVEL_DEBUG,
+ "Reference count for inode %"PRIu64" dropped to zero.",
+ inode->inum);
+ }
+
+ /* Sanity check: Is the inode clean? */
+ if (inode->change_commit < inode->change_count
+ || inode->accessed_list != NULL
+ || inode->unlogged_list != NULL
+ || inode->dirty_list != NULL) {
+ g_warning("Dropping inode which is not clean (commit %"PRIi64" < change %"PRIi64"; accessed_list = %p; dirty_list = %p)\n", inode->change_commit, inode->change_count, inode->accessed_list, inode->dirty_list);
+ }
+
+ /* These shouldn't be needed, but in case the above warning fires and
+ * we delete the inode anyway, we ought to be sure the inode is not on
+ * any LRU list. */
+ g_mutex_lock(inode->fs->lock);
+ bluesky_list_unlink(&inode->fs->accessed_list, inode->accessed_list);
+ bluesky_list_unlink(&inode->fs->dirty_list, inode->dirty_list);
+ bluesky_list_unlink(&inode->fs->unlogged_list, inode->unlogged_list);
+ g_mutex_unlock(inode->fs->lock);
+
+ bluesky_inode_free_resources(inode);
+
+ g_mutex_free(inode->lock);
+ g_free(inode);
+ }
+}
+