Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for NOLOCK (0.22 sec)

  1. cmd/object-api-interface.go

    	CreatedAt         time.Time // only for site replication
    	NoLock            bool      // does not lock the make bucket call if set to 'true'
    }
    
    // DeleteBucketOptions provides options for DeleteBucket calls.
    type DeleteBucketOptions struct {
    	NoLock     bool             // does not lock the delete bucket call if set to 'true'
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    	err = nil
    	objInfo = ObjectInfo{}
    
    	object = encodeDirObject(object)
    
    	if z.SinglePool() {
    		return z.serverPools[0].GetObjectInfo(ctx, bucket, object, opts)
    	}
    
    	if !opts.NoLock {
    		opts.NoLock = true // avoid taking locks at lower levels for multi-pool setups.
    
    		// Lock the object before reading.
    		lk := z.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  3. cmd/batch-rotate.go

    		return err
    	}
    	ctx = lkctx.Context()
    	defer lock.Unlock(lkctx)
    
    	opts := ObjectOptions{
    		VersionID:        objInfo.VersionID,
    		Versioned:        versioned,
    		VersionSuspended: versionSuspended,
    		NoLock:           true,
    	}
    	obj, err := api.GetObjectInfo(ctx, r.Bucket, objInfo.Name, opts)
    	if err != nil {
    		return err
    	}
    	oi := obj.Clone()
    	var (
    		newKeyID      string
    		newKeyContext kms.Context
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	}
    
    	data := r.Reader
    
    	if opts.CheckPrecondFn != nil {
    		if !opts.NoLock {
    			ns := er.NewNSLock(bucket, object)
    			lkctx, err := ns.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return ObjectInfo{}, err
    			}
    			ctx = lkctx.Context()
    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  5. cmd/erasure-server-pool-rebalance.go

    			return err
    		}
    		defer lock.Unlock(lkCtx)
    
    		ctx = lkCtx.Context()
    
    		noLockOpts := ObjectOptions{NoLock: true}
    		return z.rebalMeta.saveWithOpts(ctx, z.serverPools[0], noLockOpts)
    	}
    
    	return nil
    }
    
    func (z *erasureServerPools) findIndex(index int) int {
    	for i := 0; i < len(z.rebalMeta.PoolStats); i++ {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    		r, err := store.GetObjectNInfo(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, name), nil, http.Header{}, ObjectOptions{NoLock: true})
    		if err != nil {
    			switch err.(type) {
    			case ObjectNotFound, BucketNotFound:
    				r, err = store.GetObjectNInfo(ctx, dataUsageBucket, name, nil, http.Header{}, ObjectOptions{NoLock: true})
    				if err != nil {
    					switch err.(type) {
    					case ObjectNotFound, BucketNotFound:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  7. cmd/erasure-healing.go

    	result = madmin.HealResultItem{
    		Type:      madmin.HealItemObject,
    		Bucket:    bucket,
    		Object:    object,
    		VersionID: versionID,
    		DiskCount: len(storageDisks),
    	}
    
    	if !opts.NoLock {
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return result, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    						bi.Name,
    						encodeDirObject(version.Name),
    						nil,
    						http.Header{},
    						ObjectOptions{
    							VersionID:    versionID,
    							NoDecryption: true,
    							NoLock:       true,
    							NoAuditLog:   true,
    						})
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// object deleted by the application, nothing to do here we move on.
    						ignore = true
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  9. cmd/object-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer lock.RUnlock(lkctx)
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    	gopts := opts
    	gopts.NoLock = true // We already have a lock, we can live with it.
    	objInfo, err := getObjectInfo(ctx, bucket, object, gopts)
    	if err != nil {
    		// Versioning enabled quite possibly object is deleted might be delete-marker
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 125K bytes
    - Viewed (0)
Back to top