line |
true |
false |
branch |
70
|
2 |
0 |
unless ref $self |
136
|
0 |
0 |
unless $client |
137
|
0 |
0 |
unless $sleeping->{$client} |
139
|
0 |
0 |
if ($new_sleepers_list) { } |
146
|
0 |
0 |
unless %$sleeping |
170
|
0 |
0 |
unless defined $bref |
172
|
0 |
0 |
if ($self->{'fast_read'}) { } |
177
|
0 |
0 |
if $self->{'fast_read'} > 0 |
189
|
0 |
0 |
if (length $$bref == 61440) |
194
|
0 |
0 |
if length $$cref < 61440 or $limit-- < 1 |
206
|
0 |
0 |
if ($self->{'read_buf'} =~ /^\0REQ(.{8,8})/s) { } |
|
0 |
0 |
elsif ($self->{'read_buf'} =~ s/^(\w.+?)?\r?\n//) { } |
208
|
0 |
0 |
if ($blen < $len + 12) |
241
|
0 |
0 |
if $done |
254
|
0 |
0 |
if ($line and $line =~ /^(\w+)\s*(.*)/) |
258
|
0 |
0 |
if ($code) |
304
|
0 |
0 |
unless $job and $job->worker == $self |
321
|
0 |
0 |
unless $job and $job->worker == $self |
328
|
0 |
0 |
if (my $timer = $self->{'timer'}) |
341
|
0 |
0 |
unless $job and $job->worker == $self |
347
|
0 |
0 |
if (my $timer = $self->{'timer'}) |
363
|
0 |
0 |
unless $job and $job->worker == $self |
386
|
0 |
0 |
unless ($can_do_size) |
400
|
0 |
0 |
unless $job = $self->{'server'}->grab_job($job_to_grab) |
407
|
0 |
0 |
if (defined $timeout) |
411
|
0 |
0 |
unless $job->worker == $self |
445
|
0 |
0 |
if (defined $timeout) { } |
463
|
0 |
0 |
if ($$ar eq 'exceptions') |
477
|
0 |
0 |
unless length $self->{'client_id'} |
494
|
0 |
0 |
if $$ar =~ /\0/ |
499
|
0 |
0 |
if ($job) |
501
|
0 |
0 |
$job->worker ? : |
502
|
0 |
0 |
if (my $stat = $job->status) |
507
|
0 |
0 |
unless defined $num |
508
|
0 |
0 |
unless defined $den |
537
|
0 |
0 |
unless $$ar =~ s/^(.+?)\0(.*?)\0// |
545
|
0 |
0 |
if ($subscribe) { } |
578
|
0 |
0 |
unless $@ |
673
|
0 |
0 |
if ($job->worker) |
715
|
0 |
0 |
if (my $worker = $job->worker) |
774
|
0 |
0 |
if (my $worker = $job->worker) |
789
|
0 |
0 |
if ($has_gladiator) |
794
|
0 |
0 |
if (ref $it eq 'CODE') |
796
|
0 |
0 |
if $name =~ /ANON/ |
801
|
0 |
0 |
unless $ct{$n} > 1 or $args eq 'all' |
826
|
0 |
0 |
unless (length $func) |
867
|
0 |
0 |
unless $a |