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) 2007-2009 Oracle. All rights reserved.
#
# $Id$
#
# TEST repmgr018
# TEST Check repmgr stats.
# TEST
# TEST Start an appointed master and one client. Shut down the client,
# TEST run some transactions at the master and verify that there are
# TEST acknowledgement failures and one dropped connection. Shut down
# TEST and restart client again and verify that there are two dropped
# TEST connections.
# TEST
# TEST Run for btree only because access method shouldn't matter.
# TEST
proc repmgr018 { method { niter 20 } { tnum "018" } args } {
source ./include.tcl
if { $is_freebsd_test == 1 } {
puts "Skipping replication manager test on FreeBSD platform."
return
}
if { $is_windows9x_test == 1 } {
puts "Skipping replication test on Win9x platform."
return
}
# Skip for all methods except btree.
if { $checking_valid_methods } {
return btree
}
if { [is_btree $method] == 0 } {
puts "Repmgr$tnum: skipping for non-btree method $method."
return
}
set args [convert_args $method $args]
puts "Repmgr$tnum ($method): Test of repmgr stats."
repmgr018_sub $method $niter $tnum $args
}
proc repmgr018_sub { method niter tnum largs } {
global testdir
global rep_verbose
global verbose_type
set nsites 2
set verbargs ""
if { $rep_verbose == 1 } {
set verbargs " -verbose {$verbose_type on} "
}
env_cleanup $testdir
set ports [available_ports $nsites]
set masterdir $testdir/MASTERDIR
set clientdir $testdir/CLIENTDIR
file mkdir $masterdir
file mkdir $clientdir
# Use different connection retry timeout values to handle any
# collisions from starting sites at the same time by retrying
# at different times.
# Open a master.
puts "\tRepmgr$tnum.a: Start a master."
set ma_envcmd "berkdb_env_noerr -create $verbargs -errpfx MASTER \
-home $masterdir -txn -rep -thread"
set masterenv [eval $ma_envcmd]
$masterenv repmgr -ack all -nsites $nsites \
-timeout {conn_retry 20000000} \
-local [list localhost [lindex $ports 0]] \
-start master
# Open a client
puts "\tRepmgr$tnum.b: Start a client."
set cl_envcmd "berkdb_env_noerr -create $verbargs -errpfx CLIENT \
-home $clientdir -txn -rep -thread"
set clientenv [eval $cl_envcmd]
$clientenv repmgr -ack all -nsites $nsites \
-timeout {conn_retry 10000000} \
-local [list localhost [lindex $ports 1]] \
-remote [list localhost [lindex $ports 0]] \
-start client
await_startup_done $clientenv
puts "\tRepmgr$tnum.c: Run some transactions at master."
eval rep_test $method $masterenv NULL $niter 0 0 0 $largs
error_check_good perm_no_failed_stat \
[stat_field $masterenv repmgr_stat "Acknowledgement failures"] 0
error_check_good no_connections_dropped \
[stat_field $masterenv repmgr_stat "Connections dropped"] 0
$clientenv close
# Just do a few transactions (i.e., 3 of them), because each one is
# expected to time out, and if we did many the test would take a long
# time (with no benefit).
#
puts "\tRepmgr$tnum.d: Run transactions with no client."
eval rep_test $method $masterenv NULL 3 $niter $niter 0 $largs
error_check_bad perm_failed_stat \
[stat_field $masterenv repmgr_stat "Acknowledgement failures"] 0
# Wait up to 20 seconds when testing for dropped connections. This
# corresponds to the master connection_retry timeout.
set max_wait 20
await_condition {[stat_field $masterenv repmgr_stat \
"Connections dropped"] == 1} $max_wait
# Bring the client back up, and down, a couple times, to test resetting
# of stats.
#
puts "\tRepmgr$tnum.e: Shut down client (pause), check dropped connection."
# Open -recover to clear env region, including startup_done value.
set clientenv [eval $cl_envcmd -recover]
$clientenv repmgr -ack all -nsites $nsites \
-timeout {conn_retry 10000000} \
-local [list localhost [lindex $ports 1]] \
-remote [list localhost [lindex $ports 0]] \
-start client
await_startup_done $clientenv
$clientenv close
await_condition {[stat_field $masterenv repmgr_stat \
"Connections dropped"] == 2} $max_wait
$masterenv repmgr_stat -clear
puts "\tRepmgr$tnum.f: Shut down, pause, check dropped connection (reset)."
# Open -recover to clear env region, including startup_done value.
set clientenv [eval $cl_envcmd -recover]
$clientenv repmgr -ack all -nsites $nsites \
-timeout {conn_retry 10000000} \
-local [list localhost [lindex $ports 1]] \
-remote [list localhost [lindex $ports 0]] \
-start client
await_startup_done $clientenv
$clientenv close
await_condition {[stat_field $masterenv repmgr_stat \
"Connections dropped"] == 1} $max_wait
error_check_good masterenv_close [$masterenv close] 0
}
|
