utils: drop unused reader tracking

Author: djc

src/dist/download.rs

@@ -1,5 +1,6 @@
 use std::borrow::Cow;
 use std::fs;
+use std::io::Read;
 use std::ops;
 use std::path::{Path, PathBuf};
 use std::sync::Mutex;
@@ -410,8 +411,7 @@ impl DownloadStatus {
 
 fn file_hash(path: &Path) -> Result<String> {
     let mut hasher = Sha256::new();
-    let mut downloaded = utils::FileReaderWithProgress::new_file(path)?;
-    use std::io::Read;
+    let mut downloaded = utils::buffered(path)?;
     let mut buf = vec![0; 32768];
     while let Ok(n) = downloaded.read(&mut buf) {
         if n == 0 {

src/dist/manifestation.rs

@@ -399,7 +399,7 @@ impl Manifestation {
         }
 
         // Install all the components in the installer
-        let reader = utils::FileReaderWithProgress::new_file(&installer_file)?;
+        let reader = utils::buffered(&installer_file)?;
         let temp_dir = dl_cfg.tmp_cx.new_directory()?;
         let io_executor = get_executor(
             unpack_ram(IO_CHUNK_SIZE, dl_cfg.process.unpack_ram()?),
@@ -687,7 +687,7 @@ impl<'a> ComponentBinary<'a> {
 
         self.status.installing();
 
-        let reader = utils::FileReaderWithProgress::new_file(&installer_file)?;
+        let reader = utils::buffered(&installer_file)?;
         let temp_dir = self.download_cfg.tmp_cx.new_directory()?;
         let io_executor = get_executor(
             unpack_ram(IO_CHUNK_SIZE, self.download_cfg.process.unpack_ram()?),

src/utils/mod.rs

@@ -8,7 +8,7 @@ use std::ops::{BitAnd, BitAndAssign};
 use std::path::{Path, PathBuf};
 use std::process::ExitStatus;
 
-use anyhow::{Context, Result, anyhow, bail};
+use anyhow::{Context, Result, anyhow};
 use retry::delay::{Fibonacci, jitter};
 use retry::{OperationResult, retry};
 use tracing::{debug, info, warn};
@@ -441,40 +441,13 @@ pub(crate) fn delete_dir_contents_following_links(dir_path: &Path) {
     }
 }
 
-pub(crate) struct FileReaderWithProgress {
-    fh: BufReader<File>,
-    nbytes: u64,
-}
-
-impl FileReaderWithProgress {
-    pub(crate) fn new_file(path: &Path) -> Result<Self> {
-        let fh = match File::open(path) {
-            Ok(fh) => fh,
-            Err(_) => {
-                bail!(RustupError::ReadingFile {
-                    name: "downloaded",
-                    path: path.to_path_buf(),
-                })
-            }
-        };
-
-        // Inform the tracker of the file size
-        Ok(FileReaderWithProgress {
-            fh: BufReader::with_capacity(8 * 1024 * 1024, fh),
-            nbytes: 0,
-        })
-    }
-}
-
-impl io::Read for FileReaderWithProgress {
-    fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
-        match self.fh.read(buf) {
-            Ok(nbytes) => {
-                self.nbytes += nbytes as u64;
-                Ok(nbytes)
-            }
-            Err(e) => Err(e),
-        }
+pub(crate) fn buffered(path: &Path) -> Result<BufReader<File>, anyhow::Error> {
+    match File::open(path) {
+        Ok(fh) => Ok(BufReader::with_capacity(8 * 1024 * 1024, fh)),
+        Err(_) => Err(anyhow!(RustupError::ReadingFile {
+            name: "downloaded",
+            path: path.to_path_buf(),
+        })),
     }
 }