Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewNSLock (0.37 sec)

  1. cmd/erasure-server-pool.go

    		break
    	}
    
    	return z, nil
    }
    
    func (z *erasureServerPools) NewNSLock(bucket string, objects ...string) RWLocker {
    	poolID := hashKey(z.distributionAlgo, "", len(z.serverPools), z.deploymentID)
    	if len(objects) >= 1 {
    		poolID = hashKey(z.distributionAlgo, objects[0], len(z.serverPools), z.deploymentID)
    	}
    	return z.serverPools[poolID].NewNSLock(bucket, objects...)
    }
    
    // GetDisksID will return disks by their ID.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	}
    
    	// This call shouldn't be used for anything other than metadata updates or adding self referential versions.
    	if !srcInfo.metadataOnly {
    		return oi, NotImplemented{}
    	}
    
    	if !dstOpts.NoLock {
    		lk := er.NewNSLock(dstBucket, dstObject)
    		lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return oi, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
Back to top