rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-15 04:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: per review

Browse Source 
Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-03-04 11:23:39 +08:00
parent 9bc763cdbe
commit 1880ac6385
1 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/mito2/src/sst/file.rs
View File

@@ -570,10 +570,12 @@ pub async fn delete_files(
region_file_id,
path_type,
));
for version in 0..=*index_version {
let index_id = RegionIndexId::new(region_file_id, version);
paths.push(location::index_file_path(table_dir, index_id, path_type));
}
push_index_paths(
&mut paths,
table_dir,
&path_type,
(0..=*index_version).map(|version| RegionIndexId::new(region_file_id, version)),
);
}
let mut deleter = access_layer
@@ -639,9 +641,7 @@ pub async fn delete_indexes(
let table_dir = access_layer.table_dir();
let path_type = access_layer.path_type();
let mut paths = Vec::with_capacity(index_ids.len());
for index_id in index_ids {
paths.push(location::index_file_path(table_dir, *index_id, path_type));
}
push_index_paths(&mut paths, table_dir, &path_type, index_ids.iter().copied());
match access_layer.object_store().deleter().await {
Ok(mut deleter) => {
@@ -692,6 +692,17 @@ pub async fn delete_indexes(
Ok(())
}
fn push_index_paths<I>(paths: &mut Vec<String>, table_dir: &str, path_type: &PathType, index_ids: I)
where
I: IntoIterator<Item = RegionIndexId>,
{
paths.extend(
index_ids
.into_iter()
.map(|index_id| location::index_file_path(table_dir, index_id, *path_type)),
);
}
async fn delete_index_and_purge(
index_id: RegionIndexId,
access_layer: &AccessLayerRef,