1 #!/usr/bin/env perl
2 
3 use open ":std", ":encoding(UTF-8)";
4 use strict;
5 use warnings;
6 use v5.32;
7 use IO::Poll qw(POLLOUT);
8 
9 use OpenBSD::Pledge;
10 use OpenBSD::Unveil;
11 
12 my $jobs = $ENV{'MAKE_JOBS'} // 1;
13 
14 my $poll = IO::Poll->new();
15 for (1..$jobs) {
16 	open(my $kid, '|-', './mexp') or die "can't exec ./mexp: $!";
17 	$poll->mask($kid => POLLOUT);
18 }
19 
20 sub process {
21 	die "poll: $!" if $poll->poll() == -1;
22 	my @handles = $poll->handles(POLLOUT) or die "no procs ready?";
23 	my $handle = $handles[int(rand(@handles))];
24 	say $handle $_ foreach @_;
25 }
26 
27 unveil("./mexp", "rx") or die "unveil mexp: $!";
28 pledge("stdio proc exec") or die "pledge: $!";
29 
30 my @thread;
31 while (<>) {
32 	print; # continue the pipeline
33 	chomp;
34 
35 	m/^([^ ]+) <([^>]+)> (.+)(\d{4}-\d{2}-\d{2} \d{2}:\d{2}) <([^>]+)> (.*)/;
36 	die "can't parse: $_" unless defined $1;
37 
38 	my $level = length($3) - 1;
39 	$level = 10 if $3 =~ m/\.\.\d{2}\.\./;
40 
41 	if ($level == 0 && @thread) {
42 		process @thread;
43 		@thread = ();
44 	}
45 
46 	push @thread, $_;
47 }
48 
49 process @thread if @thread;