db/pgbackrest
1
0
Fork 0
mirror of https://github.com/pgbackrest/pgbackrest.git synced 2025-01-18 04:58:51 +02:00
Code Issues Releases Activity

Compress looks good, back to decompress.

Browse Source
This commit is contained in:
David Steele 2015-02-27 14:11:59 -05:00
parent bd44b2c471
commit c18c629878
1 changed files with 18 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
lib/BackRest/Remote.pm
View File

@ -573,9 +573,7 @@ sub binary_xfer
}
# Read block from protocol stream
# &log(INFO, "read new block");
$iBlockSize = $self->block_read($hIn, \$strBlock);
# &log(INFO, "block size = ${iBlockSize}");
if (!$bDestinationCompress)
{
@ -640,40 +638,35 @@ sub binary_xfer
$self->wait_pid();
confess &log(ERROR, 'unable to read');
}
}
$self->block_write($hOut, \$strBlock);
undef($strBlock);
}
# If there was nothing new to compress then close
if (!defined($strBlock))
{
$oGzip->close();
}
# If there is data in the compressed buffer, then output
if (defined($strBlock))
{
$iBlockIn = length($strBlock);
}
# Else indicate that the stream is complete
else
{
# &log(INFO, "set block in 0");
$iBlockIn = 0;
$oGzip->close();
$self->block_write($hOut, \$strBlock);
$self->block_write($hOut, undef, 0);
last;
}
}
# If source is already compressed or transfer is not compressed then just read the stream
else
{
$iBlockIn = $self->stream_read($hIn, \$strBlock, $iBlockSize);
if ($iBlockIn > 0)
{
$self->block_write($hOut, \$strBlock, $iBlockIn);
}
else
{
$self->block_write($hOut, undef, 0);
last;
}
}
$self->block_write($hOut, \$strBlock, $iBlockIn);
if ($iBlockIn == 0)
{
last;
}
undef($strBlock);
}
}
}