Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GoBlock (0.13 sec)

  1. cmd/erasure-multipart.go

    	if opts.CheckPrecondFn != nil {
    		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)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 44.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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  3. 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)
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.8K bytes
    - Viewed (0)
  4. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  5. 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
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 124.2K bytes
    - Viewed (0)
  6. src/cmd/compile/internal/ssagen/ssa.go

    	// then this code is dead. Stop here.
    	if s.curBlock == nil && n.Op() != ir.OLABEL {
    		return
    	}
    
    	s.stmtList(n.Init())
    	switch n.Op() {
    
    	case ir.OBLOCK:
    		n := n.(*ir.BlockStmt)
    		s.stmtList(n.List)
    
    	case ir.OFALL: // no-op
    
    	// Expression statements
    	case ir.OCALLFUNC:
    		n := n.(*ir.CallExpr)
    		if ir.IsIntrinsicCall(n) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 284.9K bytes
    - Viewed (0)
Back to top