add _inclusive (#27301)
This commit is contained in:
parent
15af69f4c1
commit
ae02d955b4
|
@ -2432,14 +2432,14 @@ impl AccountsDb {
|
||||||
// dirty_stores - set of stores which had accounts removed or recently rooted
|
// dirty_stores - set of stores which had accounts removed or recently rooted
|
||||||
fn construct_candidate_clean_keys(
|
fn construct_candidate_clean_keys(
|
||||||
&self,
|
&self,
|
||||||
max_clean_root: Option<Slot>,
|
max_clean_root_inclusive: Option<Slot>,
|
||||||
is_startup: bool,
|
is_startup: bool,
|
||||||
last_full_snapshot_slot: Option<Slot>,
|
last_full_snapshot_slot: Option<Slot>,
|
||||||
timings: &mut CleanKeyTimings,
|
timings: &mut CleanKeyTimings,
|
||||||
) -> Vec<Pubkey> {
|
) -> Vec<Pubkey> {
|
||||||
let mut dirty_store_processing_time = Measure::start("dirty_store_processing");
|
let mut dirty_store_processing_time = Measure::start("dirty_store_processing");
|
||||||
let max_slot_inclusive =
|
let max_slot_inclusive =
|
||||||
max_clean_root.unwrap_or_else(|| self.accounts_index.max_root_inclusive());
|
max_clean_root_inclusive.unwrap_or_else(|| self.accounts_index.max_root_inclusive());
|
||||||
let mut dirty_stores = Vec::with_capacity(self.dirty_stores.len());
|
let mut dirty_stores = Vec::with_capacity(self.dirty_stores.len());
|
||||||
self.dirty_stores.retain(|(slot, _store_id), store| {
|
self.dirty_stores.retain(|(slot, _store_id), store| {
|
||||||
if *slot > max_slot_inclusive {
|
if *slot > max_slot_inclusive {
|
||||||
|
|
Loading…
Reference in New Issue