proc rep055 { method { niter 200 } { tnum "055" } args } {
source ./include.tcl
global mixed_mode_logging
if { $is_windows9x_test == 1 } {
puts "Skipping replication test on Win 9x platform."
return
}
if { $checking_valid_methods } {
return "ALL"
}
set pgindex [lsearch -exact $args "-pagesize"]
if { $pgindex != -1 } {
puts "Rep$tnum: skipping for specific pagesizes"
return
}
if { $mixed_mode_logging > 0 } {
puts "Rep$tnum: Skipping for mixed-mode logging."
return
}
set opts { clean noclean }
foreach r $test_recopts {
foreach c $opts {
puts "Rep$tnum ($method $r $c $args):\
Test of internal initialization."
rep055_sub $method $niter $tnum $r $c $args
}
}
}
proc rep055_sub { method niter tnum recargs opts largs } {
global testdir
global passwd
global util_path
global rep_verbose
global verbose_type
set verbargs ""
if { $rep_verbose == 1 } {
set verbargs " -verbose {$verbose_type on} "
}
env_cleanup $testdir
replsetup $testdir/MSGQUEUEDIR
set masterdir $testdir/MASTERDIR
set clientdir $testdir/CLIENTDIR
file mkdir $masterdir
file mkdir $clientdir
set pagesize 4096
append largs " -pagesize $pagesize "
set log_buf [expr $pagesize * 2]
set log_max [expr $log_buf * 4]
repladd 1
set ma_envcmd "berkdb_env_noerr -create -txn nosync $verbargs \
-log_buffer $log_buf -log_max $log_max -errpfx MASTER \
-home $masterdir -rep_transport \[list 1 replsend\]"
set masterenv [eval $ma_envcmd $recargs -rep_master]
$masterenv rep_limit 0 0
repladd 2
set cl_envcmd "berkdb_env_noerr -create -txn nosync $verbargs \
-log_buffer $log_buf -log_max $log_max -errpfx CLIENT \
-home $clientdir -rep_transport \[list 2 replsend\]"
set clientenv [eval $cl_envcmd $recargs -rep_client]
$clientenv rep_limit 0 0
set envlist "{$masterenv 1} {$clientenv 2}"
process_msgs $envlist
$masterenv test force noarchive_timeout
puts "\tRep$tnum.a: Running rep_test in replicated env."
eval rep_test $method $masterenv NULL $niter 0 0 0 0 $largs
process_msgs $envlist
puts "\tRep$tnum.b: Close client."
error_check_good client_close [$clientenv close] 0
set res [eval exec $util_path/db_archive -l -h $clientdir]
set last_client_log [lindex [lsort $res] end]
set stop 0
while { $stop == 0 } {
puts "\tRep$tnum.c: Running rep_test in replicated env."
eval rep_test $method $masterenv NULL $niter 0 0 0 0 $largs
replclear 2
puts "\tRep$tnum.d: Run db_archive on master."
set res [eval exec $util_path/db_archive -d -h $masterdir]
set res [eval exec $util_path/db_archive -l -h $masterdir]
if { [lsearch -exact $res $last_client_log] == -1 } {
set stop 1
}
}
set res [eval exec $util_path/db_archive -l -h $masterdir]
set last_master_log [lindex [lsort $res] end]
set stop 0
puts "\tRep$tnum.e: Move master logs forward again."
while { $stop == 0 } {
eval rep_test $method $masterenv NULL $niter 0 0 0 0 $largs
replclear 2
set res [eval exec $util_path/db_archive -l -h $masterdir]
set last_log [lindex [lsort $res] end]
if { $last_log != $last_master_log } {
set stop 1
}
}
puts "\tRep$tnum.f: Get list of files for removal."
set logs [eval exec $util_path/db_archive -h $masterdir]
puts "\tRep$tnum.g: Reopen client ($opts)."
if { $opts == "clean" } {
env_cleanup $clientdir
}
set clientenv [eval $cl_envcmd $recargs -rep_client]
error_check_good client_env [is_valid_env $clientenv] TRUE
$clientenv rep_limit 0 0
set envlist "{$masterenv 1} {$clientenv 2}"
proc_msgs_once $envlist NONE err
if { $opts != "clean" } {
puts "\tRep$tnum.g.1: Trigger log request"
set entries 10
eval rep_test $method $masterenv NULL $entries $niter 0 0 0 $largs
proc_msgs_once $envlist NONE err
proc_msgs_once $envlist NONE err
proc_msgs_once $envlist NONE err
}
foreach l $logs {
fileremove -f $masterdir/$l
}
process_msgs $envlist 0 NONE err
puts "\tRep$tnum.h: Verify logs and databases"
rep_verify $masterdir $masterenv $clientdir $clientenv 1
error_check_good masterenv_close [$masterenv close] 0
error_check_good clientenv_close [$clientenv close] 0
replclose $testdir/MSGQUEUEDIR
}