#
#========================================================================
#
-# Version 2.0.0_CVS, released 3 Feb 2003.
+# Version 2.0.0beta3, released 1 Jun 2003.
#
# See http://backuppc.sourceforge.net.
#
attrib => {},
logHandler => \&logHandler,
stats => {
+ errorCnt => 0,
TotalFileCnt => 0,
TotalFileSize => 0,
ExistFileCnt => 0,
0,
$attr->{compress})) ) {
$fio->log("Can't open $attr->{fullPath} (name=$f->{name})");
+ $fio->{stats}{errorCnt}++;
return -1;
}
if ( $needMD4) {
return if ( !defined($fio->{fh}) );
if ( $fio->{fh}->read(\$fileData, $blockSize * $num) <= 0 ) {
- return;
+ $fio->log("$fio->{file}{name}: csumGet is at EOF - zero padding");
+ $fio->{stats}{errorCnt}++;
+ $fileData = pack("c", 0) x ($blockSize * $num);
}
$fio->{csumDigest}->add($fileData) if ( defined($fio->{csumDigest}) );
- $fio->log(sprintf("%s: getting csum ($num,$csumLen,%d,0x%x)\n",
+ $fio->log(sprintf("%s: getting csum ($num,$csumLen,%d,0x%x)",
$fio->{file}{name},
length($fileData),
$fio->{checksumSeed}))
- if ( $fio->{logLevel} >= 10 );
+ if ( $fio->{logLevel} >= 9 );
return $fio->{digest}->blockDigest($fileData, $blockSize,
$csumLen, $fio->{checksumSeed});
}
0,
$attr->{compress})) ) {
$fio->log("Can't open $attr->{fullPath} (name=$f->{name})");
+ $fio->{stats}{errorCnt}++;
return;
}
$fio->log("$f->{name}: opened for read") if ( $fio->{logLevel} >= 4 );
File::Path::mkpath($path, 0, 0777) if ( !-d $path );
return $fio->attribSet($f) if ( -d $path );
$fio->log("Can't create directory $path");
+ $fio->{stats}{errorCnt}++;
return -1;
}
$rxOutFile, $fio->{rxFile}{size},
$fio->{xfer}{compress});
$fio->log("$fio->{rxFile}{name}: opening output file $rxOutFile")
- if ( $fio->{logLevel} >= 10 );
+ if ( $fio->{logLevel} >= 9 );
$fio->{rxOutFile} = $rxOutFile;
$fio->{rxOutFileRel} = $rxOutFileRel;
$fio->{rxDigest} = File::RsyncP::Digest->new;
0,
$attr->{compress})) ) {
$fio->log("Can't open $attr->{fullPath}");
+ $fio->{stats}{errorCnt}++;
return -1;
}
- if ( $attr->{size} < 10 * 1024 * 1024 ) {
+ if ( $attr->{size} < 16 * 1024 * 1024 ) {
#
- # Cache the entire old file if it is less than 10MB
+ # Cache the entire old file if it is less than 16MB
#
my $data;
$fio->{rxInData} = "";
- while ( $fh->read(\$data, 10 * 1024 * 1024) > 0 ) {
+ while ( $fh->read(\$data, 16 * 1024 * 1024) > 0 ) {
$fio->{rxInData} .= $data;
}
+ $fio->log("$attr->{fullPath}: cached all $attr->{size}"
+ . " bytes")
+ if ( $fio->{logLevel} >= 9 );
} else {
#
# Create and write a temporary output file
if ( -f "$fio->{outDirSh}RStmp" );
if ( open(F, "+>", "$fio->{outDirSh}RStmp") ) {
my $data;
+ my $byteCnt = 0;
while ( $fh->read(\$data, 1024 * 1024) > 0 ) {
if ( syswrite(F, $data) != length($data) ) {
$fio->log(sprintf("Can't write len=%d to %s",
length($data) , "$fio->{outDirSh}RStmp"));
$fh->close;
+ $fio->{stats}{errorCnt}++;
return -1;
}
+ $byteCnt += length($data);
}
$fio->{rxInFd} = *F;
$fio->{rxInName} = "$fio->{outDirSh}RStmp";
- seek($fio->{rxInFd}, 0, 0);
+ sysseek($fio->{rxInFd}, 0, 0);
+ $fio->log("$attr->{fullPath}: copied $byteCnt,"
+ . "$attr->{size} bytes to $fio->{rxInName}")
+ if ( $fio->{logLevel} >= 9 );
} else {
$fio->log("Unable to open $fio->{outDirSh}RStmp");
$fh->close;
+ $fio->{stats}{errorCnt}++;
return -1;
}
}
$fio->{rxInName} = $attr->{fullPath};
} else {
$fio->log("Unable to open $attr->{fullPath}");
+ $fio->{stats}{errorCnt}++;
return -1;
}
}
my $lastBlk = $fio->{rxMatchNext} - 1;
$fio->log("$fio->{rxFile}{name}: writing blocks $fio->{rxMatchBlk}.."
. "$lastBlk")
- if ( $fio->{logLevel} >= 10 );
+ if ( $fio->{logLevel} >= 9 );
my $seekPosn = $fio->{rxMatchBlk} * $fio->{rxBlkSize};
- if ( defined($fio->{rxInFd}) && !seek($fio->{rxInFd}, $seekPosn, 0) ) {
- $fio->log("Unable to seek $attr->{fullPath} to $seekPosn");
+ if ( defined($fio->{rxInFd})
+ && !sysseek($fio->{rxInFd}, $seekPosn, 0) ) {
+ $fio->log("Unable to seek $attr->{rxInName} to $seekPosn");
+ $fio->{stats}{errorCnt}++;
return -1;
}
my $cnt = $fio->{rxMatchNext} - $fio->{rxMatchBlk};
}
if ( defined($fio->{rxInData}) ) {
$data = substr($fio->{rxInData}, $seekPosn, $len);
+ $seekPosn += $len;
} else {
- if ( sysread($fio->{rxInFd}, $data, $len) != $len ) {
- $fio->log("Unable to read $len bytes from"
- . " $fio->{rxInName} "
- . "($i,$thisCnt,$fio->{rxBlkCnt})");
+ my $got = sysread($fio->{rxInFd}, $data, $len);
+ if ( $got != $len ) {
+ my $inFileSize = -s $fio->{rxInName};
+ $fio->log("Unable to read $len bytes from $fio->{rxInName}"
+ . " got=$got, seekPosn=$seekPosn"
+ . " ($i,$thisCnt,$fio->{rxBlkCnt},$inFileSize"
+ . ",$attr->{size})");
+ $fio->{stats}{errorCnt}++;
return -1;
}
+ $seekPosn += $len;
}
$fio->{rxOutFd}->write(\$data);
$fio->{rxDigest}->add($data);
#
my $len = length($newData);
$fio->log("$fio->{rxFile}{name}: writing $len bytes new data")
- if ( $fio->{logLevel} >= 10 );
+ if ( $fio->{logLevel} >= 9 );
$fio->{rxOutFd}->write(\$newData);
$fio->{rxDigest}->add($newData);
$fio->{rxSize} += length($newData);
$fio->{rxDigest} = File::RsyncP::Digest->new;
$fio->{rxDigest}->add(pack("V", $fio->{checksumSeed}));
my $attr = $fio->{rxLocalAttr};
- if ( defined($attr) && defined(my $fh = BackupPC::FileZIO->open(
+ if ( defined($attr) ) {
+ if ( defined(my $fh = BackupPC::FileZIO->open(
$attr->{fullPath},
0,
$attr->{compress})) ) {
- my $data;
- while ( $fh->read(\$data, 4 * 65536) > 0 ) {
- $fio->{rxDigest}->add($data);
- $fio->{rxSize} += length($data);
+ my $data;
+ while ( $fh->read(\$data, 4 * 65536) > 0 ) {
+ $fio->{rxDigest}->add($data);
+ $fio->{rxSize} += length($data);
+ }
+ $fh->close;
+ } else {
+ $fio->log("Can't open $attr->{fullPath} for MD4 check ($name)");
+ $fio->{stats}{errorCnt}++;
}
- $fh->close;
- } else {
- # ERROR
}
$fio->log("$name got exact match")
if ( $fio->{logLevel} >= 5 );
$fio->log("$name got digests $md4Str vs $newStr")
}
if ( $md4 ne $newDigest ) {
- $fio->log("$name md4 doesn't match")
- if ( $fio->{logLevel} >= 1 );
+ $fio->log("$name: fatal error: md4 doesn't match");
+ $fio->{stats}{errorCnt}++;
if ( defined($fio->{rxOutFd}) ) {
$fio->{rxOutFd}->close;
unlink($fio->{rxOutFile});
. $fio->{bpc}->fileNameMangle($name);
if ( !link($attr->{fullPath}, $rxOutFile) ) {
$fio->log("Unable to link $attr->{fullPath} to $rxOutFile");
+ $fio->{stats}{errorCnt}++;
return -1;
}
#
|| $type == BPC_FTYPE_BLOCKDEV
|| $type == BPC_FTYPE_SYMLINK ) {
my $fh = BackupPC::FileZIO->open($a->{fullPath}, 0, $a->{compress});
- my $str;
+ my($str, $rdSize);
if ( defined($fh) ) {
- if ( $fh->read(\$str, $a->{size} + 1) == $a->{size} ) {
- if ( $type == BPC_FTYPE_SYMLINK ) {
- #
- # Reconstruct symbolic link
- #
- $extraAttribs = { link => $str };
- } elsif ( $str =~ /(\d*),(\d*)/ ) {
- #
- # Reconstruct char or block special major/minor device num
- #
- $extraAttribs = { rdev => $1 * 256 + $2 };
- } else {
+ $rdSize = $fh->read(\$str, $a->{size} + 1024);
+ if ( $type == BPC_FTYPE_SYMLINK ) {
+ #
+ # Reconstruct symbolic link
+ #
+ $extraAttribs = { link => $str };
+ if ( $rdSize != $a->{size} ) {
# ERROR
- $fio->log("$name: unexpected file contents $str");
+ $fio->log("$name: can't read exactly $a->{size} bytes");
+ $fio->{stats}{errorCnt}++;
}
+ } elsif ( $str =~ /(\d*),(\d*)/ ) {
+ #
+ # Reconstruct char or block special major/minor device num
+ #
+ # Note: char/block devices have $a->{size} = 0, so we
+ # can't do an error check on $rdSize.
+ #
+ $extraAttribs = { rdev => $1 * 256 + $2 };
} else {
- # ERROR
- $fio->log("$name: can't read exactly $a->{size} bytes");
+ $fio->log("$name: unexpected special file contents $str");
+ $fio->{stats}{errorCnt}++;
}
$fh->close;
} else {
# ERROR
$fio->log("$name: can't open");
+ $fio->{stats}{errorCnt}++;
}
}
my $f = {
projects / BackupPC.git / blobdiff