summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLars Wirzenius <liw@liw.fi>2021-08-10 10:53:11 +0300
committerLars Wirzenius <liw@liw.fi>2021-08-16 13:18:07 +0300
commit6bc136082f5fc02f4f2ebdcc0facbf666ee7b01c (patch)
treee71c58b56b3e9a04029d95c3ef5fc398dc6f464e
parent3adfd67831f0e197b8b2e23c79393056584f398e (diff)
downloadobnam2-6bc136082f5fc02f4f2ebdcc0facbf666ee7b01c.tar.gz
refactor: rename function to have a clearer name
Rename `read_file` to `upload_regular_file` to better describe the purpose of the function. Sponsored-by: author
-rw-r--r--src/backup_run.rs21
1 files changed, 8 insertions, 13 deletions
diff --git a/src/backup_run.rs b/src/backup_run.rs
index 1bb0bc0..b536f6e 100644
--- a/src/backup_run.rs
+++ b/src/backup_run.rs
@@ -297,7 +297,7 @@ impl<'a> BackupRun<'a> {
let path = e.pathbuf();
info!("uploading {:?}", path);
let ids = match e.kind() {
- FilesystemKind::Regular => self.read_file(&path, size).await?,
+ FilesystemKind::Regular => self.upload_regular_file(&path, size).await?,
FilesystemKind::Directory => vec![],
FilesystemKind::Symlink => vec![],
FilesystemKind::Socket => vec![],
@@ -313,7 +313,7 @@ impl<'a> BackupRun<'a> {
size: usize,
) -> Result<ChunkId, BackupError> {
info!("upload SQLite {}", filename.display());
- let ids = self.read_file(filename, size).await?;
+ let ids = self.upload_regular_file(filename, size).await?;
let gen = GenerationChunk::new(ids);
let data = gen.to_data_chunk(&current_timestamp())?;
let gen_id = self.client.upload_chunk(data).await?;
@@ -321,20 +321,16 @@ impl<'a> BackupRun<'a> {
Ok(gen_id)
}
- async fn read_file(&self, filename: &Path, size: usize) -> Result<Vec<ChunkId>, BackupError> {
+ async fn upload_regular_file(
+ &self,
+ filename: &Path,
+ size: usize,
+ ) -> Result<Vec<ChunkId>, BackupError> {
info!("upload file {}", filename.display());
+ 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 chunk_ids = self.upload_new_file_chunks(chunker).await?;
- Ok(chunk_ids)
- }
-
- pub async fn upload_new_file_chunks(
- &self,
- chunker: Chunker,
- ) -> Result<Vec<ChunkId>, BackupError> {
- let mut chunk_ids = vec![];
for item in chunker {
let chunk = item?;
if let Some(chunk_id) = self.client.has_chunk(chunk.meta()).await? {
@@ -346,7 +342,6 @@ impl<'a> BackupRun<'a> {
info!("created new chunk {}", chunk_id);
}
}
-
Ok(chunk_ids)
}