fs->log_state = g_new0(BlueSkyCloudLogState, 1);
fs->log_state->data = g_string_new("");
+ bluesky_cloudlog_threads_init(fs);
+
return fs;
}
if (bluesky_checkpoint_load(fs)) {
g_print("Filesystem checkpoint loaded, starting journal replay...\n");
- //bluesky_replay(fs);
+ bluesky_replay(fs);
g_print("Journal replay complete, filesystem ready.\n");
} else {
/* Initialize a fresh filesystem */
{
BlueSkyCloudLog *item = inode->committed_item;
inode->committed_item = NULL;
- g_print("Completing fetch of inode %"PRIu64"...", inode->inum);
+ g_print("Completing fetch of inode %"PRIu64"...\n", inode->inum);
g_mutex_lock(item->lock);
bluesky_cloudlog_fetch(item);