1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
# Copyright (c) 2021-2022, PostgreSQL Global Development Group
use strict;
use warnings;
use PostgreSQL::Test::Cluster;
use PostgreSQL::Test::Utils;
use Test::More;
my $node = PostgreSQL::Test::Cluster->new('main');
$node->init;
$node->start;
my $numrows = 700;
my ($out, $err) = run_command([ 'libpq_pipeline', 'tests' ]);
die "oops: $err" unless $err eq '';
my @tests = split(/\s+/, $out);
mkdir "$PostgreSQL::Test::Utils::tmp_check/traces";
for my $testname (@tests)
{
my @extraargs = ('-r', $numrows);
my $cmptrace = grep(/^$testname$/,
qw(simple_pipeline nosync multi_pipelines prepared singlerow
pipeline_abort transaction disallowed_in_pipeline)) > 0;
# For a bunch of tests, generate a libpq trace file too.
my $traceout = "$PostgreSQL::Test::Utils::tmp_check/traces/$testname.trace";
if ($cmptrace)
{
push @extraargs, "-t", $traceout;
}
# Execute the test
$node->command_ok(
[
'libpq_pipeline', @extraargs,
$testname, $node->connstr('postgres')
],
"libpq_pipeline $testname");
# Compare the trace, if requested
if ($cmptrace)
{
my $expected;
my $result;
$expected = slurp_file_eval("traces/$testname.trace");
next unless $expected ne "";
$result = slurp_file_eval($traceout);
next unless $result ne "";
is($result, $expected, "$testname trace match");
}
}
$node->stop('fast');
done_testing();
sub slurp_file_eval
{
my $filepath = shift;
my $contents;
eval { $contents = slurp_file($filepath); };
if ($@)
{
fail "reading $filepath: $@";
return "";
}
return $contents;
}
|
