+void bluesky_replay(BlueSkyFS *fs)
+{
+ BlueSkyLog *log = fs->log;
+ GList *logfiles = directory_contents(log->log_directory);
+
+ /* Scan through log files in reverse order to find the most recent commit
+ * record. */
+ logfiles = g_list_reverse(logfiles);
+ uint32_t seq_num = 0, start_offset = 0;
+ while (logfiles != NULL) {
+ char *filename = g_strdup_printf("%s/%s", log->log_directory,
+ (char *)logfiles->data);
+ g_print("Scanning file %s\n", filename);
+ GMappedFile *map = g_mapped_file_new(filename, FALSE, NULL);
+ if (map == NULL) {
+ g_warning("Mapping logfile %s failed!\n", filename);
+ } else {
+ bluesky_replay_scan_journal(g_mapped_file_get_contents(map),
+ g_mapped_file_get_length(map),
+ &seq_num, &start_offset);
+ g_mapped_file_unref(map);
+ }
+ g_free(filename);
+
+ g_free(logfiles->data);
+ logfiles = g_list_delete_link(logfiles, logfiles);
+ if (seq_num != 0 || start_offset != 0)
+ break;
+ }
+ g_list_foreach(logfiles, (GFunc)g_free, NULL);
+ g_list_free(logfiles);
+
+ /* Now, scan forward starting from the given point in the log to
+ * reconstruct all filesystem state. As we reload objects we hold a
+ * reference to each loaded object. At the end we free all these
+ * references, so that any objects which were not linked into persistent
+ * filesystem data structures are freed. */
+ GList *objects = NULL;
+ while (TRUE) {
+ char *filename = g_strdup_printf("%s/journal-%08d",
+ log->log_directory, seq_num);
+ g_print("Replaying file %s from offset %d\n", filename, start_offset);
+ GMappedFile *map = g_mapped_file_new(filename, FALSE, NULL);
+ g_free(filename);
+ if (map == NULL) {
+ g_warning("Mapping logfile failed, assuming end of journal\n");
+ break;
+ }
+
+ bluesky_replay_scan_journal2(fs, &objects, seq_num, start_offset,
+ g_mapped_file_get_contents(map),
+ g_mapped_file_get_length(map));
+ g_mapped_file_unref(map);
+ seq_num++;
+ start_offset = 0;
+ }
+
+ while (objects != NULL) {
+ bluesky_cloudlog_unref((BlueSkyCloudLog *)objects->data);
+ objects = g_list_delete_link(objects, objects);
+ }