From 93fe2a7207ea625b721f26db2fea7830e8da7cf2 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Thu, 28 Jan 2021 13:09:56 +0600
Subject: [PATCH] prep release

---
 .github/workflows/windows.yml |  1 +
 ntex/CHANGES.md               |  8 +++++++-
 ntex/Cargo.toml               |  3 +--
 ntex/src/framed/state.rs      | 13 ++++++++++++-
 4 files changed, 21 insertions(+), 4 deletions(-)

diff --git a/.github/workflows/windows.yml b/.github/workflows/windows.yml
index 20e97418..27f3ad45 100644
--- a/.github/workflows/windows.yml
+++ b/.github/workflows/windows.yml
@@ -73,3 +73,4 @@ jobs:
                 --skip test_connection_wait_queue_force_close
                 --skip test_params
                 --skip test_body
+                --skip test_form
diff --git a/ntex/CHANGES.md b/ntex/CHANGES.md
index a13aa17a..cb3e41b6 100644
--- a/ntex/CHANGES.md
+++ b/ntex/CHANGES.md
@@ -1,6 +1,12 @@
 # Changes
 
-* Allow to wake up write io task
+## [0.2.0-b.10] - 2021-01-28
+
+* framed: Allow to wake up write io task
+
+* framed: Prevent uneeded read task wakeups
+
+* framed: Cleanup State impl
 
 ## [0.2.0-b.7] - 2021-01-25
 
diff --git a/ntex/Cargo.toml b/ntex/Cargo.toml
index 4060a403..1b686b91 100644
--- a/ntex/Cargo.toml
+++ b/ntex/Cargo.toml
@@ -51,7 +51,7 @@ derive_more = "0.99.11"
 either = "1.6.1"
 encoding_rs = "0.8.26"
 futures = "0.3.12"
-ahash = "0.6.3"
+ahash = "0.7.0"
 h2 = "0.2.4"
 http = "0.2.1"
 httparse = "1.3"
@@ -97,7 +97,6 @@ brotli2 = { version="0.3.2", optional = true }
 flate2 = { version = "1.0.14", optional = true }
 
 [dev-dependencies]
-futures = "0.3.12"
 env_logger = "0.8"
 serde_derive = "1.0"
 open-ssl = { version="0.10", package = "openssl" }
diff --git a/ntex/src/framed/state.rs b/ntex/src/framed/state.rs
index da347ce5..a7f6904f 100644
--- a/ntex/src/framed/state.rs
+++ b/ntex/src/framed/state.rs
@@ -349,7 +349,18 @@ impl State {
     #[inline]
     /// Wake write io task
     pub fn dsp_restart_write_task(&self) {
-        self.0.write_task.wake();
+        // if write buffer is empty then write task is asleep
+        // otherwise write task is active
+        if self.0.write_buf.borrow().is_empty() {
+            self.0.write_task.wake();
+        }
+    }
+
+    #[doc(hidden)]
+    #[inline]
+    /// Wake write io task
+    pub fn dsp_flush_write_data(&self, _: &Waker) {
+        self.dsp_restart_write_task()
     }
 
     #[inline]