X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=t%2Fqspawn.t;h=9c42e10018c1d435dac42518b46a15be470234e2;hb=5bde05b66f084c7c9dcf7389079aab6925aef328;hp=05072e24d142bbfacd4d3d17725e17b927898a1e;hpb=3f779258173530ca88f31e1dc5332f951d2c44cd;p=public-inbox.git diff --git a/t/qspawn.t b/t/qspawn.t index 05072e24..9c42e100 100644 --- a/t/qspawn.t +++ b/t/qspawn.t @@ -2,10 +2,12 @@ # License: AGPL-3.0+ use Test::More; use_ok 'PublicInbox::Qspawn'; + +my $limiter = PublicInbox::Qspawn::Limiter->new(1); { my $x = PublicInbox::Qspawn->new([qw(true)]); my $run = 0; - $x->start(sub { + $x->start($limiter, sub { my ($rpipe) = @_; is(0, sysread($rpipe, my $buf, 1), 'read zero bytes'); ok(!$x->finish, 'no error on finish'); @@ -17,7 +19,7 @@ use_ok 'PublicInbox::Qspawn'; { my $x = PublicInbox::Qspawn->new([qw(false)]); my $run = 0; - $x->start(sub { + $x->start($limiter, sub { my ($rpipe) = @_; is(0, sysread($rpipe, my $buf, 1), 'read zero bytes from false'); my $err = $x->finish; @@ -30,7 +32,7 @@ use_ok 'PublicInbox::Qspawn'; foreach my $cmd ([qw(sleep 1)], [qw(sh -c), 'sleep 1; false']) { my $s = PublicInbox::Qspawn->new($cmd); my @run; - $s->start(sub { + $s->start($limiter, sub { my ($rpipe) = @_; push @run, 'sleep'; is(0, sysread($rpipe, my $buf, 1), 'read zero bytes'); @@ -39,7 +41,7 @@ foreach my $cmd ([qw(sleep 1)], [qw(sh -c), 'sleep 1; false']) { my @t = map { my $i = $n++; my $x = PublicInbox::Qspawn->new([qw(true)]); - $x->start(sub { + $x->start($limiter, sub { my ($rpipe) = @_; push @run, $i; });