Skip to content

Commit 06be785

Browse files
authored
check lock on retry (#1382)
1 parent a20fd42 commit 06be785

File tree

1 file changed

+7
-0
lines changed
  • code/go/0chain.net/blobbercore/writemarker

1 file changed

+7
-0
lines changed

code/go/0chain.net/blobbercore/writemarker/worker.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,8 @@ func redeemWriteMarker(wm *WriteMarkerEntity) error {
9898
if wm.ReedeemRetries == 0 && !alloc.IsRedeemRequired {
9999
wm.ReedeemRetries++
100100
go tryAgain(wm)
101+
shouldRollback = true
102+
return nil
101103
}
102104
_ = wm.UpdateStatus(ctx, Rollbacked, "rollbacked", "")
103105
err = db.Commit().Error
@@ -116,6 +118,11 @@ func redeemWriteMarker(wm *WriteMarkerEntity) error {
116118
zap.Any("wm", wm), zap.Any("error", err), zap.Any("elapsedTime", elapsedTime))
117119
if retryRedeem(err.Error()) {
118120
go tryAgain(wm)
121+
} else {
122+
mut := GetLock(allocationID)
123+
if mut != nil {
124+
mut.Release(1)
125+
}
119126
}
120127
shouldRollback = true
121128

0 commit comments

Comments
 (0)