1 files changed, 90 insertions, 0 deletions
diff --git a/ctr-std/src/sys/horizon/mutex.rs b/ctr-std/src/sys/horizon/mutex.rs
new file mode 100644
index 0000000..95c74a4
--- /dev/null
+++ b/ctr-std/src/sys/horizon/mutex.rs
@@ -0,0 +1,90 @@
+// Copyright 2017 The Rust Project Developers. See the COPYRIGHT
+// file at the top-level directory of this distribution and at
+// http://rust-lang.org/COPYRIGHT.
+//
+// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
+// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
+// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
+// option. This file may not be copied, modified, or distributed
+// except according to those terms.
+
+use cell::UnsafeCell;
+use mem;
+
+pub struct Mutex {
+    inner: UnsafeCell<::libctru::LightLock>,
+}
+
+#[inline]
+pub unsafe fn raw(m: &Mutex) -> *mut ::libctru::LightLock {
+    m.inner.get()
+}
+
+unsafe impl Send for Mutex {}
+unsafe impl Sync for Mutex {}
+
+impl Mutex {
+    pub const fn new() -> Mutex {
+        Mutex { inner: UnsafeCell::new(0) }
+    }
+
+    #[inline]
+    pub unsafe fn init(&mut self) {
+        ::libctru::LightLock_Init(self.inner.get());
+    }
+
+    #[inline]
+    pub unsafe fn lock(&self) {
+        ::libctru::LightLock_Lock(self.inner.get());
+    }
+
+    #[inline]
+    pub unsafe fn unlock(&self) {
+        ::libctru::LightLock_Unlock(self.inner.get());
+    }
+
+    #[inline]
+    pub unsafe fn try_lock(&self) -> bool {
+        match ::libctru::LightLock_TryLock(self.inner.get()) {
+            0 => false,
+            _ => true,
+        }
+    }
+
+    #[inline]
+    pub unsafe fn destroy(&self) {
+    }
+}
+
+pub struct ReentrantMutex { inner: UnsafeCell<::libctru::RecursiveLock> }
+
+unsafe impl Send for ReentrantMutex {}
+unsafe impl Sync for ReentrantMutex {}
+
+impl ReentrantMutex {
+    pub unsafe fn uninitialized() -> ReentrantMutex {
+        ReentrantMutex { inner: mem::uninitialized() }
+    }
+
+    pub unsafe fn init(&mut self) {
+        ::libctru::RecursiveLock_Init(self.inner.get());
+    }
+
+    pub unsafe fn lock(&self) {
+        ::libctru::RecursiveLock_Lock(self.inner.get());
+    }
+
+    #[inline]
+    pub unsafe fn try_lock(&self) -> bool {
+        match ::libctru::RecursiveLock_TryLock(self.inner.get()) {
+            0 => false,
+            _ => true,
+        }
+    }
+
+    pub unsafe fn unlock(&self) {
+        ::libctru::RecursiveLock_Unlock(self.inner.get());
+    }
+
+    pub unsafe fn destroy(&self) {}
+}