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
207
208
209
210
211
212
213
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2004, 2013 Oracle and/or its affiliates. All rights reserved.
#
# $Id$
#
# TEST rep023
# TEST Replication using two master handles.
# TEST
# TEST Open two handles on one master env. Create two
# TEST databases, one through each master handle. Process
# TEST all messages through the first master handle. Make
# TEST sure changes made through both handles are picked
# TEST up properly.
#
proc rep023 { method { niter 10 } { tnum "023" } args } {
source ./include.tcl
global databases_in_memory
global repfiles_in_memory
global env_private
# Run for all access methods.
if { $checking_valid_methods } {
return "ALL"
}
# We can't open two envs on HP-UX, so just skip the
# whole test since that is at the core of it.
if { $is_hp_test == 1 } {
puts "Rep$tnum: Skipping for HP-UX."
return
}
set args [convert_args $method $args]
set logsets [create_logsets 2]
# Set up for on-disk or in-memory databases.
set msg "using on-disk databases"
if { $databases_in_memory } {
set msg "using named in-memory databases"
if { [is_queueext $method] } {
puts -nonewline "Skipping rep$tnum for method "
puts "$method with named in-memory databases."
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 "with private env"
}
# Run the body of the test with and without recovery, and
# with and without -rep_start.
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
}
foreach startopt { 0 1 } {
if { $startopt == 1 } {
set startmsg "with rep_start"
} else {
set startmsg ""
}
puts "Rep$tnum ($method $r $startmsg):\
Replication with two master handles\
$msg $msg2 $msg3."
puts "Rep$tnum: Master logs are [lindex $l 0]"
puts "Rep$tnum: Client logs are [lindex $l 1]"
rep023_sub $method \
$niter $tnum $l $r $startopt $args
}
}
}
}
proc rep023_sub { method niter tnum logset recargs startopt largs } {
global testdir
global databases_in_memory
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
file mkdir $masterdir
file mkdir $clientdir
set m_logtype [lindex $logset 0]
set c_logtype [lindex $logset 1]
# In-memory logs require a large log buffer, and cannot
# be used with -txn nosync.
set m_logargs [adjust_logargs $m_logtype]
set c_logargs [adjust_logargs $c_logtype]
set m_txnargs [adjust_txnargs $m_logtype]
set c_txnargs [adjust_txnargs $c_logtype]
# Open 1st master.
repladd 1
set ma_envcmd "berkdb_env_noerr -create $m_txnargs $m_logargs \
$verbargs -errpfx MASTER -home $masterdir $repmemargs \
$privargs -rep_transport \[list 1 replsend\]"
set masterenv1 [eval $ma_envcmd $recargs -rep_master]
# Open 2nd handle on master. The master envs will share
# the same envid.
set masterenv2 [eval $ma_envcmd]
if { $startopt == 1 } {
error_check_good rep_start [$masterenv2 rep_start -master] 0
}
# Open a client.
repladd 2
set cl_envcmd "berkdb_env_noerr -create $c_txnargs $repmemargs \
$c_logargs $verbargs -errpfx CLIENT -home $clientdir \
$privargs -rep_transport \[list 2 replsend\]"
set clientenv [eval $cl_envcmd $recargs -rep_client]
# Bring the clients online by processing the startup messages.
# Process messages on the first masterenv handle, not the second.
set envlist "{$masterenv1 1} {$clientenv 2}"
process_msgs $envlist
# Set up databases in-memory or on-disk.
if { $databases_in_memory } {
set testfile1 { "" m1$tnum.db }
set testfile2 { "" m2$tnum.db }
} else {
set testfile1 "m1$tnum.db"
set testfile2 "m2$tnum.db"
}
puts "\tRep$tnum.a: Create database using 1st master handle."
# Create a database using the 1st master.
set omethod [convert_method $method]
set db1 [eval {berkdb_open_noerr -env $masterenv1 -auto_commit \
-create -mode 0644} $largs $omethod $testfile1]
error_check_good dbopen [is_valid_db $db1] TRUE
puts "\tRep$tnum.b: Create database using 2nd master handle."
# Create a different database using the 2nd master.
set db2 [eval {berkdb_open_noerr -env $masterenv2 -auto_commit \
-create -mode 0644} $largs $omethod $testfile2]
error_check_good dbopen [is_valid_db $db2] TRUE
puts "\tRep$tnum.c: Process messages."
# Process messages.
process_msgs $envlist
# Check that databases are in-memory or on-disk as expected.
check_db_location $masterenv1 $testfile1
check_db_location $masterenv2 $testfile1
check_db_location $masterenv1 $testfile2
check_db_location $masterenv2 $testfile2
puts "\tRep$tnum.d: Run rep_test in 1st master; process messages."
eval rep_test $method $masterenv1 $db1 $niter 0 0 0 $largs
process_msgs $envlist
puts "\tRep$tnum.e: Run rep_test in 2nd master; process messages."
eval rep_test $method $masterenv2 $db2 $niter 0 0 0 $largs
process_msgs $envlist
# Contents of the two databases should match.
error_check_good db_compare [db_compare \
$db1 $db2 $masterdir/$testfile1 $masterdir/$testfile2] 0
puts "\tRep$tnum.f: Close 2nd master."
error_check_good db2 [$db2 close] 0
error_check_good master2_close [$masterenv2 close] 0
puts "\tRep$tnum.g: Run test in master again."
eval rep_test $method $masterenv1 $db1 $niter $niter 0 0 $largs
process_msgs $envlist
puts "\tRep$tnum.h: Closing"
error_check_good db1 [$db1 close] 0
error_check_good env0_close [$masterenv1 close] 0
error_check_good env2_close [$clientenv close] 0
replclose $testdir/MSGQUEUEDIR
return
}
|
