| line |
true |
false |
branch |
|
65
|
0 |
9 |
if ($opt->lock_server) |
|
92
|
1 |
8 |
if ($opt->docker_health_check or $opt->lock_client) { } |
|
|
0 |
8 |
elsif ($opt->lock_server) { } |
|
140
|
0 |
0 |
if (-e $socket_path) |
|
182
|
1 |
0 |
if ($transport eq 'tcp' or $transport eq 'auto') { } |
|
203
|
0 |
0 |
unless (-e $socket_path) |
|
229
|
0 |
0 |
unless ($errno) |
|
246
|
0 |
1 |
unless ($errno) |
|
254
|
1 |
0 |
if ($opt->docker_health_check) |
|
266
|
0 |
0 |
if ($transport eq "auto" and $attempted eq "tcp") |
|
270
|
0 |
0 |
if ($socket_path and -e $socket_path) { } |
|
293
|
0 |
0 |
if ($opt->lock_client_noretry) |
|
309
|
0 |
0 |
if ($max_retries > 0 and $retry_count > $max_retries) |
|
318
|
0 |
0 |
$max_retries == 0 ? : |
|
336
|
0 |
0 |
if ($transport eq 'tcp' or $transport eq 'auto') { } |
|
358
|
0 |
0 |
unless (-e $socket_path) |
|
467
|
0 |
0 |
if ($opt->docker_health_check) { } |
|
548
|
0 |
0 |
if ($event eq 'hello' and defined $input->{'lock_id'}) { } |
|
|
0 |
0 |
elsif ($event eq 'trigger_ok') { } |
|
|
0 |
0 |
elsif ($event eq 'health_check') { } |
|
574
|
0 |
0 |
if ($idx < scalar @{$order;}) |
|
577
|
0 |
0 |
ref $step eq 'ARRAY' ? : |
|
584
|
0 |
0 |
if (&poe()->heap->{'lock'}{'step_completed'} >= $step_size) |
|
605
|
0 |
0 |
ref $step eq 'ARRAY' ? : |
|
606
|
0 |
0 |
if ($i < $idx) { } |
|
619
|
0 |
0 |
unless &poe()->heap->{'afunixsrv'}{'client'}{'obj'} |
|
639
|
0 |
0 |
if ($idx >= scalar @{$order;}) |
|
647
|
0 |
0 |
ref $step eq 'ARRAY' ? : |
|
655
|
0 |
0 |
if (defined $cid) { } |
|
658
|
0 |
0 |
unless (&poe()->heap->{'lock'}{'run_sent'}{$next_id}) |
|
691
|
0 |
0 |
ref $step eq 'ARRAY' ? : |
|
700
|
0 |
0 |
unless defined $lid |
|
701
|
0 |
0 |
if $known{$lid} |
|
702
|
0 |
0 |
if $clients->{$cid}{'unknown_handled'} |
|
704
|
0 |
0 |
if ($default_act eq 'run') { } |
|
|
0 |
0 |
elsif ($default_act eq 'runlast') { } |
|
709
|
0 |
0 |
if $wheel |
|
716
|
0 |
0 |
unless grep {$_ == $cid;} @{&poe()->heap->{"lock"}{"unknown_queue"};} |
|
743
|
0 |
0 |
if $wheel |
|
747
|
0 |
0 |
if ($action eq 'exit') { } |
|
|
0 |
0 |
elsif ($action eq 'restart') { } |
|
|
0 |
0 |
elsif ($action eq 'execute') { } |
|
797
|
0 |
0 |
if ($event eq 'run') { } |
|
|
0 |
0 |
elsif ($event eq 'health_status') { } |
|
823
|
0 |
0 |
unless ($errno) |
|
831
|
0 |
0 |
if (defined $cid) |
|
836
|
0 |
0 |
if (defined $lock_id) |
|
857
|
0 |
0 |
unless ($errno) |
|
876
|
0 |
10 |
if (&poe()->heap->{'command'}{'running'}) |
|
912
|
0 |
10 |
if ($opt->lock_client) |
|
930
|
0 |
4 |
if ($opt->lock_client and not &poe()->heap->{'command'}{'trigger_ok'}) |
|
948
|
0 |
1 |
if ($opt->lock_client and not &poe()->heap->{'command'}{'trigger_ok'}) |
|
968
|
0 |
10 |
if (&poe()->heap->{'command'}{'shutting_down'}) |
|
978
|
7 |
3 |
if ($no_restart) |
|
982
|
0 |
7 |
if ($opt->lock_client and not &poe()->heap->{'command'}{'trigger_ok'}) |
|
995
|
2 |
1 |
if ($max_restart == -1 or $count < $max_restart) { } |
|
1020
|
20 |
0 |
unless ($errno) |
|
1050
|
0 |
0 |
if ($filter eq 'time') { } |
|
|
0 |
0 |
elsif ($filter eq 'connect') { } |
|
|
0 |
0 |
elsif ($filter eq 'script') { } |
|
1080
|
0 |
0 |
unless $trigger |
|
1087
|
0 |
0 |
if $handle eq "stdout" and $source ne "stdout" |
|
1088
|
0 |
0 |
if $handle eq "stderr" and $source ne "stderr" |
|
1091
|
0 |
0 |
if ($filter eq 'text') { } |
|
|
0 |
0 |
elsif ($filter eq 'regex') { } |
|
1093
|
0 |
0 |
if (index($line, $spec) != -1) |
|
1101
|
0 |
0 |
if ($line =~ /$spec/u) |
|
1118
|
0 |
0 |
if (&poe()->heap->{'command'}{'trigger_ok'}) |
|
1128
|
0 |
0 |
if (&poe()->heap->{'afunixcli'}{'server'}{'wheel'}) |
|
1137
|
0 |
0 |
unless (&poe()->heap->{'command'}{'running'}) |
|
1155
|
0 |
0 |
if &poe()->heap->{'command'}{'trigger_ok'} |
|
1159
|
0 |
0 |
unless ($host and $port) |
|
1174
|
0 |
0 |
if ($sock) |
|
1185
|
0 |
0 |
if ($ok) { } |
|
1207
|
0 |
0 |
if &poe()->heap->{'command'}{'trigger_ok'} |
|
1219
|
0 |
0 |
if ($@) |
|
1225
|
0 |
0 |
if ($exit_code == 0) { } |
|
1248
|
0 |
0 |
if &poe()->heap->{'command'}{'lock_cleared'} |
|
1281
|
0 |
0 |
if (&poe()->heap->{'command'}{'wheel'}) |
|
1291
|
0 |
0 |
if $socket_path and -e $socket_path |
|
1312
|
0 |
0 |
if (&poe()->heap->{'command'}{'wheel'}) |
|
1322
|
0 |
0 |
if $socket_path and -e $socket_path |
|
1360
|
0 |
8 |
if (&poe()->heap->{'command'}{'trigger_ok'} and not &poe()->heap->{'command'}{'running'}) |
|
1367
|
0 |
8 |
if ($opt->lock_client) { } |
|
|
0 |
8 |
elsif ($opt->lock_server) { } |
|
1375
|
0 |
0 |
if ($timeout > 0) |