recovery/t/009_twophase.pl

53 my ($cur_master, $cur_standby) = ($node_london, $node_paris);
54 my $cur_master_name = $cur_master->name;
57 $cur_master->psql('postgres', "CREATE TABLE t_009_tbl (id int, msg text)");
66 $cur_master->psql(
78 $cur_master->stop;
79 $cur_master->start;
81 $psql_rc = $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_1'");
84 $psql_rc = $cur_master->psql('postgres', "ROLLBACK PREPARED 'xact_009_2'");
93 $cur_master->psql(
106 $cur_master->teardown_node;
107 $cur_master->start;
109 $psql_rc = $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_3'");
112 $psql_rc = $cur_master->psql('postgres', "ROLLBACK PREPARED 'xact_009_4'");
119 $cur_master->psql(
133 $cur_master->teardown_node;
134 $cur_master->start;
136 $psql_rc = $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_5'");
144 $cur_master->psql(
152 $cur_master->teardown_node;
153 $cur_master->start;
154 $psql_rc = $cur_master->psql(
165 $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_7'");
171 $cur_master->psql(
191 $cur_master->psql(
199 $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_9'");
211 $cur_master->psql(
218 $cur_master->teardown_node;
223 ($cur_master, $cur_standby) = ($node_paris, $node_london);
224 $cur_master_name = $cur_master->name;
228 $psql_rc = $cur_master->psql('postgres',
233 $cur_standby->enable_streaming($cur_master);
243 $cur_master->psql(
250 $cur_master->stop;
256 ($cur_master, $cur_standby) = ($node_london, $node_paris);
257 $cur_master_name = $cur_master->name;
259 $cur_master->psql(
267 $cur_standby->enable_streaming($cur_master);
270 $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_11'");
277 $cur_master->psql(
285 $cur_master->stop;
292 ($cur_master, $cur_standby) = ($node_paris, $node_london);
293 $cur_master_name = $cur_master->name;
295 $cur_master->psql(
303 $cur_standby->enable_streaming($cur_master);
306 $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_12'");
313 $cur_master->psql(
327   $cur_master->safe_psql('postgres', "SELECT pg_current_wal_lsn()");
344 $cur_master->psql(
357 $cur_master->teardown_node;
358 $cur_master->start;
360 $psql_rc = $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_14'");
363 $psql_rc = $cur_master->psql('postgres', "ROLLBACK PREPARED 'xact_009_15'");
371 $cur_master->psql(
384 $cur_master->stop;
385 $cur_master->start;
387 $psql_rc = $cur_master->psql('postgres', "COMMIT PREPARED 'xact_009_16'");
390 $psql_rc = $cur_master->psql('postgres', "ROLLBACK PREPARED 'xact_009_17'");
397 $cur_master->psql(
403 $cur_master->psql(
431 $cur_master->psql(