diff --git a/chain/messagepool/messagepool.go b/chain/messagepool/messagepool.go index d45edfabe..18f001981 100644 --- a/chain/messagepool/messagepool.go +++ b/chain/messagepool/messagepool.go @@ -333,7 +333,7 @@ func (mp *MessagePool) checkMessage(m *types.SignedMessage) error { } if err := mp.VerifyMsgSig(m); err != nil { - log.Warnf("mpooladd signature verification failed: %s", err) + log.Warnf("signature verification failed: %s", err) return err } @@ -558,6 +558,11 @@ func (mp *MessagePool) PushWithNonce(ctx context.Context, addr address.Address, return nil, err } + err = mp.checkMessage(msg) + if err != nil { + return nil, err + } + // reacquire the locks and check state for consistency mp.curTsLk.Lock() defer mp.curTsLk.Unlock()