| line |
true |
false |
branch |
|
44
|
1 |
3 |
unless (defined $params{'nodes'}) |
|
47
|
1 |
2 |
unless (ref $params{'nodes'} eq 'ARRAY') |
|
50
|
1 |
1 |
unless (@{$params{'nodes'};}) |
|
64
|
9 |
0 |
unless defined $params{$name} |
|
111
|
1 |
0 |
if (@_) |
|
114
|
0 |
1 |
if (defined $on_error) { } |
|
147
|
3 |
0 |
unless (defined $nodes_pool->{$hostport}) |
|
183
|
0 |
0 |
if (defined $self->{'on_node_connect'}) |
|
197
|
0 |
0 |
if (defined $self->{'on_node_disconnect'}) |
|
215
|
0 |
0 |
if ($err_code != 5 and $err_code != 4) |
|
221
|
0 |
0 |
if (defined $self->{'on_node_error'}) |
|
234
|
0 |
0 |
if (ref $args->[-1] eq 'CODE' and scalar @{$args;} % 2 > 0) |
|
237
|
0 |
0 |
if ($cmd_name eq 'SUBSCRIBE') { } |
|
248
|
0 |
0 |
if (defined $headers{$name}) |
|
252
|
0 |
0 |
if (exists $ACK_CMDS{$cmd_name}) |
|
262
|
0 |
0 |
unless (defined $cmd->{'on_receipt'}) |
|
269
|
0 |
0 |
if (defined $err) |
|
296
|
0 |
0 |
if (defined $err) |
|
300
|
0 |
0 |
if (defined $on_node_error) |
|
305
|
0 |
0 |
if ($CAN_REPEAT{$cmd->{'name'}} and $err_code != 5 and $err_code != 4 and ++$fails_cnt < scalar @{$self->{'_nodes'};}) |
|
328
|
0 |
0 |
defined $cmd->{'message'} ? : |
|
|
0 |
0 |
defined $cmd->{'on_message'} ? : |
|
337
|
0 |
1 |
defined $self->{'_node_index'} ? : |