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
155
156
157
158
159
160
161
162
163
164
165
166
167
168
|
# encoding: tarantool
import os
import time
from lib.tarantool_server import TarantoolServer
ID_BEGIN = 0
ID_STEP = 10
def insert_tuples(server, begin, end, msg = "tuple"):
server_sql = server.sql
for i in range(begin, end):
exec server_sql "insert into t0 values (%d, '%s %d')" % (i, msg, i)
def select_tuples(server, begin, end):
server_sql = server.sql
# the last lsn is end id + 1
server.wait_lsn(end + 1)
for i in range(begin, end):
exec server_sql "select * from t0 where k0 = %d" % i
# master server
master = server
# replica server
replica = TarantoolServer()
replica.deploy("replication/cfg/replica.cfg",
replica.find_exe(self.args.builddir),
os.path.join(self.args.vardir, "replica"))
# Id counter
id = 0
print "insert to master [%d, %d) entries" % (id, id + ID_STEP)
insert_tuples(master, id, id + ID_STEP, "mater")
print "select from replica [%d, %d) entries" % (id, id + ID_STEP)
select_tuples(replica, id, id + ID_STEP)
id += ID_STEP
print "master lsn = %s" % master.get_param("lsn")
print "replica lsn = %s" % replica.get_param("lsn")
print """
#
# mater lsn > replica lsn
#
"""
print """
# reconfigure replica to master
"""
replica.reconfigure("replication/cfg/replica_to_master.cfg")
print "insert to master [%d, %d) entries" % (id, id + ID_STEP)
insert_tuples(master, id, id + ID_STEP, "mater")
print "select from master [%d, %d) entries" % (id, id + ID_STEP)
select_tuples(master, id, id + ID_STEP)
print "insert to replica [%d, %d) entries" % (id, id + (ID_STEP / 2))
insert_tuples(replica, id, id + (ID_STEP / 2), "replica")
print "select from replica [%d, %d) entries" % (id, id + (ID_STEP / 2))
select_tuples(replica, id, id + (ID_STEP / 2))
print "master lsn = %s" % master.get_param("lsn")
print "replica lsn = %s" % replica.get_param("lsn")
print """
# rollback replica
"""
replica.reconfigure("replication/cfg/replica.cfg")
print "select from replica [%d, %d) entries" % (id, id + ID_STEP)
select_tuples(replica, id, id + ID_STEP)
id += ID_STEP
print "master lsn = %s" % master.get_param("lsn")
print "replica lsn = %s" % replica.get_param("lsn")
print """
#
# master lsn == replica lsn
#
"""
print """
# reconfigure replica to master
"""
replica.reconfigure("replication/cfg/replica_to_master.cfg")
print "insert to master [%d, %d) entries" % (id, id + ID_STEP)
insert_tuples(master, id, id + ID_STEP, "mater")
print "select from master [%d, %d) entries" % (id, id + ID_STEP)
select_tuples(master, id, id + ID_STEP)
print "insert to replica [%d, %d) entries" % (id, id + ID_STEP)
insert_tuples(replica, id, id + ID_STEP, "replica")
print "select from replica [%d, %d) entries" % (id, id + ID_STEP)
select_tuples(replica, id, id + ID_STEP)
print "master lsn = %s" % master.get_param("lsn")
print "replica lsn = %s" % replica.get_param("lsn")
print """
# rollback replica
"""
replica.reconfigure("replication/cfg/replica.cfg")
print "select from replica [%d, %d) entries" % (id, id + ID_STEP)
select_tuples(replica, id, id + ID_STEP)
id += ID_STEP
print "master lsn = %s" % master.get_param("lsn")
print "replica lsn = %s" % replica.get_param("lsn")
print """
#
# mater lsn < replica lsn
#
"""
print """
#reconfigure replica to master
"""
replica.reconfigure("replication/cfg/replica_to_master.cfg")
print "insert to master [%d, %d) entries" % (id, id + ID_STEP)
insert_tuples(master, id, id + ID_STEP, "mater")
print "select from master [%d, %d) entries" % (id, id + ID_STEP)
select_tuples(master, id, id + ID_STEP)
print "insert to replica [%d, %d) entries" % (id, id + (ID_STEP * 2))
insert_tuples(replica, id, id + (ID_STEP * 2), "replica")
print "select from replica [%d, %d) entries" % (id, id + (ID_STEP * 2))
select_tuples(replica, id, id + (ID_STEP * 2))
print "master lsn = %s" % master.get_param("lsn")
print "replica lsn = %s" % replica.get_param("lsn")
print """
# rollback replica
"""
replica.reconfigure("replication/cfg/replica.cfg")
print "select from replica [%d, %d) entries" % (id, id + (ID_STEP * 2))
select_tuples(replica, id, id + (ID_STEP * 2))
id += ID_STEP
print "insert to master [%d, %d) entries" % (id, id + (ID_STEP * 2))
insert_tuples(master, id, id + (ID_STEP * 2), "master")
print "select from replica [%d, %d) entries" % (id, id + (ID_STEP * 2))
select_tuples(replica, id, id + (ID_STEP * 2))
print "master lsn = %s" % master.get_param("lsn")
print "replica lsn = %s" % replica.get_param("lsn")
# Test that a replica replies with master connection URL on
# update requests.
replica_sql = replica.sql
exec replica_sql "insert into t0 values (0, 'replica is read only')"
# Cleanup.
replica.stop()
replica.cleanup(True)
server.stop()
server.deploy(self.suite_ini["config"])
# vim: syntax=python
|
