diff options
author | Lars Wirzenius <liw@liw.fi> | 2022-01-16 15:54:35 +0000 |
---|---|---|
committer | Lars Wirzenius <liw@liw.fi> | 2022-01-16 15:54:35 +0000 |
commit | 519a5f9d4ec3204f866912eb8250adc319ed4462 (patch) | |
tree | 4a87e897e74dc980c4bdf22e06ad4aa9b8ba7fef | |
parent | 8653cbf266b8088a01d74e83b7be6fb7cc7c8c48 (diff) | |
parent | 590275bbdb14ddf60542440182f72d633e680570 (diff) | |
download | obnam2-519a5f9d4ec3204f866912eb8250adc319ed4462.tar.gz |
Merge branch 'chunker' into 'main'
refactor: rename Chunker to FileChunks
Closes #179
See merge request obnam/obnam!211
-rw-r--r-- | src/backup_run.rs | 4 | ||||
-rw-r--r-- | src/chunker.rs | 6 |
2 files changed, 5 insertions, 5 deletions
diff --git a/src/backup_run.rs b/src/backup_run.rs index 2286fca..3787494 100644 --- a/src/backup_run.rs +++ b/src/backup_run.rs @@ -3,7 +3,7 @@ use crate::backup_progress::BackupProgress; use crate::backup_reason::Reason; use crate::chunk::{GenerationChunk, GenerationChunkError}; -use crate::chunker::{Chunker, ChunkerError}; +use crate::chunker::{ChunkerError, FileChunks}; use crate::chunkid::ChunkId; use crate::client::{BackupClient, ClientError}; use crate::config::ClientConfig; @@ -358,7 +358,7 @@ impl<'a> BackupRun<'a> { let mut chunk_ids = vec![]; let file = std::fs::File::open(filename) .map_err(|err| ClientError::FileOpen(filename.to_path_buf(), err))?; - let chunker = Chunker::new(size, file, filename); + let chunker = FileChunks::new(size, file, filename); for item in chunker { let chunk = item?; if let Some(chunk_id) = self.client.has_chunk(chunk.meta()).await? { diff --git a/src/chunker.rs b/src/chunker.rs index e8e31e1..7954621 100644 --- a/src/chunker.rs +++ b/src/chunker.rs @@ -7,7 +7,7 @@ use std::io::prelude::*; use std::path::{Path, PathBuf}; /// Iterator over chunks in a file. -pub struct Chunker { +pub struct FileChunks { chunk_size: usize, buf: Vec<u8>, filename: PathBuf, @@ -22,7 +22,7 @@ pub enum ChunkerError { FileRead(PathBuf, std::io::Error), } -impl Chunker { +impl FileChunks { /// Create new iterator. pub fn new(chunk_size: usize, handle: std::fs::File, filename: &Path) -> Self { let mut buf = vec![]; @@ -61,7 +61,7 @@ impl Chunker { } } -impl Iterator for Chunker { +impl Iterator for FileChunks { type Item = Result<DataChunk, ChunkerError>; /// Return the next chunk, if any, or an error. |