proc rep005 { method args } {
source ./include.tcl
if { $is_windows9x_test == 1 } {
puts "Skipping replication test on Win 9x platform."
return
}
if { $checking_valid_methods } {
set test_methods { btree }
return $test_methods
}
if { [is_btree $method] == 0 } {
puts "Rep005: Skipping for method $method."
return
}
set tnum "005"
set niter 10
set nclients 3
set logsets [create_logsets [expr $nclients + 1]]
set recargs ""
foreach l $logsets {
puts "Rep$tnum ($recargs): Replication election\
error test with $nclients clients."
puts -nonewline "Rep$tnum: Started at: "
puts [clock format [clock seconds] -format "%H:%M %D"]
puts "Rep$tnum: Master logs are [lindex $l 0]"
for { set i 0 } { $i < $nclients } { incr i } {
puts "Rep$tnum: Client $i logs are\
[lindex $l [expr $i + 1]]"
}
rep005_sub $method $tnum \
$niter $nclients $l $recargs $args
}
}
proc rep005_sub { method tnum niter nclients logset recargs largs } {
source ./include.tcl
global rand_init
error_check_good set_random_seed [berkdb srand $rand_init] 0
global rep_verbose
set verbargs ""
if { $rep_verbose == 1 } {
set verbargs " -verbose {rep on} "
}
env_cleanup $testdir
set qdir $testdir/MSGQUEUEDIR
replsetup $qdir
set masterdir $testdir/MASTERDIR
file mkdir $masterdir
set m_logtype [lindex $logset 0]
set m_logargs [adjust_logargs $m_logtype]
set m_txnargs [adjust_txnargs $m_logtype]
for { set i 0 } { $i < $nclients } { incr i } {
set clientdir($i) $testdir/CLIENTDIR.$i
file mkdir $clientdir($i)
set c_logtype($i) [lindex $logset [expr $i + 1]]
set c_logargs($i) [adjust_logargs $c_logtype($i)]
set c_txnargs($i) [adjust_txnargs $c_logtype($i)]
}
repladd 1
set env_cmd(M) "berkdb_env_noerr -create -log_max 1000000 \
-event rep_event \
-home $masterdir $m_logargs -errpfx MASTER $verbargs \
$m_txnargs -rep_master -rep_transport \[list 1 replsend\]"
set masterenv [eval $env_cmd(M) $recargs]
set envlist {}
lappend envlist "$masterenv 1"
for { set i 0 } { $i < $nclients } { incr i } {
set envid [expr $i + 2]
repladd $envid
set env_cmd($i) "berkdb_env_noerr -create \
-event rep_event \
-home $clientdir($i) $c_logargs($i) \
$c_txnargs($i) -rep_client $verbargs \
-errpfx CLIENT$i \
-rep_transport \[list $envid replsend\]"
set clientenv($i) [eval $env_cmd($i) $recargs]
lappend envlist "$clientenv($i) $envid"
}
process_msgs $envlist
puts "\tRep$tnum.a: Running test001 in replicated env."
eval rep_test $method $masterenv NULL $niter 0 0 0 0 $largs
process_msgs $envlist
error_check_good masterenv_close [$masterenv close] 0
set envlist [lreplace $envlist 0 0]
for { set i 0 } { $i < $nclients } { incr i } {
replclear [expr $i + 2]
}
set m "Rep$tnum"
set count 0
set win -1
set c0err { none electinit none }
set c1err $c0err
set c2err $c0err
set numtests [expr [llength $c0err] * [llength $c1err] * \
[llength $c2err]]
puts "\t$m.b: Starting $numtests election with error tests"
set last_win -1
set win -1
foreach c0 $c0err {
foreach c1 $c1err {
foreach c2 $c2err {
set elist [list $c0 $c1 $c2]
rep005_elect env_cmd envlist $qdir \
$m $count win last_win $elist $logset
incr count
}
}
}
foreach pair $envlist {
set cenv [lindex $pair 0]
error_check_good cenv_close [$cenv close] 0
}
replclose $testdir/MSGQUEUEDIR
puts -nonewline \
"Rep$tnum: Completed at: "
puts [clock format [clock seconds] -format "%H:%M %D"]
}
proc rep005_elect { ecmd celist qdir msg count \
winner lsn_lose elist logset} {
global elect_timeout elect_serial
global timeout_ok
upvar $ecmd env_cmd
upvar $celist envlist
upvar $winner win
upvar $lsn_lose last_win
if { [info exists timeout_ok] == 0 } {
set timeout_ok 0
}
set nclients [llength $elist]
set nsites [expr $nclients + 1]
set cl_list {}
foreach pair $envlist {
set id [lindex $pair 1]
set i [expr $id - 2]
set clientenv($i) [lindex $pair 0]
set err_cmd($i) [lindex $elist $i]
set elect_pipe($i) INVALID
replclear $id
lappend cl_list $i
}
set el 0
if { $win == -1 } {
if { $last_win != -1 } {
set cl_list [lreplace $cl_list $last_win $last_win]
set el $last_win
}
set windex [berkdb random_int 0 [expr [llength $cl_list] - 1]]
set win [lindex $cl_list $windex]
} else {
if {$win == 0} {
set el 1
}
}
for { set i 0 } { $i < $nclients } { incr i } {
set crash($i) 0
if { $i == $win } {
set pri($i) 100
} elseif { $i == $last_win } {
set pri($i) 200
} else {
set pri($i) 10
}
}
puts "\t$msg.b.$count: Start election (win=client$win) $elist"
set msg $msg.c.$count
set nsites $nclients
set nvotes $nsites
run_election env_cmd envlist err_cmd pri crash \
$qdir $msg $el $nsites $nvotes $nclients $win \
0 "test.db" 0 $timeout_ok
set close_list { 0 0 0 1 1 1 1 1 1 1}
set close_len [expr [llength $close_list] - 1]
set close_index [berkdb random_int 0 $close_len]
set timeout_ok 1
if { [lindex $close_list $close_index] == 1 } {
set timeout_ok 0
puts -nonewline "\t\t$msg: Closing "
error_check_good log_flush [$clientenv($win) log_flush] 0
error_check_good newmaster_close [$clientenv($win) close] 0
set lsn_win { 0 0 0 0 1 1 1 1 1 1 }
set lsn_len [expr [llength $lsn_win] - 1]
set lsn_index [berkdb random_int 0 $lsn_len]
set rec_arg ""
set win_inmem [expr [string compare [lindex $logset \
[expr $win + 1]] in-memory] == 0]
if { [lindex $lsn_win $lsn_index] == 1 } {
set last_win $win
set dirindex [lsearch -exact $env_cmd($win) "-home"]
incr dirindex
set lsn_dir [lindex $env_cmd($win) $dirindex]
env_cleanup $lsn_dir
puts -nonewline "and cleaning "
} else {
set rec_win { 0 0 0 0 0 0 1 1 1 1 }
set rec_len [expr [llength $rec_win] - 1]
set rec_index [berkdb random_int 0 $rec_len]
if { [lindex $rec_win $rec_index] == 1 } {
puts -nonewline "and recovering "
set rec_arg "-recover"
if { $win_inmem } {
set last_win $win
} else {
set last_win -1
}
} else {
set last_win -1
}
}
puts "new master, new client $win"
set clientenv($win) [eval $env_cmd($win) $rec_arg]
error_check_good cl($win) [is_valid_env $clientenv($win)] TRUE
set newel "$clientenv($win) [expr $win + 2]"
set envlist [lreplace $envlist $win $win $newel]
if { $rec_arg == "" || $win_inmem } {
set win -1
}
process_msgs $envlist
}
}