blob: f69a8f0518cb7670e79cbf5cb9b5dec1c213d795 (
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
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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2004
# Sleepycat Software. All rights reserved.
#
# $Id: rep029.tcl,v 11.5 2004/10/04 18:15:14 sue Exp $
#
# TEST rep029
# TEST Test of internal initialization.
# TEST
# TEST One master, one client.
# TEST Generate several log files.
# TEST Remove old master log files.
# TEST Delete client files and restart client.
# TEST Put one more record to the master.
#
proc rep029 { method { niter 200 } { tnum "029" } args } {
global passwd
global has_crypto
set args [convert_args $method $args]
set saved_args $args
# This test needs to set its own pagesize.
set pgindex [lsearch -exact $args "-pagesize"]
if { $pgindex != -1 } {
puts "Rep$tnum: skipping for specific pagesizes"
return
}
# Run the body of the test with and without recovery,
# and with and without cleaning.
set recopts { "" " -recover " }
set cleanopts { clean noclean }
foreach r $recopts {
foreach c $cleanopts {
set envargs ""
set args $saved_args
puts "Rep$tnum ($method $envargs $c $r $args):\
Test of internal initialization."
rep029_sub $method $niter $tnum $envargs \
$r $c $args
if { $has_crypto == 0 } {
continue
}
# Run same set of tests with security.
#
append envargs " -encryptaes $passwd "
append args " -encrypt "
puts "Rep$tnum ($method $envargs $r $args):\
Test of internal initialization."
rep029_sub $method $niter $tnum $envargs \
$r $c $args
}
}
}
proc rep029_sub { method niter tnum envargs recargs clean largs } {
global testdir
global passwd
global util_path
env_cleanup $testdir
replsetup $testdir/MSGQUEUEDIR
set masterdir $testdir/MASTERDIR
set clientdir $testdir/CLIENTDIR
file mkdir $masterdir
file mkdir $clientdir
# Log size is small so we quickly create more than one.
# The documentation says that the log file must be at least
# four times the size of the in-memory log buffer.
set pagesize 4096
append largs " -pagesize $pagesize "
set log_buf [expr $pagesize * 2]
set log_max [expr $log_buf * 4]
# Open a master.
repladd 1
set ma_envcmd "berkdb_env_noerr -create -txn nosync \
-log_buffer $log_buf -log_max $log_max $envargs \
-home $masterdir -rep_transport \[list 1 replsend\]"
# set ma_envcmd "berkdb_env_noerr -create -txn nosync \
# -log_buffer $log_buf -log_max $log_max $envargs \
# -verbose {rep on} -errpfx MASTER \
# -home $masterdir -rep_transport \[list 1 replsend\]"
set masterenv [eval $ma_envcmd $recargs -rep_master]
error_check_good master_env [is_valid_env $masterenv] TRUE
# Open a client
repladd 2
set cl_envcmd "berkdb_env_noerr -create -txn nosync \
-log_buffer $log_buf -log_max $log_max $envargs \
-home $clientdir -rep_transport \[list 2 replsend\]"
# set cl_envcmd "berkdb_env_noerr -create -txn nosync \
# -log_buffer $log_buf -log_max $log_max $envargs \
# -verbose {rep on} -errpfx CLIENT \
# -home $clientdir -rep_transport \[list 2 replsend\]"
set clientenv [eval $cl_envcmd $recargs -rep_client]
error_check_good client_env [is_valid_env $clientenv] TRUE
# Bring the clients online by processing the startup messages.
set envlist "{$masterenv 1} {$clientenv 2}"
process_msgs $envlist
# Run rep_test in the master (and update client).
puts "\tRep$tnum.a: Running rep_test in replicated env."
eval rep_test $method $masterenv NULL $niter 0 0 0 $largs
process_msgs $envlist
puts "\tRep$tnum.b: Close client."
error_check_good client_close [$clientenv close] 0
if { [lsearch $envargs "-encrypta*"] !=-1 } {
set enc "-P $passwd"
} else {
set enc ""
}
# Run rep_test in the master (don't update client).
puts "\tRep$tnum.c: Running rep_test in replicated env."
eval rep_test $method $masterenv NULL $niter 0 0 0 $largs
replclear 2
puts "\tRep$tnum.d: Run db_archive on master."
set res [eval exec $util_path/db_archive $enc -l -h $masterdir]
error_check_bad log.1.present [lsearch -exact $res log.0000000001] -1
set res [eval exec $util_path/db_archive $enc -d -h $masterdir]
set res [eval exec $util_path/db_archive $enc -l -h $masterdir]
error_check_good log.1.gone [lsearch -exact $res log.0000000001] -1
puts "\tRep$tnum.e: Reopen client ($clean)."
if { $clean == "clean" } {
env_cleanup $clientdir
}
set clientenv [eval $cl_envcmd $recargs -rep_client]
error_check_good client_env [is_valid_env $clientenv] TRUE
set envlist "{$masterenv 1} {$clientenv 2}"
process_msgs $envlist 0 NONE err
if { $clean == "noclean" } {
puts "\tRep$tnum.e.1: Trigger log request"
#
# When we don't clean, starting the client doesn't
# trigger any events. We need to generate some log
# records so that the client requests the missing
# logs and that will trigger it.
#
set entries 10
eval rep_test $method $masterenv NULL $entries $niter 0 0 $largs
process_msgs $envlist 0 NONE err
}
puts "\tRep$tnum.f: Verify logs and databases"
# Check that master and client logs and dbs are identical.
# Logs first ...
set stat [catch {eval exec $util_path/db_printlog $enc \
-h $masterdir > $masterdir/prlog} result]
error_check_good stat_mprlog $stat 0
set stat [catch {eval exec $util_path/db_printlog $enc \
-h $clientdir > $clientdir/prlog} result]
error_check_good stat_cprlog $stat 0
error_check_good log_cmp \
[filecmp $masterdir/prlog $clientdir/prlog] 0
# ... now the databases.
set dbname "test.db"
set db1 [eval {berkdb_open -env $masterenv} $largs {-rdonly $dbname}]
set db2 [eval {berkdb_open -env $clientenv} $largs {-rdonly $dbname}]
error_check_good comparedbs [db_compare \
$db1 $db2 $masterdir/$dbname $clientdir/$dbname] 0
error_check_good db1_close [$db1 close] 0
error_check_good db2_close [$db2 close] 0
# Add records to the master and update client.
puts "\tRep$tnum.g: Add more records and check again."
set entries 10
eval rep_test $method $masterenv NULL $entries $niter 0 0 $largs
process_msgs $envlist 0 NONE err
# Check again that master and client logs and dbs are identical.
set stat [catch {eval exec $util_path/db_printlog $enc \
-h $masterdir > $masterdir/prlog} result]
error_check_good stat_mprlog $stat 0
set stat [catch {eval exec $util_path/db_printlog $enc \
-h $clientdir > $clientdir/prlog} result]
error_check_good stat_cprlog $stat 0
error_check_good log_cmp \
[filecmp $masterdir/prlog $clientdir/prlog] 0
set db1 [eval {berkdb_open -env $masterenv} $largs {-rdonly $dbname}]
set db2 [eval {berkdb_open -env $clientenv} $largs {-rdonly $dbname}]
error_check_good comparedbs [db_compare \
$db1 $db2 $masterdir/$dbname $clientdir/$dbname] 0
error_check_good db1_close [$db1 close] 0
error_check_good db2_close [$db2 close] 0
error_check_good masterenv_close [$masterenv close] 0
error_check_good clientenv_close [$clientenv close] 0
replclose $testdir/MSGQUEUEDIR
}
|
