refactor: streamline error handling in CheckPendingMessages (#10818)
This commit is contained in:
parent
a4685b7bac
commit
c1d22d8b32
@ -35,8 +35,7 @@ func (mp *MessagePool) CheckPendingMessages(ctx context.Context, from address.Ad
|
|||||||
mp.lk.RLock()
|
mp.lk.RLock()
|
||||||
mset, ok, err := mp.getPendingMset(ctx, from)
|
mset, ok, err := mp.getPendingMset(ctx, from)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Warnf("errored while getting pending mset: %w", err)
|
return nil, xerrors.Errorf("errored while getting pending mset: %w", err)
|
||||||
return nil, err
|
|
||||||
}
|
}
|
||||||
if ok {
|
if ok {
|
||||||
msgs = make([]*types.Message, 0, len(mset.msgs))
|
msgs = make([]*types.Message, 0, len(mset.msgs))
|
||||||
|
Loading…
Reference in New Issue
Block a user