From 120dc8ecb4fbba303874e9ff4674522578753d77 Mon Sep 17 00:00:00 2001 From: ChristianVisintin Date: Mon, 28 Dec 2020 22:45:28 +0100 Subject: [PATCH] Fixed buffer sizes for transfers --- src/filetransfer/scp_transfer.rs | 4 ++-- src/filetransfer/sftp_transfer.rs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/filetransfer/scp_transfer.rs b/src/filetransfer/scp_transfer.rs index b960f8a..755dc42 100644 --- a/src/filetransfer/scp_transfer.rs +++ b/src/filetransfer/scp_transfer.rs @@ -772,7 +772,7 @@ impl FileTransfer for ScpFileTransfer { (mtime, atime) }; 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( FileTransferErrorType::ProtocolError, format!("{}", err), @@ -795,7 +795,7 @@ impl FileTransfer for ScpFileTransfer { // Set blocking to true session.set_blocking(true); 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( FileTransferErrorType::ProtocolError, format!("{}", err), diff --git a/src/filetransfer/sftp_transfer.rs b/src/filetransfer/sftp_transfer.rs index f17f75f..3208a82 100644 --- a/src/filetransfer/sftp_transfer.rs +++ b/src/filetransfer/sftp_transfer.rs @@ -578,7 +578,7 @@ impl FileTransfer for SftpFileTransfer { }; // Open remote file 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( FileTransferErrorType::NoSuchFileOrDirectory, format!("{}", err),