diff --git a/node/impl/full/mpool.go b/node/impl/full/mpool.go index bd91387a2..f792cdf99 100644 --- a/node/impl/full/mpool.go +++ b/node/impl/full/mpool.go @@ -84,9 +84,10 @@ func (a *MpoolAPI) MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*ty if mpts.Equals(ts) { return pending, nil } - // different blocks in tipsets - have, err := a.Mpool.MessagesForBlocks(ts.Blocks()) + // different blocks in tipsets of the same height + // we exclude messages that have been included in blocks in the mpool tipset + have, err := a.Mpool.MessagesForBlocks(mpts.Blocks()) if err != nil { return nil, xerrors.Errorf("getting messages for base ts: %w", err) }