summaryrefslogtreecommitdiff
path: root/db-4.8.30/test/rep007.tcl
diff options
context:
space:
mode:
authorJesse Morgan <jesse@jesterpm.net>2016-12-17 21:28:53 -0800
committerJesse Morgan <jesse@jesterpm.net>2016-12-17 21:28:53 -0800
commit54df2afaa61c6a03cbb4a33c9b90fa572b6d07b8 (patch)
tree18147b92b969d25ffbe61935fb63035cac820dd0 /db-4.8.30/test/rep007.tcl
Berkeley DB 4.8 with rust build script for linux.
Diffstat (limited to 'db-4.8.30/test/rep007.tcl')
-rw-r--r--db-4.8.30/test/rep007.tcl265
1 files changed, 265 insertions, 0 deletions
diff --git a/db-4.8.30/test/rep007.tcl b/db-4.8.30/test/rep007.tcl
new file mode 100644
index 0000000..5bd1f96
--- /dev/null
+++ b/db-4.8.30/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
+}