fix more fallout from future de-mode-ing.
This commit is contained in:
parent
9c034464fe
commit
96007441e1
@ -71,7 +71,7 @@ fn run(args: &[~str]) {
|
||||
server(from_parent, to_parent);
|
||||
}
|
||||
|
||||
vec::iter(worker_results, |r| { future::get(r); } );
|
||||
vec::iter(worker_results, |r| { future::get(&r); } );
|
||||
//error!{"sending stop message"};
|
||||
to_child.send(stop);
|
||||
move_out!{to_child};
|
||||
|
@ -68,7 +68,7 @@ fn run(args: &[~str]) {
|
||||
server(from_parent, to_parent);
|
||||
}
|
||||
|
||||
vec::iter(worker_results, |r| { future::get(r); } );
|
||||
vec::iter(worker_results, |r| { future::get(&r); } );
|
||||
//error!{"sending stop message"};
|
||||
to_child.send(stop);
|
||||
move_out!{to_child};
|
||||
|
@ -94,7 +94,7 @@ fn main(args: ~[~str]) {
|
||||
thread_ring(0u, msg_per_task, option::unwrap(num_chan), num_port);
|
||||
|
||||
// synchronize
|
||||
for futures.each |f| { future::get(f) };
|
||||
for futures.each |f| { future::get(&f) };
|
||||
|
||||
let stop = time::precise_time_s();
|
||||
|
||||
|
@ -44,7 +44,7 @@ fn run(args: ~[~str]) {
|
||||
}
|
||||
};
|
||||
}
|
||||
vec::iter(worker_results, |r| { future::get(r); } );
|
||||
vec::iter(worker_results, |r| { future::get(&r); } );
|
||||
comm::send(to_child, stop);
|
||||
let result = comm::recv(from_child);
|
||||
let end = std::time::precise_time_s();
|
||||
|
@ -76,7 +76,7 @@ fn stress(num_tasks: int) {
|
||||
stress_task(i);
|
||||
}
|
||||
}
|
||||
for results.each |r| { future::get(r); }
|
||||
for results.each |r| { future::get(&r); }
|
||||
}
|
||||
|
||||
fn main(args: ~[~str]) {
|
||||
|
@ -33,7 +33,7 @@ fn spawn_supervised_blocking(myname: &str, +f: fn~()) {
|
||||
let mut res = none;
|
||||
task::task().future_result(|+r| res = some(r)).supervised().spawn(f);
|
||||
#error["%s group waiting", myname];
|
||||
let x = future::get(option::unwrap(res));
|
||||
let x = future::get(&option::unwrap(res));
|
||||
assert x == task::success;
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user