| line |
true |
false |
branch |
|
12
|
1 |
0 |
unless $ENV{'MOJO_REACTOR'} |
|
76
|
0 |
0 |
$debug ? : |
|
84
|
0 |
0 |
unless $self->{'token'} = $args{'token'} |
|
85
|
0 |
0 |
unless $self->{'who'} = $args{'who'} |
|
88
|
0 |
0 |
unless $self->{'autoconnect'} |
|
92
|
0 |
0 |
if $self->{'auth'} |
|
112
|
0 |
0 |
unless my $rpc = 'JSON::RPC2::TwoWay'->new('debug', $self->{'debug'}, 'json', $self->{'jsonobject'}) |
|
129
|
0 |
0 |
if $self->{'tls_ca'} |
|
130
|
0 |
0 |
if $self->{'tls_cert'} |
|
131
|
0 |
0 |
if $self->{'tls_key'} |
|
136
|
0 |
0 |
if ($err) |
|
153
|
0 |
0 |
if @err |
|
154
|
0 |
0 |
if $err[0] |
|
160
|
0 |
0 |
unless $conn |
|
200
|
0 |
0 |
unless $i->{'version'} eq '1.0' |
|
210
|
0 |
0 |
if $e |
|
211
|
0 |
0 |
unless $r |
|
213
|
0 |
0 |
if ($r) { } |
|
232
|
0 |
0 |
unless ($status and $status eq 'RES_WAIT') |
|
252
|
0 |
0 |
unless my $method = $args{'method'} |
|
261
|
0 |
0 |
if ($self->{'json'}) { } |
|
264
|
0 |
0 |
unless ref $inargs eq 'HASH' |
|
266
|
0 |
0 |
unless ref $inargs eq 'HASH' |
|
269
|
0 |
0 |
if ($reqauth) |
|
273
|
0 |
0 |
if ($reqauth) |
|
274
|
0 |
0 |
if (&blessed($reqauth)) |
|
275
|
0 |
0 |
if ($reqauth->can('_to_reqauth')) { } |
|
282
|
0 |
0 |
unless ref $reqauth eq 'HASH' |
|
289
|
0 |
0 |
if ($timeout > 0) |
|
291
|
0 |
0 |
unless my $rescb = delete $req->{'rescb'} |
|
297
|
0 |
0 |
$vtag ? : |
|
301
|
0 |
0 |
$reqauth ? : |
|
309
|
0 |
0 |
if ($e) |
|
312
|
0 |
0 |
if $rescb |
|
316
|
0 |
0 |
unless $rescb |
|
318
|
0 |
0 |
if ($status eq 'RES_WAIT') { } |
|
320
|
0 |
0 |
unless ($vci) |
|
330
|
0 |
0 |
if $waitcb |
|
333
|
0 |
0 |
if $self->{'json'} and ref $outargs |
|
335
|
0 |
0 |
if $tmr |
|
342
|
0 |
0 |
if $rescb |
|
343
|
0 |
0 |
if $tmr |
|
354
|
0 |
0 |
unless $ns |
|
356
|
0 |
0 |
$notify ? : |
|
361
|
0 |
0 |
if $self->{'json'} |
|
370
|
0 |
0 |
unless $status and $status eq 'RES_WAIT' |
|
371
|
0 |
0 |
unless $notify |
|
389
|
0 |
0 |
unless $id |
|
391
|
0 |
0 |
unless $vci |
|
393
|
0 |
0 |
unless $req |
|
395
|
0 |
0 |
unless $rescb |
|
396
|
0 |
0 |
if $tmr |
|
398
|
0 |
0 |
if $self->{'json'} and ref $outargs |
|
407
|
0 |
0 |
unless $ch |
|
409
|
0 |
0 |
unless $wl |
|
412
|
0 |
0 |
if $tmr |
|
413
|
0 |
0 |
if $rescb |
|
430
|
0 |
0 |
if (not $e and $r and $r =~ /pong/u) { } |
|
453
|
0 |
0 |
if ($self->lastping // 0) > time - $pt |
|
459
|
0 |
0 |
if $pt > 0 |
|
465
|
0 |
0 |
if $prepare |
|
468
|
0 |
0 |
unless $self->ioloop->is_running |
|
470
|
0 |
0 |
if $tmr |
|
483
|
0 |
0 |
unless my $method = $args{'method'} |
|
484
|
0 |
0 |
unless my $cb = $args{'cb'} |
|
486
|
0 |
0 |
$args{'async'} ? : |
|
487
|
0 |
0 |
unless $mode =~ /^(subproc|async|async2|sync)$/u |
|
491
|
0 |
0 |
if $self->actions->{$method} |
|
502
|
0 |
0 |
$args{'filter'} ? : |
|
|
0 |
0 |
$args{'doc'} ? : |
|
510
|
0 |
0 |
if ($e) |
|
516
|
0 |
0 |
unless ($res) |
|
559
|
0 |
0 |
unless ($action) |
|
564
|
0 |
0 |
unless my $rpcswitch = $request->{'rpcswitch'} |
|
576
|
0 |
0 |
if $action->{'meta'} |
|
580
|
0 |
0 |
if ($action->{'mode'} eq 'async2') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'async') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'sync') { } |
|
|
0 |
0 |
elsif ($action->{'mode'} eq 'subproc') { } |
|
593
|
0 |
0 |
if ($@) |
|
609
|
0 |
0 |
if ($@) { } |
|
616
|
0 |
0 |
if ($@) { } |
|
634
|
0 |
0 |
if ($@) { } |
|
652
|
0 |
0 |
unless pipe my $reader, my $writer |
|
654
|
0 |
0 |
unless defined(my $pid = fork) |
|
655
|
0 |
0 |
unless ($pid) |
|
661
|
0 |
0 |
if ($@) { } |
|
683
|
0 |
0 |
unless $$ == $me |
|
686
|
0 |
0 |
if ($@) |
|
693
|
0 |
0 |
if $@ |
|
708
|
0 |
0 |
if state $looping++ |
|
713
|
0 |
0 |
if (ref $reactor eq 'Mojo::Reactor::EV') { } |
|
|
0 |
0 |
elsif (ref $reactor eq 'Mojo::Reactor::Poll') { } |
|
733
|
0 |
0 |
if $err |