diff options
| author | Alex <alex@adnab.me> | 2024-02-23 15:49:43 +0000 |
|---|---|---|
| committer | Alex <alex@adnab.me> | 2024-02-23 15:49:43 +0000 |
| commit | 61758ce0f91b930542bd2ee3c72735000cc12e75 (patch) | |
| tree | 0a8c9c8d57abfa084188873dab2987ecfe93c0d7 /src/block/repair.rs | |
| parent | 74d0c47f21ae2f9998a7dcbca3a27e3cc51e70b6 (diff) | |
| parent | 6ee691e65f2c6f7b337a62cbfacaddb9ba9cd61a (diff) | |
| download | garage-61758ce0f91b930542bd2ee3c72735000cc12e75.tar.gz garage-61758ce0f91b930542bd2ee3c72735000cc12e75.zip | |
Merge pull request 'some refactoring on data read/write path' (#729) from refactor-block into main
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/729
Diffstat (limited to 'src/block/repair.rs')
| -rw-r--r-- | src/block/repair.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/block/repair.rs b/src/block/repair.rs index 77ee0d14..2c8acbc9 100644 --- a/src/block/repair.rs +++ b/src/block/repair.rs @@ -584,8 +584,8 @@ impl Worker for RebalanceWorker { let prim_loc = self.manager.data_layout.load().primary_block_dir(&hash); if path.ancestors().all(|x| x != prim_loc) { let block_path = match path.extension() { - None => DataBlockPath::Plain(path.clone()), - Some(x) if x.to_str() == Some("zst") => DataBlockPath::Compressed(path.clone()), + None => DataBlockPath::plain(path.clone()), + Some(x) if x.to_str() == Some("zst") => DataBlockPath::compressed(path.clone()), _ => { warn!("not rebalancing file: {}", path.to_string_lossy()); return Ok(WorkerState::Busy); |