- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for unlocked (0.13 sec)
-
cmd/erasure-server-pool-rebalance.go
return err } defer lock.Unlock(lkCtx) ctx = lkCtx.Context() noLockOpts := ObjectOptions{NoLock: true} r := &rebalanceMeta{} err = r.loadWithOpts(ctx, z.serverPools[0], noLockOpts) if err != nil && !errors.Is(err, errConfigNotFound) { return err } z.rebalMu.Lock() defer z.rebalMu.Unlock() // if not found, we store the memory metadata back
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Sep 04 20:47:24 UTC 2025 - 28.9K bytes - Viewed (0) -
cmd/erasure-object.go
} return dfi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended), nil } // Send the successful but partial upload/delete, however ignore // if the channel is blocked by other items. func (er erasureObjects) addPartial(bucket, object, versionID string) { globalMRFState.addPartialOp(PartialOperation{ Bucket: bucket, Object: object, VersionID: versionID,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0) -
cmd/erasure-multipart.go
if !opts.NoLock { ns := er.NewNSLock(bucket, object) lkctx, err := ns.GetLock(ctx, globalOperationTimeout) if err != nil { return nil, err } ctx = lkctx.Context() defer ns.Unlock(lkctx) opts.NoLock = true } obj, err := er.getObjectInfo(ctx, bucket, object, opts) if err == nil && opts.CheckPrecondFn(obj) { return nil, PreConditionFailed{} }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0)