7 use TAP::Parser::Scheduler;
11 { seq => '../ext/DB_File/t/*' },
12 { seq => '../ext/IO_Compress_Zlib/t/*' },
13 { seq => '../lib/CPANPLUS/*' },
14 { seq => '../lib/ExtUtils/t/*' },
19 my $incomplete_rules = { par => [ { seq => [ '*A', '*D' ] } ] };
36 { name => 'Sequential, no rules',
40 { name => 'Sequential, Perl rules',
45 { name => 'Two in parallel, Perl rules',
50 { name => 'Massively parallel, Perl rules',
55 { name => 'Massively parallel, no rules',
59 { name => 'Sequential, incomplete rules',
60 rules => $incomplete_rules,
64 { name => 'Two in parallel, incomplete rules',
65 rules => $incomplete_rules,
69 { name => 'Massively parallel, incomplete rules',
70 rules => $incomplete_rules,
76 plan tests => @schedule * 2 + 266;
78 for my $test (@schedule) {
91 A1 A2 A3 B1 C1 C8 C5 C7 C4 C6 C3 C2 C9 D1 D2 D3 E3 E2 E1
98 { seq => [ 'C1', 'C2' ] },
100 { seq => [ 'C3', 'C4', 'C5' ] },
101 { seq => [ 'C6', 'C7', 'C8' ] }
112 my $scheduler = TAP::Parser::Scheduler->new(
117 # diag $scheduler->as_string;
119 my $A1 = ok_job( $scheduler, 'A1' );
120 my $B1 = ok_job( $scheduler, 'B1' );
122 my $A2 = ok_job( $scheduler, 'A2' );
123 my $C1 = ok_job( $scheduler, 'C1' );
125 my $A3 = ok_job( $scheduler, 'A3' );
126 my $C2 = ok_job( $scheduler, 'C2' );
128 my $C3 = ok_job( $scheduler, 'C3' );
129 my $C6 = ok_job( $scheduler, 'C6' );
130 my $D1 = ok_job( $scheduler, 'D1' );
131 my $D2 = ok_job( $scheduler, 'D2' );
133 my $C7 = ok_job( $scheduler, 'C7' );
134 my $D3 = ok_job( $scheduler, 'D3' );
135 ok_job( $scheduler, '#' );
136 ok_job( $scheduler, '#' );
137 finish( $D3, $C3, $D1, $B1 );
138 my $C4 = ok_job( $scheduler, 'C4' );
140 my $C5 = ok_job( $scheduler, 'C5' );
141 my $C8 = ok_job( $scheduler, 'C8' );
142 ok_job( $scheduler, '#' );
144 my $E3 = ok_job( $scheduler, 'E3' );
145 my $E2 = ok_job( $scheduler, 'E2' );
146 my $E1 = ok_job( $scheduler, 'E1' );
147 finish( $E1, $E2, $E3, $C5, $C8 );
148 my $C9 = ok_job( $scheduler, 'C9' );
149 ok_job( $scheduler, undef );
154 for my $t ( 'A' .. 'Z' ) {
155 push @tests, map {"$t$_"} 1 .. 9;
157 my $rules = { par => [ map { { seq => "$_*" } } 'A' .. 'Z' ] };
159 my $scheduler = TAP::Parser::Scheduler->new(
164 # diag $scheduler->as_string;
166 for my $n ( 1 .. 9 ) {
168 push @got, ok_job( $scheduler, "$_$n" ) for 'A' .. 'Z';
169 ok_job( $scheduler, $n == 9 ? undef : '#' );
174 sub finish { $_->finish for @_ }
177 my ( $scheduler, $want ) = @_;
178 my $job = $scheduler->get_job;
179 if ( !defined $want ) {
180 ok !defined $job, 'undef';
182 elsif ( $want eq '#' ) {
183 ok $job->is_spinner, 'spinner';
186 is $job->filename, $want, $want;
192 my ( $name, $tests, $rules, $jobs ) = @_;
194 ok my $scheduler = TAP::Parser::Scheduler->new(
196 defined $rules ? ( rules => $rules ) : (),
200 # diag $scheduler->as_string;
205 while ( defined( my $job = $scheduler->get_job ) ) {
207 # diag $scheduler->as_string;
208 if ( $job->is_spinner || @pipeline >= $jobs ) {
209 die "Oops! Spinner!" unless @pipeline;
210 my $done = shift @pipeline;
213 # diag "Completed ", $done->filename;
215 next if $job->is_spinner;
217 # diag " Got ", $job->filename;
218 push @pipeline, $job;
220 push @got, $job->filename;
223 is_deeply [ sort @got ], [ sort @$tests ], "$name: got all tests";