| line |
true |
false |
branch |
|
147
|
52 |
73 |
if ($self->num_workers >= $self->max_workers)
|
|
148
|
52 |
0 |
if ($$args{'enqueue'}) { }
|
|
159
|
67 |
6 |
unless (&blessed($job) and $job->isa('MooseX::Workers::Job'))
|
|
163
|
0 |
73 |
if $^O eq 'MSWin32'
|
|
169
|
13 |
60 |
if $self->stdout_filter
|
|
170
|
2 |
71 |
if $self->stderr_filter
|
|
172
|
0 |
73 |
if defined $args and not ref $args eq 'ARRAY'
|
|
174
|
1 |
72 |
$args ? :
|
|
191
|
2 |
71 |
if ($job->timeout)
|
|
196
|
71 |
2 |
unless defined $job->name
|
|
205
|
0 |
0 |
unless $^O eq 'MSWin32'
|
|
209
|
0 |
0 |
if ($job->is_coderef) { }
|
|
222
|
0 |
0 |
unless $job->args
|
|
228
|
0 |
0 |
if (not $visitor_stash->has_symbol('$__MX_WORKERS_STDIO_FIXED_UP'))
|
|
234
|
0 |
0 |
if (!defined($filter) || &blessed($filter) && $filter->isa('POE::Filter::Line') and $visitor->can($method))
|
|
240
|
0 |
0 |
if $was_immutable
|
|
250
|
0 |
0 |
if $was_immutable
|
|
262
|
1 |
0 |
if $self->visitor->can('worker_timeout')
|
|
265
|
0 |
1 |
$^O eq 'MSWin32' && $job->is_coderef ? :
|
|
270
|
14 |
1 |
if $self->visitor->can('worker_manager_start')
|
|
281
|
1 |
1 |
if uc $sig eq 'CHLD' or uc $sig eq 'CHILD'
|
|
290
|
14 |
1 |
if $self->visitor->can('worker_manager_stop')
|
|
297
|
1 |
72 |
if $self->visitor->can('sig_child')
|
|
313
|
72 |
0 |
if $self->visitor->can('worker_stdout')
|
|
321
|
70 |
0 |
if $self->visitor->can('worker_stderr')
|
|
327
|
146 |
0 |
if $_[10] eq 'read' and $_[11] == 0
|
|
330
|
0 |
0 |
if $self->visitor->can('worker_error')
|
|
337
|
2 |
71 |
if $$heap{'wheel_to_timer'}{$wheel_id}
|
|
339
|
50 |
23 |
if $self->visitor->can('worker_done')
|
|
344
|
72 |
1 |
if (my $code = $self->visitor->can('worker_finished'))
|
|
368
|
73 |
0 |
if $self->visitor->can('worker_started')
|