proc rep005 { method { niter 10 } { tnum "05" } args } {
source ./include.tcl
if { [is_record_based $method] == 1 } {
puts "Rep005: Skipping for method $method."
return
}
set nclients 3
env_cleanup $testdir
set qdir $testdir/MSGQUEUEDIR
replsetup $qdir
set masterdir $testdir/MASTERDIR
file mkdir $masterdir
for { set i 0 } { $i < $nclients } { incr i } {
set clientdir($i) $testdir/CLIENTDIR.$i
file mkdir $clientdir($i)
}
puts "Rep0$tnum: Replication election test with $nclients clients."
repladd 1
set env_cmd(M) "berkdb_env -create -log_max 1000000 -home \
$masterdir -txn -rep_master -rep_transport \[list 1 replsend\]"
set masterenv [eval $env_cmd(M)]
error_check_good master_env [is_valid_env $masterenv] TRUE
for { set i 0 } { $i < $nclients } { incr i } {
set envid [expr $i + 2]
repladd $envid
set env_cmd($i) "berkdb_env -create -home $clientdir($i) \
-txn -rep_client -rep_transport \[list $envid replsend\]"
set clientenv($i) [eval $env_cmd($i)]
error_check_good \
client_env($i) [is_valid_env $clientenv($i)] TRUE
}
puts "\tRep0$tnum.a: Running test001 in replicated env."
eval test001 $method $niter 0 $tnum 0 -env $masterenv $args
while { 1 } {
set nproced 0
incr nproced [replprocessqueue $masterenv 1]
for { set i 0 } { $i < $nclients } { incr i } {
set envid [expr $i + 2]
incr nproced [replprocessqueue $clientenv($i) $envid]
}
if { $nproced == 0 } {
break
}
}
for { set i 0 } { $i < $nclients } { incr i } {
puts "\tRep0$tnum.b: Verifying contents of client database $i."
set testdir [get_home $masterenv]
set t1 $testdir/t1
set t2 $testdir/t2
set t3 $testdir/t3
open_and_dump_file test0$tnum.db $clientenv($i) $testdir/t1 \
test001.check dump_file_direction "-first" "-next"
if { [string compare [convert_method $method] -recno] != 0 } {
filesort $t1 $t3
}
error_check_good diff_files($t2,$t3) [filecmp $t2 $t3] 0
verify_dir $clientdir($i) "\tRep0$tnum.c: " 0 0 1
}
error_check_good master_flush [$masterenv rep_flush] 0
while { 1 } {
set nproced 0
incr nproced [replprocessqueue $masterenv 1 0]
for { set i 0 } { $i < $nclients } { incr i } {
incr nproced [replprocessqueue $clientenv($i) \
[expr $i + 2] 0]
}
if { $nproced == 0 } {
break
}
}
error_check_good masterenv_close [$masterenv close] 0
for { set i 0 } { $i < $nclients } { incr i } {
replclear [expr $i + 2]
}
set m "Rep0$tnum"
set count 0
foreach c0 { electinit electsend electvote1 electwait1 electvote2 \
electwait2 } {
foreach c1 { electinit electvote1 electwait1 electvote2 \
electwait2 } {
foreach c2 { electinit electvote1 electwait1 \
electvote2 electwait2 } {
set elist [list $c0 $c1 $c2]
rep005_elect env_cmd clientenv $qdir $m \
$count $elist
incr count
}
}
}
for { set i 0 } { $i < $nclients } { incr i } {
error_check_good clientenv_close($i) [$clientenv($i) close] 0
}
replclose $testdir/MSGQUEUEDIR
}
proc rep005_elect { ecmd cenv qdir msg count elist } {
global elect_timeout
upvar $ecmd env_cmd
upvar $cenv clientenv
set elect_timeout 1000000
set nclients [llength $elist]
for { set i 0 } { $i < $nclients } { incr i } {
set err_cmd($i) [lindex $elist $i]
}
puts "\t$msg.d.$count: Starting election with errors $elist"
set elect_pipe(0) [start_election $qdir $env_cmd(0) \
[expr $nclients + 1] 20 $elect_timeout $err_cmd(0)]
tclsleep 1
set got_newmaster 0
set tries 10
while { 1 } {
set nproced 0
set he 0
set nm 0
for { set i 0 } { $i < $nclients } { incr i } {
set he 0
set envid [expr $i + 2]
incr nproced \
[replprocessqueue $clientenv($i) $envid 0 he nm]
if { $he == 1 } {
if { $i == 1 } {
set pri 100
} else {
set pri 10
}
set elect_pipe($i) [start_election $qdir \
$env_cmd($i) [expr $nclients + 1] $pri \
$elect_timeout $err_cmd($i)]
set got_hold_elect($i) 1
}
if { $nm != 0 } {
error_check_good newmaster_is_master $nm \
[expr 1 + 2]
set got_newmaster $nm
if { $nm == $envid } {
error_check_good make_master($i) \
[$clientenv($i) rep_start -master] \
0
}
}
}
if { $nproced == 0 } {
incr tries -1
if { $tries == 0 } {
break
} else {
tclsleep 1
}
}
}
error_check_good "client 1 wins" $got_newmaster [expr 1 + 2]
cleanup_elections
}