| line |
true |
false |
branch |
|
55
|
0 |
0 |
unless $self->{'_cmd_cb'} |
|
61
|
0 |
0 |
unless (shift())->{'_reserve_pending'} |
|
68
|
0 |
0 |
if ($condvar) |
|
89
|
0 |
0 |
unless @_ and $_[0] eq 'USING' |
|
97
|
0 |
0 |
unless @_ and $_[0] eq 'WATCHING' |
|
132
|
0 |
0 |
if (@_) |
|
138
|
0 |
0 |
if $self->{'_sock'} |
|
143
|
0 |
0 |
unless my $fh = shift() |
|
149
|
0 |
0 |
if $on_connect |
|
164
|
0 |
0 |
if @_ and &blessed($_[-1]) eq 'AnyEvent::CondVar' |
|
165
|
0 |
0 |
if @_ and ref $_[-1] eq 'CODE' |
|
168
|
0 |
0 |
$command eq 'put' ? : |
|
182
|
0 |
0 |
if $cb |
|
184
|
0 |
0 |
if $command =~ /^reserve/ |
|
194
|
0 |
0 |
if $command =~ /^reserve/ |
|
196
|
0 |
0 |
unless ($resp eq $EXPECT{$command}) |
|
202
|
0 |
0 |
if ($resp =~ /^ (?: RESERVED | FOUND ) $/x) { } |
|
|
0 |
0 |
elsif ($resp =~ /^ (?: INSERTED | BURIED ) $/x) { } |
|
|
0 |
0 |
elsif ($resp eq 'OK') { } |
|
|
0 |
0 |
elsif ($resp =~ /^ (?: RELEASED | TOUCHED ) $/x) { } |
|
|
0 |
0 |
elsif ($resp =~ /^ (?: USING | WATCHING ) $/x) { } |
|
220
|
0 |
0 |
$resp eq 'BURIED' ? : |
|
238
|
0 |
0 |
if $command =~ /^stats/ |
|
246
|
0 |
0 |
$command eq 'release' ? : |
|
274
|
0 |
0 |
unless $self->{'_connect_queue'} |
|
286
|
0 |
0 |
if @_ and ref $_[-1] eq 'CODE' |
|
296
|
0 |
0 |
if $cb |
|
298
|
0 |
0 |
unless (@_) |
|
312
|
0 |
0 |
unless $r and $r =~ /^OK\b/ |
|
315
|
0 |
0 |
unless delete $tubes{$t} |
|
318
|
0 |
0 |
unless (keys %tubes) |
|
324
|
0 |
0 |
$tubes{$t} ? : |
|
328
|
0 |
0 |
if ($_[1] and $_[1] =~ /^WATCHING\b/) { } |
|
329
|
0 |
0 |
$tubes{$t} ? : |
|
331
|
0 |
0 |
unless @err |
|
334
|
0 |
0 |
@err ? : |
|
|
0 |
0 |
unless keys %tubes |
|
348
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
351
|
0 |
0 |
exists $opt->{'priority'} ? : |
|
352
|
0 |
0 |
exists $opt->{'ttr'} ? : |
|
353
|
0 |
0 |
exists $opt->{'delay'} ? : |
|
357
|
0 |
0 |
exists $opt->{'encode'} ? : |
|
|
0 |
0 |
exists $opt->{'data'} ? : |
|
362
|
0 |
0 |
unless defined $data |
|
364
|
0 |
0 |
if utf8::is_utf8($data) |
|
372
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
379
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
387
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
395
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
403
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
410
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
415
|
0 |
0 |
if @_ and $_[1] =~ /^USING\b/ |
|
416
|
0 |
0 |
if @cb |
|
424
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
427
|
0 |
0 |
defined $timeout ? : |
|
434
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
442
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
450
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
454
|
0 |
0 |
exists $opt->{'priority'} ? : |
|
455
|
0 |
0 |
exists $opt->{'delay'} ? : |
|
463
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
467
|
0 |
0 |
exists $opt->{'priority'} ? : |
|
475
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
481
|
0 |
0 |
if @_ and $_[1] =~ /^WATCHING\b/ |
|
482
|
0 |
0 |
if @cb |
|
490
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
496
|
0 |
0 |
if @_ and $_[1] =~ /^WATCHING\b/ |
|
497
|
0 |
0 |
if @cb |
|
505
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
514
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
523
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
532
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
541
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
548
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
555
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
562
|
0 |
0 |
@_ && ref $_[-1] eq 'CODE' ? : |
|
571
|
0 |
0 |
unless $self->{'_sock'} |
|
572
|
0 |
0 |
unless my $watching = $self->{'__watching'} |