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
|
env = require('test_run')
test_run = env.new()
box.schema.user.grant('guest', 'replication')
box.schema.func.create('_set_pri_lsn')
box.schema.user.grant('guest', 'execute', 'function', '_set_pri_lsn')
test_run:cmd("create server hot_standby with script='replication/hot_standby.lua', rpl_master=default")
test_run:cmd("create server replica with rpl_master=default, script='replication/replica.lua'")
test_run:cmd("start server hot_standby")
test_run:cmd("start server replica")
test_run:cmd("setopt delimiter ';'")
test_run:cmd("set connection default, hot_standby, replica")
fiber = require('fiber');
while box.info.server.id == 0 do fiber.sleep(0.01) end;
while box.space['_priv']:len() < 1 do fiber.sleep(0.001) end;
do
local pri_id = ''
local begin_lsn = 0
function _set_pri_lsn(_id, _lsn)
pri_id = _id
begin_lsn = _lsn
end
function _get_pri_lsn()
return box.info.vclock[pri_id]
end
function _print_lsn()
return (_get_pri_lsn() - begin_lsn + 1)
end
function _insert(_begin, _end)
local a = {}
for i = _begin, _end do
table.insert(a, box.space.tweedledum:insert{i, 'the tuple '..i})
end
return a
end
function _select(_begin, _end)
local a = {}
for i = _begin, _end do
local tuple = box.space.tweedledum:get{i}
if tuple ~= nil then
table.insert(a, tuple)
end
end
return a
end
function _wait_lsn(_lsnd)
while _get_pri_lsn() < _lsnd + begin_lsn do
fiber.sleep(0.001)
end
begin_lsn = begin_lsn + _lsnd
end
end;
test_run:cmd("setopt delimiter ''");
test_run:cmd("switch replica")
fiber = require('fiber')
test_run:cmd("switch hot_standby")
fiber = require('fiber')
box.info.status
test_run:cmd("switch default")
fiber = require('fiber')
box.info.status
space = box.schema.space.create('tweedledum')
index = space:create_index('primary', { type = 'hash' })
-- set begin lsn on master, replica and hot_standby.
test_run:cmd("set variable replica_port to 'replica.listen'")
REPLICA = require('uri').parse(tostring(replica_port))
REPLICA ~= nil
a = (require 'net.box').connect(REPLICA.host, REPLICA.service)
a:call('_set_pri_lsn', box.info.server.id, box.info.server.lsn)
a:close()
_insert(1, 10)
_select(1, 10)
test_run:cmd("switch replica")
_wait_lsn(10)
_select(1, 10)
test_run:cmd("stop server default")
test_run:cmd("switch hot_standby")
while box.info.status ~= 'running' do fiber.sleep(0.001) end
test_run:cmd("switch replica")
-- hot_standby.listen is garbage, since hot_standby.lua
-- uses MASTER environment variable for its listen
test_run:cmd("set variable hot_standby_port to 'hot_standby.master'")
HOT_STANDBY = require('uri').parse(tostring(hot_standby_port))
HOT_STANDBY ~= nil
a = (require 'net.box').connect(HOT_STANDBY.host, HOT_STANDBY.service)
a:call('_set_pri_lsn', box.info.server.id, box.info.server.lsn)
a:close()
test_run:cmd("switch hot_standby")
_insert(11, 20)
_select(11, 20)
test_run:cmd("switch replica")
_wait_lsn(10)
_select(11, 20)
test_run:cmd("deploy server default")
test_run:cmd("start server default")
test_run:cmd("switch default")
test_run:cmd("stop server hot_standby")
test_run:cmd("stop server replica")
test_run:cmd("cleanup server hot_standby")
test_run:cmd("cleanup server replica")
|
