-
Notifications
You must be signed in to change notification settings - Fork 3
Open
Description
Prune tracked_uploads when we successfully upload some artifact:
battleware/node/src/seeder/actor.rs
Lines 143 to 163 in 51db184
| 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; | |
| }; |
Metadata
Metadata
Assignees
Labels
No labels