Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for GoBlock (0.2 sec)

  1. 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)
  2. 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:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 10 14:49:50 UTC 2024
    - 42.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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  4. 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)
  5. 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
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 06 14:30:43 UTC 2024
    - 41.5K bytes
    - Viewed (1)
  6. src/runtime/proc.go

    	traceLockInit()
    	// Enforce that this lock is always a leaf lock.
    	// All of this lock's critical sections should be
    	// extremely short.
    	lockInit(&memstats.heapStats.noPLock, lockRankLeafRank)
    
    	// raceinit must be the first call to race detector.
    	// In particular, it must be done before mallocinit below calls racemapshadow.
    	gp := getg()
    	if raceenabled {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  7. 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