| line |
true |
false |
branch |
|
43
|
0 |
0 |
@_ == 1 ? : |
|
47
|
0 |
0 |
unless $$args{'servers'} |
|
63
|
0 |
0 |
if $$self{'report_errors'} |
|
69
|
0 |
0 |
if $$self{'report_errors'} |
|
76
|
0 |
0 |
if ($$self{'random_servers'} and not $internal) { } |
|
80
|
0 |
0 |
if (not defined $$self{'current_server'}) { } |
|
94
|
0 |
0 |
if ($internal and $$self{'_connect_retries'}++ >= $$self{'max_autoretry'}) |
|
104
|
0 |
0 |
if (defined $sock) |
|
117
|
0 |
0 |
if ($$self{'connect_timeout'}) { } |
|
125
|
0 |
0 |
if (not $ret and $$self{'connect_timeout'} and $! == 115) |
|
130
|
0 |
0 |
if (select(undef, $win, undef, $$self{'connect_timeout'}) > 0) |
|
133
|
0 |
0 |
if not $ret and $! == 106 |
|
137
|
0 |
0 |
unless ($$self{'connect_timeout'}) |
|
151
|
0 |
0 |
unless $ret |
|
165
|
0 |
0 |
if (/OK (\d+)/) { } |
|
180
|
0 |
0 |
unless $FLAG_NOSIGNAL |
|
182
|
0 |
0 |
unless $$self{'select_timeout'} |
|
186
|
0 |
0 |
if ($last_state != $state) |
|
187
|
0 |
0 |
if $state == 3 |
|
189
|
0 |
0 |
if $state == 1 or $state == 2 |
|
190
|
0 |
0 |
if $state == 0 |
|
195
|
0 |
0 |
unless $nfound |
|
197
|
0 |
0 |
if (vec $wout, fileno $sock, 1) |
|
200
|
0 |
0 |
if not defined $res and $! == 11 |
|
202
|
0 |
0 |
if (not defined $res or $res <= 0) |
|
207
|
0 |
0 |
if ($res == length $line) { } |
|
214
|
0 |
0 |
if (vec $rout, fileno $sock, 1) |
|
218
|
0 |
0 |
if not defined $res and $! == 11 |
|
220
|
0 |
0 |
if ($res <= 0) |
|
227
|
0 |
0 |
if ($state == 1 and $ret =~ /\r\n/) |
|
229
|
0 |
0 |
unless defined $return[0] |
|
239
|
0 |
0 |
if ($state == 2 and $offset - 2 == $toread) |
|
247
|
0 |
0 |
unless ($state == 3) |
|
252
|
0 |
0 |
unless $$self{'select_timeout'} |
|
275
|
0 |
0 |
unless $FLAG_NOSIGNAL |
|
279
|
0 |
0 |
if ($last_state != $state) |
|
280
|
0 |
0 |
if $state == 2 |
|
282
|
0 |
0 |
if $state == 1 |
|
283
|
0 |
0 |
if $state == 0 |
|
288
|
0 |
0 |
unless $nfound |
|
290
|
0 |
0 |
if (vec $wout, fileno $sock, 1) |
|
293
|
0 |
0 |
if not defined $res and $! == 11 |
|
295
|
0 |
0 |
if (not defined $res or $res <= 0) |
|
300
|
0 |
0 |
if ($res == length $line) { } |
|
307
|
0 |
0 |
if (vec $rout, fileno $sock, 1) |
|
310
|
0 |
0 |
if not defined $res and $! == 11 |
|
312
|
0 |
0 |
if ($res <= 0) |
|
319
|
0 |
0 |
if &$check_complete(\$ret) |
|
323
|
0 |
0 |
unless ($state == 2) |
|
337
|
0 |
0 |
if ($message =~ /DRAINING/i) |
|
352
|
0 |
0 |
defined $ttr ? : |
|
356
|
0 |
0 |
unless defined $ret |
|
358
|
0 |
0 |
if $$self{'auto_next_server'} |
|
360
|
0 |
0 |
if ($ret =~ /INSERTED (\d+)/) |
|
364
|
0 |
0 |
if $ret =~ /BURIED/ |
|
368
|
0 |
0 |
unless $self->handle_errors($ret, 'put', @_) |
|
374
|
0 |
0 |
defined $_[0] ? : |
|
377
|
0 |
0 |
if ($_[0] =~ /ok (\d+)/i) { } |
|
385
|
0 |
0 |
if ($result) { } |
|
396
|
0 |
0 |
if ($$self{'job_id'}) |
|
411
|
0 |
0 |
if ($_[0] =~ /reserved (\d+) (\d+) (\d+)/i) { } |
|
418
|
0 |
0 |
unless defined $bytes |
|
432
|
0 |
0 |
if ($$self{'job_id'}) |
|
436
|
0 |
0 |
defined $delay ? : |
|
442
|
0 |
0 |
if ($res =~ /RELEASED|BURIED/) |
|
447
|
0 |
0 |
if $$self{'auto_next_server'} |
|
449
|
0 |
0 |
if $res =~ /RELEASED/i |
|
450
|
0 |
0 |
if $res =~ /BURIED/i |
|
459
|
0 |
0 |
unless (defined $$self{'job_id'} and $$self{'job_id'}) |
|
466
|
0 |
0 |
if ($res =~ /DELETED/) |
|
471
|
0 |
0 |
if $$self{'auto_next_server'} |