t/qspawn.t

   1 # Copyright (C) 2016-2019 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 {
   7         my $cmd = [qw(sh -c), 'echo >&2 err; echo out'];
   8         my $qsp = PublicInbox::Qspawn->new($cmd, {}, { 2 => 1 });
   9         my $res;
  10         $qsp->psgi_qx({}, undef, sub { $res = ${$_[0]} });
  11         is($res, "err\nout\n", 'captured stderr and stdout');
  12 }
  13
  14 sub finish_err ($) {
  15         my ($qsp) = @_;
  16         $qsp->finish;
  17         $qsp->{err};
  18 }
  19
  20 my $limiter = PublicInbox::Qspawn::Limiter->new(1);
  21 {
  22         my $x = PublicInbox::Qspawn->new([qw(true)]);
  23         my $run = 0;
  24         $x->start($limiter, sub {
  25                 my ($rpipe) = @_;
  26                 is(0, sysread($rpipe, my $buf, 1), 'read zero bytes');
  27                 ok(!finish_err($x), 'no error on finish');
  28                 $run = 1;
  29         });
  30         is($run, 1, 'callback ran alright');
  31 }
  32
  33 {
  34         my $x = PublicInbox::Qspawn->new([qw(false)]);
  35         my $run = 0;
  36         $x->start($limiter, sub {
  37                 my ($rpipe) = @_;
  38                 is(0, sysread($rpipe, my $buf, 1), 'read zero bytes from false');
  39                 ok(finish_err($x), 'error on finish');
  40                 $run = 1;
  41         });
  42         is($run, 1, 'callback ran alright');
  43 }
  44
  45 foreach my $cmd ([qw(sleep 1)], [qw(sh -c), 'sleep 1; false']) {
  46         my $s = PublicInbox::Qspawn->new($cmd);
  47         my @run;
  48         $s->start($limiter, sub {
  49                 my ($rpipe) = @_;
  50                 push @run, 'sleep';
  51                 is(0, sysread($rpipe, my $buf, 1), 'read zero bytes');
  52         });
  53         my $n = 0;
  54         my @t = map {
  55                 my $i = $n++;
  56                 my $x = PublicInbox::Qspawn->new([qw(true)]);
  57                 $x->start($limiter, sub {
  58                         my ($rpipe) = @_;
  59                         push @run, $i;
  60                 });
  61                 [$x, $i]
  62         } (0..2);
  63
  64         if ($cmd->[-1] =~ /false\z/) {
  65                 ok(finish_err($s), 'got error on false after sleep');
  66         } else {
  67                 ok(!finish_err($s), 'no error on sleep');
  68         }
  69         ok(!finish_err($_->[0]), "true $_->[1] succeeded") foreach @t;
  70         is_deeply([qw(sleep 0 1 2)], \@run, 'ran in order');
  71 }
  72
  73 done_testing();
  74
  75 1;