line |
true |
false |
branch |
39
|
0 |
28 |
unless defined $self->{'work_handler'} |
62
|
0 |
86 |
if ($@) |
78
|
0 |
43 |
unless defined $n |
100
|
43 |
1 |
unless defined $args{'blocking'} |
101
|
0 |
44 |
unless $self->pending |
106
|
31 |
13 |
unless (@{$self->{'result_queue'};}) |
111
|
1 |
0 |
unless ($args{'blocking'} or @{$self->{'result_queue'};}) |
119
|
0 |
6 |
if ($self->{'pending'} == 0 and $self->{'shutting_down'}) |
124
|
43 |
0 |
$self->{'result_handler'} ? : |
125
|
0 |
43 |
unless defined $retval |
153
|
0 |
6 |
if ($args{'force'}) { } |
|
0 |
6 |
elsif ($self->pending) { } |
171
|
0 |
127 |
if ($^O eq 'MSWin32') { } |
175
|
0 |
0 |
$makeblocking ? : |
181
|
0 |
0 |
unless ioctl $socket, 2147772030, $plong |
187
|
0 |
127 |
unless my $flags = fcntl($socket, 3, 0) |
190
|
54 |
73 |
if ($blocking and not $makeblocking) { } |
|
1 |
72 |
elsif (not $blocking and $makeblocking) { } |
199
|
0 |
55 |
unless fcntl $socket, 4, $flags |
212
|
0 |
28 |
unless socketpair $b1, $b2, 1, 1, 0 |
216
|
0 |
28 |
unless defined $pid |
218
|
6 |
22 |
if ($pid) { } |
247
|
0 |
6 |
if ($@) |
259
|
0 |
47 |
unless socketpair $w1, $w2, 1, 1, 0 |
263
|
0 |
47 |
unless defined $pid |
265
|
31 |
16 |
if ($pid) { } |
288
|
0 |
6 |
if ($@) |
325
|
6 |
0 |
if ($self->{'shutting_down'} and not @{$self->{'job_queue'};} and not @{$self->{'result_queue'};}) |
331
|
0 |
16 |
if (not $workers->{$s}{'idle'}) { } |
|
0 |
16 |
elsif (exists $workers->{$s}{'partial_job'}) { } |
339
|
6 |
0 |
unless ($busy or $partials) |
354
|
59 |
0 |
unless ($self->{'shutting_down'}) |
359
|
20 |
39 |
if (@{$self->{'result_queue'};}) |
368
|
103 |
60 |
if ($workers->{$s}{'idle'}) { } |
369
|
48 |
55 |
if (@{$self->{'job_queue'};} or exists $workers->{$s}{'partial_job'}) |
381
|
0 |
59 |
unless (@rdy) |
382
|
0 |
0 |
if ($! == 4) |
398
|
43 |
12 |
if ($rh != $self->{'app_socket'}) { } |
414
|
48 |
20 |
exists $workers->{$wh} ? : |
421
|
0 |
6 |
if ($@) |
429
|
20 |
48 |
if ($socket == $self->{'app_socket'}) { } |
450
|
0 |
43 |
if (not defined $n) { } |
|
0 |
43 |
elsif ($n == 0) { } |
452
|
0 |
0 |
if ($! == 11) { } |
492
|
48 |
0 |
if (not exists $self->{'workers'}{$socket}{'partial_job'}) { } |
494
|
43 |
5 |
if (@{$self->{'job_queue'};}) { } |
509
|
0 |
43 |
if (not defined $n) { } |
|
0 |
43 |
elsif ($n == 0) { } |
511
|
0 |
0 |
if ($! == 11) { } |
547
|
59 |
86 |
unless defined $rstream |
548
|
79 |
66 |
unless defined $$rstream |
552
|
55 |
90 |
if ($iam eq 'boss') { } |
553
|
12 |
43 |
if ($socket == $self->{'app_socket'}) { } |
566
|
50 |
145 |
if (not defined $n) { } |
|
22 |
123 |
elsif ($n == 0) { } |
567
|
0 |
50 |
if ($! == 4) { } |
|
50 |
0 |
elsif ($! == 11) { } |
583
|
6 |
16 |
if ($iam eq 'boss') { } |
|
16 |
0 |
elsif ($iam eq 'worker') { } |
584
|
6 |
0 |
if ($socket == $self->{'app_socket'}) { } |
|
0 |
0 |
elsif (exists $self->{'workers'}{$socket}) { } |
611
|
123 |
0 |
if ($records[$#records] =~ /$self->{'msg_delimiter'}$/) { } |
617
|
43 |
80 |
if (exists $self->{'workers'}{$socket}) |
627
|
73 |
50 |
if $rcount and $iam ne 'boss' |
644
|
3 |
13 |
if ($self->{'init_handler'}) |
652
|
43 |
59 |
if (defined $result_stream) { } |
657
|
0 |
43 |
unless defined $n |
658
|
43 |
0 |
if defined $n |
668
|
16 |
43 |
unless @queue |
689
|
1 |
42 |
if ($@) |
700
|
3 |
13 |
if ($self->{'exit_handler'}) |
705
|
0 |
16 |
if $@ |
706
|
0 |
16 |
if ($errm) |
717
|
0 |
1461 |
if $self->{'verbose'} |