line |
true |
false |
branch |
51
|
0 |
0 |
if $conn_count <= 1 |
80
|
0 |
0 |
unless defined $config |
84
|
0 |
0 |
if ($listener->{'users'}) |
129
|
0 |
0 |
unless $rbuff_len >= 2 |
131
|
0 |
0 |
unless ($packet_type) |
140
|
0 |
0 |
unless $byte & 128 |
141
|
0 |
0 |
if $offs >= $rbuff_len |
143
|
0 |
0 |
if $offs < 5 |
146
|
0 |
0 |
if ($max_packet_size and $packet_len > $max_packet_size) |
156
|
0 |
0 |
if ($rbuff_len < $offs + $packet_len) |
167
|
0 |
0 |
if ($packet_type == 3) { } |
|
0 |
0 |
elsif ($packet_type == 4) { } |
|
0 |
0 |
elsif ($packet_type == 12) { } |
|
0 |
0 |
elsif ($packet_type == 13) { } |
|
0 |
0 |
elsif ($packet_type == 8) { } |
|
0 |
0 |
elsif ($packet_type == 10) { } |
|
0 |
0 |
elsif ($packet_type == 1) { } |
|
0 |
0 |
elsif ($packet_type == 14) { } |
|
0 |
0 |
elsif ($packet_type == 5) { } |
|
0 |
0 |
elsif ($packet_type == 6) { } |
|
0 |
0 |
elsif ($packet_type == 7) { } |
|
0 |
0 |
elsif ($packet_type == 15) { } |
226
|
0 |
0 |
if defined $fh->{'rbuf'} |
264
|
0 |
0 |
if $flags & 2 |
265
|
0 |
0 |
if $flags & 128 |
266
|
0 |
0 |
if $flags & 64 |
267
|
0 |
0 |
if $flags & 4 |
269
|
0 |
0 |
if $flags & 32 |
282
|
0 |
0 |
if ($prop_id == 17) { } |
|
0 |
0 |
elsif ($prop_id == 33) { } |
|
0 |
0 |
elsif ($prop_id == 39) { } |
|
0 |
0 |
elsif ($prop_id == 34) { } |
|
0 |
0 |
elsif ($prop_id == 25) { } |
|
0 |
0 |
elsif ($prop_id == 23) { } |
|
0 |
0 |
elsif ($prop_id == 38) { } |
|
0 |
0 |
elsif ($prop_id == 21) { } |
|
0 |
0 |
elsif ($prop_id == 22) { } |
331
|
0 |
0 |
if ($prop{'will'}) |
346
|
0 |
0 |
if ($prop{'username'}) |
351
|
0 |
0 |
if ($prop{'password'}) |
356
|
0 |
0 |
unless ($prop{'protocol_version'} eq 5) |
375
|
0 |
0 |
if (exists $args{'session_expiry_interval'}) |
380
|
0 |
0 |
if (exists $args{'receive_maximum'}) |
385
|
0 |
0 |
if (exists $args{'maximum_qos'}) |
390
|
0 |
0 |
if (exists $args{'retain_available'}) |
395
|
0 |
0 |
if (exists $args{'maximum_packet_size'}) |
400
|
0 |
0 |
if (exists $args{'assigned_client_identifier'}) |
406
|
0 |
0 |
if (exists $args{'topic_alias_maximum'}) |
411
|
0 |
0 |
if (exists $args{'reason_string'}) |
417
|
0 |
0 |
if (exists $args{'wildcard_subscription_available'}) |
422
|
0 |
0 |
if (exists $args{'subscription_identifier_available'}) |
427
|
0 |
0 |
if (exists $args{'shared_subscription_available'}) |
432
|
0 |
0 |
if (exists $args{'server_keep_alive'}) |
437
|
0 |
0 |
if (exists $args{'response_information'}) |
443
|
0 |
0 |
if (exists $args{'server_reference'}) |
449
|
0 |
0 |
if (exists $args{'authentication_method'}) |
455
|
0 |
0 |
if (exists $args{'authentication_data'}) |
463
|
0 |
0 |
unless defined $val |
475
|
0 |
0 |
$session_present ? : |
492
|
0 |
0 |
if length $$packet == 0 |
510
|
0 |
0 |
if ($prop_id == 17) { } |
|
0 |
0 |
elsif ($prop_id == 31) { } |
|
0 |
0 |
elsif ($prop_id == 38) { } |
|
0 |
0 |
elsif ($prop_id == 28) { } |
548
|
0 |
0 |
if (exists $args{'reason_string'}) |
554
|
0 |
0 |
if (exists $args{'server_reference'}) |
563
|
0 |
0 |
unless defined $val |
611
|
0 |
0 |
if ($prop_id == 11) { } |
|
0 |
0 |
elsif ($prop_id == 38) { } |
667
|
0 |
0 |
if (exists $args{'reason_string'}) |
676
|
0 |
0 |
unless defined $val |
721
|
0 |
0 |
if ($prop_id == 38) { } |
765
|
0 |
0 |
if (exists $args{'reason_string'}) |
774
|
0 |
0 |
unless defined $val |
846
|
0 |
0 |
if ($prop{'qos'} > 0) |
863
|
0 |
0 |
if ($prop_id == 1) { } |
|
0 |
0 |
elsif ($prop_id == 2) { } |
|
0 |
0 |
elsif ($prop_id == 35) { } |
|
0 |
0 |
elsif ($prop_id == 8) { } |
|
0 |
0 |
elsif ($prop_id == 9) { } |
|
0 |
0 |
elsif ($prop_id == 38) { } |
|
0 |
0 |
elsif ($prop_id == 11) { } |
|
0 |
0 |
elsif ($prop_id == 3) { } |
877
|
0 |
0 |
if (length $topic) { } |
926
|
0 |
0 |
if ($prop{'payload_format'}) |
931
|
0 |
0 |
if ($prop{'qos'} == 1) |
953
|
0 |
0 |
unless defined $topic |
955
|
0 |
0 |
unless defined $payload |
956
|
0 |
0 |
ref $payload eq 'SCALAR' ? : |
963
|
0 |
0 |
if $qos |
964
|
0 |
0 |
if $dup |
965
|
0 |
0 |
if $retain |
969
|
0 |
0 |
if (utf8::is_utf8($$payload_ref)) |
975
|
0 |
0 |
if (exists $args{'message_expiry_interval'}) |
980
|
0 |
0 |
if ($topic_alias) |
985
|
0 |
0 |
if (exists $args{'response_topic'}) |
991
|
0 |
0 |
if (exists $args{'correlation_data'}) |
996
|
0 |
0 |
if (exists $args{'subscription_identifier'}) |
1002
|
0 |
0 |
if (exists $args{'content_type'}) |
1011
|
0 |
0 |
unless defined $val |
1022
|
0 |
0 |
if $packet_id |
1043
|
0 |
0 |
unless $args{'packet_id'} |
1060
|
0 |
0 |
unless defined $reason_code |
1105
|
0 |
0 |
unless length $client_id |
1106
|
0 |
0 |
unless length $username |
1107
|
0 |
0 |
unless length $password |
1109
|
0 |
0 |
unless $users_cfg |
1110
|
0 |
0 |
unless $users_cfg->{$username} |
1111
|
0 |
0 |
unless $users_cfg->{$username}{'password'} eq $password |
1116
|
0 |
0 |
unless ($authorized) |
1143
|
0 |
0 |
unless $client |
1162
|
0 |
0 |
unless $message->{'topic'} =~ /$topic->{'topic_regex'}/ |
1174
|
0 |
0 |
unless defined $topic_filter |
1180
|
0 |
0 |
unless $topic_filter =~ m[^ (( [-\w]+ | \+ ) /)* ( [-\w]+ | \+ | \# ) $]x |
1190
|
0 |
0 |
unless defined $topic_filter |
1196
|
0 |
0 |
unless ($topic) |
1203
|
0 |
0 |
$prop->{'maximum_qos'} ? : |
1212
|
0 |
0 |
if ($shared_group) { } |
1229
|
0 |
0 |
unless defined $topic_filter |
1233
|
0 |
0 |
unless defined $topic |
1239
|
0 |
0 |
if ($shared_group) { } |
1246
|
0 |
0 |
unless $topic->has_subscriptions |
1250
|
0 |
0 |
$success ? : |
1282
|
0 |
0 |
if ($message->{'qos'}) |
1285
|
0 |
0 |
if $packet_id == 65535 |
1290
|
0 |
0 |
if $packet_id |
1312
|
0 |
0 |
unless $sender->has_subscriptions |
1343
|
0 |
0 |
scalar keys %{$$self{'subscriptions'};} ? : |
1357
|
0 |
0 |
unless ($shared) |
1370
|
0 |
0 |
$existed ? : |
1378
|
0 |
0 |
unless $shared |
1382
|
0 |
0 |
unless $shared->has_subscriptions |
1414
|
0 |
0 |
scalar keys %{$$self{'subscriptions'};} ? : |
1420
|
0 |
0 |
if $self->{'id'} |
1422
|
0 |
0 |
if $self->{'max_qos'} == 0 |
1460
|
0 |
0 |
$existed ? : |
1466
|
0 |
0 |
scalar keys %{$$self{'subscriptions'};} ? : |