blockworks-foundation
/
solana-rpc-v2
mirror of https://github.com/blockworks-foundation/solana-rpc-v2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

change and remove some logs

This commit is contained in:
musitdev 2023-11-03 10:04:03 +01:00
parent 132fdc7851
commit 320efb4992
4 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
rust-toolchain.toml Normal file
View File

@ -0,0 +1,2 @@
[toolchain]
channel = "1.70.0"

4
stake_aggregate/src/main.rs
View File

@ -300,7 +300,7 @@ async fn run_loop<F: Interceptor>(mut client: GeyserGrpcClient<F>) -> anyhow::Re
}; };
if let Err(err) = tx.send((current_stakes, extract_slot)){ 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"); log::info!("RPC GetStakestore account send");
@ -354,7 +354,7 @@ async fn run_loop<F: Interceptor>(mut client: GeyserGrpcClient<F>) -> anyhow::Re
//log::trace!("Geyser receive new account"); //log::trace!("Geyser receive new account");
match account.owner { match account.owner {
solana_sdk::stake::program::ID => { 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( if let Err(err) = stakestore.notify_stake_change(
account, account,
current_epoch_state.current_epoch_end_slot(), current_epoch_state.current_epoch_end_slot(),

6
stake_aggregate/src/stakestore.rs
View File

@ -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. //doesn't erase new state with an old one. Can arrive during bootstrapping.
//several instructions can be done in the same slot. //several instructions can be done in the same slot.
if strstake.last_update_slot <= stake.last_update_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; *strstake = stake;
} }
} }
// If value doesn't exist yet, then insert a new value of 1 // If value doesn't exist yet, then insert a new value of 1
std::collections::hash_map::Entry::Vacant(vacant) => { std::collections::hash_map::Entry::Vacant(vacant) => {
log::info!( log::trace!(
"stake_map_notify_stake Stake store insert stake: {} stake:{stake:?}", "stake_map_notify_stake Stake store insert stake: {} stake:{stake:?}",
stake.pubkey stake.pubkey
); );
@ -262,7 +262,7 @@ pub fn merge_program_account_in_strake_map(
}, },
) )
.for_each(|(pk, delegated_stake, lamports)| { .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 { let stake = StoredStake {
pubkey: pk, pubkey: pk,
lamports, lamports,

16
stake_aggregate/src/votestore.rs
View File

@ -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.node_pubkey,
// vote_data.vote_data.root_slot, // vote_data.vote_data.root_slot,
// ); // );
if vote_data.vote_data.root_slot.is_none() { // if vote_data.vote_data.root_slot.is_none() {
log::info!("Update vote account:{vote_account_pk} with None root slot."); // log::info!("Update vote account:{vote_account_pk} with None root slot.");
} // }
if voteacc.vote_data.root_slot.is_none() { // if voteacc.vote_data.root_slot.is_none() {
log::info!( // log::info!(
"Update vote account:{vote_account_pk} that were having None root slot." // "Update vote account:{vote_account_pk} that were having None root slot."
); // );
} // }
*voteacc = Arc::new(vote_data); *voteacc = Arc::new(vote_data);
} }