Prune tracked_uploads when we successfully upload some artifact:
|
let mut tracked_uploads = RMap::new(); |
|
info!(cursor, "initial seed cursor"); |
|
|
|
// Process messages |
|
loop { |
|
let Some(message) = self.mailbox.next().await else { |
|
warn!("mailbox closed"); |
|
break; |
|
}; |
|
match message { |
|
Message::Uploaded { view } => { |
|
// Decrement uploads outstanding |
|
uploads_outstanding -= 1; |
|
|
|
// Track uploaded view |
|
tracked_uploads.insert(view); |
|
|
|
// Update metadata if lowest uploaded has increased |
|
let Some(end_region) = tracked_uploads.next_gap(boundary).0 else { |
|
continue; |
|
}; |
Prune
tracked_uploadswhen we successfully upload some artifact:battleware/node/src/seeder/actor.rs
Lines 143 to 163 in 51db184