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;