| line |
true |
false |
branch |
|
38
|
0 |
23 |
unless defined $$self{'work_handler'} |
|
61
|
0 |
66 |
if ($@) |
|
77
|
0 |
33 |
unless defined $n |
|
99
|
33 |
1 |
unless defined $args{'blocking'} |
|
100
|
0 |
34 |
unless $self->pending |
|
105
|
20 |
14 |
unless (@{$$self{'result_queue'};}) |
|
110
|
1 |
0 |
unless ($args{'blocking'} or @{$$self{'result_queue'};}) |
|
118
|
0 |
33 |
if ($$self{'pending'} == 0 and $$self{'shutting_down'}) |
|
123
|
33 |
0 |
$$self{'result_handler'} ? : |
|
124
|
0 |
33 |
unless defined $retval |
|
152
|
0 |
5 |
if ($args{'force'}) { } |
|
|
0 |
5 |
elsif ($self->pending) { } |
|
168
|
0 |
96 |
unless my $flags = fcntl($socket, 3, 0) |
|
171
|
44 |
52 |
if ($blocking and not $makeblocking) { } |
|
|
1 |
51 |
elsif (not $blocking and $makeblocking) { } |
|
180
|
0 |
45 |
unless fcntl $socket, 4, $flags |
|
191
|
0 |
23 |
unless socketpair $b1, $b2, 1, 1, 0 |
|
195
|
0 |
23 |
unless defined $pid |
|
197
|
5 |
18 |
if ($pid) { } |
|
226
|
0 |
5 |
if ($@) |
|
238
|
0 |
38 |
unless socketpair $w1, $w2, 1, 1, 0 |
|
242
|
0 |
38 |
unless defined $pid |
|
244
|
25 |
13 |
if ($pid) { } |
|
267
|
0 |
5 |
if ($@) |
|
304
|
5 |
0 |
if ($$self{'shutting_down'} and not @{$$self{'job_queue'};} and not @{$$self{'result_queue'};}) |
|
310
|
0 |
13 |
if (not $$workers{$s}{'idle'}) { } |
|
|
0 |
13 |
elsif (exists $$workers{$s}{'partial_job'}) { } |
|
318
|
5 |
0 |
unless ($busy or $partials) |
|
333
|
59 |
0 |
unless ($$self{'shutting_down'}) |
|
338
|
21 |
38 |
if (@{$$self{'result_queue'};}) |
|
347
|
83 |
80 |
if ($$workers{$s}{'idle'}) { } |
|
348
|
37 |
46 |
if (@{$$self{'job_queue'};} or exists $$workers{$s}{'partial_job'}) |
|
360
|
0 |
59 |
unless (@rdy) |
|
361
|
0 |
0 |
if ($! == 4) |
|
377
|
33 |
10 |
if ($rh != $$self{'app_socket'}) { } |
|
393
|
37 |
21 |
exists $$workers{$wh} ? : |
|
400
|
0 |
5 |
if ($@) |
|
408
|
21 |
37 |
if ($socket == $$self{'app_socket'}) { } |
|
429
|
0 |
33 |
if (not defined $n) { } |
|
|
0 |
33 |
elsif ($n == 0) { } |
|
431
|
0 |
0 |
if ($! == 11) { } |
|
471
|
37 |
0 |
if (not exists $$self{'workers'}{$socket}{'partial_job'}) { } |
|
473
|
33 |
4 |
if (@{$$self{'job_queue'};}) { } |
|
488
|
0 |
33 |
if (not defined $n) { } |
|
|
0 |
33 |
elsif ($n == 0) { } |
|
490
|
0 |
0 |
if ($! == 11) { } |
|
526
|
46 |
63 |
unless defined $rstream |
|
527
|
62 |
47 |
unless defined $$rstream |
|
531
|
43 |
66 |
if ($iam eq 'boss') { } |
|
532
|
10 |
33 |
if ($socket == $$self{'app_socket'}) { } |
|
545
|
39 |
109 |
if (not defined $n) { } |
|
|
18 |
91 |
elsif ($n == 0) { } |
|
546
|
0 |
39 |
if ($! == 4) { } |
|
|
39 |
0 |
elsif ($! == 11) { } |
|
562
|
5 |
13 |
if ($iam eq 'boss') { } |
|
|
13 |
0 |
elsif ($iam eq 'worker') { } |
|
563
|
5 |
0 |
if ($socket == $$self{'app_socket'}) { } |
|
|
0 |
0 |
elsif (exists $$self{'workers'}{$socket}) { } |
|
590
|
91 |
0 |
if ($records[$#records] =~ /$$self{'msg_delimiter'}$/) { } |
|
596
|
33 |
58 |
if (exists $$self{'workers'}{$socket}) |
|
606
|
52 |
39 |
if $rcount and $iam ne 'boss' |
|
623
|
0 |
13 |
if ($$self{'init_handler'}) |
|
631
|
33 |
46 |
if (defined $result_stream) { } |
|
636
|
0 |
33 |
unless defined $n |
|
637
|
33 |
0 |
if defined $n |
|
647
|
13 |
33 |
unless @queue |
|
668
|
1 |
32 |
if ($@) |
|
677
|
0 |
13 |
if ($@) |
|
688
|
0 |
1133 |
if $$self{'verbose'} |