Skip to content

Commit

Permalink
update comments
Browse files Browse the repository at this point in the history
  • Loading branch information
losfair committed Nov 9, 2023
1 parent 027fed8 commit 560c3d5
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions timemachine/src/time_travel.rs
Original file line number Diff line number Diff line change
Expand Up @@ -194,8 +194,6 @@ impl TimeTravelControl {
}

// Step 2: Pull snapshot ranges that are not yet pulled
// Ranges must be pulled in order of (format_version, monoseq, seq) so that
// incremental compaction works correctly
{
let mut incoming =
futures::stream::iter(ranges.iter().filter(|x| !x.pulled).map(|x| {
Expand Down Expand Up @@ -251,8 +249,10 @@ impl TimeTravelControl {
}
}

// Step 3: Fetch REDO logs until DV is reached and we are up to date as measured
// in real time
// Step 3: Fetch REDO logs until DV is reached and one of the following conditions hold:
// - the (real) timestamp of the current log entry is greater than the time at which log
// fetching starts
// - the end of logs has been reached
let start_ts = SystemTime::now()
.duration_since(SystemTime::UNIX_EPOCH)
.unwrap()
Expand Down

0 comments on commit 560c3d5

Please sign in to comment.