From b99a4b84252dbf6d236f7ac328f7f5da3e4fc79f Mon Sep 17 00:00:00 2001
From: Stjepan Glavina <stjepang@gmail.com>
Date: Sun, 21 Jun 2020 17:05:29 +0200
Subject: [PATCH] Use patched version of wepoll-sys

---
 Cargo.toml     |  2 +-
 src/reactor.rs | 22 +++++++++++++---------
 2 files changed, 14 insertions(+), 10 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index af7b526..fb8042f 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -47,7 +47,7 @@ optional = true
 libc = "0.2.70"
 
 [target.'cfg(windows)'.dependencies]
-wepoll-sys = "2.0.0"
+wepoll-sys-stjepang = { git = "https://github.com/stjepang/wepoll-sys-stjepang.git" }
 
 [dev-dependencies]
 futures = { version = "0.3.5", default-features = false, features = ["std"] }
diff --git a/src/reactor.rs b/src/reactor.rs
index d1ae330..8cd926b 100644
--- a/src/reactor.rs
+++ b/src/reactor.rs
@@ -700,14 +700,10 @@ mod sys {
     use std::os::windows::io::{AsRawSocket, RawSocket};
     use std::time::Duration;
 
-    use once_cell::sync::Lazy;
-    use wepoll_sys::*;
-
-    use crate::io_event::IoEvent;
+    use wepoll_sys_stjepang::*;
 
     pub struct Reactor {
         handle: HANDLE,
-        io_event: Lazy<IoEvent>,
     }
     unsafe impl Send for Reactor {}
     unsafe impl Sync for Reactor {}
@@ -717,8 +713,7 @@ mod sys {
             if handle.is_null() {
                 return Err(io::Error::last_os_error());
             }
-            let io_event = Lazy::<IoEvent>::new(|| IoEvent::new().unwrap());
-            Ok(Reactor { handle, io_event })
+            Ok(Reactor { handle })
         }
         pub fn register(&self, sock: RawSocket, key: usize) -> io::Result<()> {
             let mut ev = epoll_event {
@@ -796,12 +791,21 @@ mod sys {
             if ret == -1 {
                 return Err(io::Error::last_os_error());
             }
-            self.io_event.clear();
             events.len = ret as usize;
             Ok(ret as usize)
         }
         pub fn notify(&self) -> io::Result<()> {
-            self.io_event.notify();
+            unsafe {
+                extern "system" {
+                    fn PostQueuedCompletionStatus(
+                        CompletionPort: HANDLE,
+                        dwNumberOfBytesTransferred: u32,
+                        dwCompletionKey: usize,
+                        lpOverlapped: usize,
+                    ) -> c_int;
+                }
+                PostQueuedCompletionStatus(self.handle, 0, 0, 0);
+            }
             Ok(())
         }
     }