lotus-pcr: ignore all other messages
This commit is contained in:
parent
6eb49b717f
commit
0d34881a0c
@ -1037,30 +1037,23 @@ func (r *refunder) ProcessTipset(ctx context.Context, tipset *types.TipSet, refu
|
|||||||
}
|
}
|
||||||
|
|
||||||
var messageMethod string
|
var messageMethod string
|
||||||
|
var processed bool
|
||||||
|
|
||||||
if m.To == builtin.StorageMarketActorAddr {
|
if m.To == builtin.StorageMarketActorAddr {
|
||||||
var err error
|
|
||||||
var processed bool
|
|
||||||
processed, messageMethod, refundValue, err = r.processTipsetStorageMarketActor(ctx, tipset, msg, recps[i])
|
processed, messageMethod, refundValue, err = r.processTipsetStorageMarketActor(ctx, tipset, msg, recps[i])
|
||||||
if err != nil {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
if !processed {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if a.IsStorageMinerActor() {
|
if a.IsStorageMinerActor() {
|
||||||
var err error
|
|
||||||
var processed bool
|
|
||||||
processed, messageMethod, refundValue, err = r.processTipsetStorageMinerActor(ctx, tipset, msg, recps[i])
|
processed, messageMethod, refundValue, err = r.processTipsetStorageMinerActor(ctx, tipset, msg, recps[i])
|
||||||
|
}
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
log.Errorw("error while processing message", "cid", msg.Cid)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if !processed {
|
if !processed {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
log.Debugw(
|
log.Debugw(
|
||||||
"processing message",
|
"processing message",
|
||||||
|
Loading…
Reference in New Issue
Block a user