| line |
true |
false |
branch |
|
12
|
1 |
0 |
unless $ENV{'MOJO_REACTOR'} |
|
62
|
0 |
0 |
$debug ? : |
|
70
|
0 |
0 |
unless my $token = $args{'token'} |
|
71
|
0 |
0 |
unless my $who = $args{'who'} |
|
92
|
0 |
0 |
unless $args{'autoconnect'} |
|
96
|
0 |
0 |
if $self->{'auth'} |
|
116
|
0 |
0 |
if ($self->{'log'}) { } |
|
122
|
0 |
0 |
$self->{'debug'} ? : |
|
127
|
0 |
0 |
unless my $rpc = "JSON::RPC2::TwoWay"->new("debug", $debug, "json", $self->{'jsonobject'}) |
|
138
|
0 |
0 |
if $self->{'tls_ca'} |
|
139
|
0 |
0 |
if $self->{'tls_cert'} |
|
140
|
0 |
0 |
if $self->{'tls_key'} |
|
145
|
0 |
0 |
if ($err) |
|
162
|
0 |
0 |
if @err |
|
163
|
0 |
0 |
if $err[0] |
|
169
|
0 |
0 |
unless $conn |
|
209
|
0 |
0 |
unless $i->{'version'} eq "1.1" |
|
217
|
0 |
0 |
if $e |
|
218
|
0 |
0 |
unless $r |
|
220
|
0 |
0 |
if ($r) { } |
|
239
|
0 |
0 |
if $self->{'json'} |
|
242
|
0 |
0 |
if ($rescb) { } |
|
248
|
0 |
0 |
if $@ |
|
259
|
0 |
0 |
unless $job_id |
|
274
|
0 |
0 |
unless my $wfname = $args{'wfname'} |
|
284
|
0 |
0 |
if ($self->{'json'}) { } |
|
287
|
0 |
0 |
unless ref $inargs eq "HASH" |
|
288
|
0 |
0 |
if ($clenv) |
|
290
|
0 |
0 |
unless ref $clenv eq "HASH" |
|
292
|
0 |
0 |
if ($reqauth) |
|
294
|
0 |
0 |
unless ref $reqauth eq "HASH" |
|
297
|
0 |
0 |
unless ref $inargs eq "HASH" |
|
300
|
0 |
0 |
if ($clenv) |
|
301
|
0 |
0 |
unless ref $clenv eq "HASH" |
|
303
|
0 |
0 |
if ($reqauth) |
|
304
|
0 |
0 |
unless ref $reqauth eq "HASH" |
|
309
|
0 |
0 |
$vtag ? : |
|
314
|
0 |
0 |
$clenv ? : |
|
|
0 |
0 |
$reqauth ? : |
|
326
|
0 |
0 |
if ($e) { } |
|
331
|
0 |
0 |
if ($msg) { } |
|
|
0 |
0 |
elsif ($job_id) { } |
|
338
|
0 |
0 |
if ($msg) |
|
339
|
0 |
0 |
unless ref $msg |
|
340
|
0 |
0 |
if $self->{'json'} |
|
347
|
0 |
0 |
if $self->{'json'} |
|
363
|
0 |
0 |
unless $filter |
|
366
|
0 |
0 |
if ref $filter eq "HASH" |
|
379
|
0 |
0 |
if ($e) |
|
393
|
0 |
0 |
if ref $jobs eq "ARRAY" |
|
399
|
0 |
0 |
unless $locktype |
|
400
|
0 |
0 |
unless $lockvalue |
|
417
|
0 |
0 |
if ($e) |
|
430
|
0 |
0 |
if $self->{'json'} |
|
436
|
0 |
0 |
unless $what |
|
448
|
0 |
0 |
if ($e) |
|
467
|
0 |
0 |
unless $job_id |
|
485
|
0 |
0 |
unless my $job_id = $args{'job_id'} |
|
488
|
0 |
0 |
if ref $statuscb ne "CODE" |
|
492
|
0 |
0 |
if $notifycb and ref $notifycb ne "CODE" |
|
500
|
0 |
0 |
$notifycb ? : |
|
511
|
0 |
0 |
if ($e) |
|
514
|
0 |
0 |
if $self->{'json'} |
|
519
|
0 |
0 |
if ($notifycb and not $job_id2 and not $outargs) |
|
522
|
0 |
0 |
if $self->{'json'} and ref $outargs |
|
529
|
0 |
0 |
if $self->{'json'} |
|
546
|
0 |
0 |
if (not $e and $r and $r =~ /pong/u) { } |
|
568
|
0 |
0 |
if ($self->lastping // 0) > time - $pt |
|
574
|
0 |
0 |
if $pt > 0 |
|
580
|
0 |
0 |
if $prepare |
|
584
|
0 |
0 |
unless "Mojo::IOLoop"->is_running |
|
586
|
0 |
0 |
if $tmr |
|
599
|
0 |
0 |
unless $name |
|
611
|
0 |
0 |
if ($e) |
|
630
|
0 |
0 |
unless my $actionname = $args{'actionname'} |
|
631
|
0 |
0 |
unless my $cb = $args{'cb'} |
|
633
|
0 |
0 |
$args{'async'} ? : |
|
634
|
0 |
0 |
unless $mode =~ /^(subproc|async|sync)$/u |
|
639
|
0 |
0 |
if $self->actions->{$actionname} |
|
650
|
0 |
0 |
$args{'filter'} ? : |
|
657
|
0 |
0 |
if ($e) |
|
668
|
0 |
0 |
if $res |
|
670
|
0 |
0 |
unless $res |
|
693
|
0 |
0 |
unless ($action) |
|
707
|
0 |
0 |
if ($e) |
|
710
|
0 |
0 |
unless ($r) |
|
716
|
0 |
0 |
unless ($cookie) |
|
720
|
0 |
0 |
unless $action->{'addenv'} |
|
722
|
0 |
0 |
if ($action->{'mode'} eq 'subproc') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'async') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'sync') { } |
|
726
|
0 |
0 |
if $@ |
|
733
|
0 |
0 |
if $@ |
|
736
|
0 |
0 |
if $@ |
|
754
|
0 |
0 |
unless pipe my $reader, my $writer |
|
756
|
0 |
0 |
unless defined(my $pid = fork) |
|
757
|
0 |
0 |
unless ($pid) |
|
763
|
0 |
0 |
if ($@) { } |
|
|
0 |
0 |
elsif (ref $outargs eq 'HASH' and $outargs->{'error'}) { } |
|
769
|
0 |
0 |
if ($undo and $action->{'undocb'}) |
|
772
|
0 |
0 |
if $@ |
|
785
|
0 |
0 |
unless $writer->flush |
|
786
|
0 |
0 |
unless CORE::close $writer |
|
787
|
0 |
0 |
if ($undo and $action->{'undocb'}) |
|
806
|
0 |
0 |
unless $$ == $me |
|
809
|
0 |
0 |
if $@ |
|
810
|
0 |
0 |
if ($outargs and ref $outargs eq "HASH") |
|
823
|
0 |
0 |
if state $looping++ |
|
828
|
0 |
0 |
if (ref $reactor eq 'Mojo::Reactor::EV') { } |
|
|
0 |
0 |
elsif (ref $reactor eq 'Mojo::Reactor::Poll') { } |
|
848
|
0 |
0 |
if $err |