Skip to content

Commit

Permalink
add debug logging
Browse files Browse the repository at this point in the history
  • Loading branch information
areshand committed Jan 23, 2025
1 parent ed2b26d commit a58e2d2
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ use aptos_db_indexer::{
indexer_reader::IndexerReaders,
};
use aptos_indexer_grpc_utils::counters::{log_grpc_step, IndexerGrpcStep};
use aptos_logger::info;
use aptos_storage_interface::DbReader;
use aptos_types::{indexer::indexer_db_reader::IndexerReader, transaction::Version};
use std::{
Expand Down Expand Up @@ -173,6 +174,7 @@ impl InternalIndexerDBService {
if target_version == start_version {
match self.update_receiver.changed().await {
Ok(_) => {
info!("bowu update_receiver changed");
(step_timer, target_version) = *self.update_receiver.borrow();
},
Err(e) => {
Expand All @@ -195,6 +197,7 @@ impl InternalIndexerDBService {
None,
);
start_version = next_version;
info!("bowu next_version: {:?}, start_version: {:?}, target_version: {:?}", next_version, start_version, target_version);
}
}

Expand Down
1 change: 1 addition & 0 deletions storage/aptosdb/src/db/include/aptosdb_writer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -591,6 +591,7 @@ impl AptosDB {

COMMITTED_TXNS.inc_by(num_txns);
LATEST_TXN_VERSION.set(version as i64);
info!("bowu post_commit: {:?}", version);
if let Some(update_sender) = &self.update_subscriber {
update_sender.send(
(Instant::now(), version)
Expand Down

0 comments on commit a58e2d2

Please sign in to comment.