diff options
Diffstat (limited to 'client-native-rift/src')
| -rw-r--r-- | client-native-rift/src/main.rs | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/client-native-rift/src/main.rs b/client-native-rift/src/main.rs index 48dac0b..e00d4c9 100644 --- a/client-native-rift/src/main.rs +++ b/client-native-rift/src/main.rs @@ -259,6 +259,7 @@ impl LocalResource for FileSender { fn on_request(&self, peer: Arc<Peer>) -> DynFut<()> { let id = self.info().id.clone(); + let total_size = self.info().size.unwrap_or(0); let reader_factory = self.reader_factory.clone(); Box::pin(async move { let channel = peer @@ -299,6 +300,7 @@ impl LocalResource for FileSender { let channel2 = channel.clone(); channel .on_buffered_amount_low(box move || { + let pos = pos.clone(); let reader = reader.clone(); let channel = channel2.clone(); Box::pin(async move { @@ -316,7 +318,12 @@ impl LocalResource for FileSender { info!("reached EOF, closing channel"); channel.close().await.unwrap(); } else { - debug!("sending {size} bytes"); + let progress_size = pos.fetch_add(size, Ordering::Relaxed); + info!( + "sending {size} bytes ({} of {})", + humansize::format_size(progress_size, DECIMAL), + humansize::format_size(total_size, DECIMAL), + ); channel .send(&Bytes::copy_from_slice(&buf[..size])) .await |