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
|
env = require('test_run')
---
...
test_run = env.new()
---
...
engine = test_run:get_cfg('engine')
---
...
net_box = require('net.box')
---
...
errinj = box.error.injection
---
...
box.schema.user.grant('guest', 'replication')
---
...
test_run:cmd("create server replica with rpl_master=default, script='replication/replica_timeout.lua'")
---
- true
...
test_run:cmd("start server replica with args='0.1'")
---
- true
...
test_run:cmd("switch replica")
---
- true
...
test_run:cmd("switch default")
---
- true
...
s = box.schema.space.create('test', {engine = engine});
---
...
-- Vinyl does not support hash index.
index = s:create_index('primary', {type = (engine == 'vinyl' and 'tree' or 'hash') })
---
...
test_run:cmd("switch replica")
---
- true
...
fiber = require('fiber')
---
...
while box.space.test == nil do fiber.sleep(0.01) end
---
...
test_run:cmd("switch default")
---
- true
...
test_run:cmd("stop server replica")
---
- true
...
-- Insert values on the master while replica is stopped and can't
-- fetch them.
errinj.set('ERRINJ_RELAY_SEND_DELAY', true)
---
- ok
...
for i = 1, 100 do s:insert{i, 'this is test message12345'} end
---
...
test_run:cmd("start server replica with args='0.01'")
---
- true
...
test_run:cmd("switch replica")
---
- true
...
-- Check that replica doesn't enter read-write mode before
-- catching up with the master: to check that we stop sending
-- rows on the master in relay_send function and attempt a data
-- modifying statement in replica while it's still fetching data
-- from the master.
--
-- In the next two cases we try to replace a tuple while replica
-- is catching up with the master (local replace, remote replace)
-- case.
--
-- Case #1: replace tuple on replica locally.
--
box.space.test ~= nil
---
- true
...
box.space.test:replace{1}
---
- error: Can't modify data because this instance is in read-only mode.
...
-- Case #2: replace tuple on replica by net.box.
test_run:cmd("switch default")
---
- true
...
test_run:cmd("set variable r_uri to 'replica.listen'")
---
- true
...
c = net_box.connect(r_uri)
---
...
d = c.space.test:replace{1}
---
- error: Can't modify data because this instance is in read-only mode.
...
-- Resume replication.
errinj.set('ERRINJ_RELAY_SEND_DELAY', false)
---
- ok
...
-- Cleanup.
test_run:cmd("stop server replica")
---
- true
...
test_run:cmd("cleanup server replica")
---
- true
...
test_run:cmd("delete server replica")
---
- true
...
test_run:cleanup_cluster()
---
...
box.space.test:drop()
---
...
box.schema.user.revoke('guest', 'replication')
---
...
|
