tests

Author: kelvich

t/001_basic_recovery.pl

@@ -3,8 +3,6 @@
 use Cluster;
 use TestLib;
 use Test::More tests => 3;
-use DBI;
-use DBD::Pg ':async';
 
 my $cluster = new Cluster(3);
 $cluster->init();
@@ -43,11 +41,13 @@
 diag("stopping node 2");
 $cluster->{nodes}->[2]->teardown_node;
 
-diag("sleeping 15");
-sleep(15);
+my $ret = $cluster->psql(0, 'postgres', "insert into t values(4, 40);");
+diag "tx1 status = $ret";
 
 diag("inserting 2");
-$cluster->psql(0, 'postgres', "insert into t values(2, 20);");
+my $ret = $cluster->psql(0, 'postgres', "insert into t values(2, 20);");
+diag "tx2 status = $ret";
+
 diag("selecting");
 $cluster->psql(1, 'postgres', "select v from t where k=2;", stdout => \$psql_out);
 diag("selected");
@@ -58,15 +58,19 @@
 ###############################################################################
 
 diag("starting node 2");
-$nodes[2]->start;
-diag("sleeping 10");
+$cluster->{nodes}->[2]->start;
+#diag("sleeping 10");
 #sleep(10); # XXX: here we can poll
+
 $cluster->psql(0, 'postgres', "select mtm.poll_node(3);");
 diag("inserting 3");
+
 $cluster->psql(0, 'postgres', "insert into t values(3, 30);");
 diag("selecting");
+
 $cluster->psql(2, 'postgres', "select v from t where k=3;", stdout => \$psql_out);
 diag("selected");
+
 is($psql_out, '30', "Check replication after failed node recovery.");
 
 

testeaux/Cluster.pm

@@ -109,9 +109,9 @@ sub configure
 			multimaster.queue_size = 10485760 # 10mb
 			multimaster.node_id = $id
 			multimaster.conn_strings = '$connstr'
-			multimaster.use_raftable = true
+			multimaster.use_raftable = false
 			multimaster.ignore_tables_without_pk = true
-			multimaster.twopc_min_timeout = 60000
+			multimaster.twopc_min_timeout = 10000
 			raftable.id = $id
 			raftable.peers = '$raftpeers'
 		));