Fixed buffer sizes for transfers

This commit is contained in:
ChristianVisintin
2020-12-28 22:45:28 +01:00
parent 06a2373776
commit 120dc8ecb4
2 changed files with 3 additions and 3 deletions

View File

@@ -772,7 +772,7 @@ impl FileTransfer for ScpFileTransfer {
(mtime, atime) (mtime, atime)
}; };
match session.scp_send(file_name, mode, local.size as u64, Some(times)) { match session.scp_send(file_name, mode, local.size as u64, Some(times)) {
Ok(channel) => Ok(Box::new(BufWriter::with_capacity(8192, channel))), Ok(channel) => Ok(Box::new(BufWriter::with_capacity(65536, channel))),
Err(err) => Err(FileTransferError::new_ex( Err(err) => Err(FileTransferError::new_ex(
FileTransferErrorType::ProtocolError, FileTransferErrorType::ProtocolError,
format!("{}", err), format!("{}", err),
@@ -795,7 +795,7 @@ impl FileTransfer for ScpFileTransfer {
// Set blocking to true // Set blocking to true
session.set_blocking(true); session.set_blocking(true);
match session.scp_recv(file.abs_path.as_path()) { match session.scp_recv(file.abs_path.as_path()) {
Ok(reader) => Ok(Box::new(BufReader::with_capacity(8192, reader.0))), Ok(reader) => Ok(Box::new(BufReader::with_capacity(65536, reader.0))),
Err(err) => Err(FileTransferError::new_ex( Err(err) => Err(FileTransferError::new_ex(
FileTransferErrorType::ProtocolError, FileTransferErrorType::ProtocolError,
format!("{}", err), format!("{}", err),

View File

@@ -578,7 +578,7 @@ impl FileTransfer for SftpFileTransfer {
}; };
// Open remote file // Open remote file
match sftp.open(remote_path.as_path()) { match sftp.open(remote_path.as_path()) {
Ok(file) => Ok(Box::new(BufReader::with_capacity(8192, file))), Ok(file) => Ok(Box::new(BufReader::with_capacity(65536, file))),
Err(err) => Err(FileTransferError::new_ex( Err(err) => Err(FileTransferError::new_ex(
FileTransferErrorType::NoSuchFileOrDirectory, FileTransferErrorType::NoSuchFileOrDirectory,
format!("{}", err), format!("{}", err),