about summary refs log tree commit homepage
path: root/lib/yahns/queue_quitter_pipe.rb
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2014-03-13 20:48:26 +0000
committerEric Wong <e@80x24.org>2014-03-13 20:48:26 +0000
commitc28223d381a6714cf005843e029c6ef211980c72 (patch)
tree7ec524339a79966417ec80e8147e7470cbab2de8 /lib/yahns/queue_quitter_pipe.rb
parente59f1c0c1018b4e252585bcd4ca0f688689ae8a5 (diff)
parentf46aea4aa26d3c3c5613d6800b2832cddb14b754 (diff)
downloadyahns-c28223d381a6714cf005843e029c6ef211980c72.tar.gz
* origin/freebsd:
  implement kqueue and sendfile compatibility support
  test: log skipped tests on non-Linux systems
  test_server: check_client_connection uses Unix sockets
  test_client_expire: add delays for non-Linux OSes
  wbuf_common: avoid trysendfile on empty sf_count
  sigevent_pipe: kgio_wait_writable takes variadic args
  queue_quitter_pipe: do not prematurely close reader
Diffstat (limited to 'lib/yahns/queue_quitter_pipe.rb')
-rw-r--r--lib/yahns/queue_quitter_pipe.rb4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/yahns/queue_quitter_pipe.rb b/lib/yahns/queue_quitter_pipe.rb
index 1aa0643..e18e249 100644
--- a/lib/yahns/queue_quitter_pipe.rb
+++ b/lib/yahns/queue_quitter_pipe.rb
@@ -5,9 +5,8 @@
 class Yahns::QueueQuitter # :nodoc:
   attr_reader :to_io
   def initialize
-    reader, @to_io = IO.pipe
+    @reader, @to_io = IO.pipe
     @to_io.close_on_exec = true
-    reader.close
   end
 
   def yahns_step
@@ -19,6 +18,7 @@ class Yahns::QueueQuitter # :nodoc:
   end
 
   def close
+    @reader.close
     @to_io.close
   end
 end