1 // Copyright 2014 The Rust Project Developers. See the COPYRIGHT
2 // file at the top-level directory of this distribution and at
3 // http://rust-lang.org/COPYRIGHT.
5 // Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
6 // http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
7 // <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
8 // option. This file may not be copied, modified, or distributed
9 // except according to those terms.
14 use libc::{self, DWORD};
16 use sys::mutex::{self, Mutex};
20 pub struct Condvar { inner: UnsafeCell<ffi::CONDITION_VARIABLE> }
22 unsafe impl Send for Condvar {}
23 unsafe impl Sync for Condvar {}
25 pub const CONDVAR_INIT: Condvar = Condvar {
26 inner: UnsafeCell { value: ffi::CONDITION_VARIABLE_INIT }
31 pub unsafe fn new() -> Condvar { CONDVAR_INIT }
34 pub unsafe fn wait(&self, mutex: &Mutex) {
35 let r = ffi::SleepConditionVariableSRW(self.inner.get(),
39 debug_assert!(r != 0);
42 pub unsafe fn wait_timeout(&self, mutex: &Mutex, dur: Duration) -> bool {
43 let r = ffi::SleepConditionVariableSRW(self.inner.get(),
45 dur.num_milliseconds() as DWORD,
48 const ERROR_TIMEOUT: DWORD = 0x5B4;
49 debug_assert_eq!(os::errno() as uint, ERROR_TIMEOUT as uint);
57 pub unsafe fn notify_one(&self) {
58 ffi::WakeConditionVariable(self.inner.get())
62 pub unsafe fn notify_all(&self) {
63 ffi::WakeAllConditionVariable(self.inner.get())
66 pub unsafe fn destroy(&self) {