eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-07-04 12:03:41 +02:00
Code Releases Activity

app/ship_processor.go: improve logging info.

Browse source
This commit is contained in:
Henrik Hautakoski 2024-01-21 14:06:08 +01:00
parent 0b3b383977
commit a3624d131e
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
app/ship_processor.go
View file

@ -173,11 +173,13 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
processor.encodeQueue(api.HeartbeatChannel, hb) processor.encodeQueue(api.HeartbeatChannel, hb)
} }
mainLogger := log.WithField("block", block.ThisBlock.BlockNum).Dup()
// Process traces // Process traces
if block.Traces != nil && len(block.Traces.Elem) > 0 { if block.Traces != nil && len(block.Traces.Elem) > 0 {
for _, trace := range block.Traces.AsTransactionTracesV0() { for _, trace := range block.Traces.AsTransactionTracesV0() {
logger := log.WithField("tx_id", trace.ID.String()).Dup() logger := mainLogger.WithField("type", "trace").WithField("tx_id", trace.ID.String()).Dup()
transaction := message.TransactionTrace{ transaction := message.TransactionTrace{
ID: trace.ID.String(), ID: trace.ID.String(),
@ -299,7 +301,7 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
// Process deltas // Process deltas
for _, delta := range block.Deltas.AsTableDeltasV0() { for _, delta := range block.Deltas.AsTableDeltasV0() {
logger := log.WithField("type", "table_delta").WithField("table", delta.Name).Dup() logger := mainLogger.WithField("type", "table_delta").WithField("table", delta.Name).Dup()
rows := []message.TableDeltaRow{} rows := []message.TableDeltaRow{}
for _, row := range delta.Rows { for _, row := range delta.Rows {