# See the file LICENSE for redistribution information. # # Copyright (c) 2010, 2012 Oracle and/or its affiliates. All rights reserved. # # $Id$ # # TEST repmgr003 # TEST Basic repmgr init test. # TEST # TEST Run all combinations of the basic_repmgr_init_test. # TEST proc repmgr003 { {display 0} {run 1} args } { source ./include.tcl if { !$display && $is_freebsd_test == 1 } { puts "Skipping replication manager tests on FreeBSD platform." return } run_repmgr_tests init } # This is the basis for simple repmgr internal init test cases. It starts # an appointed master and two clients, processing transactions between each # additional site. Then it verifies all expected transactions are # replicated. The following parameters control runtime options: # niter - number of records to process # inmemdb - put databases in-memory (0, 1) # inmemlog - put logs in-memory (0, 1) # inmemrep - put replication files in-memory (0, 1) # envprivate - put region files in-memory (0, 1) # bulk - use bulk processing (0, 1) # proc basic_repmgr_init_test { niter inmemdb inmemlog \ inmemrep envprivate bulk args } { source ./include.tcl global rep_verbose global verbose_type global overflowword1 global overflowword2 global databases_in_memory set overflowword1 "0" set overflowword2 "0" set nsites 3 if { $is_freebsd_test == 1 } { puts "Skipping basic_repmgr_init_test on FreeBSD platform." return } set method "btree" set largs [convert_args $method $args] # Set databases_in_memory for this test, preserving original value. if { $inmemdb } { set restore_dbinmem $databases_in_memory set databases_in_memory 1 } set verbargs "" if { $rep_verbose == 1 } { set verbargs " -verbose {$verbose_type on} " } env_cleanup $testdir set ports [available_ports $nsites] set masterdir $testdir/MASTERDIR set clientdir $testdir/CLIENTDIR set clientdir2 $testdir/CLIENTDIR2 file mkdir $masterdir file mkdir $clientdir file mkdir $clientdir2 # In-memory logs require a large log buffer, and cannot # be used with -txn nosync. Adjust the args. set logtype "on-disk" if { $inmemlog } { set logtype "in-memory" } set logargs [adjust_logargs $logtype] set txnargs [adjust_txnargs $logtype] # Determine in-memory replication argument for environments. Also # beef up cachesize for clients because the second client will need # to catch up with a few sets of records which could build up in the # tempdb, which is in-memory in this case. if { $inmemrep } { set repmemarg " -rep_inmem_files " set cachesize [expr 2 * (1024 * 1024)] set cacheargs "-cachesize { 0 $cachesize 1 }" } else { set repmemarg "" set cacheargs "" } # Determine argument for region files. if { $envprivate } { set private "-private " } else { set private "" } print_repmgr_headers basic_repmgr_init_test $niter $inmemdb\ $inmemlog $inmemrep $envprivate $bulk # Open a master. puts "\tBasic repmgr init test.a: Start a master." set ma_envcmd "berkdb_env_noerr -create $verbargs $private \ $logargs $txnargs \ -errpfx MASTER -home $masterdir -rep -thread $repmemarg" set masterenv [eval $ma_envcmd] $masterenv repmgr -ack all \ -local [list 127.0.0.1 [lindex $ports 0]] \ -start master puts "\tBasic repmgr init test.b: Run some transactions at master." eval rep_test $method $masterenv NULL $niter 0 0 0 $largs # Open first client puts "\tBasic repmgr init test.c: Start first client." set cl_envcmd "berkdb_env_noerr -create $verbargs $private \ $logargs $txnargs $cacheargs \ -errpfx CLIENT -home $clientdir -rep -thread $repmemarg" set clientenv [eval $cl_envcmd] $clientenv repmgr -ack all \ -local [list 127.0.0.1 [lindex $ports 1]] \ -remote [list 127.0.0.1 [lindex $ports 0]] \ -remote [list 127.0.0.1 [lindex $ports 2]] \ -start client await_startup_done $clientenv # # Use of -ack all guarantees replication complete before repmgr send # function returns and rep_test finishes. # puts "\tBasic repmgr init test.d: Run some more transactions at master." if { $bulk } { error_check_good set_bulk [$masterenv rep_config {bulk on}] 0 eval rep_test_bulk $method $masterenv NULL $niter 0 0 0 $largs # Must turn off bulk because some configs (debug_rop/wop) # generate log records when verifying databases. error_check_good set_bulk [$masterenv rep_config {bulk off}] 0 } else { eval rep_test $method $masterenv NULL $niter $niter 0 0 $largs } # Open second client puts "\tBasic repmgr init test.e: Start second client." set cl_envcmd "berkdb_env_noerr -create $verbargs $private \ $logargs $txnargs $cacheargs \ -errpfx CLIENT2 -home $clientdir2 -rep -thread $repmemarg" set clientenv2 [eval $cl_envcmd] $clientenv2 repmgr -ack all \ -local [list 127.0.0.1 [lindex $ports 2]] \ -remote [list 127.0.0.1 [lindex $ports 0]] \ -remote [list 127.0.0.1 [lindex $ports 1]] \ -start client await_startup_done $clientenv2 puts "\tBasic repmgr init test.f: Verifying client database contents." rep_verify $masterdir $masterenv $clientdir $clientenv 1 1 1 rep_verify $masterdir $masterenv $clientdir2 $clientenv2 1 1 1 # For in-memory replication, verify replication files not there. if { $inmemrep } { puts "\tBasic repmgr init test.g:\ Verify no replication files on disk." no_rep_files_on_disk $masterdir no_rep_files_on_disk $clientdir no_rep_files_on_disk $clientdir2 } # For private envs, verify region files are not on disk. if { $envprivate } { puts "\tBasic repmgr init test.h:\ Verify no region files on disk." no_region_files_on_disk $masterdir no_region_files_on_disk $clientdir no_region_files_on_disk $clientdir2 } # Restore original databases_in_memory value. if { $inmemdb } { set databases_in_memory $restore_dbinmem } error_check_good client2_close [$clientenv2 close] 0 error_check_good client_close [$clientenv close] 0 error_check_good masterenv_close [$masterenv close] 0 }