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

time

Browse source
This commit is contained in:
Ahmet Kaan GÜMÜŞ 2023-09-17 07:28:18 +03:00
parent afde42ea58
commit 8fa908f571
1 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/main.rs
View file

@ -1,4 +1,5 @@
use std::fs::File; use std::fs::File;
use std::time::Instant;
use std::net::{TcpListener, TcpStream}; use std::net::{TcpListener, TcpStream};
use std::io::{Read, Write, self}; use std::io::{Read, Write, self};
use std::env::{self}; use std::env::{self};
@ -97,6 +98,7 @@ impl Connection
while stay while stay
{ {
let mut data = vec![]; let mut data = vec![];
let start_time = Instant::now();
match stream.read_to_end(&mut data) match stream.read_to_end(&mut data)
{ {
Ok(res) => Ok(res) =>
@ -107,7 +109,12 @@ impl Connection
return; return;
} }
file_info.bytes = data; file_info.bytes = data;
let start_disk_time = Instant::now();
println!("Passed: Network -> {:#?}", start_disk_time.duration_since(start_time));
FileInfo::write_file(file_info); FileInfo::write_file(file_info);
let finish_time = Instant::now();
println!("Passed: Write -> {:#?}", finish_time.duration_since(start_disk_time));
println!("Passed: Total -> {:#?}", finish_time.duration_since(start_time));
} }
Err(e) => Err(e) =>
{ {
@ -146,10 +153,16 @@ impl Connection
{ {
Ok(mut socket) => Ok(mut socket) =>
{ {
let start_time = Instant::now();
println!("Connected"); println!("Connected");
FileInfo::read_file(file_info); FileInfo::read_file(file_info);
FileInfo::file_to_byte(file_info); FileInfo::file_to_byte(file_info);
let start_network_time = Instant::now();
println!("Passed: Read -> {:#?}", start_network_time.duration_since(start_time));
socket.write_all(&file_info.bytes).unwrap(); socket.write_all(&file_info.bytes).unwrap();
let finish_time = Instant::now();
println!("Passed: Network -> {:#?}", finish_time.duration_since(start_network_time));
println!("Passed: Total -> {:#?}", finish_time.duration_since(start_time));
} }
Err(e) => Err(e) =>
{ {