1 files changed, 93 insertions, 0 deletions
diff --git a/third_party/rust/miow-0.2.1/src/handle.rs b/third_party/rust/miow-0.2.1/src/handle.rs
new file mode 100644
index 0000000000..a2be11da62
--- /dev/null
+++ b/third_party/rust/miow-0.2.1/src/handle.rs
@@ -0,0 +1,93 @@
+use std::io;
+use std::cmp;
+
+use winapi::*;
+use kernel32::*;
+
+#[derive(Debug)]
+pub struct Handle(HANDLE);
+
+unsafe impl Send for Handle {}
+unsafe impl Sync for Handle {}
+
+impl Handle {
+    pub fn new(handle: HANDLE) -> Handle {
+        Handle(handle)
+    }
+
+    pub fn raw(&self) -> HANDLE { self.0 }
+
+    pub fn into_raw(self) -> HANDLE {
+        use std::mem;
+
+        let ret = self.0;
+        mem::forget(self);
+        ret
+    }
+
+    pub fn write(&self, buf: &[u8]) -> io::Result<usize> {
+        let mut bytes = 0;
+        let len = cmp::min(buf.len(), <DWORD>::max_value() as usize) as DWORD;
+        try!(::cvt(unsafe {
+            WriteFile(self.0, buf.as_ptr() as *const _, len, &mut bytes,
+                      0 as *mut _)
+        }));
+        Ok(bytes as usize)
+    }
+
+    pub fn read(&self, buf: &mut [u8]) -> io::Result<usize> {
+        let mut bytes = 0;
+        let len = cmp::min(buf.len(), <DWORD>::max_value() as usize) as DWORD;
+        try!(::cvt(unsafe {
+            ReadFile(self.0, buf.as_mut_ptr() as *mut _, len, &mut bytes,
+                     0 as *mut _)
+        }));
+        Ok(bytes as usize)
+    }
+
+    pub unsafe fn read_overlapped(&self, buf: &mut [u8],
+                                  overlapped: *mut OVERLAPPED)
+                                  -> io::Result<Option<usize>> {
+        let len = cmp::min(buf.len(), <DWORD>::max_value() as usize) as DWORD;
+        let mut bytes = 0;
+        let res = ::cvt({
+            ReadFile(self.0,
+                     buf.as_mut_ptr() as *mut _,
+                     len,
+                     &mut bytes,
+                     overlapped)
+        });
+        match res {
+            Ok(_) => Ok(Some(bytes as usize)),
+            Err(ref e) if e.raw_os_error() == Some(ERROR_IO_PENDING as i32)
+                => Ok(None),
+            Err(e) => Err(e),
+        }
+    }
+
+    pub unsafe fn write_overlapped(&self, buf: &[u8],
+                                   overlapped: *mut OVERLAPPED)
+                                   -> io::Result<Option<usize>> {
+        let len = cmp::min(buf.len(), <DWORD>::max_value() as usize) as DWORD;
+        let mut bytes = 0;
+        let res = ::cvt({
+            WriteFile(self.0,
+                      buf.as_ptr() as *const _,
+                      len,
+                      &mut bytes,
+                      overlapped)
+        });
+        match res {
+            Ok(_) => Ok(Some(bytes as usize)),
+            Err(ref e) if e.raw_os_error() == Some(ERROR_IO_PENDING as i32)
+                => Ok(None),
+            Err(e) => Err(e),
+        }
+    }
+}
+
+impl Drop for Handle {
+    fn drop(&mut self) {
+        unsafe { CloseHandle(self.0) };
+    }
+}