TudbuT/qft
1
0
Fork 0
Code Issues 5 Pull requests Projects Releases 31 Packages Wiki Activity Actions

Attempted to add speed indicator on both sender and receiver (untested)

Browse source
This commit is contained in:
amatgil 2022-10-03 00:56:32 +02:00
parent f5caf49c92
commit 93d5806e49
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/main.rs
View file

@ -411,7 +411,8 @@ pub fn sender<F: Fn(f32)>(args: &Vec<String>, on_progress: F) {
sc.write_safe(&buf[..read]).expect("send error"); sc.write_safe(&buf[..read]).expect("send error");
bytes_sent += read as u64; bytes_sent += read as u64;
if (bytes_sent % (br * 20) as u64) < (br as u64) { if (bytes_sent % (br * 20) as u64) < (br as u64) {
print!("\r\x1b[KSent {} bytes", bytes_sent); print!("\r\x1b[KSent {} bytes; Speed: {} kb/s",
bytes_sent, (read / 1000) / last_update as usize );
stdout().flush().unwrap(); stdout().flush().unwrap();
} }
if unix_millis() - last_update > 100 { if unix_millis() - last_update > 100 {
@ -478,7 +479,8 @@ pub fn receiver<F: Fn(f32)>(args: &Vec<String>, on_progress: F) {
file.flush().expect("file flush error"); file.flush().expect("file flush error");
bytes_received += amount as u64; bytes_received += amount as u64;
if (bytes_received % (br * 20) as u64) < (br as u64) { if (bytes_received % (br * 20) as u64) < (br as u64) {
print!("\r\x1b[KReceived {} bytes", bytes_received); print!("\r\x1b[KSent {} bytes; Speed: {} kb/s",
bytes_sent, (read / 1000) / last_update as usize );
stdout().flush().unwrap(); stdout().flush().unwrap();
} }
if unix_millis() - last_update > 100 { if unix_millis() - last_update > 100 {