Skip to content

Commit

Permalink
Changed signature of the Supervisor::stop method
Browse files Browse the repository at this point in the history
  • Loading branch information
Relrin committed Jan 21, 2020
1 parent f0e4354 commit af58a40
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions bastion/src/supervisor.rs
Expand Up @@ -18,7 +18,7 @@ use fxhash::FxHashMap;
use lightproc::prelude::*;
use log::Level;
use std::cmp::{Eq, PartialEq};
use std::ops::{Range, RangeFrom};
use std::ops::Range;
use std::sync::Arc;
use std::task::Poll;
use std::time::Duration;
Expand Down Expand Up @@ -851,7 +851,7 @@ impl Supervisor {
}
}

async fn stop(&mut self, range: RangeFrom<usize>) {
async fn stop(&mut self, range: Range<usize>) {
debug!("Supervisor({}): Stopping range: {:?}", self.id(), range);
if range.start == 0 {
self.bcast.stop_children();
Expand Down Expand Up @@ -982,7 +982,7 @@ impl Supervisor {
msg: BastionMessage::Stop,
..
} => {
self.stop(0..).await;
self.stop(0..self.order.len()).await;
self.stopped();

return Err(());
Expand Down

0 comments on commit af58a40

Please sign in to comment.