|
2 | 2 | use warnings;
|
3 | 3 | use PostgresNode;
|
4 | 4 | use TestLib;
|
5 |
| -use Test::More tests => 1; |
| 5 | +use Test::More tests => 2; |
6 | 6 |
|
7 | 7 | # Setup master node
|
8 |
| -my $node_master = get_new_node("Candie"); |
| 8 | +my $node_master = get_new_node("master"); |
9 | 9 | $node_master->init(allows_streaming => 1);
|
10 | 10 | $node_master->append_conf('postgresql.conf', qq(
|
11 | 11 | max_prepared_transactions = 10
|
|
14 | 14 | $node_master->backup('master_backup');
|
15 | 15 | $node_master->psql('postgres', "create table t(id int)");
|
16 | 16 |
|
17 |
| -# Setup master node |
18 |
| -my $node_slave = get_new_node('Django'); |
| 17 | +# Setup slave node |
| 18 | +my $node_slave = get_new_node('slave'); |
19 | 19 | $node_slave->init_from_backup($node_master, 'master_backup', has_streaming => 1);
|
20 | 20 | $node_slave->start;
|
21 | 21 |
|
|
35 | 35 | select * from t2 for share;
|
36 | 36 | prepare transaction 'x';
|
37 | 37 | ");
|
38 |
| -sleep 2; |
| 38 | +sleep 2; # wait for changes to arrive on slave |
39 | 39 | $node_slave->teardown_node;
|
40 | 40 | $node_master->psql('postgres',"commit prepared 'x'");
|
41 | 41 | $node_slave->start;
|
42 | 42 | $node_slave->psql('postgres',"select count(*) from pg_prepared_xacts", stdout => \$psql_out);
|
43 |
| - |
44 | 43 | is($psql_out, '0', "Commit prepared on master while slave is down.");
|
45 |
| - |
46 |
| - |
| 44 | +$node_slave->psql('postgres',"select sum(id) from t2", stdout => \$psql_out); |
| 45 | +is($psql_out, '2', "Check that tx changes are visible."); |
0 commit comments