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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2009, 2013 Oracle and/or its affiliates. All rights reserved.
#
# TEST repmgr106
# TEST Simple smoke test for repmgr elections with multi-process envs.
proc repmgr106 { } {
source ./include.tcl
set tnum "106"
puts "Repmgr$tnum:\
Smoke test for repmgr elections with multi-process envs."
env_cleanup $testdir
# Assign values for each port variable from list contents.
foreach {portA portB portC} [available_ports 3] {}
set timeouts {
{rep_set_timeout DB_REP_ELECTION_RETRY 2000000}
{rep_set_timeout DB_REP_ELECTION_TIMEOUT 1000000}
}
# First just create the group.
file mkdir $testdir/A
make_dbconfig $testdir/A \
[linsert $timeouts 0 [list repmgr_site 127.0.0.1 $portA db_local_site on]]
file mkdir $testdir/B
make_dbconfig $testdir/B \
[linsert $timeouts 0 [list repmgr_site 127.0.0.1 $portB db_local_site on] \
[list repmgr_site 127.0.0.1 $portA db_bootstrap_helper on]]
file mkdir $testdir/C
make_dbconfig $testdir/C \
[linsert $timeouts 0 [list repmgr_site 127.0.0.1 $portC db_local_site on] \
[list repmgr_site 127.0.0.1 $portA db_bootstrap_helper on]]
set cmds {
{home $testdir/A}
{open_env}
{start master}
}
set cmds [subst $cmds]
set a [open_site_prog [linsert $cmds 1 "output $testdir/aoutput"]]
set cmds {
{home $testdir/B}
{open_env}
{start client}
}
set cmds [subst $cmds]
set b [open_site_prog [linsert $cmds 1 "output $testdir/boutput"]]
set clientenv [berkdb_env -home $testdir/B]
await_startup_done $clientenv
$clientenv close
set cmds {
{home $testdir/C}
{open_env}
{start client}
}
set cmds [subst $cmds]
set c [open_site_prog [linsert $cmds 1 "output $testdir/coutput"]]
set clientenv [berkdb_env -home $testdir/C]
await_startup_done $clientenv
$clientenv close
close $c
close $b
close $a
puts "\tRepmgr$tnum.a: Start 3 sites (with 2 processes each)."
set cmds {
{home $testdir/A}
{open_env}
{start election}
}
set cmds [subst $cmds]
set a1 [open_site_prog [linsert $cmds 1 "output $testdir/a1output"]]
set a2 [open_site_prog [linsert $cmds 1 "output $testdir/a2output"]]
set cmds {
{home $testdir/B}
{open_env}
{start election}
}
set cmds [subst $cmds]
set b1 [open_site_prog [linsert $cmds 1 "output $testdir/b1output"]]
set b2 [open_site_prog [linsert $cmds 1 "output $testdir/b2output"]]
set cmds {
{home $testdir/C}
{open_env}
{start election}
}
set cmds [subst $cmds]
set c1 [open_site_prog [linsert $cmds 1 "output $testdir/c1output"]]
set c2 [open_site_prog [linsert $cmds 1 "output $testdir/c2output"]]
puts "\tRepmgr$tnum.b: Wait for an election to choose initial master."
set a [berkdb_env -home $testdir/A]
set b [berkdb_env -home $testdir/B]
set c [berkdb_env -home $testdir/C]
set sites "$a $b $c"
set menv [repmgr106_await_election $sites]
set i [lsearch -exact $sites $menv]
error_check_bad notfound $i -1
set site_names "abc"
set m [string range $site_names $i $i]
puts "\tRepmgr$tnum.c: (site $m is master)."
puts "\tRepmgr$tnum.d: Wait for other two sites to sync up."
set clients [lreplace $sites $i $i]
set site_names [string replace $site_names $i $i]
await_startup_done [lindex $clients 0]
await_startup_done [lindex $clients 1]
set m1 [subst $${m}1]
set m2 [subst $${m}2]
puts $m2 "open_db test.db"
puts $m2 "put key1 value1"
puts $m2 "echo done"
gets $m2
puts "\tRepmgr$tnum.e:\
Shut down master, wait for survivors to elect new master."
$menv close
close $m1
close $m2
set menv [repmgr106_await_election $clients]
set i [lsearch -exact $clients $menv]
error_check_bad notfound2 $i -1
set m [string range $site_names $i $i]
puts "\tRepmgr$tnum.f: (site $m is new master)."
puts "\tRepmgr$tnum.g: Wait for remaining client to sync to new master."
set client [lreplace $clients $i $i]
await_condition {[stat_field $client rep_stat "Master changes"] == 3}
await_startup_done $client
puts "\tRepmgr$tnum.h: Clean up."
$client close
$menv close
set c [string range $site_names 0 0]
close [subst $${c}1]
close [subst $${c}2]
set c [string range $site_names 1 1]
close [subst $${c}1]
close [subst $${c}2]
}
proc repmgr106_await_election { env_list } {
set cond {
foreach e $env_list {
if {[stat_field $e rep_stat "Role"] == "master"} {
set answer $e
break
}
}
expr {[info exists answer]}
}
await_condition {[eval $cond]} 20
return $answer
}
|
