]> Sergey Matveev's repositories - public-inbox.git/blob - t/qspawn.t
msgmap: add tmp_clone to create an anonymous copy
[public-inbox.git] / t / qspawn.t
1 # Copyright (C) 2016-2018 all contributors <meta@public-inbox.org>
2 # License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
3 use Test::More;
4 use_ok 'PublicInbox::Qspawn';
5
6 my $limiter = PublicInbox::Qspawn::Limiter->new(1);
7 {
8         my $x = PublicInbox::Qspawn->new([qw(true)]);
9         my $run = 0;
10         $x->start($limiter, sub {
11                 my ($rpipe) = @_;
12                 is(0, sysread($rpipe, my $buf, 1), 'read zero bytes');
13                 ok(!$x->finish, 'no error on finish');
14                 $run = 1;
15         });
16         is($run, 1, 'callback ran alright');
17 }
18
19 {
20         my $x = PublicInbox::Qspawn->new([qw(false)]);
21         my $run = 0;
22         $x->start($limiter, sub {
23                 my ($rpipe) = @_;
24                 is(0, sysread($rpipe, my $buf, 1), 'read zero bytes from false');
25                 my $err = $x->finish;
26                 is($err, 256, 'error on finish');
27                 $run = 1;
28         });
29         is($run, 1, 'callback ran alright');
30 }
31
32 foreach my $cmd ([qw(sleep 1)], [qw(sh -c), 'sleep 1; false']) {
33         my $s = PublicInbox::Qspawn->new($cmd);
34         my @run;
35         $s->start($limiter, sub {
36                 my ($rpipe) = @_;
37                 push @run, 'sleep';
38                 is(0, sysread($rpipe, my $buf, 1), 'read zero bytes');
39         });
40         my $n = 0;
41         my @t = map {
42                 my $i = $n++;
43                 my $x = PublicInbox::Qspawn->new([qw(true)]);
44                 $x->start($limiter, sub {
45                         my ($rpipe) = @_;
46                         push @run, $i;
47                 });
48                 [$x, $i]
49         } (0..2);
50
51         if ($cmd->[-1] =~ /false\z/) {
52                 ok($s->finish, 'got error on false after sleep');
53         } else {
54                 ok(!$s->finish, 'no error on sleep');
55         }
56         ok(!$_->[0]->finish, "true $_->[1] succeeded") foreach @t;
57         is_deeply([qw(sleep 0 1 2)], \@run, 'ran in order');
58 }
59
60 done_testing();
61
62 1;