From 392b42c68b2a2e4c5beb60f59048b4813dae7c35 Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Fri, 3 Apr 2015 00:13:25 +0000 Subject: wbuf: store busy signal inside this object This should make it easier to track state for asynchronous proxy_pass buffering. --- test/test_wbuf.rb | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'test/test_wbuf.rb') diff --git a/test/test_wbuf.rb b/test/test_wbuf.rb index bfdfa2b..e6f8790 100644 --- a/test/test_wbuf.rb +++ b/test/test_wbuf.rb @@ -19,7 +19,8 @@ class TestWbuf < Testcase buf = "*" * (16384 * 2) nr = 1000 [ true, false ].each do |persist| - wbuf = Yahns::Wbuf.new([], persist, Dir.tmpdir) + wbuf = Yahns::Wbuf.new([], persist, Dir.tmpdir, :wait_writable) + assert_equal :wait_writable, wbuf.busy a, b = socketpair assert_nil wbuf.wbuf_write(a, "HIHI") assert_equal "HIHI", b.read(4) @@ -69,7 +70,7 @@ class TestWbuf < Testcase break end while true end - wbuf = Yahns::Wbuf.new([], true, Dir.tmpdir) + wbuf = Yahns::Wbuf.new([], true, Dir.tmpdir, :wait_writable) assert_equal :wait_writable, wbuf.wbuf_write(a, buf) assert_equal :wait_writable, wbuf.wbuf_flush(a) @@ -93,7 +94,7 @@ class TestWbuf < Testcase def test_wbuf_flush_close pipe = cloexec_pipe persist = true - wbuf = Yahns::Wbuf.new(pipe[0], persist, Dir.tmpdir) + wbuf = Yahns::Wbuf.new(pipe[0], persist, Dir.tmpdir, :wait_writable) refute wbuf.respond_to?(:close) # we don't want this for HttpResponse body sp = socketpair rv = nil -- cgit v1.2.3-24-ge0c7