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