diff options
Diffstat (limited to 'src/test/subscription/t/015_stream.pl')
| -rw-r--r-- | src/test/subscription/t/015_stream.pl | 20 |
1 files changed, 6 insertions, 14 deletions
diff --git a/src/test/subscription/t/015_stream.pl b/src/test/subscription/t/015_stream.pl index cbaa327e441..50422589fb1 100644 --- a/src/test/subscription/t/015_stream.pl +++ b/src/test/subscription/t/015_stream.pl @@ -50,21 +50,15 @@ my $result = is($result, qq(2|2|2), 'check initial data was copied to subscriber'); # Interleave a pair of transactions, each exceeding the 64kB limit. -my $in = ''; -my $out = ''; - -my $timer = IPC::Run::timeout($PostgreSQL::Test::Utils::timeout_default); - -my $h = $node_publisher->background_psql('postgres', \$in, \$out, $timer, +my $h = $node_publisher->background_psql('postgres', on_error_stop => 0); -$in .= q{ +$h->query_safe(q{ BEGIN; INSERT INTO test_tab SELECT i, md5(i::text) FROM generate_series(3, 5000) s(i); UPDATE test_tab SET b = md5(b) WHERE mod(a,2) = 0; DELETE FROM test_tab WHERE mod(a,3) = 0; -}; -$h->pump_nb; +}); $node_publisher->safe_psql( 'postgres', q{ @@ -74,11 +68,9 @@ DELETE FROM test_tab WHERE a > 5000; COMMIT; }); -$in .= q{ -COMMIT; -\q -}; -$h->finish; # errors make the next test fail, so ignore them here +$h->query_safe('COMMIT'); +# errors make the next test fail, so ignore them here +$h->quit; $node_publisher->wait_for_catchup($appname); |