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
|
net_box = require('net.box')
fiber = require('fiber')
LISTEN = require('uri').parse(box.cfg.listen)
-- create first space
s = box.schema.create_space('test')
i = s:create_index('primary')
box.schema.user.grant('guest', 'read', 'space', 'test')
cn = net_box.connect(LISTEN.host, LISTEN.service)
-- check that schema is correct
cn.space.test ~= nil
old_schema_version = cn.schema_version
-- create one more space
s2 = box.schema.create_space('test2')
i2 = s2:create_index('primary')
box.schema.user.grant('guest', 'read', 'space', 'test2')
----------------------------------
-- TEST #1 simple reload
----------------------------------
-- check that schema is not fresh
cn.space.test2 == nil
cn.schema_version == old_schema_version
-- exec request with reload
cn.space.test:select{}
cn.schema_version > old_schema_version
----------------------------------
-- TEST #2 parallel select/reload
----------------------------------
env = require('test_run')
test_run = env.new()
requests = 0
reloads = 0
test_run:cmd('setopt delimiter ";"')
function selector()
while true do
cn.space.test:select{}
requests = requests + 1
fiber.sleep(0.01)
end
end
function reloader()
while true do
cn:reload_schema()
reloads = reloads + 1
fiber.sleep(0.001)
end
end;
test_run:cmd('setopt delimiter ""');
request_fiber = fiber.create(selector)
reload_fiber = fiber.create(reloader)
-- Check that each fiber works
while requests < 10 or reloads < 10 do fiber.sleep(0.01) end
requests < reloads
-- cleanup
request_fiber:cancel()
reload_fiber:cancel()
s:drop()
s2:drop()
cn:close()
--------------------------------------------------------------------------------
-- gh-1808: support schema_version in CALL, EVAL and PING
--------------------------------------------------------------------------------
test_run:cmd('setopt delimiter ";"')
function bump_schema_version()
if box.space.bump_schema_version == nil then
box.schema.create_space('bump_schema_version')
else
box.space.bump_schema_version:drop()
end
end;
test_run:cmd('setopt delimiter ""');
cn = net_box.connect(box.cfg.listen)
-- ping
schema_version = cn.schema_version
bump_schema_version()
cn:ping()
function wait_new_schema() while cn.schema_version == schema_version do fiber.sleep(0.0001) end end
wait_new_schema()
cn.schema_version == schema_version + 1
-- call
schema_version = cn.schema_version
bump_schema_version()
function somefunc() return true end
box.schema.func.create('somefunc')
box.schema.user.grant('guest', 'execute', 'function', 'somefunc')
cn:call('somefunc')
wait_new_schema()
cn.schema_version == schema_version + 1
somefunc = nil
-- failed call
schema_version = cn.schema_version
bump_schema_version()
cn:call('somefunc')
wait_new_schema()
cn.schema_version == schema_version + 1
box.schema.func.drop('somefunc')
cn:close()
box.schema.user.grant('guest', 'execute', 'universe')
cn = net_box.connect(box.cfg.listen)
-- eval
schema_version = cn.schema_version
bump_schema_version()
cn:eval('return')
wait_new_schema()
cn.schema_version == schema_version + 1
somefunc = nil
-- failed eval
schema_version = cn.schema_version
bump_schema_version()
cn:eval('error("xx")')
wait_new_schema()
cn.schema_version == schema_version + 1
somefunc = nil
cn:close()
-- box.internal.schema_version()
schema_version = box.internal.schema_version()
schema_version > 0
bump_schema_version()
box.internal.schema_version() == schema_version + 1
if box.space.bump_schema_version ~= nil then box.space.bump_schema_version:drop() end
box.schema.user.revoke('guest', 'execute', 'universe')
|
