Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for blocked (0.1 sec)

  1. src/runtime/mgc.go

    	// this before waking blocked assists.
    	atomic.Store(&gcBlackenEnabled, 0)
    
    	// Notify the CPU limiter that GC assists will now cease.
    	gcCPULimiter.startGCTransition(false, now)
    
    	// Wake all blocked assists. These will run when we
    	// start the world again.
    	gcWakeAllAssists()
    
    	// Likewise, release the transition lock. Blocked
    	// workers and assists will run when we start the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  2. src/runtime/mgcmark.go

    // condition.
    //
    //go:nowritebarrierrec
    func gcFlushBgCredit(scanWork int64) {
    	if work.assistQueue.q.empty() {
    		// Fast path; there are no blocked assists. There's a
    		// small window here where an assist may add itself to
    		// the blocked queue and park. If that happens, we'll
    		// just get it on the next flush.
    		gcController.bgScanCredit.Add(scanWork)
    		return
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  3. src/internal/trace/order.go

    	pid := ProcID(ev.args[0])
    	// N.B. In practice Ps can't block while they're sweeping, so this can only
    	// ever reference curCtx.P. However, be lenient about this like we are with
    	// GCMarkAssistActive; there's no reason the runtime couldn't change to block
    	// in the middle of a sweep.
    	pState, ok := o.pStates[pid]
    	if !ok {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	defer c.finishDispatching()
    	// Watchers stopped after startDispatching will be delayed to finishDispatching,
    
    	// Since add() can block, we explicitly add when cacher is unlocked.
    	// Dispatching event in nonblocking way first, which make faster watchers
    	// not be blocked by slower ones.
    	if event.Type == watch.Bookmark {
    		for _, watcher := range c.watchersBuffer {
    			watcher.nonblockingAdd(event)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  5. src/runtime/mprof.go

    // SetBlockProfileRate controls the fraction of goroutine blocking events
    // that are reported in the blocking profile. The profiler aims to sample
    // an average of one blocking event per rate nanoseconds spent blocked.
    //
    // To include every blocking event in the profile, pass rate = 1.
    // To turn off profiling entirely, pass rate <= 0.
    func SetBlockProfileRate(rate int) {
    	var r int64
    	if rate <= 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    		}
    	}
    
    	// Ensure there is some budget for slowing down processing.
    	// We use the fakeTimeBudget to prevent this test from flaking under
    	// the following conditions:
    	// 1) the watch w1 is blocked, so we were consuming the whole budget once
    	//    its buffer was filled in (10 items)
    	// 2) the budget is refreshed once per second, so it basically wasn't
    	//    happening in the test at all
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  7. src/testing/testing.go

    	go tRunner(t, f)
    
    	// The parent goroutine will block until the subtest either finishes or calls
    	// Parallel, but in general we don't know whether the parent goroutine is the
    	// top-level test function or some other goroutine it has spawned.
    	// To avoid confusing false-negatives, we leave the parent in the running map
    	// even though in the typical case it is blocked.
    
    	if !<-t.signal {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  8. src/cmd/vendor/golang.org/x/sys/unix/zerrors_aix_ppc.go

    	{45, "EDEADLK", "deadlock condition if locked"},
    	{46, "ENOTREADY", "device not ready"},
    	{47, "EWRPROTECT", "write-protected media"},
    	{48, "EFORMAT", "unformatted or incompatible media"},
    	{49, "ENOLCK", "no locks available"},
    	{50, "ENOCONNECT", "cannot Establish Connection"},
    	{52, "ESTALE", "missing file or filesystem"},
    	{53, "EDIST", "requests blocked by Administrator"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 52.4K bytes
    - Viewed (0)
  9. src/cmd/vendor/golang.org/x/sys/unix/zerrors_aix_ppc64.go

    	{45, "EDEADLK", "deadlock condition if locked"},
    	{46, "ENOTREADY", "device not ready"},
    	{47, "EWRPROTECT", "write-protected media"},
    	{48, "EFORMAT", "unformatted or incompatible media"},
    	{49, "ENOLCK", "no locks available"},
    	{50, "ENOCONNECT", "cannot Establish Connection"},
    	{52, "ESTALE", "missing file or filesystem"},
    	{53, "EDIST", "requests blocked by Administrator"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 52.7K bytes
    - Viewed (0)
  10. src/runtime/traceback.go

    		} else {
    			print(" m=nil")
    		}
    	}
    	print(" [", status)
    	if isScan {
    		print(" (scan)")
    	}
    	if waitfor >= 1 {
    		print(", ", waitfor, " minutes")
    	}
    	if gp.lockedm != 0 {
    		print(", locked to thread")
    	}
    	print("]:\n")
    }
    
    func tracebackothers(me *g) {
    	level, _, _ := gotraceback()
    
    	// Show the current goroutine first, if we haven't already.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 55.1K bytes
    - Viewed (0)
Back to top