add more logs for txindex

sei-protocol · Mar 25, 2024 · 100f53a · 100f53a
1 parent b46ea58
commit 100f53a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git a/debugutil/timer.go b/debugutil/timer.go
@@ -39,5 +39,8 @@ func PrintStats(msg string, durations []time.Duration) {
 		}
 	}
 	avg := sum / time.Duration(len(durations))
-	fmt.Printf("[Debug] %s count=%d sum=%s avg=%s max=%s min=%s\n", msg, len(durations), sum, avg, max, min)
+	// only show the slow ones
+	if sum > 500*time.Millisecond {
+		fmt.Printf("[Debug] %s count=%d sum=%s avg=%s max=%s min=%s\n", msg, len(durations), sum, avg, max, min)
+	}
 }
diff --git a/internal/state/indexer/tx/kv/kv.go b/internal/state/indexer/tx/kv/kv.go
@@ -71,6 +71,7 @@ func (txi *TxIndex) Index(results []*abci.TxResult) error {
 	b := txi.store.NewBatch()
 	defer b.Close()
 
+	var durations []time.Duration
 	for _, result := range results {
 		hash := types.Tx(result.Tx).Hash()
 
@@ -91,13 +92,18 @@ func (txi *TxIndex) Index(results []*abci.TxResult) error {
 			return err
 		}
 		// index by hash (always)
+		start := time.Now()
 		err = b.Set(primaryKey(hash), rawBytes)
+		durations = append(durations, time.Since(start))
 		if err != nil {
 			return err
 		}
 	}
-
-	return b.WriteSync()
+	debugutil.PrintStats("TxIndex.Index b.Set(primaryKey(hash), rawBytes)", durations)
+	t2 := debugutil.NewTimer(fmt.Sprintf("TxIndex.Index WriteSync (txs=%d)", len(results)))
+	err := b.WriteSync()
+	t2.Stop()
+	return err
 }
 
 func (txi *TxIndex) indexEvents(result *abci.TxResult, hash []byte, store dbm.Batch) error {