diff --git a/rust-toolchain.toml b/rust-toolchain.toml new file mode 100644 index 0000000..22048ac --- /dev/null +++ b/rust-toolchain.toml @@ -0,0 +1,2 @@ +[toolchain] +channel = "1.70.0" diff --git a/stake_aggregate/src/main.rs b/stake_aggregate/src/main.rs index 6aef61c..52c2de4 100644 --- a/stake_aggregate/src/main.rs +++ b/stake_aggregate/src/main.rs @@ -300,7 +300,7 @@ async fn run_loop(mut client: GeyserGrpcClient) -> anyhow::Re }; if let Err(err) = tx.send((current_stakes, extract_slot)){ - println!("Channel error during sending back request status error:{err:?}"); + log::error!("Channel error during sending back request status error:{err:?}"); } log::info!("RPC GetStakestore account send"); @@ -354,7 +354,7 @@ async fn run_loop(mut client: GeyserGrpcClient) -> anyhow::Re //log::trace!("Geyser receive new account"); match account.owner { solana_sdk::stake::program::ID => { - log::info!("Geyser notif stake account:{}", account); + //log::info!("Geyser notif stake account:{}", account); if let Err(err) = stakestore.notify_stake_change( account, current_epoch_state.current_epoch_end_slot(), diff --git a/stake_aggregate/src/stakestore.rs b/stake_aggregate/src/stakestore.rs index c98221b..e0b0a14 100644 --- a/stake_aggregate/src/stakestore.rs +++ b/stake_aggregate/src/stakestore.rs @@ -46,13 +46,13 @@ fn stake_map_notify_stake(map: &mut StakeMap, stake: StoredStake) { //doesn't erase new state with an old one. Can arrive during bootstrapping. //several instructions can be done in the same slot. if strstake.last_update_slot <= stake.last_update_slot { - log::info!("stake_map_notify_stake Stake store updated stake: {} old_stake:{strstake:?} stake:{stake:?}", stake.pubkey); + log::trace!("stake_map_notify_stake Stake store updated stake: {} old_stake:{strstake:?} stake:{stake:?}", stake.pubkey); *strstake = stake; } } // If value doesn't exist yet, then insert a new value of 1 std::collections::hash_map::Entry::Vacant(vacant) => { - log::info!( + log::trace!( "stake_map_notify_stake Stake store insert stake: {} stake:{stake:?}", stake.pubkey ); @@ -262,7 +262,7 @@ pub fn merge_program_account_in_strake_map( }, ) .for_each(|(pk, delegated_stake, lamports)| { - log::info!("RPC merge {pk} stake:{delegated_stake:?}"); + //log::info!("RPC merge {pk} stake:{delegated_stake:?}"); let stake = StoredStake { pubkey: pk, lamports, diff --git a/stake_aggregate/src/votestore.rs b/stake_aggregate/src/votestore.rs index 34ceba7..394d4c8 100644 --- a/stake_aggregate/src/votestore.rs +++ b/stake_aggregate/src/votestore.rs @@ -189,15 +189,15 @@ fn vote_map_insert_vote(map: &mut VoteMap, vote_account_pk: Pubkey, vote_data: S // vote_data.vote_data.node_pubkey, // vote_data.vote_data.root_slot, // ); - if vote_data.vote_data.root_slot.is_none() { - log::info!("Update vote account:{vote_account_pk} with None root slot."); - } + // if vote_data.vote_data.root_slot.is_none() { + // log::info!("Update vote account:{vote_account_pk} with None root slot."); + // } - if voteacc.vote_data.root_slot.is_none() { - log::info!( - "Update vote account:{vote_account_pk} that were having None root slot." - ); - } + // if voteacc.vote_data.root_slot.is_none() { + // log::info!( + // "Update vote account:{vote_account_pk} that were having None root slot." + // ); + // } *voteacc = Arc::new(vote_data); }