@@ -138,7 +138,6 @@ func redeemWriteMarker(md *markerData) error {
138
138
}
139
139
allocMu .RUnlock ()
140
140
}()
141
- logging .Logger .Debug ("getAllocation" , zap .Any ("allocation" , allocationID ))
142
141
alloc , err := allocation .Repo .GetAllocationFromDB (ctx , allocationID )
143
142
if err != nil {
144
143
logging .Logger .Error ("Error redeeming the write marker." , zap .Any ("allocation" , allocationID ), zap .Any ("wm" , allocationID ), zap .Any ("error" , err ))
@@ -155,7 +154,6 @@ func redeemWriteMarker(md *markerData) error {
155
154
shouldRollback = true
156
155
return nil
157
156
}
158
- logging .Logger .Debug ("getWritemarker" , zap .Any ("allocation" , allocationID ))
159
157
wm , err := GetWriteMarkerEntity (ctx , alloc .ID , alloc .AllocationRoot )
160
158
if err != nil {
161
159
logging .Logger .Error ("Error redeeming the write marker." , zap .Any ("allocation" , allocationID ), zap .Any ("wm" , alloc .AllocationRoot ), zap .Any ("error" , err ))
@@ -165,7 +163,6 @@ func redeemWriteMarker(md *markerData) error {
165
163
shouldRollback = true
166
164
return err
167
165
}
168
- logging .Logger .Debug ("RedeemMarker" , zap .Any ("allocation" , allocationID ), zap .Any ("wm" , wm .WM .AllocationRoot ), zap .Any ("txn" , wm .CloseTxnID ))
169
166
err = wm .RedeemMarker (ctx , alloc .LastRedeemedSeq + 1 )
170
167
if err != nil {
171
168
elapsedTime := time .Since (start )
@@ -180,7 +177,6 @@ func redeemWriteMarker(md *markerData) error {
180
177
shouldRollback = true
181
178
return err
182
179
}
183
- logging .Logger .Debug ("UpdateAllocationRedeem" , zap .Any ("allocation" , allocationID ), zap .Any ("wm" , wm .WM .AllocationRoot ), zap .Any ("txn" , wm .CloseTxnID ))
184
180
err = allocation .Repo .UpdateAllocationRedeem (ctx , allocationID , wm .WM .AllocationRoot , alloc , wm .Sequence )
185
181
if err != nil {
186
182
logging .Logger .Error ("Error redeeming the write marker. Allocation latest wm redeemed update failed" ,
@@ -190,7 +186,6 @@ func redeemWriteMarker(md *markerData) error {
190
186
go tryAgain (md )
191
187
return err
192
188
}
193
- logging .Logger .Debug ("RedeemMarker" , zap .Any ("allocation" , allocationID ), zap .Any ("wm" , wm .WM .AllocationRoot ), zap .Any ("txn" , wm .CloseTxnID ))
194
189
err = db .Commit ().Error
195
190
if err != nil {
196
191
logging .Logger .Error ("Error committing the writemarker redeem" ,
0 commit comments