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
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2001, 2013 Oracle and/or its affiliates. All rights reserved.
#
# $Id$
#
# TEST rep009
# TEST Replication and DUPMASTERs
# TEST Run test001 in a replicated environment.
# TEST
# TEST Declare one of the clients to also be a master.
# TEST Close a client, clean it and then declare it a 2nd master.
proc rep009 { method { niter 10 } { tnum "009" } args } {
source ./include.tcl
global repfiles_in_memory
global env_private
# Run for btree only.
if { $checking_valid_methods } {
set test_methods { btree }
return $test_methods
}
if { [is_btree $method] == 0 } {
puts "Rep009: Skipping for method $method."
return
}
set msg2 "and on-disk replication files"
if { $repfiles_in_memory } {
set msg2 "and in-memory replication files"
}
set msg3 ""
if { $env_private } {
set msg3 "and private env"
}
set logsets [create_logsets 3]
# Run the body of the test with and without recovery.
foreach r $test_recopts {
foreach l $logsets {
set logindex [lsearch -exact $l "in-memory"]
if { $r == "-recover" && $logindex != -1 } {
puts "Rep$tnum: Skipping\
for in-memory logs with -recover."
continue
}
puts -nonewline "Rep$tnum ($r):"
puts "Replication DUPMASTER test $msg2 $msg3."
puts "Rep$tnum: Master logs are [lindex $l 0]"
puts "Rep$tnum: Client1 logs are [lindex $l 1]"
puts "Rep$tnum: Client2 logs are [lindex $l 2]"
rep009_sub $method $niter $tnum 0 $l $r $args
rep009_sub $method $niter $tnum 1 $l $r $args
}
}
}
proc rep009_sub { method niter tnum clean logset recargs largs } {
global testdir
global repfiles_in_memory
global env_private
global rep_verbose
global verbose_type
set verbargs ""
if { $rep_verbose == 1 } {
set verbargs " -verbose {$verbose_type on} "
}
set repmemargs ""
if { $repfiles_in_memory } {
set repmemargs "-rep_inmem_files "
}
set privargs ""
if { $env_private == 1 } {
set privargs " -private "
}
env_cleanup $testdir
replsetup $testdir/MSGQUEUEDIR
set masterdir $testdir/MASTERDIR
set clientdir $testdir/CLIENTDIR
set clientdir2 $testdir/CLIENTDIR.2
file mkdir $masterdir
file mkdir $clientdir
file mkdir $clientdir2
set m_logtype [lindex $logset 0]
set m_logargs [adjust_logargs $m_logtype]
set m_txnargs [adjust_txnargs $m_logtype]
set c_logtype [lindex $logset 1]
set c_logargs [adjust_logargs $c_logtype]
set c_txnargs [adjust_txnargs $c_logtype]
set c2_logtype [lindex $logset 2]
set c2_logargs [adjust_logargs $c2_logtype]
set c2_txnargs [adjust_txnargs $c2_logtype]
# Open a master.
repladd 1
set ma_envcmd "berkdb_env_noerr -create $m_txnargs $m_logargs \
-home $masterdir $verbargs -errpfx MASTER $repmemargs \
$privargs -rep_transport \[list 1 replsend\]"
set masterenv [eval $ma_envcmd $recargs -rep_master]
# Open a client.
repladd 2
set cl_envcmd "berkdb_env_noerr -create $c_txnargs $c_logargs \
-home $clientdir $verbargs -errpfx CLIENT1 $repmemargs \
$privargs -rep_transport \[list 2 replsend\]"
set clientenv [eval $cl_envcmd $recargs -rep_client]
# Open a second client.
repladd 3
set cl2_envcmd "berkdb_env_noerr -create $c2_txnargs $c2_logargs \
-home $clientdir2 $verbargs -errpfx CLIENT2 $repmemargs \
$privargs -rep_transport \[list 3 replsend\]"
set cl2env [eval $cl2_envcmd $recargs -rep_client]
# Bring the clients online by processing the startup messages.
set envlist "{$masterenv 1} {$clientenv 2} {$cl2env 3}"
process_msgs $envlist
# Run a modified test001 in the master (and update client).
puts "\tRep$tnum.a: Running test001 in replicated env."
eval test001 $method $niter 0 0 $tnum -env $masterenv $largs
process_msgs $envlist
puts "\tRep$tnum.b: Declare a client to be a master."
if { $clean } {
error_check_good clientenv_close [$clientenv close] 0
env_cleanup $clientdir
set clientenv [eval $cl_envcmd $recargs -rep_master]
error_check_good client_env [is_valid_env $clientenv] TRUE
} else {
error_check_good client_master [$clientenv rep_start -master] 0
}
#
# Process the messages to get them out of the db.
#
for { set i 1 } { $i <= 3 } { incr i } {
set seen_dup($i) 0
}
while { 1 } {
set nproced 0
incr nproced [replprocessqueue \
$masterenv 1 0 NONE dup1 err1]
incr nproced [replprocessqueue \
$clientenv 2 0 NONE dup2 err2]
incr nproced [replprocessqueue \
$cl2env 3 0 NONE dup3 err3]
if { $dup1 != 0 } {
set seen_dup(1) 1
error_check_good downgrade1 \
[$masterenv rep_start -client] 0
}
if { $dup2 != 0 } {
set seen_dup(2) 1
error_check_good downgrade1 \
[$clientenv rep_start -client] 0
}
#
# We might get errors after downgrading as the former
# masters might get old messages from other clients.
# If we get an error make sure it is after downgrade.
if { $err1 != 0 } {
error_check_good seen_dup1_err $seen_dup(1) 1
error_check_good err1str [is_substr \
$err1 "invalid argument"] 1
}
if { $err2 != 0 } {
error_check_good seen_dup2_err $seen_dup(2) 1
error_check_good err2str [is_substr \
$err2 "invalid argument"] 1
}
#
# This should never happen. We'll check below.
#
if { $dup3 != 0 } {
set seen_dup(3) 1
}
if { $nproced == 0 } {
break
}
}
error_check_good seen_dup1 $seen_dup(1) 1
error_check_good seen_dup2 $seen_dup(2) 1
error_check_bad seen_dup3 $seen_dup(3) 1
puts "\tRep$tnum.c: Close environments"
error_check_good master_close [$masterenv close] 0
error_check_good clientenv_close [$clientenv close] 0
error_check_good cl2_close [$cl2env close] 0
replclose $testdir/MSGQUEUEDIR
}
|
