| line |
true |
false |
branch |
|
12
|
1 |
0 |
unless $ENV{'MOJO_REACTOR'} |
|
61
|
0 |
0 |
$debug ? : |
|
69
|
0 |
0 |
unless my $token = $args{'token'} |
|
70
|
0 |
0 |
unless my $who = $args{'who'} |
|
90
|
0 |
0 |
unless $args{'autoconnect'} |
|
94
|
0 |
0 |
if $self->{'auth'} |
|
114
|
0 |
0 |
unless my $rpc = 'JSON::RPC2::TwoWay'->new('debug', $self->{'debug'}, 'json', $self->{'jsonobject'}) |
|
125
|
0 |
0 |
if $self->{'tls_ca'} |
|
126
|
0 |
0 |
if $self->{'tls_cert'} |
|
127
|
0 |
0 |
if $self->{'tls_key'} |
|
132
|
0 |
0 |
if ($err) |
|
149
|
0 |
0 |
if @err |
|
150
|
0 |
0 |
if $err[0] |
|
156
|
0 |
0 |
unless $conn |
|
196
|
0 |
0 |
unless $i->{'version'} eq '1.1' |
|
204
|
0 |
0 |
if $e |
|
205
|
0 |
0 |
unless $r |
|
207
|
0 |
0 |
if ($r) { } |
|
226
|
0 |
0 |
if $self->{'json'} |
|
229
|
0 |
0 |
if ($rescb) { } |
|
235
|
0 |
0 |
if $@ |
|
246
|
0 |
0 |
unless $job_id |
|
261
|
0 |
0 |
unless my $wfname = $args{'wfname'} |
|
271
|
0 |
0 |
if ($self->{'json'}) { } |
|
274
|
0 |
0 |
unless ref $inargs eq 'HASH' |
|
275
|
0 |
0 |
if ($clenv) |
|
277
|
0 |
0 |
unless ref $clenv eq 'HASH' |
|
279
|
0 |
0 |
if ($reqauth) |
|
281
|
0 |
0 |
unless ref $reqauth eq 'HASH' |
|
284
|
0 |
0 |
unless ref $inargs eq 'HASH' |
|
287
|
0 |
0 |
if ($clenv) |
|
288
|
0 |
0 |
unless ref $clenv eq 'HASH' |
|
290
|
0 |
0 |
if ($reqauth) |
|
291
|
0 |
0 |
unless ref $reqauth eq 'HASH' |
|
296
|
0 |
0 |
$vtag ? : |
|
301
|
0 |
0 |
$clenv ? : |
|
|
0 |
0 |
$reqauth ? : |
|
313
|
0 |
0 |
if ($e) { } |
|
318
|
0 |
0 |
if ($msg) { } |
|
|
0 |
0 |
elsif ($job_id) { } |
|
325
|
0 |
0 |
if ($msg) |
|
326
|
0 |
0 |
unless ref $msg |
|
327
|
0 |
0 |
if $self->{'json'} |
|
334
|
0 |
0 |
if $self->{'json'} |
|
350
|
0 |
0 |
unless $filter |
|
353
|
0 |
0 |
if ref $filter eq 'HASH' |
|
366
|
0 |
0 |
if ($e) |
|
380
|
0 |
0 |
if ref $jobs eq 'ARRAY' |
|
386
|
0 |
0 |
unless $what |
|
398
|
0 |
0 |
if ($e) |
|
417
|
0 |
0 |
unless $job_id |
|
435
|
0 |
0 |
unless my $job_id = $args{'job_id'} |
|
438
|
0 |
0 |
if ref $statuscb ne 'CODE' |
|
442
|
0 |
0 |
if $notifycb and ref $notifycb ne 'CODE' |
|
450
|
0 |
0 |
$notifycb ? : |
|
461
|
0 |
0 |
if ($e) |
|
467
|
0 |
0 |
if ($notifycb and not $job_id2 and not $outargs) |
|
470
|
0 |
0 |
if $self->{'json'} and ref $outargs |
|
477
|
0 |
0 |
if $self->{'json'} |
|
494
|
0 |
0 |
if (not $e and $r and $r =~ /pong/u) { } |
|
516
|
0 |
0 |
if ($self->lastping // 0) > time - $pt |
|
522
|
0 |
0 |
if $pt > 0 |
|
528
|
0 |
0 |
if $prepare |
|
532
|
0 |
0 |
unless 'Mojo::IOLoop'->is_running |
|
534
|
0 |
0 |
if $tmr |
|
547
|
0 |
0 |
unless $name |
|
559
|
0 |
0 |
if ($e) |
|
578
|
0 |
0 |
unless my $actionname = $args{'actionname'} |
|
579
|
0 |
0 |
unless my $cb = $args{'cb'} |
|
581
|
0 |
0 |
$args{'async'} ? : |
|
582
|
0 |
0 |
unless $mode =~ /^(subproc|async|sync)$/u |
|
587
|
0 |
0 |
if $self->actions->{$actionname} |
|
598
|
0 |
0 |
$args{'filter'} ? : |
|
605
|
0 |
0 |
if ($e) |
|
616
|
0 |
0 |
if $res |
|
618
|
0 |
0 |
unless $res |
|
641
|
0 |
0 |
unless ($action) |
|
655
|
0 |
0 |
if ($e) |
|
658
|
0 |
0 |
unless ($r) |
|
664
|
0 |
0 |
unless ($cookie) |
|
668
|
0 |
0 |
unless $action->{'addenv'} |
|
670
|
0 |
0 |
if ($action->{'mode'} eq 'subproc') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'async') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'sync') { } |
|
674
|
0 |
0 |
if $@ |
|
681
|
0 |
0 |
if $@ |
|
684
|
0 |
0 |
if $@ |
|
702
|
0 |
0 |
unless pipe my $reader, my $writer |
|
704
|
0 |
0 |
unless defined(my $pid = fork) |
|
705
|
0 |
0 |
unless ($pid) |
|
711
|
0 |
0 |
if ($@) { } |
|
|
0 |
0 |
elsif (ref $outargs eq 'HASH' and $outargs->{'error'}) { } |
|
717
|
0 |
0 |
if ($undo and $action->{'undocb'}) |
|
720
|
0 |
0 |
if $@ |
|
733
|
0 |
0 |
unless $writer->flush |
|
734
|
0 |
0 |
unless CORE::close $writer |
|
735
|
0 |
0 |
if ($undo and $action->{'undocb'}) |
|
754
|
0 |
0 |
unless $$ == $me |
|
757
|
0 |
0 |
if $@ |
|
758
|
0 |
0 |
if ($outargs and ref $outargs eq 'HASH') |
|
771
|
0 |
0 |
if state $looping++ |
|
776
|
0 |
0 |
if (ref $reactor eq 'Mojo::Reactor::EV') { } |
|
|
0 |
0 |
elsif (ref $reactor eq 'Mojo::Reactor::Poll') { } |
|
796
|
0 |
0 |
if $err |