Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for notBlock (0.05 sec)

  1. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  3. cmd/erasure-healing_test.go

    				ScanMode: madmin.HealNormalScan,
    			})
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			firstGr, err := obj.GetObjectNInfo(ctx, bucket, object, nil, nil, ObjectOptions{NoLock: true})
    			if err != nil {
    				t.Fatal(err)
    			}
    			defer firstGr.Close()
    
    			firstHealedH := sha256.New()
    			_, err = io.Copy(firstHealedH, firstGr)
    			if err != nil {
    				t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
Back to top