From 041361da04b6a61ec57b8fa55e0cf4835d8c453d Mon Sep 17 00:00:00 2001 From: William Banfield Date: Tue, 8 Mar 2022 15:59:49 -0500 Subject: [PATCH] add logic to check tx to the mempool if marked added --- internal/state/execution.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/state/execution.go b/internal/state/execution.go index c913b48a4..fa125ccbb 100644 --- a/internal/state/execution.go +++ b/internal/state/execution.go @@ -128,7 +128,6 @@ func (blockExec *BlockExecutor) CreateProposalBlock( MaxTxBytes: maxDataBytes, }, ) - if err != nil { // The App MUST ensure that only valid (and hence 'processable') transactions // enter the mempool. Hence, at this point, we can't have any non-processable @@ -148,6 +147,11 @@ func (blockExec *BlockExecutor) CreateProposalBlock( blockExec.logger.Debug("error removing transaction from the mempool", "error", err) } } + for _, rtx := range rpp.AddedTxs() { + if err := blockExec.mempool.CheckTx(ctx, rtx.Tx, nil, mempool.TxInfo{}); err != nil { + blockExec.logger.Debug("error removing transaction from the mempool", "error", err) + } + } return state.MakeBlock(height, types.TxRecordsToTxs(rpp.IncludedTxs()), commit, evidence, proposerAddr) }