| line |
true |
false |
branch |
|
233
|
0 |
0 |
if ($callback) { } |
|
234
|
0 |
0 |
if defined wantarray |
|
238
|
0 |
0 |
unless defined wantarray |
|
239
|
0 |
0 |
ref $SIG{'__DIE__'} eq 'GLOB' ? : |
|
|
0 |
0 |
ref $SIG{'__DIE__'} eq 'CODE' ? : |
|
240
|
0 |
0 |
if $olddie |
|
249
|
0 |
0 |
if $$message{'continue'} and not $conn |
|
252
|
0 |
0 |
$$message{'continue'} ? : |
|
254
|
0 |
0 |
if ref $$message{'continue'} eq 'CODE' |
|
255
|
0 |
0 |
if $error |
|
260
|
0 |
0 |
if $$message{'continue'} |
|
287
|
0 |
0 |
if ($callback) { } |
|
288
|
0 |
0 |
if defined wantarray |
|
295
|
0 |
0 |
blessed $data ? : |
|
305
|
0 |
0 |
unless defined wantarray |
|
306
|
0 |
0 |
ref $SIG{'__DIE__'} eq 'GLOB' ? : |
|
|
0 |
0 |
ref $SIG{'__DIE__'} eq 'CODE' ? : |
|
307
|
0 |
0 |
if $olddie |
|
312
|
0 |
0 |
blessed $data ? : |
|
324
|
0 |
0 |
@_ == 1 ? : |
|
325
|
0 |
0 |
if ref $message eq 'HASH' |
|
327
|
0 |
0 |
unless eval {
do {
$data = $self->send($message);
1
}
} |
|
328
|
0 |
0 |
wantarray ? : |
|
333
|
0 |
0 |
@_ == 1 ? : |
|
335
|
0 |
0 |
$@ =~ /^(.*?) at \S+ line \d+/s ? : |
|
|
0 |
0 |
eval {
do {
$data = $self->send($message);
1
}
} ? : |
|
506
|
0 |
0 |
if ($self->_in_progress < $self->max_parallel) { } |
|
508
|
0 |
0 |
unless eval {
do {
$self->_send_now($message, $callback);
1
}
} |
|
519
|
0 |
0 |
if (my $task = shift @{$self->_queue;}) { } |
|
520
|
0 |
0 |
unless eval {
do {
$self->_send_now(@$task);
1
}
} |
|
533
|
0 |
0 |
if (ref $message ne 'HASH') { } |
|
536
|
0 |
0 |
unless $response_class |
|
548
|
0 |
0 |
unless $$message{'unpack'} or $$message{'no_reply'} |
|
551
|
0 |
0 |
ref $$message{'data'} ? : |
|
|
0 |
0 |
exists $$args{'payload'} ? : |
|
570
|
0 |
0 |
$sync ? : |
|
572
|
0 |
0 |
if $self->debug >= 2 |
|
575
|
0 |
0 |
unless $connection->send($$args{'msg'}, $$args{'body'}, $handler, $$args{'no_reply'}, $$args{'sync'}) |
|
576
|
0 |
0 |
if $sync |
|
583
|
0 |
0 |
if ($sync) { } |
|
606
|
0 |
0 |
if ($error) { } |
|
609
|
0 |
0 |
ref $$args{'retry'} eq 'CODE' ? : |
|
|
0 |
0 |
defined $$args{'request'} ? : |
|
612
|
0 |
0 |
if $self->debug >= 2 |
|
613
|
0 |
0 |
if ($retry and $$try++ < $$args{'max_request_retries'}) { } |
|
623
|
0 |
0 |
unless $$args{'no_reply'} or $resp_msg == $$args{'msg'} |
|
625
|
0 |
0 |
if (defined $$args{'request'}) { } |
|
629
|
0 |
0 |
ref $$args{'unpack'} eq 'CODE' ? : |
|
|
0 |
0 |
$$args{'no_reply'} ? : |
|
633
|
0 |
0 |
if ($ok) { } |
|
634
|
0 |
0 |
if (defined $$args{'request'} and $data->retry and $$try++ < $$args{'max_request_retries'}) { } |
|
|
0 |
0 |
elsif (defined $$args{'is_retry'} and $$args{'is_retry'}($data) and $$try++ < $$args{'max_request_retries'}) { } |
|
642
|
0 |
0 |
unless $sync |
|
652
|
0 |
0 |
unless (eval {
do {
if ($error) {
$! = $errno;
$@ = $error;
my $retry = defined $$args{'request'} ? $$args{'request'}->retry : (ref $$args{'retry'} eq 'CODE' ? $$args{'retry'}() : $$args{'retry'});
$self->_debug("send: failed[@{[$retry, $$try + 1, $$args{'max_request_retries'}];}]") if $self->debug >= 2;
if ($retry and $$try++ < $$args{'max_request_retries'}) {
$self->_send_retry($sync, $args, $$handler, $$try);
}
else {
undef $$handler;
$self->_report_error($$args{'request'}, $callback, $error, $sync, $errno);
} ;
}
else {
my $ok = eval {
do {
die "Request and reply message code is different: $resp_msg != $$args{'msg'}\n" unless $$args{'no_reply'} or $resp_msg == $$args{'msg'};
if (defined $$args{'request'}) {
$data = $$args{'response_class'}->new('data', $data, 'request', $$args{'request'});
}
else {
$data = $$args{'no_reply'} ? [0] : [ref $$args{'unpack'} eq 'CODE' ? $$args{'unpack'}($data) : unpack($$args{'unpack'}, $data)];
} ;
1
}
};
if ($ok) {
if (defined $$args{'request'} and $data->retry and $$try++ < $$args{'max_request_retries'}) {
$self->_send_retry($sync, $args, $$handler, $$try);
}
elsif (defined $$args{'is_retry'} and $$args{'is_retry'}($data) and $$try++ < $$args{'max_request_retries'}) {
$self->_send_retry($sync, $args, $$handler, $$try);
}
else {
undef $$handler;
$self->_finish_and_start unless $sync;
&$callback($data);
} ;
}
else {
undef $$handler;
$self->_report_error($$args{'request'}, $callback, $@, $sync);
} ;
} ;
1
}
}) |
|
670
|
0 |
0 |
defined $errno ? : |
|
|
0 |
0 |
defined $request && ref $request ne 'HASH' ? : |
|
677
|
0 |
0 |
unless $sync |