blob: 7b6fcc0f30435209b4d1ce4f597fee4ac4e783f5 (
plain)
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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2004,2007 Oracle. All rights reserved.
#
# $Id: rep023.tcl,v 12.14 2007/05/17 18:17:21 bostic Exp $
#
# 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
if { $is_windows9x_test == 1 } {
puts "Skipping replication test on Win 9x platform."
return
}
# 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]
# 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 msg "with rep_start"
} else {
set msg ""
}
puts "Rep$tnum ($method $r $msg):\
Replication and openfiles."
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 rep_verbose
set verbargs ""
if { $rep_verbose == 1 } {
set verbargs " -verbose {rep on} "
}
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 \
-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 \
$c_logargs $verbargs -errpfx CLIENT -home $clientdir \
-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
puts "\tRep$tnum.a: Create database using 1st master handle."
# Create a database using the 1st master.
set testfile1 "m1$tnum.db"
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 testfile2 "m2$tnum.db"
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
puts "\tRep$tnum.d: Run rep_test in 1st master; process messages."
eval rep_test $method $masterenv1 $db1 $niter 0 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 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 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
}
|
