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
|
test_run = require('test_run').new()
fiber = require('fiber')
net_box = require('net.box')
box.schema.user.grant('guest', 'read,write,execute', 'universe')
conn = net_box.connect(box.cfg.listen)
conn2 = net_box.connect(box.cfg.listen)
active = 0
finished = 0
continue = false
limit = 768
run_max = (limit - 100) / 2
old_readahead = box.cfg.readahead
box.cfg{readahead = 9000}
long_str = string.rep('a', 1000)
test_run:cmd("setopt delimiter ';'")
function do_long_f(...)
active = active + 1
while not continue do
fiber.sleep(0.01)
end
active = active - 1
finished = finished + 1
end;
function do_long(c)
c:call('do_long_f', {long_str})
end;
function run_workers(c)
finished = 0
continue = false
for i = 1, run_max do
fiber.create(do_long, c)
end
end;
-- Wait until 'active' stops growing - it means, that the input
-- is blocked.
function wait_active(value)
while value ~= active do
fiber.sleep(0.01)
end
end;
function wait_finished(needed)
continue = true
while finished ~= needed do fiber.sleep(0.01) end
end;
test_run:cmd("setopt delimiter ''");
--
-- Test that message count limit is reachable.
--
run_workers(conn)
run_workers(conn2)
wait_active(run_max * 2)
active == run_max * 2 or active
wait_finished(active)
conn2:close()
conn:close()
box.schema.user.revoke('guest', 'read,write,execute', 'universe')
box.cfg{readahead = old_readahead}
|
