Skip to content

Commit

Permalink
Tidy warnings (#542)
Browse files Browse the repository at this point in the history
  • Loading branch information
frankmcsherry authored Feb 5, 2024
1 parent 86b3d69 commit f2245d0
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions timely/examples/rc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ use abomonation::Abomonation;

#[derive(Debug, Clone)]
pub struct Test {
field: Rc<usize>,
_field: Rc<usize>,
}

impl Abomonation for Test {
Expand All @@ -32,7 +32,7 @@ fn main() {

// introduce data and watch!
for round in 0..10 {
input.send(Test { field: Rc::new(round) } );
input.send(Test { _field: Rc::new(round) } );
input.advance_to(round + 1);
worker.step_while(|| probe.less_than(input.time()));
}
Expand Down
4 changes: 2 additions & 2 deletions timely/src/synchronization/sequence.rs
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ impl<T: ExchangeData> Sequencer<T> {
}

let mut activator_borrow = activator_source.borrow_mut();
let mut activator = activator_borrow.as_mut().unwrap();
let activator = activator_borrow.as_mut().unwrap();

if let Some(t) = activator.catchup_until {
if capability.time().less_than(&t) {
Expand Down Expand Up @@ -190,7 +190,7 @@ impl<T: ExchangeData> Sequencer<T> {

if let Some(last) = recvd.last() {
let mut activator_borrow = activator_sink.borrow_mut();
let mut activator = activator_borrow.as_mut().unwrap();
let activator = activator_borrow.as_mut().unwrap();

activator.catchup_until = Some((last.0).0);
activator.activate();
Expand Down

0 comments on commit f2245d0

Please sign in to comment.