Reverting adding transaction data
This commit is contained in:
parent
8b37b3e2d9
commit
295277fbf0
|
@ -11,8 +11,8 @@ use std::{sync::Arc, time::Duration};
|
|||
lazy_static::lazy_static! {
|
||||
static ref ALTS_IN_STORE: IntGauge =
|
||||
register_int_gauge!(opts!("banking_stage_sidecar_alts_stored", "Alts stored in sidecar")).unwrap();
|
||||
|
||||
static ref ALTS_IN_LOADING_QUEUE: IntGauge =
|
||||
|
||||
static ref ALTS_IN_LOADING_QUEUE: IntGauge =
|
||||
register_int_gauge!(opts!("banking_stage_sidecar_alts_loading_queue", "Alts in loading queue in sidecar")).unwrap();
|
||||
}
|
||||
|
||||
|
@ -103,10 +103,7 @@ impl ALTStore {
|
|||
}
|
||||
|
||||
pub async fn start_loading_missing_alts(&self, alts_list: &Vec<Pubkey>) {
|
||||
for key in alts_list
|
||||
.iter()
|
||||
.filter(|x| !self.map.contains_key(x))
|
||||
{
|
||||
for key in alts_list.iter().filter(|x| !self.map.contains_key(x)) {
|
||||
ALTS_IN_LOADING_QUEUE.inc();
|
||||
let _ = self.loading_queue.send(*key).await;
|
||||
}
|
||||
|
|
|
@ -51,7 +51,10 @@ lazy_static::lazy_static! {
|
|||
|
||||
static ref TIME_TO_SAVE_TRANSACTION: IntGauge =
|
||||
register_int_gauge!(opts!("banking_stage_sidecar_transaction_time", "Account in tx save transactions")).unwrap();
|
||||
|
||||
|
||||
static ref TIME_TO_SAVE_TRANSACTION_DATA: IntGauge =
|
||||
register_int_gauge!(opts!("banking_stage_sidecar_transaction_data_time", "Account in tx save transactions")).unwrap();
|
||||
|
||||
}
|
||||
|
||||
pub struct TempTableTracker {
|
||||
|
@ -906,6 +909,12 @@ impl PostgresSession {
|
|||
ACCOUNTS_SAVING_QUEUE.inc();
|
||||
let _ = self.accounts_for_transaction_sender.send(txs_accounts);
|
||||
|
||||
// insert transactions
|
||||
let instant_save_tx = Instant::now();
|
||||
self.insert_transactions_for_block(&block_info.transactions, block_info.slot)
|
||||
.await?;
|
||||
TIME_TO_SAVE_TRANSACTION_DATA.set(instant_save_tx.elapsed().as_millis() as i64);
|
||||
|
||||
// save account usage in blocks
|
||||
let ins = Instant::now();
|
||||
self.save_account_usage_in_block(&block_info).await?;
|
||||
|
|
Loading…
Reference in New Issue