Skip to content

Commit e7fd871

Browse files
committed
chore
Signed-off-by: discord9 <[email protected]>
1 parent aee4eaf commit e7fd871

File tree

3 files changed

+10
-11
lines changed

3 files changed

+10
-11
lines changed

src/meta-srv/src/gc/mock.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -363,7 +363,7 @@ fn mock_region_stat(
363363
region_manifest: RegionManifestInfo::Mito {
364364
manifest_version: 0,
365365
flushed_entry_id: 0,
366-
file_removal_rate: 0,
366+
file_removed_cnt: 0,
367367
},
368368
rcus: 0,
369369
wcus: 0,

src/meta-srv/src/gc/mock/err_handle.rs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -34,13 +34,13 @@ async fn test_gc_regions_failure_handling() {
3434
let region_id = RegionId::new(table_id, 1);
3535
let peer = Peer::new(1, "");
3636

37-
// Create region stat with proper size and file_removal_rate to ensure it gets selected as candidate
37+
// Create region stat with proper size and file_removed_cnt to ensure it gets selected as candidate
3838
let mut region_stat = mock_region_stat(region_id, RegionRole::Leader, 200_000_000, 10); // 200MB
3939
if let RegionManifestInfo::Mito {
40-
file_removal_rate, ..
40+
file_removed_cnt, ..
4141
} = &mut region_stat.region_manifest
4242
{
43-
*file_removal_rate = 5;
43+
*file_removed_cnt = 5;
4444
}
4545

4646
let table_stats = HashMap::from([(table_id, vec![region_stat])]);
@@ -131,13 +131,13 @@ async fn test_get_file_references_failure() {
131131
let region_id = RegionId::new(table_id, 1);
132132
let peer = Peer::new(1, "");
133133

134-
// Create region stat with proper size and file_removal_rate to ensure it gets selected as candidate
134+
// Create region stat with proper size and file_removed_cnt to ensure it gets selected as candidate
135135
let mut region_stat = mock_region_stat(region_id, RegionRole::Leader, 200_000_000, 10); // 200MB
136136
if let RegionManifestInfo::Mito {
137-
file_removal_rate, ..
137+
file_removed_cnt, ..
138138
} = &mut region_stat.region_manifest
139139
{
140-
*file_removal_rate = 5;
140+
*file_removed_cnt = 5;
141141
}
142142

143143
let table_stats = HashMap::from([(table_id, vec![region_stat])]);
@@ -185,13 +185,13 @@ async fn test_get_table_route_failure() {
185185
let table_id = 1;
186186
let region_id = RegionId::new(table_id, 1);
187187

188-
// Create region stat with proper size and file_removal_rate to ensure it gets selected as candidate
188+
// Create region stat with proper size and file_removed_cnt to ensure it gets selected as candidate
189189
let mut region_stat = mock_region_stat(region_id, RegionRole::Leader, 200_000_000, 10); // 200MB
190190
if let RegionManifestInfo::Mito {
191-
file_removal_rate, ..
191+
file_removed_cnt, ..
192192
} = &mut region_stat.region_manifest
193193
{
194-
*file_removal_rate = 5;
194+
*file_removed_cnt = 5;
195195
}
196196

197197
let table_stats = HashMap::from([(table_id, vec![region_stat])]);

src/meta-srv/src/gc/procedure.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@ use crate::handler::HeartbeatMailbox;
3636
use crate::service::mailbox::{Channel, MailboxRef};
3737

3838
/// TODO(discord9): another procedure which do both get file refs and gc regions.
39-
4039
pub struct GcRegionProcedure {
4140
mailbox: MailboxRef,
4241
data: GcRegionData,

0 commit comments

Comments
 (0)