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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2007, 2013 Oracle and/or its affiliates. All rights reserved.
#
# $Id$
#
# TEST rep080
# TEST AUTOINIT off with empty client logs.
# TEST
# TEST Verify that a fresh client trying to join the group for
# TEST the first time observes the setting of DELAY_SYNC and !AUTOINIT
# TEST properly.
# TEST
proc rep080 { method { niter 200 } { tnum "080" } args } {
source ./include.tcl
global mixed_mode_logging
global databases_in_memory
global repfiles_in_memory
global env_private
# Skip for all methods except btree.
if { $checking_valid_methods } {
return btree
}
if { [is_btree $method] == 0 } {
puts "Rep$tnum: skipping for non-btree method $method."
return
}
if { $mixed_mode_logging != 0 } {
puts "Rep$tnum: skipping for in-mem (or mixed) logging."
return
}
set args [convert_args $method $args]
# 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"
}
# The {"" "-recover"} loop that is typical in replication tests can be
# useful for tests which close existing environments at some point, and
# then later reopen them. (When we reopen, we do so either with
# recovery, or without it.) But this test never does that.
#
puts "Rep$tnum ($method):\
Test of AUTOINIT off with empty client logs $msg $msg2 $msg3."
rep080_sub $method $niter $tnum $args
}
proc rep080_sub { method niter tnum 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 clientdir1 $testdir/CLIENTDIR1
set clientdir2 $testdir/CLIENTDIR2
set clientdir3 $testdir/CLIENTDIR3
set clientdir4 $testdir/CLIENTDIR4
file mkdir $masterdir
file mkdir $clientdir1
file mkdir $clientdir2
file mkdir $clientdir3
file mkdir $clientdir4
# Open a master.
repladd 1
set ma_envcmd "berkdb_env_noerr -create $verbargs -errpfx MASTER \
$repmemargs $privargs \
-home $masterdir -txn -rep_transport \[list 1 replsend\]"
set masterenv [eval $ma_envcmd -rep_master]
set envlist "{$masterenv 1}"
# Run rep_test in the master.
puts "\tRep$tnum.a: Running rep_test in replicated env."
eval rep_test $method $masterenv NULL $niter 0 0 $largs
process_msgs $envlist
# Open a client
puts "\tRep$tnum.b: Add a normal client."
repladd 2
set cl_envcmd "berkdb_env_noerr -create $verbargs -errpfx CLIENT \
$repmemargs $privargs \
-home $clientdir1 -txn -rep_transport \[list 2 replsend\]"
set clientenv1 [eval $cl_envcmd -rep_client]
lappend envlist [list $clientenv1 2]
process_msgs $envlist
rep_verify $masterdir $masterenv $clientdir1 $clientenv1 0 1 1
# Open a client with AUTOINIT turned off.
#
puts "\tRep$tnum.c: Add a client with AUTOINIT off (should fail)."
repladd 3
set cl_envcmd "berkdb_env_noerr -create $verbargs -errpfx CLIENT \
$repmemargs $privargs \
-home $clientdir2 -txn -rep_transport \[list 3 replsend\]"
set clientenv2 [eval $cl_envcmd -rep_client]
$clientenv2 rep_config {autoinit off}
lappend envlist [list $clientenv2 3]
process_msgs $envlist 0 NONE error
error_check_good errchk [is_substr $error JOIN_FAILURE] 1
# Open a client with DELAY_SYNC
#
puts "\tRep$tnum.d: Add a client with DELAY_SYNC."
repladd 4
set cl_envcmd "berkdb_env_noerr -create $verbargs -errpfx CLIENT \
$repmemargs $privargs \
-home $clientdir3 -txn -rep_transport \[list 4 replsend\]"
set clientenv3 [eval $cl_envcmd -rep_client]
$clientenv3 rep_config {delayclient on}
lappend envlist [list $clientenv3 4]
process_msgs $envlist 0 NONE error
error_check_good errchk2 $error 0
error_check_bad expect_error [catch {rep_verify \
$masterdir $masterenv $clientdir3 $clientenv3 0 1 1}] 0
error_check_good rep_sync [$clientenv3 rep_sync] 0
process_msgs $envlist 0 NONE error
error_check_good errchk3 $error 0
rep_verify $masterdir $masterenv $clientdir3 $clientenv3
# Open a client with both DELAY_SYNC and AUTOINIT off.
#
puts "\tRep$tnum.f: Add a client with DELAY_SYNC and AUTOINIT off."
repladd 5
set cl_envcmd "berkdb_env_noerr -create $verbargs -errpfx CLIENT \
$repmemargs $privargs \
-home $clientdir4 -txn -rep_transport \[list 5 replsend\]"
set clientenv4 [eval $cl_envcmd -rep_client]
$clientenv4 rep_config {delayclient on}
$clientenv4 rep_config {autoinit off}
lappend envlist [list $clientenv4 5]
process_msgs $envlist 0 NONE error
error_check_good process_msgs $error 0
error_check_bad expect_error2 [catch {rep_verify\
$masterdir $masterenv $clientdir4 $clientenv4 0 1 1}] 0
error_check_bad rep_sync [catch {$clientenv4 rep_sync} result] 0
error_check_good errchk5 [is_substr $result JOIN_FAILURE] 1
$masterenv close
$clientenv1 close
$clientenv2 close
$clientenv3 close
$clientenv4 close
replclose $testdir/MSGQUEUEDIR
}
|
