+
+ /* Wait until all segments have been written to the cloud, so that it
+ * becomes safe to free up journal segments. */
+ while (fs->log_state->pending_segments != NULL) {
+ SerializedRecord *segment
+ = (SerializedRecord *)fs->log_state->pending_segments->data;
+ g_mutex_lock(segment->lock);
+ while (!segment->complete)
+ g_cond_wait(segment->cond, segment->lock);
+ g_mutex_unlock(segment->lock);
+
+ g_mutex_free(segment->lock);
+ g_cond_free(segment->cond);
+ g_free(segment);
+
+ fs->log_state->pending_segments
+ = g_list_delete_link(fs->log_state->pending_segments,
+ fs->log_state->pending_segments);
+ }
+
+ bluesky_log_write_commit_point(fs, marker);
+
+ g_print("All segments have been flushed, journal < %d is clean\n",
+ journal_seq_start);
+
+ fs->log->journal_watermark = journal_seq_start;