Branch Coverage

lib/Beekeeper/Worker.pm

Criterion	Covered	Total	%
branch	0	162	0.0

line	true	false	branch
46	0	0	if $LogLevel >= 1
47	0	0	if $LogLevel >= 2
48	0	0	if $LogLevel >= 3
49	0	0	if $LogLevel >= 4
50	0	0	if $LogLevel >= 5
51	0	0	if $LogLevel >= 5
52	0	0	if $LogLevel >= 6
53	0	0	if $LogLevel >= 7
54	0	0	if $LogLevel >= 8
55	0	0	if $LogLevel >= 9
56	0	0	if scalar @_
113	0	0	if (defined $SIG{'TERM'} and $SIG{'TERM'} eq "DEFAULT")
118	0	0	if (defined $SIG{'INT'} and $SIG{'INT'} eq "DEFAULT" and $args{'foreground'})
132	0	0	if exists $self->{'_LOGGER'}{'_BUS'}
139	0	0	if ($@)
167	0	0	unless $auth_data and $auth_level
168	0	0	unless exists $AUTH_TOKENS{$auth_level}
169	0	0	unless $AUTH_TOKENS{$auth_level} eq $auth_data
178	0	0	if $self->{'_WORKER'}{'debug'} or $self->{'_WORKER'}{'config'}{'debug'}
273	0	0	unless $fq_meth =~ /^ ( [\w-]+ (?: \.[\w-]+ )* )  \. ( [\w-]+ | \* ) $/x
280	0	0	if exists $$callbacks{"msg.$fq_meth"}
296	0	0	unless ($worker->{'queued_tasks'})
303	0	0	unless $success
312	0	0	if (ref $callback eq 'CODE') { }
	0	0	elsif (not ref $callback and $self->can($callback)) { }
342	0	0	unless $fq_meth =~ /^ ( [\w-]+ (?: \.[\w-]+ )* )  \. ( [\w-]+ | \* ) $/x
349	0	0	if exists $$callbacks{"req.$fq_meth"}
352	0	0	if $subscribed_to{$service}
355	0	0	if (keys %subscribed_to == 2)
373	0	0	unless ($worker->{'queued_tasks'})
380	0	0	unless $success
392	0	0	if $_TASK_QUEUE_DEPTH
397	0	0	unless (defined $BUSY_SINCE)
430	0	0	unless (ref $request eq "HASH" and $request->{'jsonrpc'} eq "2.0")
440	0	0	unless (defined $method and $method =~ /^([\.\w-]+)\.([\w-]+)$/)
452	0	0	unless (($self->authorize_request($request) || '') eq 34756660)
457	0	0	unless ($cb)
465	0	0	if ($@)
472	0	0	if ($task = shift @{$$worker{"task_queue_low"};})
485	0	0	unless (ref $request eq "HASH" and $request->{'jsonrpc'} eq "2.0")
496	0	0	unless (defined $method and $method =~ /^([\.\w-]+)\.([\w-]+)$/)
508	0	0	unless (($self->authorize_request($request) || '') eq 34756660)
513	0	0	unless ($cb)
522	0	0	if ($@) { }
	0	0	elsif (&blessed($result) and $result->isa('Beekeeper::JSONRPC::Error')) { }
	0	0	elsif ($request->{'_async_response'}) { }
524	0	0	if (&blessed($@) and $@->isa('Beekeeper::JSONRPC::Error')) { }
535	0	0	if $worker->{'debug'}
557	0	0	if (defined $request_id and defined $response) { }
565	0	0	if ($@)
573	0	0	if ($request->{'_deflate_response'} and length $json > $request->{'_deflate_response'})
593	0	0	if (exists $mqtt_properties->{'packet_id'}) { }
618	0	0	if @{$worker->{'task_queue_high'};} or @{$worker->{'task_queue_low'};}
621	0	0	if (exists $worker->{'postponed'})
629	0	0	if (defined $timing_tasks)
647	0	0	unless defined $request->{'id'}
649	0	0	unless (defined $BUSY_SINCE)
654	0	0	if (&blessed($result) and $result->isa('Beekeeper::JSONRPC::Error')) { }
672	0	0	if ($@)
681	0	0	if ($request->{'_deflate_response'} and length $json > $request->{'_deflate_response'})
695	0	0	if (defined $timing_tasks)
708	0	0	unless @methods
712	0	0	unless $fq_meth =~ /^ ( [\w-]+ (?: \.[\w-]+ )* )  \. ( [\w-]+ | \* ) $/x
719	0	0	unless (defined $worker->{'callbacks'}{"msg.$fq_meth"})
749	0	0	unless $success
767	0	0	unless @methods
771	0	0	unless $fq_meth =~ /^ ( [\w-]+ (?: \.[\w-]+ )* )  \. ( [\w-]+ | \* ) $/x
776	0	0	unless ($method eq "*")
789	0	0	unless (@cb_keys)
814	0	0	unless $worker->{'shutting_down'}
816	0	0	if ($worker->{'in_progress'} > 0)
826	0	0	unless ($worker->{'in_progress'} > 0 and --$wait_time > 0)
844	0	0	unless $success
875	0	0	if ($@)
880	0	0	if ($self->{'_BUS'}{'is_connected'})
893	0	0	if $worker->{'shutting_down'}
896	0	0	unless (defined $worker->{'stop_cv'})
903	0	0	unless $fq_meth =~ /^req\.(?!_sync)(.*)\./
907	0	0	if (keys %services) { }
953	0	0	unless $queue =~ /^req\.(?!_sync)(.*)\./
980	0	0	unless $self->{'_BUS'}{'is_connected'}