| 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'} |
|
91
|
0 |
0 |
unless $args{'autoconnect'} |
|
95
|
0 |
0 |
if $self->{'auth'} |
|
115
|
0 |
0 |
unless my $rpc = 'JSON::RPC2::TwoWay'->new('debug', $self->{'debug'}, 'json', $self->{'jsonobject'}) |
|
126
|
0 |
0 |
if $self->{'tls_ca'} |
|
127
|
0 |
0 |
if $self->{'tls_cert'} |
|
128
|
0 |
0 |
if $self->{'tls_key'} |
|
133
|
0 |
0 |
if ($err) |
|
150
|
0 |
0 |
if @err |
|
151
|
0 |
0 |
if $err[0] |
|
157
|
0 |
0 |
unless $conn |
|
197
|
0 |
0 |
unless $i->{'version'} eq '1.1' |
|
205
|
0 |
0 |
if $e |
|
206
|
0 |
0 |
unless $r |
|
208
|
0 |
0 |
if ($r) { } |
|
227
|
0 |
0 |
if $self->{'json'} |
|
230
|
0 |
0 |
if ($rescb) { } |
|
236
|
0 |
0 |
if $@ |
|
247
|
0 |
0 |
unless $job_id |
|
262
|
0 |
0 |
unless my $wfname = $args{'wfname'} |
|
272
|
0 |
0 |
if ($self->{'json'}) { } |
|
275
|
0 |
0 |
unless ref $inargs eq 'HASH' |
|
276
|
0 |
0 |
if ($clenv) |
|
278
|
0 |
0 |
unless ref $clenv eq 'HASH' |
|
280
|
0 |
0 |
if ($reqauth) |
|
282
|
0 |
0 |
unless ref $reqauth eq 'HASH' |
|
285
|
0 |
0 |
unless ref $inargs eq 'HASH' |
|
288
|
0 |
0 |
if ($clenv) |
|
289
|
0 |
0 |
unless ref $clenv eq 'HASH' |
|
291
|
0 |
0 |
if ($reqauth) |
|
292
|
0 |
0 |
unless ref $reqauth eq 'HASH' |
|
297
|
0 |
0 |
$vtag ? : |
|
302
|
0 |
0 |
$clenv ? : |
|
|
0 |
0 |
$reqauth ? : |
|
314
|
0 |
0 |
if ($e) { } |
|
319
|
0 |
0 |
if ($msg) { } |
|
|
0 |
0 |
elsif ($job_id) { } |
|
326
|
0 |
0 |
if ($msg) |
|
327
|
0 |
0 |
unless ref $msg |
|
328
|
0 |
0 |
if $self->{'json'} |
|
335
|
0 |
0 |
if $self->{'json'} |
|
351
|
0 |
0 |
unless $filter |
|
354
|
0 |
0 |
if ref $filter eq 'HASH' |
|
367
|
0 |
0 |
if ($e) |
|
381
|
0 |
0 |
if ref $jobs eq 'ARRAY' |
|
387
|
0 |
0 |
unless $locktype |
|
388
|
0 |
0 |
unless $lockvalue |
|
405
|
0 |
0 |
if ($e) |
|
419
|
0 |
0 |
if $self->{'json'} |
|
425
|
0 |
0 |
unless $what |
|
437
|
0 |
0 |
if ($e) |
|
456
|
0 |
0 |
unless $job_id |
|
474
|
0 |
0 |
unless my $job_id = $args{'job_id'} |
|
477
|
0 |
0 |
if ref $statuscb ne 'CODE' |
|
481
|
0 |
0 |
if $notifycb and ref $notifycb ne 'CODE' |
|
489
|
0 |
0 |
$notifycb ? : |
|
500
|
0 |
0 |
if ($e) |
|
506
|
0 |
0 |
if ($notifycb and not $job_id2 and not $outargs) |
|
509
|
0 |
0 |
if $self->{'json'} and ref $outargs |
|
516
|
0 |
0 |
if $self->{'json'} |
|
533
|
0 |
0 |
if (not $e and $r and $r =~ /pong/u) { } |
|
555
|
0 |
0 |
if ($self->lastping // 0) > time - $pt |
|
561
|
0 |
0 |
if $pt > 0 |
|
567
|
0 |
0 |
if $prepare |
|
571
|
0 |
0 |
unless 'Mojo::IOLoop'->is_running |
|
573
|
0 |
0 |
if $tmr |
|
586
|
0 |
0 |
unless $name |
|
598
|
0 |
0 |
if ($e) |
|
617
|
0 |
0 |
unless my $actionname = $args{'actionname'} |
|
618
|
0 |
0 |
unless my $cb = $args{'cb'} |
|
620
|
0 |
0 |
$args{'async'} ? : |
|
621
|
0 |
0 |
unless $mode =~ /^(subproc|async|sync)$/u |
|
626
|
0 |
0 |
if $self->actions->{$actionname} |
|
637
|
0 |
0 |
$args{'filter'} ? : |
|
644
|
0 |
0 |
if ($e) |
|
655
|
0 |
0 |
if $res |
|
657
|
0 |
0 |
unless $res |
|
680
|
0 |
0 |
unless ($action) |
|
694
|
0 |
0 |
if ($e) |
|
697
|
0 |
0 |
unless ($r) |
|
703
|
0 |
0 |
unless ($cookie) |
|
707
|
0 |
0 |
unless $action->{'addenv'} |
|
709
|
0 |
0 |
if ($action->{'mode'} eq 'subproc') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'async') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'sync') { } |
|
713
|
0 |
0 |
if $@ |
|
720
|
0 |
0 |
if $@ |
|
723
|
0 |
0 |
if $@ |
|
741
|
0 |
0 |
unless pipe my $reader, my $writer |
|
743
|
0 |
0 |
unless defined(my $pid = fork) |
|
744
|
0 |
0 |
unless ($pid) |
|
750
|
0 |
0 |
if ($@) { } |
|
|
0 |
0 |
elsif (ref $outargs eq 'HASH' and $outargs->{'error'}) { } |
|
756
|
0 |
0 |
if ($undo and $action->{'undocb'}) |
|
759
|
0 |
0 |
if $@ |
|
772
|
0 |
0 |
unless $writer->flush |
|
773
|
0 |
0 |
unless CORE::close $writer |
|
774
|
0 |
0 |
if ($undo and $action->{'undocb'}) |
|
793
|
0 |
0 |
unless $$ == $me |
|
796
|
0 |
0 |
if $@ |
|
797
|
0 |
0 |
if ($outargs and ref $outargs eq 'HASH') |
|
810
|
0 |
0 |
if state $looping++ |
|
815
|
0 |
0 |
if (ref $reactor eq 'Mojo::Reactor::EV') { } |
|
|
0 |
0 |
elsif (ref $reactor eq 'Mojo::Reactor::Poll') { } |
|
835
|
0 |
0 |
if $err |