Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 587 for sweep (0.12 sec)

  1. cmd/object-multipart-handlers.go

    	if !globalTierConfigMgr.Empty() {
    		// Schedule object for immediate transition if eligible.
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CompleteMultipartUpload)
    		os.Sweep()
    	}
    }
    
    // AbortMultipartUploadHandler - Abort multipart upload
    func (api objectAPIHandlers) AbortMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  2. src/internal/trace/event.go

    		r.Name = "GC concurrent mark phase"
    		r.Scope = ResourceID{Kind: ResourceNone}
    	case go122.EvGCSweepBegin, go122.EvGCSweepActive, go122.EvGCSweepEnd:
    		r.Name = "GC incremental sweep"
    		r.Scope = ResourceID{Kind: ResourceProc}
    		if e.base.typ == go122.EvGCSweepActive {
    			r.Scope.id = int64(e.base.args[0])
    		} else {
    			r.Scope.id = int64(e.Proc())
    		}
    		r.Scope.id = int64(e.Proc())
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 12:39:00 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  3. src/runtime/mstats.go

    // counters.
    //
    // gcMarkPhase indicates that we're in the mark phase and that certain counter
    // values should be used.
    func (s *cpuStats) accumulate(now int64, gcMarkPhase bool) {
    	// N.B. Mark termination and sweep termination pauses are
    	// accumulated in work.cpuStats at the end of their respective pauses.
    	var (
    		markAssistCpu     int64
    		markDedicatedCpu  int64
    		markFractionalCpu int64
    		markIdleCpu       int64
    	)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 08 21:03:13 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  4. src/time/sleep.go

    // license that can be found in the LICENSE file.
    
    package time
    
    import (
    	"internal/godebug"
    	"unsafe"
    )
    
    // Sleep pauses the current goroutine for at least the duration d.
    // A negative or zero duration causes Sleep to return immediately.
    func Sleep(d Duration)
    
    var asynctimerchan = godebug.New("asynctimerchan")
    
    // syncTimer returns c as an unsafe.Pointer, for passing to newTimer.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 04 14:21:30 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    		})
    	}
    
    	// Clean up transitioned objects from remote tier
    	for _, os := range oss {
    		if os == nil { // skip objects that weren't deleted due to invalid versionID etc.
    			continue
    		}
    		os.Sweep()
    	}
    }
    
    // PutBucketHandler - PUT Bucket
    // ----------
    // This implementation of the PUT operation creates a new bucket for authenticated request
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  6. src/runtime/mgcmark.go

    			}
    			// Check that this span was swept (it may be cached or uncached).
    			if !useCheckmark && !(s.sweepgen == sg || s.sweepgen == sg+3) {
    				// sweepgen was updated (+2) during non-checkmark GC pass
    				print("sweep ", s.sweepgen, " ", sg, "\n")
    				throw("gc: unswept span")
    			}
    
    			// Lock the specials to prevent a special from being
    			// removed from the list while we're traversing it.
    			lock(&s.speciallock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/syntax/parser.go

    				// If named == typed we must have parameters that have no types,
    				// and they must be at the end of the parameter list, otherwise
    				// the types would have been filled in by the right-to-left sweep
    				// above and we wouldn't have an error. Since we are in a type
    				// parameter list, the missing types are constraints.
    				if named == typed {
    					errPos = end // position error at closing ]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 62.9K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    				tier = oi.TransitionedObject.Tier
    			}
    			if sizeS.tiers != nil {
    				if st, ok := sizeS.tiers[tier]; ok {
    					sizeS.tiers[tier] = st.add(oi.tierStats())
    				}
    			}
    		}
    
    		// apply tier sweep action on free versions
    		for _, freeVersion := range fivs.FreeVersions {
    			oi := freeVersion.ToObjectInfo(item.bucket, item.objectPath(), versioned)
    			done = globalScannerMetrics.time(scannerMetricTierObjSweep)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  9. src/cmd/trace/testdata/go122.test

    String id=16
    	data="preempted"
    String id=17
    	data="wait for debug call"
    String id=18
    	data="wait until GC ends"
    String id=19
    	data="sleep"
    String id=20
    	data="runtime.Gosched"
    String id=21
    	data="start trace"
    String id=22
    	data="GC sweep termination"
    String id=23
    	data="GC mark termination"
    String id=24
    	data="syscall.read"
    String id=25
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 17:15:58 UTC 2024
    - 166K bytes
    - Viewed (0)
  10. src/runtime/proc.go

    					// Make wake-up period small enough
    					// for the sampling to be correct.
    					sleep := forcegcperiod / 2
    					if next-now < sleep {
    						sleep = next - now
    					}
    					shouldRelax := sleep >= osRelaxMinNS
    					if shouldRelax {
    						osRelax(true)
    					}
    					syscallWake = notetsleep(&sched.sysmonnote, sleep)
    					if shouldRelax {
    						osRelax(false)
    					}
    					lock(&sched.lock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
Back to top