about summary refs log tree commit diff
path: root/src/libstd/sync.rs
diff options
context:
space:
mode:
authorTim Chevalier <chevalier@alum.wellesley.edu>2012-09-10 17:50:48 -0700
committerTim Chevalier <chevalier@alum.wellesley.edu>2012-09-10 17:51:24 -0700
commit9869d071d101c580e1b54f077a30af8ee0fc960c (patch)
tree123d33a953945afed2461b7a3ea33211a8b12b9b /src/libstd/sync.rs
parent73eb89430569d80a2f3ff124514f2905b25dbe68 (diff)
Make remaining moves explicit in libstd
Diffstat (limited to 'src/libstd/sync.rs')
-rw-r--r--src/libstd/sync.rs12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/libstd/sync.rs b/src/libstd/sync.rs
index 92e64ccc5a5..6719b8ad6cd 100644
--- a/src/libstd/sync.rs
+++ b/src/libstd/sync.rs
@@ -84,7 +84,7 @@ fn new_sem_and_signal(count: int, num_condvars: uint)
     for num_condvars.times {
         vec::push(queues, new_waitqueue());
     }
-    new_sem(count, queues)
+    new_sem(count, move queues)
 }
 
 #[doc(hidden)]
@@ -98,9 +98,9 @@ impl<Q: Send> &Sem<Q> {
                     // Create waiter nobe.
                     let (SignalEnd, WaitEnd) = pipes::oneshot();
                     // Tell outer scope we need to block.
-                    waiter_nobe = Some(WaitEnd);
+                    waiter_nobe = Some(move WaitEnd);
                     // Enqueue ourself.
-                    state.waiters.tail.send(SignalEnd);
+                    state.waiters.tail.send(move SignalEnd);
                 }
             }
         }
@@ -203,8 +203,8 @@ impl &Condvar {
     fn wait_on(condvar_id: uint) {
         // Create waiter nobe.
         let (SignalEnd, WaitEnd) = pipes::oneshot();
-        let mut WaitEnd   = Some(WaitEnd);
-        let mut SignalEnd = Some(SignalEnd);
+        let mut WaitEnd   = Some(move WaitEnd);
+        let mut SignalEnd = Some(move SignalEnd);
         let mut reacquire = None;
         let mut out_of_bounds = None;
         unsafe {
@@ -219,7 +219,7 @@ impl &Condvar {
                         }
                         // Enqueue ourself to be woken up by a signaller.
                         let SignalEnd = option::swap_unwrap(&mut SignalEnd);
-                        state.blocked[condvar_id].tail.send(SignalEnd);
+                        state.blocked[condvar_id].tail.send(move SignalEnd);
                     } else {
                         out_of_bounds = Some(vec::len(state.blocked));
                     }