diff options
Diffstat (limited to 'src/components/util/task.rs')
-rw-r--r-- | src/components/util/task.rs | 40 |
1 files changed, 0 insertions, 40 deletions
diff --git a/src/components/util/task.rs b/src/components/util/task.rs deleted file mode 100644 index b3e03771610..00000000000 --- a/src/components/util/task.rs +++ /dev/null @@ -1,40 +0,0 @@ -/* This Source Code Form is subject to the terms of the Mozilla Public - * License, v. 2.0. If a copy of the MPL was not distributed with this - * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ - -use std::str::IntoMaybeOwned; -use std::task; -use std::comm::Sender; -use std::task::TaskBuilder; -use native::task::NativeTaskBuilder; - -pub fn spawn_named<S: IntoMaybeOwned<'static>>(name: S, f: proc():Send) { - let builder = task::TaskBuilder::new().named(name); - builder.spawn(f); -} - -/// Arrange to send a particular message to a channel if the task built by -/// this `TaskBuilder` fails. -pub fn spawn_named_with_send_on_failure<T: Send>(name: &'static str, - f: proc(): Send, - msg: T, - dest: Sender<T>, - native: bool) { - let future_result = if native { - TaskBuilder::new().named(name).native().try_future(f) - } else { - TaskBuilder::new().named(name).try_future(f) - }; - - let watched_name = name.to_string(); - let watcher_name = format!("{:s}Watcher", watched_name); - TaskBuilder::new().named(watcher_name).spawn(proc() { - match future_result.unwrap() { - Ok(()) => (), - Err(..) => { - debug!("{:s} failed, notifying constellation", name); - dest.send(msg); - } - } - }); -} |