(&self, offset: u64)
| 312 | } |
| 313 | |
| 314 | fn remove_segment(&self, offset: u64) -> io::Result<()> { |
| 315 | let _ = self.remove_offset_index(offset).map_err(|e| { |
| 316 | warn!( |
| 317 | "repo {}: failed to remove offset index for segment {}: {}", |
| 318 | self, offset, e |
| 319 | ); |
| 320 | }); |
| 321 | fs::remove_file(self.segment_path(offset)) |
| 322 | } |
| 323 | |
| 324 | fn compress_segment_with(&self, offset: u64, f: impl CompressOnce) -> io::Result<CompressionStats> { |
| 325 | let src = self.open_segment_reader(offset)?; |
no test coverage detected