Branch Coverage

lib/Beekeeper/Service/ToyBroker/Worker.pm
Criterion Covered Total %
branch 0 274 0.0


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'};} ? :