diff --git a/code/go/0chain.net/blobbercore/handler/object_operation_handler.go b/code/go/0chain.net/blobbercore/handler/object_operation_handler.go index 968eaa2a1..438aeca44 100644 --- a/code/go/0chain.net/blobbercore/handler/object_operation_handler.go +++ b/code/go/0chain.net/blobbercore/handler/object_operation_handler.go @@ -631,6 +631,7 @@ func (fsh *StorageHandler) CommitWrite(ctx context.Context, r *http.Request) (*b err = checkPendingMarkers(ctx, allocationObj.ID) if err != nil { + fmt.Println("Error checking pending markers", err) Logger.Error("Error checking pending markers", zap.Error(err)) return nil, common.NewError("pending_markers", "previous marker is still pending to be redeemed") } diff --git a/code/go/0chain.net/blobbercore/writemarker/worker.go b/code/go/0chain.net/blobbercore/writemarker/worker.go index 7d5a3f924..8f60ef8a9 100644 --- a/code/go/0chain.net/blobbercore/writemarker/worker.go +++ b/code/go/0chain.net/blobbercore/writemarker/worker.go @@ -2,6 +2,7 @@ package writemarker import ( "context" + "fmt" "math/rand" "strings" "sync" @@ -80,7 +81,9 @@ func SaveMarkerData(allocationID string, timestamp common.Timestamp, chainLength func CheckProcessingMarker(allocationID string) bool { markerDataMut.Lock() defer markerDataMut.Unlock() + fmt.Println("CheckProcessingMarker", allocationID) if data, ok := markerDataMap[allocationID]; ok { + fmt.Println("CheckProcessingMarker: data.processing", data.processing) return data.processing } return false