diff --git a/node/node.go b/node/node.go index 67d04fc04..c0f47a469 100644 --- a/node/node.go +++ b/node/node.go @@ -286,6 +286,9 @@ func addPendingTransactions(registry *registry.Registry, newTxs types.Transactio continue } } + utils.Logger().Debug(). + Str("tx_hash", tx.Hash().Hex()). + Msg("[addPendingTransactions] tx is added to the txs pool array") poolTxs = append(poolTxs, tx) } errs = append(errs, registry.GetTxPool().AddRemotes(poolTxs)...) @@ -305,6 +308,9 @@ func (node *Node) addPendingStakingTransactions(newStakingTxs staking.StakingTra if node.Blockchain().Config().IsPreStaking(node.Blockchain().CurrentHeader().Epoch()) { poolTxs := types.PoolTransactions{} for _, tx := range newStakingTxs { + utils.Logger().Debug(). + Str("tx_hash", tx.Hash().Hex()). + Msg("[addPendingStakingTransactions] tx is added to the txs pool array") poolTxs = append(poolTxs, tx) } errs := node.TxPool.AddRemotes(poolTxs) diff --git a/node/node_newblock.go b/node/node_newblock.go index fdca8b741..675267295 100644 --- a/node/node_newblock.go +++ b/node/node_newblock.go @@ -175,14 +175,17 @@ func (node *Node) ProposeNewBlock(commitSigs chan []byte) (*types.Block, error) plainTxsPerAcc := types.Transactions{} for _, tx := range poolTxs { if plainTx, ok := tx.(*types.Transaction); ok { + utils.Logger().Info().Str("tx_hash", tx.Hash().Hex()).Msg("add transaction to proposing block") plainTxsPerAcc = append(plainTxsPerAcc, plainTx) } else if stakingTx, ok := tx.(*staking.StakingTransaction); ok { // Only process staking transactions after pre-staking epoch happened. if node.Blockchain().Config().IsPreStaking(node.Worker.GetCurrentHeader().Epoch()) { + utils.Logger().Info().Str("tx_hash", tx.Hash().Hex()).Msg("add staking transaction to proposing block") pendingStakingTxs = append(pendingStakingTxs, stakingTx) } } else { utils.Logger().Err(types.ErrUnknownPoolTxType). + Str("tx_hash", tx.Hash().Hex()). Msg("Failed to parse pending transactions") return nil, types.ErrUnknownPoolTxType }