about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2011-05-20 18:13:21 -0700
committerEric Wong <normalperson@yhbt.net>2011-05-21 01:37:08 +0000
commit0b9b4edc63c0021e567c68137e1ee7f9e99ddcc5 (patch)
treeb86f1c27240e9637c2372c4ffc509c96c0881533
parenta5419a5fd57a231e40b7a3ba48a02cdef15909be (diff)
downloadrainbows-0b9b4edc63c0021e567c68137e1ee7f9e99ddcc5.tar.gz
We need to trigger a recv() to uncork the response.
This won't affect fairness (much) since all recv()s
are non-blocking and a successful header parse will
put us in the back of the queue.
-rw-r--r--lib/rainbows/xepoll_thread_pool/client.rb2
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/rainbows/xepoll_thread_pool/client.rb b/lib/rainbows/xepoll_thread_pool/client.rb
index 2cf05e5..625d1ac 100644
--- a/lib/rainbows/xepoll_thread_pool/client.rb
+++ b/lib/rainbows/xepoll_thread_pool/client.rb
@@ -127,7 +127,7 @@ module Rainbows::XEpollThreadPool::Client
   def pipeline_ready(hp)
     # be fair to other clients, let others run first
     hp.parse and return queue!
-    kato_set
+    epoll_run("")
     false
   end
 end