summaryrefslogtreecommitdiff
path: root/test/rep060.tcl
diff options
context:
space:
mode:
authorZhang Qiang <qiang.z.zhang@intel.com>2012-05-29 11:25:24 +0800
committerZhang Qiang <qiang.z.zhang@intel.com>2012-05-29 11:25:24 +0800
commite776056ea09ba0b6d9505ced6913c9190a12d632 (patch)
tree092838f2a86042abc586aa5576e36ae6cb47e256 /test/rep060.tcl
parent2e082c838d2ca750f5daac6dcdabecc22dfd4e46 (diff)
downloaddb4-e776056ea09ba0b6d9505ced6913c9190a12d632.tar.gz
db4-e776056ea09ba0b6d9505ced6913c9190a12d632.tar.bz2
db4-e776056ea09ba0b6d9505ced6913c9190a12d632.zip
updated with Tizen:Base source codes
Diffstat (limited to 'test/rep060.tcl')
-rw-r--r--test/rep060.tcl346
1 files changed, 0 insertions, 346 deletions
diff --git a/test/rep060.tcl b/test/rep060.tcl
deleted file mode 100644
index a78c7cd..0000000
--- a/test/rep060.tcl
+++ /dev/null
@@ -1,346 +0,0 @@
-# See the file LICENSE for redistribution information.
-#
-# Copyright (c) 2004-2009 Oracle. All rights reserved.
-#
-# $Id$
-#
-# TEST rep060
-# TEST Test of normally running clients and internal initialization.
-# TEST Have a client running normally, but slow/far behind the master.
-# TEST Then the master checkpoints and archives, causing the client
-# TEST to suddenly be thrown into internal init. This test tests
-# TEST that we clean up the old files/pages in mpool and dbreg.
-# TEST Also test same thing but the app holding an open dbp as well.
-#
-proc rep060 { method { niter 200 } { tnum "060" } args } {
-
- source ./include.tcl
- global databases_in_memory
- global repfiles_in_memory
-
- # Run for btree and queue only.
- if { $checking_valid_methods } {
- set test_methods {}
- foreach method $valid_methods {
- if { [is_btree $method] == 1 || \
- [is_queue $method] == 1 } {
- lappend test_methods $method
- }
- }
- return $test_methods
- }
- if { [is_btree $method] != 1 && [is_queue $method] != 1 } {
- puts "Skipping rep060 for method $method."
- return
- }
-
- set args [convert_args $method $args]
-
- # This test needs to set its own pagesize.
- set pgindex [lsearch -exact $args "-pagesize"]
- if { $pgindex != -1 } {
- puts "Rep$tnum: skipping for specific pagesizes"
- return
- }
-
- set logsets [create_logsets 2]
-
- # 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,
- # and with and without cleaning. Skip recovery with in-memory
- # logging - it doesn't make sense.
- #
- # 'user' means that the "app" (the test in this case) has
- # its own handle open to the database.
- set opts { "" user }
- foreach r $test_recopts {
- foreach o $opts {
- 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
- }
- puts "Rep$tnum ($method $r $o $args):\
- Test of internal initialization and\
- slow client $msg $msg2."
- puts "Rep$tnum: Master logs are [lindex $l 0]"
- puts "Rep$tnum: Client logs are [lindex $l 1]"
- rep060_sub $method $niter $tnum $l $r $o $args
- }
- }
- }
-}
-
-proc rep060_sub { method niter tnum logset recargs opt largs } {
- source ./include.tcl
- 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
-
- replsetup $testdir/MSGQUEUEDIR
-
- set masterdir $testdir/MASTERDIR
- set clientdir $testdir/CLIENTDIR
-
- file mkdir $masterdir
- file mkdir $clientdir
-
- # Log size is small so we quickly create more than one.
- # The documentation says that the log file must be at least
- # four times the size of the in-memory log buffer.
- set pagesize 4096
- append largs " -pagesize $pagesize "
- set log_max [expr $pagesize * 4]
-
- 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 $m_txnargs \
- $repmemargs \
- $m_logargs -log_max $log_max -errpfx MASTER $verbargs \
- -home $masterdir -rep_transport \[list 1 replsend\]"
- set masterenv [eval $ma_envcmd $recargs -rep_master]
-
- # Open a client
- puts "\tRep$tnum.a: Open client."
- repladd 2
- set cl_envcmd "berkdb_env_noerr -create $c_txnargs \
- $repmemargs \
- $c_logargs -log_max $log_max -errpfx CLIENT $verbargs \
- -home $clientdir -rep_transport \[list 2 replsend\]"
- set clientenv [eval $cl_envcmd $recargs -rep_client]
-
- # Bring the client online by processing the startup messages.
- set envlist "{$masterenv 1} {$clientenv 2}"
- process_msgs $envlist
-
- # Clobber replication's 30-second anti-archive timer, which will have
- # been started by client sync-up internal init.
- #
- $masterenv test force noarchive_timeout
-
- # Set a low limit so that there are lots of reps between
- # master and client. This allows greater control over
- # the test.
- error_check_good thr [$masterenv rep_limit 0 [expr 10 * 1024]] 0
-
- # It is *key* to this test that we have a database handle
- # open for the duration of the test. The problem this
- # test checks for regards internal init when there are open
- # database handles around.
- #
- if { $databases_in_memory } {
- set dbname { "" "test.db" }
- } else {
- set dbname "test.db"
- }
-
- set omethod [convert_method $method]
- set db [eval {berkdb_open_noerr -env $masterenv -auto_commit \
- -create -mode 0644} $largs $omethod $dbname]
- error_check_good dbopen [is_valid_db $db] TRUE
-
- # Put some data into the database, running the master up past
- # log file 10, discarding messages to the client so that it will
- # be forced to request them as a gap.
- #
- puts "\tRep$tnum.c: Run rep_test in master env."
- set start 0
-
- set stop 0
- set endlog 10
- while { $stop == 0 } {
- # Run test in the master (don't update client).
- eval rep_test $method \
- $masterenv $db $niter $start $start 0 $largs
- incr start $niter
- replclear 2
-
- if { $m_logtype != "in-memory" } {
- set res \
- [eval exec $util_path/db_archive -l -h $masterdir]
- }
- # Make sure the master has gone as far as we requested.
- set last_master_log [get_logfile $masterenv last]
- if { $last_master_log > $endlog } {
- set stop 1
- }
- }
-
- # Do one more set of txns at the master, replicating log records
- # normally, to give the client a chance to notice how many messages
- # it is missing.
- #
- eval rep_test $method $masterenv $db $niter $start $start 0 $largs
- incr start $niter
-
- set stop 0
- set client_endlog 5
- set last_client_log 0
- set nproced 0
- incr nproced [proc_msgs_once $envlist NONE err]
- incr nproced [proc_msgs_once $envlist NONE err]
-
- puts "\tRep$tnum.d: Client catches up partway."
- error_check_good ckp [$masterenv txn_checkpoint] 0
-
- # We have checkpointed on the master, but we want to get the
- # client a healthy way through the logs before archiving on
- # the master.
- while { $stop == 0 } {
- set nproced 0
- incr nproced [proc_msgs_once $envlist NONE err]
- if { $nproced == 0 } {
- error_check_good \
- ckp [$masterenv txn_checkpoint -force] 0
- }
-
- # Stop processing when the client is partway through.
- if { $c_logtype != "in-memory" } {
- set res \
- [eval exec $util_path/db_archive -l -h $clientdir]
- }
- set last_client_log [get_logfile $clientenv last]
- set first_client_log [get_logfile $clientenv first]
- if { $last_client_log > $client_endlog } {
- set stop 1
- }
- }
-
- #
- # The user may have the database open itself.
- #
- if { $opt == "user" } {
- set cdb [eval {berkdb_open_noerr -env} $clientenv $dbname]
- error_check_good dbopen [is_valid_db $cdb] TRUE
- set ccur [$cdb cursor]
- error_check_good curs [is_valid_cursor $ccur $cdb] TRUE
- set ret [$ccur get -first]
- set kd [lindex $ret 0]
- set key [lindex $kd 0]
- error_check_good cclose [$ccur close] 0
- } else {
- set cdb NULL
- }
-
- # Now that the client is well on its way of normal processing,
- # simply fairly far behind the master, archive on the master,
- # removing the log files the client needs, sending it into
- # internal init with the database pages reflecting the client's
- # current LSN.
- #
- puts "\tRep$tnum.e: Force internal initialization."
- if { $m_logtype != "in-memory" } {
- puts "\tRep$tnum.e1: Archive on master."
- set res [eval exec $util_path/db_archive -d -h $masterdir]
- } else {
- # Master is in-memory, and we'll need a different
- # technique to create the gap forcing internal init.
- puts "\tRep$tnum.e1: Run rep_test until gap is created."
- set stop 0
- while { $stop == 0 } {
- eval rep_test $method $masterenv \
- NULL $niter $start $start 0 $largs
- incr start $niter
- set first_master_log [get_logfile $masterenv first]
- if { $first_master_log > $last_client_log } {
- set stop 1
- }
- }
- }
-
- puts "\tRep$tnum.f: Process messages."
- if { $opt == "user" } {
- for { set loop 0 } { $loop < 5 } { incr loop } {
- set nproced 0
- incr nproced [proc_msgs_once $envlist]
- if { $cdb == "NULL" } {
- continue
- }
- puts "\tRep$tnum.g.$loop: Check user database."
- set status [catch {$cdb get $key} ret]
- if { $status != 0 } {
- #
- # For db operations, DB doesn't block, but
- # returns DEADLOCK.
- #
- set is_lock [is_substr $ret DB_LOCK_DEADLOCK]
- set is_dead [is_substr $ret DB_REP_HANDLE_DEAD]
- error_check_good lock_dead \
- [expr $is_lock || $is_dead] 1
- if { $is_dead } {
- error_check_good cclose [$cdb close] 0
- set cdb NULL
- }
- }
- }
- }
- process_msgs $envlist
-
- #
- # If we get through the user loop with a valid db, then it better
- # be a dead handle after we've completed processing all the
- # messages and running recovery.
- #
- if { $cdb != "NULL" } {
- puts "\tRep$tnum.h: Check dead handle."
- set status [catch {$cdb get $key} ret]
- error_check_good status $status 1
- error_check_good is_dead [is_substr $ret DB_REP_HANDLE_DEAD] 1
- error_check_good cclose [$cdb close] 0
- puts "\tRep$tnum.i: Verify correct internal initialization."
- } else {
- puts "\tRep$tnum.h: Verify correct internal initialization."
- }
- error_check_good close [$db close] 0
- process_msgs $envlist
-
- # We have now forced an internal initialization. Verify it is correct.
- rep_verify $masterdir $masterenv $clientdir $clientenv 1 1 1
-
- # Check that logs are in-memory or on-disk 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
-}