diff options
Diffstat (limited to 'db/test/rep037.tcl')
| -rw-r--r-- | db/test/rep037.tcl | 142 |
1 files changed, 89 insertions, 53 deletions
diff --git a/db/test/rep037.tcl b/db/test/rep037.tcl index 6d3ab4649..89ef004c6 100644 --- a/db/test/rep037.tcl +++ b/db/test/rep037.tcl @@ -1,9 +1,9 @@ # See the file LICENSE for redistribution information. # -# Copyright (c) 2004 -# Sleepycat Software. All rights reserved. +# Copyright (c) 2004-2006 +# Oracle Corporation. All rights reserved. # -# $Id: rep037.tcl,v 11.2 2004/10/14 14:55:55 sue Exp $ +# $Id: rep037.tcl,v 12.10 2006/08/24 14:46:37 bostic Exp $ # # TEST rep037 # TEST Test of internal initialization and page throttling. @@ -16,6 +16,18 @@ # TEST Verify page throttling occurred. # proc rep037 { method { niter 1500 } { tnum "037" } args } { + + source ./include.tcl + if { $is_windows9x_test == 1 } { + puts "Skipping replication test on Win 9x platform." + return + } + + # Valid for all access methods. + if { $checking_valid_methods } { + return "ALL" + } + set args [convert_args $method $args] set saved_args $args @@ -26,21 +38,32 @@ proc rep037 { method { niter 1500 } { tnum "037" } args } { return } + set logsets [create_logsets 2] + # Run the body of the test with and without recovery, # and with and without cleaning. - set recopts { "" " -recover " } set cleanopts { clean noclean } - foreach r $recopts { + foreach r $test_recopts { foreach c $cleanopts { - set args $saved_args - puts "Rep$tnum ($method $c $r $args):\ - Test of internal initialization - page throttling." - rep037_sub $method $niter $tnum $r $c $args + foreach l $logsets { + set logindex [lsearch -exact $l "in-memory"] + if { $r == "-recover" && $logindex != -1 } { + puts "Skipping rep$tnum for -recover\ + with in-memory logs." + continue + } + set args $saved_args + puts "Rep$tnum ($method $c $r $args):\ + Test of internal init with page throttling." + puts "Rep$tnum: Master logs are [lindex $l 0]" + puts "Rep$tnum: Client logs are [lindex $l 1]" + rep037_sub $method $niter $tnum $l $r $c $args + } } } } -proc rep037_sub { method niter tnum recargs clean largs } { +proc rep037_sub { method niter tnum logset recargs clean largs } { global testdir global util_path @@ -61,14 +84,25 @@ proc rep037_sub { method niter tnum recargs clean largs } { append largs " -pagesize $pagesize " set log_buf [expr $pagesize * 2] set log_max [expr $log_buf * 4] + set m_logargs " -log_buffer $log_buf" + set c_logargs " -log_buffer $log_buf" + + set m_logtype [lindex $logset 0] + set c_logtype [lindex $logset 1] + + # In-memory logs cannot be used with -txn nosync. + 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] # Open a master. repladd 1 - set ma_envcmd "berkdb_env_noerr -create -txn nosync \ - -log_buffer $log_buf -log_max $log_max \ + set ma_envcmd "berkdb_env_noerr -create $m_txnargs \ + $m_logargs -log_max $log_max \ -home $masterdir -rep_transport \[list 1 replsend\]" -# set ma_envcmd "berkdb_env_noerr -create -txn nosync \ -# -log_buffer $log_buf -log_max $log_max \ +# set ma_envcmd "berkdb_env_noerr -create $m_txnargs \ +# $m_logargs -log_max $log_max \ # -verbose {rep on} -errpfx MASTER \ # -home $masterdir -rep_transport \[list 1 replsend\]" set masterenv [eval $ma_envcmd $recargs -rep_master] @@ -77,11 +111,11 @@ proc rep037_sub { method niter tnum recargs clean largs } { # Open a client repladd 2 - set cl_envcmd "berkdb_env_noerr -create -txn nosync \ - -log_buffer $log_buf -log_max $log_max \ + set cl_envcmd "berkdb_env_noerr -create $c_txnargs \ + $c_logargs -log_max $log_max \ -home $clientdir -rep_transport \[list 2 replsend\]" -# set cl_envcmd "berkdb_env_noerr -create -txn nosync \ -# -log_buffer $log_buf -log_max $log_max \ +# set cl_envcmd "berkdb_env_noerr -create $c_txnargs \ +# $c_logargs -log_max $log_max \ # -verbose {rep on} -errpfx CLIENT \ # -home $clientdir -rep_transport \[list 2 replsend\]" set clientenv [eval $cl_envcmd $recargs -rep_client] @@ -93,23 +127,39 @@ proc rep037_sub { method niter tnum recargs clean largs } { # Run rep_test in the master (and update client). puts "\tRep$tnum.a: Running rep_test in replicated env." - eval rep_test $method $masterenv NULL $niter 0 0 0 $largs + set start 0 + eval rep_test $method $masterenv NULL $niter $start $start 0 0 $largs + incr start $niter process_msgs $envlist puts "\tRep$tnum.b: Close client." + if { $c_logtype != "in-memory" } { + set res [eval exec $util_path/db_archive -l -h $clientdir] + } + set last_client_log [get_logfile $clientenv last] error_check_good client_close [$clientenv close] 0 - # Run rep_test in the master (don't update client). - puts "\tRep$tnum.c: Running rep_test in replicated env." - eval rep_test $method $masterenv NULL $niter 0 0 0 $largs - replclear 2 - - puts "\tRep$tnum.d: Run db_archive on master." - set res [eval exec $util_path/db_archive -l -h $masterdir] - error_check_bad log.1.present [lsearch -exact $res log.0000000001] -1 - set res [eval exec $util_path/db_archive -d -h $masterdir] - set res [eval exec $util_path/db_archive -l -h $masterdir] - error_check_good log.1.gone [lsearch -exact $res log.0000000001] -1 + set stop 0 + while { $stop == 0 } { + # Run rep_test in the master (don't update client). + puts "\tRep$tnum.c: Running rep_test in replicated env." + eval rep_test \ + $method $masterenv NULL $niter $start $start 0 0 $largs + incr start $niter + replclear 2 + + puts "\tRep$tnum.d: Run db_archive on master." + if { $m_logtype != "in-memory"} { + set res \ + [eval exec $util_path/db_archive -d -h $masterdir] + } + # Make sure that we have a gap between the last client + # log and the first master log. + set first_master_log [get_logfile $masterenv first] + if { $first_master_log > $last_client_log } { + set stop 1 + } + } puts "\tRep$tnum.e: Reopen client ($clean)." if { $clean == "clean" } { @@ -128,33 +178,14 @@ proc rep037_sub { method niter tnum recargs clean largs } { # logs and that will trigger it. # set entries 10 - eval rep_test $method $masterenv NULL $entries $niter 0 0 $largs + eval rep_test $method \ + $masterenv NULL $entries $niter $start $start 0 $largs process_msgs $envlist 0 NONE err } puts "\tRep$tnum.f: Verify logs and databases" - # Check that master and client logs and dbs are identical. - # Logs first ... - set stat [catch {eval exec $util_path/db_printlog \ - -h $masterdir > $masterdir/prlog} result] - error_check_good stat_mprlog $stat 0 - set stat [catch {eval exec $util_path/db_printlog \ - -h $clientdir > $clientdir/prlog} result] - error_check_good stat_cprlog $stat 0 - error_check_good log_cmp \ - [filecmp $masterdir/prlog $clientdir/prlog] 0 - - # ... now the databases. - set dbname "test.db" - set db1 [eval {berkdb_open -env $masterenv} $largs {-rdonly $dbname}] - set db2 [eval {berkdb_open -env $clientenv} $largs {-rdonly $dbname}] - - error_check_good comparedbs [db_compare \ - $db1 $db2 $masterdir/$dbname $clientdir/$dbname] 0 - error_check_good db1_close [$db1 close] 0 - error_check_good db2_close [$db2 close] 0 - - # + rep_verify $masterdir $masterenv $clientdir $clientenv 1 + puts "\tRep$tnum.g: Verify throttling." if { $niter > 1000 } { set nthrottles \ @@ -162,6 +193,11 @@ proc rep037_sub { method niter tnum recargs clean largs } { error_check_bad nthrottles $nthrottles -1 error_check_bad nthrottles $nthrottles 0 } + + # Make sure log files are on-disk or not as expected. + check_log_location $masterenv + check_log_location $clientenv + error_check_good masterenv_close [$masterenv close] 0 error_check_good clientenv_close [$clientenv close] 0 replclose $testdir/MSGQUEUEDIR |