Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 271 for preemption (0.38 sec)

  1. pkg/scheduler/framework/preemption/preemption.go

    // We will only check <candidates> with extenders that support preemption.
    // Extenders which do not support preemption may later prevent preemptor from being scheduled on the nominated
    // node. In that case, scheduler will find a different host for the preemptor in subsequent scheduling cycles.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  2. pkg/kubelet/preemption/preemption.go

    	return s + "]"
    }
    
    // sortPodsByQOS returns lists containing besteffort, burstable, and guaranteed pods that
    // can be preempted by preemptor pod.
    func sortPodsByQOS(preemptor *v1.Pod, pods []*v1.Pod) (bestEffort, burstable, guaranteed []*v1.Pod) {
    	for _, pod := range pods {
    		if kubetypes.Preemptable(preemptor, pod) {
    			switch v1qos.GetPodQOS(pod) {
    			case v1.PodQOSBestEffort:
    				bestEffort = append(bestEffort, pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 16:53:19 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  3. plugin/pkg/admission/priority/admission_test.go

    				Priority:          &systemClusterCritical.Value,
    			},
    		},
    		// pod[11]: Pod without a preemption policy that matches the resolved preemption policy
    		{
    			ObjectMeta: metav1.ObjectMeta{
    				Name:      "pod-never-preemption-policy-matching-resolved-preemption-policy",
    				Namespace: metav1.NamespaceSystem,
    			},
    			Spec: api.PodSpec{
    				Containers: []api.Container{
    					{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 03 18:43:48 UTC 2022
    - 21.2K bytes
    - Viewed (0)
  4. src/runtime/preempt.go

    // stack bound to a value that will cause the next stack bound check
    // to fail and enter the stack growth implementation, which will
    // detect that it was actually a preemption and redirect to preemption
    // handling.
    //
    // Preemption at asynchronous safe-points is implemented by suspending
    // the thread using an OS mechanism (e.g., signals) and inspecting its
    // state to determine if the goroutine was at an asynchronous
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  5. src/sync/atomic/value.go

    	}
    	vp := (*efaceWords)(unsafe.Pointer(v))
    	vlp := (*efaceWords)(unsafe.Pointer(&val))
    	for {
    		typ := LoadPointer(&vp.typ)
    		if typ == nil {
    			// Attempt to start first store.
    			// Disable preemption so that other goroutines can use
    			// active spin wait to wait for completion.
    			runtime_procPin()
    			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
    				runtime_procUnpin()
    				continue
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:48:55 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    // of candidates that should be shortlisted for dry running preemption.
    func (pl *DefaultPreemption) GetOffsetAndNumCandidates(numNodes int32) (int32, int32) {
    	return rand.Int31n(numNodes), pl.calculateNumCandidates(numNodes)
    }
    
    // This function is not applicable for out-of-tree preemption plugins that exercise
    // different preemption candidates on the same nominated node.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  7. src/runtime/debug.go

    func debug_modinfo() string {
    	return modinfo
    }
    
    // mayMoreStackPreempt is a maymorestack hook that forces a preemption
    // at every possible cooperative preemption point.
    //
    // This is valuable to apply to the runtime, which can be sensitive to
    // preemption points. To apply this to all preemption points in the
    // runtime and runtime-like code, use the following in bash or zsh:
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 11 20:38:24 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  8. src/internal/abi/symtab.go

    )
    
    // Special values for the PCDATA_UnsafePoint table.
    const (
    	UnsafePointSafe   = -1 // Safe for async preemption
    	UnsafePointUnsafe = -2 // Unsafe for async preemption
    
    	// UnsafePointRestart1(2) apply on a sequence of instructions, within
    	// which if an async preemption happens, we should back off the PC
    	// to the start of the sequence when resuming.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 16 14:25:22 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. src/runtime/os_windows.go

    	// this fails, a preemption is in progress, so the thread must
    	// wait for the preemption. preemptM also CASes this from 0 to
    	// 1. If this fails, the preemption fails (as it would if the
    	// PC weren't in Go code). The value is reset to 0 when
    	// returning from external code or after a preemption is
    	// complete.
    	//
    	// TODO(austin): We may not need this if preemption were more
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 22:55:25 UTC 2024
    - 41.5K bytes
    - Viewed (0)
  10. pkg/scheduler/testing/framework/fake_extender.go

    	for nodeName, victims := range nodeNameToVictimsCopy {
    		// Try to do preemption on extender side.
    		nodeInfo, _ := nodeInfos.Get(nodeName)
    		extenderVictimPods, extenderPDBViolations, fits, err := f.selectVictimsOnNodeByExtender(logger, pod, nodeInfo)
    		if err != nil {
    			return nil, err
    		}
    		// If it's unfit after extender's preemption, this node is unresolvable by preemption overall,
    		// let's remove it from potential preemption nodes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top