blob: 77293cdbaaec363f866959a771cd522089ec70a9 (
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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c) 2004
# Sleepycat Software. All rights reserved.
#
# $Id: rep032.tcl,v 1.3 2004/09/22 18:01:06 bostic Exp $
#
# TEST rep032
# TEST Test of log gap processing.
# TEST
# TEST One master, one clients.
# TEST Run rep_test.
# TEST Run rep_test without sending messages to client.
# TEST Make sure client missing the messages catches up properly.
#
proc rep032 { method { niter 200 } { tnum "032" } args } {
set args [convert_args $method $args]
set logsets [create_logsets 2]
# Run the body of the test with and without recovery.
set recopts { "" "-recover" }
foreach r $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
}
puts "Rep$tnum ($method $r $args):\
Test of log gap processing."
puts "Rep$tnum: Master logs are [lindex $l 0]"
puts "Rep$tnum: Client logs are [lindex $l 1]"
rep032_sub $method $niter $tnum $l $r $args
}
}
}
proc rep032_sub { method niter tnum logset 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
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 a master.
repladd 1
set ma_envcmd "berkdb_env_noerr -create $m_txnargs $m_logargs \
-home $masterdir -rep_transport \[list 1 replsend\]"
# set ma_envcmd "berkdb_env_noerr -create $m_txnargs $m_logargs \
# -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 $c_txnargs $c_logargs \
-home $clientdir -rep_transport \[list 2 replsend\]"
# set cl_envcmd "berkdb_env_noerr -create $c_txnargs $c_logargs \
# -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: Check client processed everything properly."
set queued [stat_field $clientenv rep_stat "Maximum log records queued"]
set request [stat_field $clientenv rep_stat "Log records requested"]
error_check_good queued $queued 0
error_check_good request $request 0
# Run rep_test in the master (don't update client).
# First run with dropping all client messages via replclear.
puts "\tRep$tnum.c: Running rep_test dropping client msgs."
eval rep_test $method $masterenv NULL $niter 0 0 0 $largs
replclear 2
process_msgs $envlist
#
# Need new operations to force log gap processing to
# request missing pieces.
#
puts "\tRep$tnum.d: Running rep_test again replicated."
eval rep_test $method $masterenv NULL $niter 0 0 0 $largs
process_msgs $envlist
puts "\tRep$tnum.e: Check we re-requested and had a backlog."
set queued [stat_field $clientenv rep_stat "Maximum log records queued"]
set request [stat_field $clientenv rep_stat "Log records requested"]
error_check_bad queued $queued 0
error_check_bad request $request 0
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 \
-h $masterdir > $masterdir/prlog} result]
error_check_good stat_mprlog $stat 0
set stat [catch {eval exec $util_path/db_printlog \
-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
error_check_good masterenv_close [$masterenv close] 0
error_check_good clientenv_close [$clientenv close] 0
replclose $testdir/MSGQUEUEDIR
}
|
