|
2 | 2 | use warnings; |
3 | 3 | use PostgresNode; |
4 | 4 | use TestLib; |
5 | | -use Test::Moretests=>1; |
| 5 | +use Test::Moretests=>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 | | -# Setupmaster node |
18 | | -my$node_slave = get_new_node('Django'); |
| 17 | +# Setupslave 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."); |