test/test_backend.rb in polyphony-0.71 vs test/test_backend.rb in polyphony-0.72

- old
+ new

@@ -34,11 +34,11 @@ i, o = IO.pipe buf = +'' f = spin { @backend.read(i, buf, 5, false, 0) } @backend.write(o, 'Hello world') return_value = f.await - + assert_equal 'Hello', buf assert_equal return_value, buf end def test_write_read_to_eof_limited_buffer @@ -49,11 +49,11 @@ snooze @backend.write(o, ' world') snooze o.close return_value = f.await - + assert_equal 'Hello', buf assert_equal return_value, buf end def test_write_read_to_eof @@ -64,38 +64,38 @@ snooze @backend.write(o, ' world') snooze o.close return_value = f.await - + assert_equal 'Hello world', buf assert_equal return_value, buf end def test_write_read_with_buffer_position i, o = IO.pipe buf = +'abcdefghij' f = spin { @backend.read(i, buf, 20, false, 0) } @backend.write(o, 'blah') return_value = f.await - + assert_equal 'blah', buf assert_equal return_value, buf buf = +'abcdefghij' f = spin { @backend.read(i, buf, 20, false, -1) } @backend.write(o, 'klmn') return_value = f.await - + assert_equal 'abcdefghijklmn', buf assert_equal return_value, buf buf = +'abcdefghij' f = spin { @backend.read(i, buf, 20, false, 3) } @backend.write(o, 'DEF') return_value = f.await - + assert_equal 'abcDEF', buf assert_equal return_value, buf end def test_read_concat_big @@ -107,16 +107,16 @@ "get /?q=time HTTP/1.1\r\nContent-Length: #{body.bytesize}\r\n\r\n#{body}" + "get /?q=time HTTP/1.1\r\nCookie: foo\r\nCookie: bar\r\n\r\n" o << data o.close - + buf = +'' @backend.read(i, buf, 4096, false, -1) assert_equal 4096, buf.bytesize - + @backend.read(i, buf, 1, false, -1) assert_equal 4097, buf.bytesize @backend.read(i, buf, 4096, false, -1) @@ -127,11 +127,11 @@ def test_waitpid pid = fork do @backend.post_fork exit(42) end - + result = @backend.waitpid(pid) assert_equal [pid, 42], result end def test_read_loop @@ -425,11 +425,11 @@ def test_idle_proc counter = 0 @backend.idle_proc = proc { counter += 1 } - + 3.times { snooze } assert_equal 0, counter sleep 0.01 assert_equal 1, counter @@ -486,11 +486,11 @@ end end snooze client = TCPSocket.new('127.0.0.1', port) - + result = Thread.backend.chain( [:send, client, 'hello', 0], [:send, client, " world\n", 0] ) sleep 0.1 @@ -510,10 +510,10 @@ i, o = IO.pipe backend = Thread.current.backend while true len = o.splice(from, 8192) break if len == 0 - + backend.chain( [:write, to, chunk_header(len)], [:splice, i, to, len] ) end