blob: d43d531ae3a940fdc865ab11fcda53fd113ed03f (
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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2001-2006
# Oracle Corporation. All rights reserved.
#
# $Id: rep008.tcl,v 12.9 2006/08/24 14:46:37 bostic Exp $
#
# TEST rep008
# TEST Replication, back up and synchronizing
# TEST
# TEST Run a modified version of test001 in a replicated master
# TEST environment.
# TEST Close master and client.
# TEST Copy the master log to the client.
# TEST Clean the master.
# TEST Reopen the master and client.
proc rep008 { method { niter 10 } { tnum "008" } args } {
source ./include.tcl
if { $is_windows9x_test == 1 } {
puts "Skipping replication test on Win 9x platform."
return
}
# Run for btree only.
if { $checking_valid_methods } {
set test_methods { btree }
return $test_methods
}
if { [is_btree $method] == 0 } {
puts "Rep$tnum: Skipping for method $method."
return
}
# This test depends on copying logs, so can't be run with
# in-memory logging.
global mixed_mode_logging
if { $mixed_mode_logging > 0 } {
puts "Rep$tnum: Skipping for mixed-mode logging."
return
}
set args [convert_args $method $args]
# Run the body of the test with and without recovery.
foreach r $test_recopts {
puts "Rep$tnum ($method $r):\
Replication backup and synchronizing."
rep008_sub $method $niter $tnum $r $args
}
}
proc rep008_sub { method niter tnum recargs largs } {
global testdir
global util_path
env_cleanup $testdir
replsetup $testdir/MSGQUEUEDIR
set masterdir $testdir/MASTERDIR
set clientdir $testdir/CLIENTDIR
file mkdir $masterdir
file mkdir $clientdir
# Open a master.
repladd 1
set ma_envcmd "berkdb_env_noerr -create -txn nosync \
-home $masterdir -rep_transport \[list 1 replsend\]"
# set ma_envcmd "berkdb_env_noerr -create -txn nosync \
# -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 \
-home $clientdir -rep_transport \[list 2 replsend\]"
# set cl_envcmd "berkdb_env_noerr -create -txn nosync \
# -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 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: Close client and master. Copy logs."
error_check_good client_close [$clientenv close] 0
error_check_good master_close [$masterenv close] 0
file copy -force $masterdir/log.0000000001 $testdir/log.save
puts "\tRep$tnum.c: Clean master and reopen"
#
# Add sleep calls to ensure master's new log doesn't match
# its old one in the ckp timestamp.
#
tclsleep 1
env_cleanup $masterdir
tclsleep 1
env_cleanup $clientdir
file copy -force $testdir/log.save $clientdir/log.0000000001
set masterenv [eval $ma_envcmd $recargs -rep_master]
error_check_good master_env [is_valid_env $masterenv] TRUE
set clientenv [eval $cl_envcmd $recargs -rep_client]
error_check_good client_env [is_valid_env $clientenv] TRUE
#
# Process the messages to get them out of the db.
#
set envlist "{$masterenv 1} {$clientenv 2}"
process_msgs $envlist 0 NONE err
error_check_bad err $err 0
error_check_good errchk [is_substr $err "Client was never part"] 1
error_check_good masterenv_close [$masterenv close] 0
error_check_good clientenv_close [$clientenv close] 0
replclose $testdir/MSGQUEUEDIR
}
|
