line |
true |
false |
branch |
58
|
0 |
2 |
unless $ipc_loop |
64
|
0 |
2 |
unless socketpair my $child, my $parent, 1, 2049, 0 |
79
|
0 |
9 |
unless defined $vpid |
80
|
0 |
9 |
unless defined $msg |
81
|
4 |
5 |
if $vpid == 0 |
82
|
0 |
9 |
if $DEBUG |
84
|
0 |
9 |
if $msg eq 'close' or $msg eq 'exit' |
94
|
0 |
1 |
unless defined $vpid |
95
|
0 |
1 |
unless defined $msg |
103
|
0 |
0 |
unless defined $host |
104
|
0 |
0 |
unless defined $port |
106
|
0 |
0 |
if ($sock) { } |
107
|
0 |
0 |
unless &_pack_unpack($sock, %args) |
120
|
0 |
0 |
unless defined $host |
121
|
0 |
0 |
unless defined $port |
126
|
0 |
0 |
if ($rv) { } |
127
|
0 |
0 |
unless &_pack_unpack($sock, %args) |
144
|
0 |
0 |
if (my $pack = $args{'pack'} and my $unpack = $args{'unpack'}) { } |
|
0 |
0 |
elsif ($args{'pack'} or $args{'unpack'}) { } |
147
|
0 |
0 |
if (ref $r eq 'HASH' and ref $r->{'a'} eq 'ARRAY' and $r->{'a'}[0] and $r->{'a'}[0] eq 'b') { } |
155
|
0 |
0 |
if (not $r or $@) |
172
|
0 |
3 |
if $DEBUG > 1 |
181
|
0 |
2 |
unless defined $kid_pid |
183
|
1 |
1 |
if ($kid_pid) { } |
187
|
0 |
1 |
if $_->[2] ne $parent |
253
|
2 |
0 |
unless ($ipc_loop) |
263
|
0 |
1 |
unless defined $waited_vpid |
264
|
0 |
1 |
unless defined $waited_msg |
265
|
0 |
1 |
if $waited_vpid == 0 |
268
|
0 |
0 |
if ($from eq $waited_vpid and $msg eq $waited_msg) |
270
|
0 |
0 |
wantarray ? : |
273
|
0 |
1 |
if $DEBUG |
280
|
0 |
3 |
if $DEBUG |
284
|
8 |
8 |
if (@{$snd{$to};}) |
286
|
0 |
8 |
unless ($fh) |
287
|
0 |
0 |
if (@spawn) { } |
291
|
0 |
0 |
if ($self_parent_fh) { } |
292
|
0 |
0 |
if ($self_parent_closed) { } |
303
|
8 |
0 |
unless (exists $w_bufs{$fh}) |
305
|
0 |
8 |
if (my $pack = $pack{$fh}) { } |
312
|
0 |
8 |
if $DEBUG |
319
|
0 |
17 |
if ($DEBUG > 1) |
320
|
0 |
0 |
$DEBUG > 2 ? : |
325
|
0 |
0 |
$can_write ? : |
|
0 |
17 |
if $DEBUG > 1 |
328
|
0 |
9 |
if ($listener{$fh}) |
342
|
8 |
1 |
if ($len) { } |
|
1 |
0 |
elsif (defined $len) { } |
346
|
8 |
0 |
if (length $buf >= 4) |
348
|
8 |
0 |
if (length $buf >= $packet_length) |
351
|
0 |
8 |
if $DEBUG |
354
|
0 |
8 |
if (my $unpack = $unpack{$fh}) { } |
360
|
0 |
8 |
if ($node{$fh}) |
365
|
0 |
8 |
if $DEBUG |
366
|
8 |
0 |
if ($to == $self_vpid) { } |
|
0 |
0 |
elsif ($vpid2fh{$to}) { } |
367
|
0 |
8 |
if $DEBUG |
368
|
1 |
7 |
if (defined $waited_vpid and defined $waited_msg) { } |
371
|
7 |
0 |
if ($msg{$msg}) { } |
374
|
0 |
0 |
if $DEBUG |
378
|
0 |
0 |
if $DEBUG |
384
|
0 |
8 |
if $r_bufs{$fh} |
399
|
0 |
1 |
if (my $node_vpid = $node{$fh}) { } |
401
|
0 |
0 |
if ($msg{'NODE_CLOSED'}) |
402
|
0 |
0 |
$fh->connected ? : |
|
0 |
0 |
unless $closed{$vpid} |
405
|
0 |
1 |
if ($msg{'SPAWN_CLOSED'}) |
406
|
0 |
0 |
unless $closed{$vpid} |
411
|
1 |
0 |
if ($self_parent_fh and $self_parent_fh eq $fh) |
413
|
1 |
0 |
unless (defined $waited_vpid and defined $waited_msg) |
414
|
1 |
0 |
unless (@rcv) |
420
|
0 |
0 |
if $DEBUG |
425
|
2 |
14 |
if (defined $waited_vpid and defined $waited_msg) { } |
428
|
1 |
0 |
if ($msg eq $waited_msg and $from eq $waited_vpid) |
430
|
0 |
1 |
if $DEBUG |
432
|
0 |
1 |
wantarray ? : |
435
|
0 |
1 |
unless (exists $vpid2fh{$waited_vpid}) |
441
|
7 |
0 |
unless $closed{$from} |
444
|
0 |
14 |
if ($need_reset) |
451
|
0 |
8 |
unless $fh2fh{$fh} |
455
|
8 |
0 |
if ($len) { } |
457
|
0 |
8 |
if (length $buf) { } |
463
|
0 |
0 |
if $DEBUG |