diff options
Diffstat (limited to 'test/rep007.tcl')
| -rw-r--r-- | test/rep007.tcl | 265 |
1 files changed, 265 insertions, 0 deletions
diff --git a/test/rep007.tcl b/test/rep007.tcl new file mode 100644 index 0000000..5bd1f96 --- /dev/null +++ b/test/rep007.tcl @@ -0,0 +1,265 @@ +# See the file LICENSE for redistribution information. +# +# Copyright (c) 2001-2009 Oracle. All rights reserved. +# +# $Id$ +# +# TEST rep007 +# TEST Replication and bad LSNs +# TEST +# TEST Run rep_test in a replicated master env. +# TEST Close the client. Make additional changes to master. +# TEST Close the master. Open the client as the new master. +# TEST Make several different changes. Open the old master as +# TEST the client. Verify periodically that contents are correct. +# TEST This test is not appropriate for named in-memory db testing +# TEST because the databases are lost when both envs are closed. +proc rep007 { method { niter 10 } { tnum "007" } args } { + + source ./include.tcl + global databases_in_memory + global repfiles_in_memory + + if { $is_windows9x_test == 1 } { + puts "Skipping replication test on Win 9x platform." + return + } + + # All access methods are allowed. + if { $checking_valid_methods } { + return "ALL" + } + + set args [convert_args $method $args] + set logsets [create_logsets 3] + + # Set up for on-disk or in-memory databases. + set msg "using on-disk databases" + if { $databases_in_memory } { + set msg "using named in-memory databases" + if { [is_queueext $method] } { + puts -nonewline "Skipping rep$tnum for method " + puts "$method with named in-memory databases." + return + } + } + + set msg2 "and on-disk replication files" + if { $repfiles_in_memory } { + set msg2 "and in-memory replication files" + } + + # Run the body of the test with and without recovery. + foreach r $test_recopts { + foreach l $logsets { + set logindex [lsearch -exact $l "in-memory"] + if { $r == "-recover" && $logindex != -1 } { + puts "Rep$tnum: Skipping for\ + in-memory logs with -recover." + continue + } + if { $r == "-recover" && $databases_in_memory } { + puts "Rep$tnum: Skipping for\ + named in-memory databases with -recover." + continue + } + puts "Rep$tnum ($method $r):\ + Replication and bad LSNs $msg $msg2." + puts "Rep$tnum: Master logs are [lindex $l 0]" + puts "Rep$tnum: Client1 logs are [lindex $l 1]" + puts "Rep$tnum: Client2 logs are [lindex $l 2]" + rep007_sub $method $niter $tnum $l $r $args + } + } +} + +proc rep007_sub { method niter tnum logset recargs largs } { + global testdir + global databases_in_memory + global repfiles_in_memory + global rep_verbose + global verbose_type + + set verbargs "" + if { $rep_verbose == 1 } { + set verbargs " -verbose {$verbose_type on} " + } + + set repmemargs "" + if { $repfiles_in_memory } { + set repmemargs "-rep_inmem_files " + } + + env_cleanup $testdir + + set omethod [convert_method $method] + + replsetup $testdir/MSGQUEUEDIR + + set masterdir $testdir/MASTERDIR + set clientdir $testdir/CLIENTDIR + set clientdir2 $testdir/CLIENTDIR.2 + file mkdir $masterdir + file mkdir $clientdir + file mkdir $clientdir2 + + set m_logtype [lindex $logset 0] + set m_logargs [adjust_logargs $m_logtype] + set m_txnargs [adjust_txnargs $m_logtype] + + set c_logtype [lindex $logset 1] + set c_logargs [adjust_logargs $c_logtype] + set c_txnargs [adjust_txnargs $c_logtype] + + set c2_logtype [lindex $logset 2] + set c2_logargs [adjust_logargs $c2_logtype] + set c2_txnargs [adjust_txnargs $c2_logtype] + + # Open a master. + repladd 1 + set ma_envcmd "berkdb_env_noerr -create $m_txnargs $m_logargs \ + -home $masterdir $verbargs -errpfx MASTER $repmemargs \ + -rep_transport \[list 1 replsend\]" + set masterenv [eval $ma_envcmd $recargs -rep_master] + + # Open two clients + repladd 2 + set cl_envcmd "berkdb_env_noerr -create $c_txnargs $c_logargs \ + -home $clientdir $verbargs -errpfx CLIENT1 $repmemargs \ + -rep_transport \[list 2 replsend\]" + set clientenv [eval $cl_envcmd $recargs -rep_client] + + repladd 3 + set cl2_envcmd "berkdb_env_noerr -create $c2_txnargs $c2_logargs \ + -home $clientdir2 $verbargs -errpfx CLIENT2 $repmemargs \ + -rep_transport \[list 3 replsend\]" + set cl2env [eval $cl2_envcmd $recargs -rep_client] + + # Bring the clients online by processing the startup messages. + set envlist "{$masterenv 1} {$clientenv 2} {$cl2env 3}" + process_msgs $envlist + + # Run rep_test in the master (and update clients). + puts "\tRep$tnum.a: Running rep_test in replicated env." + eval rep_test $method $masterenv NULL $niter 0 0 0 $largs + process_msgs $envlist + + # Databases should now have identical contents. + if { $databases_in_memory } { + set dbname { "" "test.db" } + } else { + set dbname "test.db" + } + + rep_verify $masterdir $masterenv $clientdir $clientenv 0 1 1 + rep_verify $masterdir $masterenv $clientdir2 $cl2env 0 1 1 + + puts "\tRep$tnum.b: Close client 1 and make master changes." + # Flush the log so that we don't lose any changes, since we'll be + # relying on having a good log when we run recovery when we open it + # later. + # + $clientenv log_flush + error_check_good client_close [$clientenv close] 0 + + # Change master and propagate changes to client 2. + set start $niter + eval rep_test $method $masterenv NULL $niter $start $start 0 $largs + set envlist "{$masterenv 1} {$cl2env 3}" + process_msgs $envlist + + # We need to do a deletion here to cause meta-page updates, + # particularly for queue. Delete the first pair and remember + # what it is -- it should come back after the master is closed + # and reopened as a client. + set db1 [eval {berkdb_open_noerr} -env $masterenv -auto_commit $dbname] + error_check_good dbopen [is_valid_db $db1] TRUE + set txn [$masterenv txn] + set c [eval $db1 cursor -txn $txn] + error_check_good db_cursor [is_valid_cursor $c $db1] TRUE + set first [$c get -first] + set pair [lindex [$c get -first] 0] + set key [lindex $pair 0] + set data [lindex $pair 1] + + error_check_good cursor_del [$c del] 0 + error_check_good dbcclose [$c close] 0 + error_check_good txn_commit [$txn commit] 0 + error_check_good db1_close [$db1 close] 0 + # + # Process the messages to get them out of the db. This also + # propagates the delete to client 2. + # + process_msgs $envlist + + # Nuke those for closed client + replclear 2 + + # Databases 1 and 3 should now have identical contents. + # Database 2 should be different. First check 1 and 3. We + # have to wait to check 2 until the env is open again. + rep_verify $masterdir $masterenv $clientdir2 $cl2env 0 1 1 + + puts "\tRep$tnum.c: Close master, reopen client as master." + $masterenv log_flush + error_check_good master_close [$masterenv close] 0 + set newmasterenv [eval $cl_envcmd $recargs -rep_master] + + # Now we can check that database 2 does not match 3. + rep_verify $clientdir $newmasterenv $clientdir2 $cl2env 0 0 0 + + puts "\tRep$tnum.d: Make incompatible changes to new master." + set envlist "{$newmasterenv 2} {$cl2env 3}" + process_msgs $envlist + + set db [eval {berkdb_open_noerr} \ + -env $newmasterenv -auto_commit -create $omethod $dbname] + error_check_good dbopen [is_valid_db $db] TRUE + set t [$newmasterenv txn] + + # Force in a pair {10 10}. This works for all access + # methods and won't overwrite the old first pair for record-based. + set ret [eval {$db put} -txn $t 10 [chop_data $method 10]] + error_check_good put $ret 0 + error_check_good txn [$t commit] 0 + error_check_good dbclose [$db close] 0 + + eval rep_test $method $newmasterenv NULL $niter $start $start 0 $largs + set envlist "{$newmasterenv 2} {$cl2env 3}" + process_msgs $envlist + + # Nuke those for closed old master + replclear 1 + + # Databases 2 and 3 should now match. + rep_verify $clientdir $newmasterenv $clientdir2 $cl2env 0 1 1 + + puts "\tRep$tnum.e: Open old master as client." + set newclientenv [eval $ma_envcmd -rep_client -recover] + set envlist "{$newclientenv 1} {$newmasterenv 2} {$cl2env 3}" + process_msgs $envlist + + # The pair we deleted earlier from the master should now + # have reappeared. + set db1 [eval {berkdb_open_noerr}\ + -env $newclientenv -auto_commit $dbname] + error_check_good dbopen [is_valid_db $db1] TRUE + set ret [$db1 get -get_both $key [pad_data $method $data]] + error_check_good get_both $ret [list $pair] + error_check_good db1_close [$db1 close] 0 + + set start [expr $niter * 2] + eval rep_test $method $newmasterenv NULL $niter $start $start 0 $largs + set envlist "{$newclientenv 1} {$newmasterenv 2} {$cl2env 3}" + process_msgs $envlist + + # Now all 3 should match again. + rep_verify $masterdir $newclientenv $clientdir $newmasterenv 0 1 1 + rep_verify $masterdir $newclientenv $clientdir2 $cl2env 0 1 1 + + error_check_good newmasterenv_close [$newmasterenv close] 0 + error_check_good newclientenv_close [$newclientenv close] 0 + error_check_good cl2_close [$cl2env close] 0 + replclose $testdir/MSGQUEUEDIR + return +} |