| line |
true |
false |
branch |
|
36
|
0 |
0 |
unless +(shift())->{'queue'} |
|
50
|
0 |
0 |
unless $str |
|
52
|
0 |
0 |
unless $url->protocol eq 'mongodb' |
|
58
|
0 |
0 |
$2 ? : |
|
59
|
0 |
0 |
if @hosts |
|
62
|
0 |
0 |
if (my $db = $url->path->parts->[0]) |
|
65
|
0 |
0 |
if (($url->userinfo // '') =~ /^([^:]+):([^:]+)$/) |
|
73
|
0 |
0 |
if (my $j = $query->param('journal')) |
|
74
|
0 |
0 |
if (my $w = $query->param('w')) |
|
75
|
0 |
0 |
if (my $timeout = $query->param('wtimeoutMS')) |
|
78
|
0 |
0 |
if (@extra) |
|
93
|
0 |
0 |
unless $mode |
|
111
|
0 |
0 |
unless $self->_loop(0) |
|
118
|
0 |
0 |
if $loop |
|
131
|
0 |
0 |
unless my $c = delete $self->{'connections'}{$id} |
|
133
|
0 |
0 |
if $last |
|
134
|
0 |
0 |
if @{$self->{'queue'};} |
|
150
|
0 |
0 |
if ($err) |
|
151
|
0 |
0 |
unless @$hosts |
|
158
|
0 |
0 |
if $self |
|
159
|
0 |
0 |
if $self |
|
176
|
0 |
0 |
unless my $c = delete $self->{'connections'}{$id} |
|
180
|
0 |
0 |
if $last |
|
192
|
0 |
0 |
unless $err |
|
194
|
0 |
0 |
unless my $last = shift @{$$self{'queue'};} |
|
213
|
0 |
0 |
$_[1] ? : |
|
220
|
0 |
0 |
unless ($doc->{'maxWireVersion'} || 0) >= 3 |
|
223
|
0 |
0 |
if ($doc->{'ismaster'}) |
|
224
|
0 |
0 |
$self->_auth ? : |
|
230
|
0 |
0 |
if ($doc->{'primary'} // '') =~ /^(.+):(\d+)$/ |
|
231
|
0 |
0 |
unless @$hosts |
|
241
|
0 |
0 |
if $op |
|
247
|
0 |
0 |
unless $op |
|
250
|
0 |
0 |
unless $op->{'nb'} or grep {not $connections->{$_}{'nb'};} @ids |
|
254
|
0 |
0 |
if not $start and @{$self->{'queue'};} and @ids < $self->max_connections |
|
259
|
0 |
0 |
ref $_[-1] eq 'CODE' ? : |
|
272
|
0 |
0 |
unless $reply->{'to'} == $c->{'last'}{'id'} |
|
282
|
0 |
0 |
unless ($self->{'pid'} //= $$) eq $$ |
|
285
|
0 |
0 |
if $op->{'cb'} |
|
292
|
0 |
0 |
$err ? : |
|
300
|
0 |
0 |
if $c->{'last'} |
|
302
|
0 |
0 |
unless my $stream = $loop->stream($id) |
|
303
|
0 |
0 |
if (not $loop->is_running and $stream->is_readable) |
|
309
|
0 |
0 |
unless my $last = delete $c->{'fast'} |
|
313
|
0 |
0 |
unless $last or ($c->{'nb'} xor not +($self->{'queue'}[-1] || {})->{'nb'}) |
|
314
|
0 |
0 |
$c->{'nb'} ? : |
|
316
|
0 |
0 |
unless $c->{'last'} = $last |
|
321
|
0 |
0 |
if $last->{'safe'} |