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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2001, 2013 Oracle and/or its affiliates. All rights reserved.
#
# $Id$
#
# 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
global mixed_mode_logging
global repfiles_in_memory
global env_private
# 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.
if { $mixed_mode_logging > 0 } {
puts "Rep$tnum: Skipping for mixed-mode logging."
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 "and private env"
}
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 $msg2 $msg3."
rep008_sub $method $niter $tnum $r $args
}
}
proc rep008_sub { method niter tnum recargs largs } {
global testdir
global util_path
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
# Open a master.
repladd 1
set ma_envcmd "berkdb_env_noerr -create -txn nosync $verbargs \
-home $masterdir -errpfx MASTER $repmemargs $privargs \
-rep_transport \[list 1 replsend\]"
set masterenv [eval $ma_envcmd $recargs -rep_master]
# Open a client
repladd 2
set cl_envcmd "berkdb_env_noerr -create -txn nosync $verbargs \
-home $clientdir -errpfx CLIENT $repmemargs $privargs \
-rep_transport \[list 2 replsend\]"
set clientenv [eval $cl_envcmd $recargs -rep_client]
# 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
#
# We'll only catch this error if we turn off autoinit.
# Otherwise, the system will throw away everything on the
# client and resync.
#
$clientenv rep_config {autoinit off}
# 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 "DB_REP_JOIN_FAILURE"] 1
error_check_good masterenv_close [$masterenv close] 0
error_check_good clientenv_close [$clientenv close] 0
replclose $testdir/MSGQUEUEDIR
}
|
