| line |
true |
false |
branch |
|
55
|
18 |
2 |
if ($self->{'handle'}) |
|
73
|
5 |
0 |
if $self->{'on_error'} |
|
74
|
3 |
2 |
if $reconnect |
|
81
|
7 |
1 |
exists $p{'topic'} ? : |
|
82
|
4 |
3 |
exists $p{'qos'} ? : |
|
83
|
1 |
6 |
exists $p{'cv'} ? : |
|
85
|
3 |
4 |
if ($qos) |
|
86
|
2 |
1 |
$qos == 1 ? : |
|
89
|
4 |
3 |
if (defined $message) |
|
98
|
2 |
1 |
exists $p{'handle'} ? : |
|
99
|
1 |
1 |
unless ($handle->isa('AnyEvent::Handle')) |
|
100
|
0 |
1 |
unless $p{'handle_args'} |
|
108
|
2 |
0 |
if $error_sub |
|
115
|
1 |
1 |
unless $p{'push_read_args'} |
|
141
|
1 |
70017 |
if $self->{'message_id'} >= 65536 |
|
147
|
5 |
3 |
if ($args->{'qos'}) { } |
|
148
|
3 |
2 |
unless (exists $args->{'message_id'}) |
|
174
|
1 |
7 |
if $dup |
|
182
|
18 |
1 |
exists $p{'topic'} ? : |
|
184
|
17 |
1 |
exists $p{'callback'} ? : |
|
185
|
5 |
12 |
exists $p{'qos'} ? : |
|
186
|
1 |
16 |
exists $p{'cv'} ? : |
|
188
|
12 |
5 |
if (defined $mid) |
|
200
|
6 |
1 |
exists $p{'topic'} ? : |
|
201
|
1 |
5 |
exists $p{'cv'} ? : |
|
203
|
2 |
4 |
if (defined $mid) |
|
214
|
2 |
15 |
if ($rec) |
|
224
|
3 |
12 |
if ($rec) |
|
241
|
1 |
5 |
if ($rec) |
|
247
|
1 |
4 |
unless ($rec) |
|
253
|
3 |
1 |
if (defined $sub) |
|
254
|
0 |
3 |
unless (exists $rec->{'cb'}{$sub}) |
|
261
|
2 |
1 |
if (keys %{$$rec{'cb'};}) |
|
279
|
1 |
12 |
unless (defined $topic) |
|
296
|
1 |
2 |
unless (defined $topic) |
|
312
|
35 |
21 |
$self->{'connected'} ? : |
|
320
|
35 |
21 |
unless defined $self->{'_waiting'} |
|
328
|
16 |
98 |
if (@_) { } |
|
331
|
48 |
50 |
unless my $args = shift @{$$self{'write_queue'};} |
|
336
|
5 |
61 |
if $self->{'message_log_callback'} |
|
346
|
3 |
68 |
$wait ? : |
|
374
|
2 |
1 |
unless defined $self->{'_keep_alive_waiting'} |
|
383
|
21 |
9 |
if ($msg) { } |
|
384
|
12 |
9 |
unless $cv |
|
387
|
7 |
2 |
unless exists $self->{'connect_cv'} |
|
390
|
12 |
18 |
if $self->{'handle'} |
|
418
|
0 |
16 |
if $weak_self->{'on_connect'} |
|
459
|
0 |
58 |
if $error |
|
460
|
1 |
57 |
if $self->{'message_log_callback'} |
|
461
|
0 |
58 |
unless $self->_call_callback('before_msg_callback', $msg) |
|
464
|
0 |
58 |
unless $self->_call_callback('before_' . $msg_type . '_callback', $msg) |
|
466
|
1 |
57 |
unless ($self->can($method)) |
|
478
|
173 |
0 |
unless exists $self->{$cb_name} |
|
485
|
1 |
12 |
unless ($msg->return_code == 0) |
|
491
|
3 |
9 |
if $self->{'connect_cv'} |
|
500
|
31 |
20 |
if ref $w and defined $w->[1] |
|
530
|
1 |
15 |
unless (scalar @$matches) |
|
538
|
0 |
19 |
if ($msg_retain) |
|
539
|
0 |
0 |
if ($msg_data eq '') { } |
|
548
|
2 |
25 |
if $matched{$cb}++ |
|
558
|
1 |
15 |
if ($qos == 2) |
|
565
|
1 |
14 |
if $qos == 1 |
|
573
|
2 |
5 |
unless (exists $self->{'inflight'}{$mid}) |
|
579
|
1 |
4 |
unless ($got_type == $exp_type) |
|
589
|
1 |
2 |
unless my $rec = $self->_inflight_record($msg) |
|
598
|
1 |
1 |
unless my $rec = $self->_inflight_record($msg) |
|
613
|
1 |
1 |
unless ($pubmsg) |
|
623
|
1 |
1 |
unless my $rec = $self->_inflight_record($msg) |
|
637
|
0 |
51 |
unless defined $$rbuf |
|
640
|
51 |
58 |
unless $msg |