Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 164 for preemption (0.18 sec)

  1. src/runtime/traceback_test.go

    	}
    	return n
    }
    
    // nosplit to avoid preemption or morestack spilling registers.
    //
    //go:nosplit
    //go:noinline
    func testTracebackArgs10(a, b, c, d, e int32) int {
    	// no use of any args
    	return runtime.Stack(testTracebackArgsBuf[:], false)
    }
    
    // norace to avoid race instrumentation changing spill locations.
    // nosplit to avoid preemption or morestack spilling registers.
    //
    //go:norace
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Dec 14 17:22:18 UTC 2023
    - 22.9K bytes
    - Viewed (0)
  2. pkg/scheduler/metrics/metrics.go

    		},
    	)
    	PreemptionVictims = metrics.NewHistogram(
    		&metrics.HistogramOpts{
    			Subsystem: SchedulerSubsystem,
    			Name:      "preemption_victims",
    			Help:      "Number of selected preemption victims",
    			// we think #victims>64 is pretty rare, therefore [64, +Inf) is considered a single bucket.
    			Buckets:        metrics.ExponentialBuckets(1, 2, 7),
    			StabilityLevel: metrics.STABLE,
    		})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 08:22:53 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. src/runtime/cgocall.go

    	// saved by entersyscall here.
    	entersyscall()
    
    	// Tell asynchronous preemption that we're entering external
    	// code. We do this after entersyscall because this may block
    	// and cause an async preemption to fail, but at this point a
    	// sync preemption will succeed (though this is not a matter
    	// of correctness).
    	osPreemptExtEnter(mp)
    
    	mp.incgo = true
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:47 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  4. pkg/scheduler/extender.go

    	return h.ignorable
    }
    
    // SupportsPreemption returns true if an extender supports preemption.
    // An extender should have preempt verb defined and enabled its own node cache.
    func (h *HTTPExtender) SupportsPreemption() bool {
    	return len(h.preemptVerb) > 0
    }
    
    // ProcessPreemption returns filtered candidate nodes and victims after running preemption logic in extender.
    func (h *HTTPExtender) ProcessPreemption(
    	pod *v1.Pod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    }
    
    // CAVEAT: the reason that `[2]criticalPath` can work is based on the implementation of current
    // preemption algorithm, in particular the following 2 facts:
    // Fact 1: we only preempt pods on the same node, instead of pods on multiple nodes.
    // Fact 2: each node is evaluated on a separate copy of the preFilterState during its preemption cycle.
    // If we plan to turn to a more complex algorithm like "arbitrary pods on multiple nodes", this
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. src/cmd/internal/obj/plist.go

    // p0 is the start of the instruction stream.
    // isUnsafePoint(p) returns true if p is not safe for async preemption.
    // isRestartable(p) returns true if we can restart at the start of p (this Prog)
    // upon async preemption. (Currently multi-Prog restartable sequence is not
    // supported.)
    // isRestartable can be nil. In this case it is treated as always returning false.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 01 15:52:41 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  7. src/runtime/runtime2.go

    	vdsoPC uintptr // PC for traceback while in VDSO call
    
    	// preemptGen counts the number of completed preemption
    	// signals. This is used to detect when a preemption is
    	// requested, but fails.
    	preemptGen atomic.Uint32
    
    	// Whether this is a pending preemption signal on this M.
    	signalPending atomic.Uint32
    
    	// pcvalue lookup cache
    	pcvalueCache pcvalueCache
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  8. src/runtime/mgcwork.go

    //
    //	(preemption must be disabled)
    //	gcw := &getg().m.p.ptr().gcw
    //	.. call gcw.put() to produce and gcw.tryGet() to consume ..
    //
    // It's important that any use of gcWork during the mark phase prevent
    // the garbage collector from transitioning to mark termination since
    // gcWork may locally hold GC work buffers. This can be done by
    // disabling preemption (systemstack or acquirem).
    type gcWork struct {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. pkg/scheduler/schedule_one.go

    		// will fit due to the preemption. It is also possible that a different pod will schedule
    		// into the resources that were preempted, but this is harmless.
    
    		if !fwk.HasPostFilterPlugins() {
    			logger.V(3).Info("No PostFilter plugins are registered, so no preemption will be performed")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  10. pkg/kubelet/metrics/metrics.go

    			StabilityLevel: metrics.ALPHA,
    		},
    		[]string{"eviction_signal"},
    	)
    	// Preemptions is a Counter that tracks the cumulative number of pod preemptions initiated by the kubelet.
    	// Broken down by preemption signal. A preemption is only recorded for one resource, the sum of all signals
    	// is the number of preemptions on the given node.
    	Preemptions = metrics.NewCounterVec(
    		&metrics.CounterOpts{
    			Subsystem:      KubeletSubsystem,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
Back to top