diff options
Diffstat (limited to 'src/libstd/rt')
| -rw-r--r-- | src/libstd/rt/kill.rs | 4 | ||||
| -rw-r--r-- | src/libstd/rt/message_queue.rs | 4 | ||||
| -rw-r--r-- | src/libstd/rt/sleeper_list.rs | 4 | ||||
| -rw-r--r-- | src/libstd/rt/uv/uvio.rs | 4 | ||||
| -rw-r--r-- | src/libstd/rt/work_queue.rs | 4 |
5 files changed, 10 insertions, 10 deletions
diff --git a/src/libstd/rt/kill.rs b/src/libstd/rt/kill.rs index cfd8e46dfdb..2bf4543df50 100644 --- a/src/libstd/rt/kill.rs +++ b/src/libstd/rt/kill.rs @@ -57,7 +57,7 @@ struct KillHandleInner { // Shared state between task and children for exit code propagation. These // are here so we can re-use the kill handle to implement watched children - // tasks. Using a separate ARClike would introduce extra atomic adds/subs + // tasks. Using a separate Arc-like would introduce extra atomic adds/subs // into common spawn paths, so this is just for speed. // Locklessly accessed; protected by the enclosing refcount's barriers. @@ -217,7 +217,7 @@ impl KillHandle { // Exit code propagation fields any_child_failed: false, child_tombstones: None, - graveyard_lock: LittleLock(), + graveyard_lock: LittleLock::new(), })); (handle, flag_clone) } diff --git a/src/libstd/rt/message_queue.rs b/src/libstd/rt/message_queue.rs index 6ef07577415..8518ddaeae1 100644 --- a/src/libstd/rt/message_queue.rs +++ b/src/libstd/rt/message_queue.rs @@ -16,7 +16,7 @@ use kinds::Send; use vec::OwnedVector; use cell::Cell; use option::*; -use unstable::sync::{Exclusive, exclusive}; +use unstable::sync::Exclusive; use clone::Clone; pub struct MessageQueue<T> { @@ -27,7 +27,7 @@ pub struct MessageQueue<T> { impl<T: Send> MessageQueue<T> { pub fn new() -> MessageQueue<T> { MessageQueue { - queue: ~exclusive(~[]) + queue: ~Exclusive::new(~[]) } } diff --git a/src/libstd/rt/sleeper_list.rs b/src/libstd/rt/sleeper_list.rs index 3d6e9ef5635..d327023de97 100644 --- a/src/libstd/rt/sleeper_list.rs +++ b/src/libstd/rt/sleeper_list.rs @@ -15,7 +15,7 @@ use container::Container; use vec::OwnedVector; use option::{Option, Some, None}; use cell::Cell; -use unstable::sync::{Exclusive, exclusive}; +use unstable::sync::Exclusive; use rt::sched::SchedHandle; use clone::Clone; @@ -26,7 +26,7 @@ pub struct SleeperList { impl SleeperList { pub fn new() -> SleeperList { SleeperList { - stack: ~exclusive(~[]) + stack: ~Exclusive::new(~[]) } } diff --git a/src/libstd/rt/uv/uvio.rs b/src/libstd/rt/uv/uvio.rs index fc4a668bdf6..5397b5f2c5c 100644 --- a/src/libstd/rt/uv/uvio.rs +++ b/src/libstd/rt/uv/uvio.rs @@ -28,7 +28,7 @@ use rt::io::{standard_error, OtherIoError}; use rt::tube::Tube; use rt::local::Local; use str::StrSlice; -use unstable::sync::{Exclusive, exclusive}; +use unstable::sync::Exclusive; #[cfg(test)] use container::Container; #[cfg(test)] use uint; @@ -158,7 +158,7 @@ pub struct UvRemoteCallback { impl UvRemoteCallback { pub fn new(loop_: &mut Loop, f: ~fn()) -> UvRemoteCallback { - let exit_flag = exclusive(false); + let exit_flag = Exclusive::new(false); let exit_flag_clone = exit_flag.clone(); let async = do AsyncWatcher::new(loop_) |watcher, status| { assert!(status.is_none()); diff --git a/src/libstd/rt/work_queue.rs b/src/libstd/rt/work_queue.rs index 00d27744268..24792f3904e 100644 --- a/src/libstd/rt/work_queue.rs +++ b/src/libstd/rt/work_queue.rs @@ -11,7 +11,7 @@ use container::Container; use option::*; use vec::OwnedVector; -use unstable::sync::{Exclusive, exclusive}; +use unstable::sync::Exclusive; use cell::Cell; use kinds::Send; use clone::Clone; @@ -24,7 +24,7 @@ pub struct WorkQueue<T> { impl<T: Send> WorkQueue<T> { pub fn new() -> WorkQueue<T> { WorkQueue { - queue: ~exclusive(~[]) + queue: ~Exclusive::new(~[]) } } |
