proc rep044 { method { tnum "044" } args } {
source ./include.tcl
if { $is_windows9x_test == 1 } {
puts "Skipping replication test on Win 9x platform."
return
}
if { $checking_valid_methods } {
return "ALL"
}
set args [convert_args $method $args]
set logsets [create_logsets 2]
if { $is_hp_test == 1 } {
puts "Skipping rep$tnum for HP-UX."
return
}
foreach l $logsets {
set logindex [lsearch -exact $l "in-memory"]
puts "Rep$tnum ($method): Replication with rollbacks\
and open file ids."
puts "Rep$tnum: Master logs are [lindex $l 0]"
puts "Rep$tnum: Client 0 logs are [lindex $l 1]"
rep044_sub $method $tnum $l $args
}
}
proc rep044_sub { method tnum logset largs } {
source ./include.tcl
set orig_tdir $testdir
global rep_verbose
global verbose_type
set verbargs ""
if { $rep_verbose == 1 } {
set verbargs " -verbose {$verbose_type on} "
}
set masterdir $testdir/ENV0
set clientdir $testdir/ENV1
set m_logtype [lindex $logset 0]
set c_logtype [lindex $logset 1]
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]
set niter 20
set omethod [convert_method $method]
set optionsets {
{1 1 1}
{1 1 0}
{1 0 1}
{1 0 0}
{0 1 1}
{0 1 0}
{0 0 1}
{0 0 0}
}
foreach set $optionsets {
env_cleanup $testdir
replsetup $testdir/MSGQUEUEDIR
file mkdir $masterdir
file mkdir $clientdir
set processopens [lindex $set 0]
set processwrites [lindex $set 1]
set processcloses [lindex $set 2]
set notdoing {}
if { $processopens == 0 } {
append notdoing " OPENS"
}
if { $processwrites == 0 } {
append notdoing " WRITES"
}
if { $processcloses == 0 } {
append notdoing " CLOSES"
}
if { $notdoing != {} } {
puts "Rep$tnum:\
Loop with $notdoing not processed to client."
}
repladd 1
set envcmd(M0) "berkdb_env_noerr -create $m_txnargs \
$m_logargs -lock_detect default \
-errpfx ENV.M0 $verbargs \
-home $masterdir -rep_transport \[list 1 replsend\]"
set menv0 [eval $envcmd(M0) -rep_master]
set envcmd(M1) "berkdb_env_noerr $m_txnargs \
$m_logargs -lock_detect default \
-errpfx ENV.M1 $verbargs \
-home $masterdir -rep_transport \[list 1 replsend\]"
set menv1 [eval $envcmd(M1)]
error_check_good rep_start [$menv1 rep_start -master] 0
repladd 2
set envcmd(C) "berkdb_env_noerr -create $c_txnargs \
$c_logargs -errpfx ENV.C $verbargs \
-lock_detect default \
-home $clientdir -rep_transport \[list 2 replsend\]"
set cenv [eval $envcmd(C) -rep_client]
set envlist "{$menv0 1} {$cenv 2}"
process_msgs $envlist
puts "\tRep$tnum.a: Run rep_test in 1st master env."
set start 0
eval rep_test $method $menv0 NULL $niter $start $start 0 0 $largs
incr start $niter
process_msgs $envlist
puts "\tRep$tnum.b: Open db in 2nd master env."
set db1 [eval {berkdb_open_noerr -env $menv1 -auto_commit \
-mode 0644} $largs $omethod test.db]
error_check_good dbopen [is_valid_db $db1] TRUE
if { $processopens == 1 } {
puts "\tRep$tnum.b1:\
Process db open messages to client."
process_msgs $envlist
} else {
set start [do_switch $method $niter $start $menv0 $cenv $largs]
}
puts "\tRep$tnum.c: Write to database in 2nd master."
for { set i 1 } { $i <= $niter } { incr i } {
set t [$menv1 txn]
set key $i
set str STRING.$i
if [catch {eval {$db1 put}\
-txn $t {$key [chop_data $method $str]}} result] {
error_check_good handle_dead \
[is_substr $result HANDLE_DEAD] 1
error_check_good txn_abort [$t abort] 0
error_check_good close_handle [$db1 close] 0
set db1 [eval {berkdb_open_noerr \
-env $menv1 -auto_commit -mode 0644}\
$largs $omethod test.db]
} else {
error_check_good txn_commit [$t commit] 0
}
}
if { $processwrites == 1 } {
puts "\tRep$tnum.c1:\
Process db put messages to client."
process_msgs $envlist
} else {
set start [do_switch $method $niter $start $menv0 $cenv $largs]
}
puts "\tRep$tnum.d: Close database using 2nd master env handle."
error_check_good db_close [$db1 close] 0
if { $processcloses == 1 } {
puts "\tRep$tnum.d1:\
Process db close messages to client."
process_msgs $envlist
} else {
set start [do_switch $method $niter $start $menv0 $cenv $largs]
}
puts "\tRep$tnum.e: Clean up."
error_check_good menv0_close [$menv0 close] 0
error_check_good menv1_close [$menv1 close] 0
error_check_good cenv_close [$cenv close] 0
replclose $testdir/MSGQUEUEDIR
}
set testdir $orig_tdir
return
}
proc do_switch { method niter start masterenv clientenv largs } {
set envlist "{$masterenv 1} {$clientenv 2}"
error_check_good master_downgrade [$masterenv rep_start -client] 0
error_check_good client_upgrade [$clientenv rep_start -master] 0
process_msgs $envlist
eval rep_test $method $clientenv NULL $niter $start $start 0 0 $largs
incr start $niter
process_msgs $envlist
error_check_good client_downgrade [$clientenv rep_start -client] 0
error_check_good master_upgrade [$masterenv rep_start -master] 0
eval rep_test $method $masterenv NULL $niter $start $start 0 0 $largs
incr start $niter
process_msgs $envlist
return $start
}