diff --git a/parser/worker.go b/parser/worker.go index 6f0a547b..5ad8cdc7 100644 --- a/parser/worker.go +++ b/parser/worker.go @@ -109,25 +109,38 @@ func (w Worker) Process(height int64) error { w.logger.Debug("processing block", "height", height) + // w.logger.Error("***** Processing block **********", "module", module.Name(), "height", b.Block.Height) + start := time.Now() block, err := w.node.Block(height) if err != nil { return fmt.Errorf("failed to get block from node: %s", err) } + elapsed := time.Since(start).Seconds() + w.logger.Debug("******** processing block ********", "height", height, "time", elapsed) + start2 := time.Now() events, err := w.node.BlockResults(height) if err != nil { return fmt.Errorf("failed to get block results from node: %s", err) } + elapsed2 := time.Since(start2).Seconds() + w.logger.Debug("******** processing block results ********", "height", height, "time", elapsed2) + start3 := time.Now() txs, err := w.node.Txs(block) if err != nil { return fmt.Errorf("failed to get transactions for block: %s", err) } + elapsed3 := time.Since(start3).Seconds() + w.logger.Debug("******** processing transactions for block ********", "height", height, "time", elapsed3) + start4 := time.Now() vals, err := w.node.Validators(height) if err != nil { return fmt.Errorf("failed to get validators for block: %s", err) } + elapsed4 := time.Since(start4).Seconds() + w.logger.Debug("******** processing validators for block ********", "height", height, "time", elapsed4) return w.ExportBlock(block, events, txs, vals) }