| line |
true |
false |
branch |
|
83
|
0 |
0 |
if defined $cof->{'base'}
|
|
88
|
0 |
0 |
if $_[0]->opened
|
|
104
|
0 |
0 |
if $cof->opened
|
|
108
|
0 |
0 |
if (fcread($flags) and not fctrunc($flags))
|
|
109
|
0 |
0 |
unless $hdr = $cof->readHeader
|
|
111
|
0 |
0 |
unless $cof->loadHeaderData($hdr)
|
|
117
|
0 |
0 |
if ($hdr and !defined($hdr->{'version'}) || 'version'->parse($hdr->{'version'}) < $min_version)
|
|
126
|
0 |
0 |
unless $cof->{'r1'}->open("$base.dba1", $flags, 'perms', $cof->{'perms'}, 'packas', "$cof->{'pack_i'}")
|
|
128
|
0 |
0 |
unless $cof->{'r2'}->open("$base.dba2", $flags, 'perms', $cof->{'perms'}, 'packas', "$cof->{'pack_i'}$cof->{'pack_d'}$cof->{'pack_f'}")
|
|
130
|
0 |
0 |
unless $cof->{'r3'}->open("$base.dba3", $flags, 'perms', $cof->{'perms'}, 'packas', "$cof->{'pack_i'}$cof->{'pack_f'}")
|
|
132
|
0 |
0 |
unless $cof->{'rN'}->open("$base.dbaN", $flags, 'perms', $cof->{'perms'}, 'packas', "$cof->{'pack_f'}")
|
|
145
|
0 |
0 |
if ($cof->opened and fcwrite($cof->{'flags'}))
|
|
146
|
0 |
0 |
unless $cof->saveHeader
|
|
148
|
0 |
0 |
unless $cof->{'r1'}->close
|
|
149
|
0 |
0 |
unless $cof->{'r2'}->close
|
|
150
|
0 |
0 |
unless $cof->{'r3'}->close
|
|
151
|
0 |
0 |
unless $cof->{'rN'}->close
|
|
183
|
0 |
0 |
if (not defined $hdr || fccreat($cof->{'flags'})) { }
|
|
|
0 |
0 |
elsif (defined $hdr) { }
|
|
216
|
0 |
0 |
if (not ref $cof) { }
|
|
221
|
0 |
0 |
unless $cof->opened
|
|
223
|
0 |
0 |
$cof->wantXS ? :
|
|
233
|
0 |
0 |
unless $cof->opened
|
|
260
|
0 |
0 |
if ($i1_cur >= 0)
|
|
261
|
0 |
0 |
if ($i1_cur != $pos1)
|
|
272
|
0 |
0 |
if $f < $fmin or $_ < 0
|
|
278
|
0 |
0 |
if (defined $d1_cur)
|
|
285
|
0 |
0 |
if ($i1 != $i1_cur)
|
|
301
|
0 |
0 |
if (not defined $i1) { }
|
|
|
0 |
0 |
elsif (not defined $d1) { }
|
|
309
|
0 |
0 |
if $i1 != $i1_cur or $d1 != $d1_cur
|
|
323
|
0 |
0 |
$N1 > $N ? :
|
|
357
|
0 |
0 |
unless $cof->opened
|
|
366
|
0 |
0 |
exists $opts{'i2s1'} ? :
|
|
367
|
0 |
0 |
exists $opts{'i2s2'} ? :
|
|
378
|
0 |
0 |
unless $r1->read(\$buf1)
|
|
380
|
0 |
0 |
$i2s1 ? :
|
|
383
|
0 |
0 |
unless $r2->read(\$buf2)
|
|
387
|
0 |
0 |
unless $r3->read(\$buf3)
|
|
390
|
0 |
0 |
$i2s2 ? :
|
|
395
|
0 |
0 |
if $f12sum != $f1
|
|
410
|
0 |
0 |
if (not defined $WANT_XS or $WANT_XS and not $INC{'DiaColloDB/XS/CofUtils.pm'})
|
|
431
|
0 |
0 |
unless ref $cof
|
|
437
|
0 |
0 |
unless $cof->opened or $cof->open(undef, 'rw')
|
|
441
|
0 |
0 |
$cof->wantXS ? :
|
|
444
|
0 |
0 |
unless $cof->generatePairs($tokfile, $datfile)
|
|
449
|
0 |
0 |
unless $cof->loadTextFile($datfile)
|
|
453
|
0 |
0 |
unless $cof->saveHeader
|
|
457
|
0 |
0 |
unless $cof->{'keeptmp'}
|
|
475
|
0 |
0 |
unless $outfile
|
|
476
|
0 |
0 |
$cof->wantXS ? :
|
|
486
|
0 |
0 |
unless $outfile
|
|
490
|
0 |
0 |
unless CORE::open my $tokfh, "<$tokfile"
|
|
495
|
0 |
0 |
unless my $tmpfile = tmpfile("$outfile.tmp", 'UNLINK', !$cof->{'keeptmp'})
|
|
497
|
0 |
0 |
unless CORE::open my $tmpfh, ">$tmpfile"
|
|
507
|
0 |
0 |
if /^$/
|
|
510
|
0 |
0 |
unless @sent
|
|
517
|
0 |
0 |
if $_ >= 0 and $_ <= $#sent
|
|
522
|
0 |
0 |
unless CORE::close $tmpfh
|
|
527
|
0 |
0 |
unless runcmd("sort -nk1 -nk2 -nk3 $tmpfile " . sortJobs() . " | uniq -c - $outfile") == 0
|
|
532
|
0 |
0 |
unless $cof->{'keeptmp'}
|
|
552
|
0 |
0 |
unless ref $cof
|
|
557
|
0 |
0 |
unless my $tmpfh = 'IO::File'->new(">$tmpfile")
|
|
567
|
0 |
0 |
if UNIVERSAL::can($pi2u, 'toArray')
|
|
569
|
0 |
0 |
unless $pcof->saveTextFh($tmpfh, 'i2s', sub {
|
|
573
|
0 |
0 |
unless $tmpfh->close
|
|
578
|
0 |
0 |
unless my $sortfh = opencmd('sort -n -k2 -k3 -k4 ' . sortJobs() . " $tmpfile |")
|
|
581
|
0 |
0 |
unless $cof->loadTextFh($sortfh)
|
|
583
|
0 |
0 |
unless $sortfh->close
|
|
588
|
0 |
0 |
unless $cof->saveHeader
|
|
592
|
0 |
0 |
unless $cof->{'keeptmp'}
|
|
651
|
0 |
0 |
unless UNIVERSAL::isa($tids, 'ARRAY')
|
|
677
|
0 |
0 |
$slice ? :
|
|
683
|
0 |
0 |
if $i1 >= $size1
|
|
684
|
0 |
0 |
$i1 == 0 ? :
|
|
687
|
0 |
0 |
if $beg2 >= $size2
|
|
689
|
0 |
0 |
$pos2 == 0 ? :
|
|
693
|
0 |
0 |
if $dfilter and not &$dfilter($d1)
|
|
694
|
0 |
0 |
$slice ? :
|
|
698
|
0 |
0 |
if $beg3 >= $size3
|
|
701
|
0 |
0 |
$groupby ? :
|
|
703
|
0 |
0 |
if not defined $key2 or $extend and not exists $extend->{$ds}{$key2}
|
|
706
|
0 |
0 |
if ($onepass and not exists $id2{"$i2 $d1"})
|
|
709
|
0 |
0 |
$i2 == 0 ? :
|
|
746
|
0 |
0 |
UNIVERSAL::isa($r2, 'DiaColloDB::PackedFile::MMap') ? :
|
|
764
|
0 |
0 |
if exists $mspv{$mspvi}
|
|
772
|
0 |
0 |
$ts2g ? :
|
|
|
0 |
0 |
unless defined($key2 = $ts2g ? &$ts2g($t2) : pack($mspgpack, $i2))
|
|
775
|
0 |
0 |
$i2 == 0 ? :
|
|
778
|
0 |
0 |
$bufr2 ? :
|
|
781
|
0 |
0 |
if $dfilter and not &$dfilter($d2)
|
|
782
|
0 |
0 |
$slice ? :
|
|
786
|
0 |
0 |
unless exists $prf2->{'f12'}{$key2}
|
|
812
|
0 |
0 |
@$q1strs ? :
|
|
813
|
0 |
0 |
@$q2strs ? :
|
|
816
|
0 |
0 |
@$fstrs ? :
|