diff options
| author | bors <bors@rust-lang.org> | 2013-08-23 00:16:28 -0700 |
|---|---|---|
| committer | bors <bors@rust-lang.org> | 2013-08-23 00:16:28 -0700 |
| commit | 5e5e2c71e403371ff8a5d5430e7696654214a438 (patch) | |
| tree | 25ca443f4dd0b513202ddf00a4ad53515f8b184c /src/libstd/rt | |
| parent | 0688bde47f1288eec730a3e01dcbf825900db3c0 (diff) | |
| parent | 0081961c57494162d9f2d19265175af95fbdd8d7 (diff) | |
| download | rust-5e5e2c71e403371ff8a5d5430e7696654214a438.tar.gz rust-5e5e2c71e403371ff8a5d5430e7696654214a438.zip | |
auto merge of #8677 : bblum/rust/scratch, r=alexcrichton
r anybody; there isn't anything complicated here
Diffstat (limited to 'src/libstd/rt')
| -rw-r--r-- | src/libstd/rt/comm.rs | 13 | ||||
| -rw-r--r-- | src/libstd/rt/mod.rs | 1 |
2 files changed, 8 insertions, 6 deletions
diff --git a/src/libstd/rt/comm.rs b/src/libstd/rt/comm.rs index 5d55261a69d..8ef9c1332f9 100644 --- a/src/libstd/rt/comm.rs +++ b/src/libstd/rt/comm.rs @@ -499,13 +499,14 @@ impl<T> GenericPort<T> for Port<T> { } fn try_recv(&self) -> Option<T> { - let pone = self.next.take(); - match pone.try_recv() { - Some(StreamPayload { val, next }) => { - self.next.put_back(next); - Some(val) + do self.next.take_opt().map_move_default(None) |pone| { + match pone.try_recv() { + Some(StreamPayload { val, next }) => { + self.next.put_back(next); + Some(val) + } + None => None } - None => None } } } diff --git a/src/libstd/rt/mod.rs b/src/libstd/rt/mod.rs index db1bfdf1bf5..8b3e65b57ab 100644 --- a/src/libstd/rt/mod.rs +++ b/src/libstd/rt/mod.rs @@ -323,6 +323,7 @@ fn run_(main: ~fn(), use_main_sched: bool) -> int { // task tree, shut down the schedulers and set the exit code. let handles = Cell::new(handles); let on_exit: ~fn(bool) = |exit_success| { + assert_once_ever!("last task exiting"); let mut handles = handles.take(); for handle in handles.mut_iter() { |
