1
#!/usr/bin/env perl
2
#
3
# pe was written by Omar Polo <op@openbsd.org> and is placed in the
4
# public domain.  The author hereby disclaims copyright to this source
5
# code.
6

7
use open ":std", ":encoding(UTF-8)";
8
use strict;
9
use warnings;
10
use v5.32;
11
use IO::Poll qw(POLLOUT);
12

13
use OpenBSD::Pledge;
14
use OpenBSD::Unveil;
15

16
my $jobs = $ENV{'MAKE_JOBS'} // 1;
17

18
my $poll = IO::Poll->new();
19
for (1..$jobs) {
20
	open(my $kid, '|-', './mexp') or die "can't exec ./mexp: $!";
21
	$poll->mask($kid => POLLOUT);
22
}
23

24
sub process {
25
	die "poll: $!" if $poll->poll() == -1;
26
	my @handles = $poll->handles(POLLOUT) or die "no procs ready?";
27
	my $handle = $handles[int(rand(@handles))];
28
	print $handle $_ foreach @_;
29
}
30

31
unveil("./mexp", "rx") or die "unveil mexp: $!";
32
pledge("stdio proc exec") or die "pledge: $!";
33

34
my @thread;
35
while (<>) {
36
	print; # continue the pipeline
37

38
	my $new_thread = m/^-/;
39
	if ($new_thread && @thread) {
40
		process @thread;
41
		@thread = ();
42
	}
43

44
	push @thread, $_;
45
}
46

47
process @thread if @thread;