1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
# vim:set ft= ts=4 sw=4 et fdm=marker:
use Test::Nginx::Socket;
use Test::Nginx::Socket::Lua::Stream;
log_level('warn');
repeat_each(2);
if (defined $ENV{TEST_NGINX_USE_HTTP3}) {
plan(skip_all => "HTTP3 does not support client abort");
} elsif (defined $ENV{TEST_NGINX_USE_HTTP2}) {
plan(skip_all => "HTTP2 does not support client abort");
} else {
plan tests => repeat_each() * (blocks() * 2);
}
run_tests();
__DATA__
=== TEST 1: ngx.say and cosocket
--- stream_server_config
content_by_lua_block {
local sock = assert(ngx.req.socket(true))
sock:settimeout(1000)
while true do
local data = sock:receive(5)
if not data then
return
end
ngx.print(data)
ngx.flush(true)
end
}
--- config
location /test {
content_by_lua_block {
ngx.say("hello")
--ngx.flush(true)
local sock = ngx.socket.tcp()
local ok, err = sock:connect("127.0.0.1", ngx.var.server_port + 1)
assert(ok)
local last_duration = 0
local cnt = 0
local t1, t2
local err_cnt = 0
local ERR_THRESHOLD_MS = 100
for i = 1,100000 do
if cnt == 0 then
ngx.update_time()
t1 = ngx.now()
end
cnt = cnt + 1
local sent = sock:send("hello")
local data = sock:receive(5)
assert(data=="hello")
if cnt == 1000 then
cnt = 0
ngx.update_time()
t2 = ngx.now()
local duration = (t2 - t1) * 1000
if last_duration > 0 and (duration - last_duration) > ERR_THRESHOLD_MS then
if err_cnt >= 3 then
ngx.log(ngx.ERR,
"more than ", err_cnt, " times, duration larger than ",
ERR_THRESHOLD_MS, " ms, ",
"last_duration: ", math.floor(duration), " ms")
return ngx.exit(500)
end
err_cnt = err_cnt + 1
end
last_duration = duration
end
end
sock:close()
ngx.exit(200)
}
}
--- no_error_log
[error]
--- timeout: 30
--- request
GET /test
|
