Tahinli/rust-tcp-file-transfer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove_ram_limitations

Browse source
This commit is contained in:
Ahmet Kaan GÜMÜŞ 2023-10-12 14:21:47 +03:00
parent 3c011983a3
commit d42412c57d
2 changed files with 8 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

2
README.md
View file

@ -4,7 +4,7 @@ TCP File Transfer Server and Client in Rust
☑ File transfer over network.
☐ Remove memory limitations.
☑ Remove memory limitations.
☐ Folder transfer.

15
src/main.rs
View file

@ -1,7 +1,8 @@
use std::fs::{File, Metadata, self};
use std::os::unix::prelude::FileExt;
use std::time::Instant;
use std::net::{TcpListener, TcpStream};
use std::io::{Read, Write, self, BufWriter, BufReader, BufRead};
use std::io::{Read, Write, self, BufWriter, BufReader, BufRead, Seek};
use std::env::{self};
@ -143,7 +144,7 @@ impl FileInfo
let mut file_reader = BufReader::new(self.file.as_ref().unwrap());
if iteration != 0
{
match file_reader.read_exact(&mut buffer)
match self.file.as_ref().unwrap().read_exact(&mut buffer)
{
Ok(_) =>
{
@ -161,14 +162,12 @@ impl FileInfo
}
else
{
let mut last_buffer:Vec<u8> = Vec::new();
match file_reader.read_to_end(&mut last_buffer)
match self.file.as_ref().unwrap().read_exact(&mut buffer[..(self.metadata.as_ref().unwrap().len()%BUFFER_SIZE as u64) as usize])
{
Ok(read_size) =>
//fix it
Ok(_) =>
{
self.size_current += read_size;
last_buffer.append(&mut buffer[..(self.metadata.as_ref().unwrap().len()%BUFFER_SIZE as u64) as usize].to_vec());
buffer.copy_from_slice(&last_buffer);
self.size_current += (self.metadata.as_ref().unwrap().len()%BUFFER_SIZE as u64) as usize;
println!("Size now = {}", self.size_current);
//println!("{} | {} | {:#?}", iteration,buffer.len(), buffer);
}