|
2 | 2 | use warnings;
|
3 | 3 | use Cluster;
|
4 | 4 | use TestLib;
|
5 |
| -use Test::More tests => 3; |
| 5 | +use Test::More tests => 4; |
6 | 6 |
|
7 | 7 | my $cluster = new Cluster(3);
|
8 | 8 | $cluster->init();
|
|
60 | 60 | diag("starting node 2");
|
61 | 61 | $cluster->{nodes}->[2]->start;
|
62 | 62 | #diag("sleeping 10");
|
63 |
| -sleep(10); # XXX: here we can poll |
| 63 | +#sleep(10); # XXX: here we can poll |
64 | 64 |
|
65 |
| -#$cluster->psql(0, 'postgres', "select mtm.poll_node(3);"); |
66 |
| -#$cluster->psql(1, 'postgres', "select mtm.poll_node(3);"); |
67 |
| -#$cluster->psql(2, 'postgres', "select mtm.poll_node(3);"); |
68 |
| -diag("inserting 3"); |
| 65 | +$cluster->psql(0, 'postgres', "select mtm.poll_node(3);"); |
69 | 66 |
|
| 67 | +diag("inserting 3"); |
70 | 68 | $cluster->psql(0, 'postgres', "insert into t values(3, 30);");
|
71 |
| -diag("selecting"); |
| 69 | +diag("inserting 4"); |
| 70 | +$cluster->psql(1, 'postgres', "insert into t values(4, 40);"); |
72 | 71 |
|
| 72 | +diag("selecting"); |
73 | 73 | $cluster->psql(2, 'postgres', "select v from t where k=3;", stdout => \$psql_out);
|
74 | 74 | diag("selected");
|
75 | 75 |
|
76 | 76 | is($psql_out, '30', "Check replication after failed node recovery.");
|
77 | 77 |
|
| 78 | +$cluster->psql(2, 'postgres', "select v from t where k=4;", stdout => \$psql_out); |
| 79 | +diag("selected"); |
| 80 | + |
| 81 | +is($psql_out, '40', "Check replication after failed node recovery."); |
| 82 | + |
78 | 83 |
|
0 commit comments