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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
# vim:set ft= ts=4 sw=4 et fdm=marker:
use lib 'lib';
use Test::Nginx::Socket::Lua;
#worker_connections(10140);
#workers(1);
log_level('warn');
master_process_enabled(1);
repeat_each(1);
plan tests => repeat_each() * (blocks() * 3);
no_long_string();
#no_diff();
add_block_preprocessor(sub {
my $block = shift;
my $http_config = $block->http_config || '';
$http_config .= <<'_EOC_';
lua_package_path "../lua-resty-core/lib/?.lua;../lua-resty-lrucache/lib/?.lua;;";
lua_shared_dict shdict 4m;
init_by_lua_block {
require "resty.core"
local process = require "ngx.process"
local ok, err = process.enable_privileged_agent()
if not ok then
ngx.log(ngx.ERR, "failed to enable_privileged_agent: ", err)
end
}
init_worker_by_lua_block {
local function test(pre)
if pre then
return
end
local semaphore = require "ngx.semaphore"
local sem = semaphore.new()
ngx.log(ngx.ERR, "created semaphore object")
local function sem_wait()
local ok, err = sem:wait(100)
if not ok then
ngx.log(ngx.ERR, "err: ", err)
else
ngx.log(ngx.ERR, "wait success")
end
end
while not ngx.worker.exiting() do
local co = ngx.thread.spawn(sem_wait)
ngx.thread.wait(co)
end
end
local ok, err = ngx.timer.at(0, test)
if not ok then
ngx.log(ngx.ERR, "failed to create semaphore timer err: ", err)
end
local function reload(pre)
if pre then
return
end
shdict = ngx.shared.shdict
local success = shdict:add("reloaded", 1)
if not success then
return
end
ngx.log(ngx.ERR, "try to reload nginx")
local f, err = io.open(ngx.config.prefix() .. "/logs/nginx.pid", "r")
if not f then
ngx.say("failed to open nginx.pid: ", err)
return
end
local pid = f:read()
f:close()
os.execute("kill -HUP " .. pid)
end
local typ = require "ngx.process".type
if typ() == "privileged agent" then
local ok, err = ngx.timer.at(0.1, reload)
if not ok then
ngx.log(ngx.ERR, "failed to create semaphore timer err: ", err)
end
end
}
_EOC_
$block->set_value("http_config", $http_config);
});
run_tests();
__DATA__
=== TEST 1: timer + reload
--- config
location /test {
content_by_lua_block {
ngx.sleep(1)
ngx.say("hello")
}
}
--- request
GET /test
--- response_body
hello
--- grep_error_log eval: qr/created semaphore object|try to reload nginx|semaphore gc wait queue is not empty/
--- grep_error_log_out
created semaphore object
created semaphore object
try to reload nginx
created semaphore object
created semaphore object
--- skip_nginx: 3: < 1.11.2
--- no_check_leak
--- wait: 0.2
=== TEST 2: timer + reload (lua code cache off)
--- http_config
lua_code_cache off;
--- config
location /test {
content_by_lua_block {
ngx.sleep(1)
ngx.say("hello")
}
}
--- request
GET /test
--- response_body
hello
--- grep_error_log eval: qr/created semaphore object|try to reload nginx|semaphore gc wait queue is not empty/
--- grep_error_log_out
created semaphore object
created semaphore object
try to reload nginx
created semaphore object
created semaphore object
--- skip_nginx: 3: < 1.11.2
--- no_check_leak
--- wait: 0.2
|
