Use Arc instead of &Arc in AccountsBackgroundService::new (#31268)
This commit is contained in:
parent
80b27f3cd9
commit
ca1bde3591
|
@ -734,7 +734,7 @@ impl Validator {
|
||||||
let last_full_snapshot_slot = starting_snapshot_hashes.map(|x| x.full.0 .0);
|
let last_full_snapshot_slot = starting_snapshot_hashes.map(|x| x.full.0 .0);
|
||||||
let accounts_background_service = AccountsBackgroundService::new(
|
let accounts_background_service = AccountsBackgroundService::new(
|
||||||
bank_forks.clone(),
|
bank_forks.clone(),
|
||||||
&exit,
|
exit.clone(),
|
||||||
AbsRequestHandlers {
|
AbsRequestHandlers {
|
||||||
snapshot_request_handler,
|
snapshot_request_handler,
|
||||||
pruned_banks_request_handler,
|
pruned_banks_request_handler,
|
||||||
|
|
|
@ -217,7 +217,7 @@ impl BackgroundServices {
|
||||||
};
|
};
|
||||||
let accounts_background_service = AccountsBackgroundService::new(
|
let accounts_background_service = AccountsBackgroundService::new(
|
||||||
bank_forks,
|
bank_forks,
|
||||||
&exit,
|
exit.clone(),
|
||||||
AbsRequestHandlers {
|
AbsRequestHandlers {
|
||||||
snapshot_request_handler,
|
snapshot_request_handler,
|
||||||
pruned_banks_request_handler,
|
pruned_banks_request_handler,
|
||||||
|
|
|
@ -1009,8 +1009,13 @@ fn test_snapshots_with_background_services(
|
||||||
snapshot_test_config.snapshot_config.clone(),
|
snapshot_test_config.snapshot_config.clone(),
|
||||||
);
|
);
|
||||||
|
|
||||||
let accounts_background_service =
|
let accounts_background_service = AccountsBackgroundService::new(
|
||||||
AccountsBackgroundService::new(bank_forks.clone(), &exit, abs_request_handler, false, None);
|
bank_forks.clone(),
|
||||||
|
exit.clone(),
|
||||||
|
abs_request_handler,
|
||||||
|
false,
|
||||||
|
None,
|
||||||
|
);
|
||||||
|
|
||||||
let mut last_full_snapshot_slot = None;
|
let mut last_full_snapshot_slot = None;
|
||||||
let mut last_incremental_snapshot_slot = None;
|
let mut last_incremental_snapshot_slot = None;
|
||||||
|
|
|
@ -1282,7 +1282,7 @@ fn load_bank_forks(
|
||||||
let exit = Arc::new(AtomicBool::new(false));
|
let exit = Arc::new(AtomicBool::new(false));
|
||||||
let accounts_background_service = AccountsBackgroundService::new(
|
let accounts_background_service = AccountsBackgroundService::new(
|
||||||
bank_forks.clone(),
|
bank_forks.clone(),
|
||||||
&exit,
|
exit.clone(),
|
||||||
abs_request_handler,
|
abs_request_handler,
|
||||||
process_options.accounts_db_test_hash_calculation,
|
process_options.accounts_db_test_hash_calculation,
|
||||||
None,
|
None,
|
||||||
|
|
|
@ -529,12 +529,11 @@ pub struct AccountsBackgroundService {
|
||||||
impl AccountsBackgroundService {
|
impl AccountsBackgroundService {
|
||||||
pub fn new(
|
pub fn new(
|
||||||
bank_forks: Arc<RwLock<BankForks>>,
|
bank_forks: Arc<RwLock<BankForks>>,
|
||||||
exit: &Arc<AtomicBool>,
|
exit: Arc<AtomicBool>,
|
||||||
request_handlers: AbsRequestHandlers,
|
request_handlers: AbsRequestHandlers,
|
||||||
test_hash_calculation: bool,
|
test_hash_calculation: bool,
|
||||||
mut last_full_snapshot_slot: Option<Slot>,
|
mut last_full_snapshot_slot: Option<Slot>,
|
||||||
) -> Self {
|
) -> Self {
|
||||||
let exit = exit.clone();
|
|
||||||
let mut last_cleaned_block_height = 0;
|
let mut last_cleaned_block_height = 0;
|
||||||
let mut removed_slots_count = 0;
|
let mut removed_slots_count = 0;
|
||||||
let mut total_remove_slots_time = 0;
|
let mut total_remove_slots_time = 0;
|
||||||
|
|
Loading…
Reference in New Issue