blob: fdea674239b9e6b51a62b1de757a0d7aa973141e (
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
|
# See the file LICENSE for redistribution information.
#
# Copyright (c)-2009 Oracle. All rights reserved.
#
# TEST repmgr029
# TEST Repmgr combined with replication-unaware process at master.
proc repmgr029 { } {
source ./include.tcl
set tnum "029"
puts "Repmgr$tnum: Replication-unaware process at master."
env_cleanup $testdir
set ports [available_ports 2]
foreach {mport cport} $ports {}
file mkdir [set mdir $testdir/MASTER]
file mkdir [set cdir $testdir/CLIENT]
puts "\tRepmgr$tnum.a: Set up simple master/client pair."
make_dbconfig $mdir [set dbconfig {{rep_set_nsites 3}}]
set cmds {
"home $mdir"
"local $mport"
"output $testdir/moutput"
"open_env"
"start master"
"open_db test.db"
"put k1 v1"
"put k2 v2"
}
set m [open_site_prog [subst $cmds]]
make_dbconfig $cdir $dbconfig
set cmds {
"home $cdir"
"local $cport"
"output $testdir/coutput"
"remote localhost $mport"
"open_env"
"start client"
}
set c [open_site_prog [subst $cmds]]
puts "\tRepmgr$tnum.b: Wait for client to finish start-up."
set cenv [berkdb_env -home $cdir]
await_startup_done $cenv
puts "\tRepmgr$tnum.c: Run checkpoint in a separate process."
exec $util_path/db_checkpoint -h $mdir -1
# Find out where the checkpoint record is.
#
set menv [berkdb_env -home $mdir]
set curs [$menv log_cursor]
set ckp_lsn1 [lindex [$curs get -last] 0]
puts "\tRepmgr$tnum.d: Write more log records at master."
puts $m "put k3 v3"
puts $m "put k4 v4"
puts $m "echo done"
gets $m
puts "\tRepmgr$tnum.e: Do another checkpoint."
exec $util_path/db_checkpoint -h $mdir -1
set ckp_lsn2 [lindex [$curs get -last] 0]
error_check_bad same_ckp_lsn $ckp_lsn2 $ckp_lsn1
# db_checkpoint could have produced perm failures, because it doesn't
# start repmgr explicitly. Instead repmgr starts up automatically, on
# the fly, by trapping the first transmitted log record that gets sent.
# This causes a connection to be initiated, but that may take some time,
# too much time for that first log record to be transmitted. This means
# the client will have to request retransmission of this log record
# "gap".
#
# So, pause for a moment, to let replication's gap measurement algorithm
# expire, and then send one more transaction from the master, so that
# the client is forced to request the gap if necessary.
#
set perm_failures "Acknowledgement failures"
set pfs1 [stat_field $menv repmgr_stat $perm_failures]
tclsleep 1
puts $m "put k5 v5"
puts $m "echo done"
gets $m
set pfs2 [stat_field $menv repmgr_stat $perm_failures]
# The last "put" operation shouldn't have resulted in any additional
# perm failures.
#
error_check_good perm_fail $pfs2 $pfs1
# Pause again to allow time for the request for retransmission to be
# fulfilled.
#
tclsleep 1
# At this point that both checkpoint operations should have been
# successfully replicated. Examine the client-side log at the expected
# LSNs.
#
puts "\tRepmgr$tnum.f: Examine client log."
foreach lsn [list $ckp_lsn1 $ckp_lsn2] {
set lsnarg [join $lsn /]
set listing [exec $util_path/db_printlog \
-h $cdir -b $lsnarg -e $lsnarg]
set first_line [lindex [split $listing "\n"] 0]
error_check_good found_ckp \
[string match "*__txn_ckp*" $first_line] 1
}
$curs close
$cenv close
$menv close
close $c
close $m
}
|
