Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 57 for preemption (0.19 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. 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)
  3. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			},
    			wantResult: framework.NewPostFilterResultWithNominatedNode(""),
    			wantStatus: framework.NewStatus(framework.Unschedulable, "preemption: 0/1 nodes are available: 1 No preemption victims found for incoming pod."),
    		},
    		{
    			name: "preemption should respect filteredNodesStatuses",
    			pod:  st.MakePod().Name("p").UID("p").Namespace(v1.NamespaceDefault).Priority(highPriority).Obj(),
    			pods: []*v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  4. src/internal/runtime/exithook/hooks.go

    // Package exithook provides limited support for on-exit cleanup.
    //
    // CAREFUL! The expectation is that Add should only be called
    // from a safe context (e.g. not an error/panic path or signal
    // handler, preemption enabled, allocation allowed, write barriers
    // allowed, etc), and that the exit function F will be invoked under
    // similar circumstances. That is the say, we are expecting that F
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 16:41:13 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/interface.go

    	// NodeInfoSnapshot because we don't guarantee that they will be the same.
    	// For example, during preemption, we may pass a copy of the original
    	// nodeInfo object that has some pods removed from it to evaluate the
    	// possibility of preempting them to schedule the target pod.
    	Filter(ctx context.Context, state *CycleState, pod *v1.Pod, nodeInfo *NodeInfo) *Status
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  6. manifests/charts/gateway/values.yaml

      # Configure this to a higher priority class in order to make sure your Istio gateway pods
      # will not be killed because of low priority class.
      # Refer to https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/#priorityclass
      # for more detail.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 07 16:51:35 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. 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)
  8. src/sync/pool.go

    		}
    	}
    
    	// Mark the victim cache as empty for future gets don't bother
    	// with it.
    	atomic.StoreUintptr(&p.victimSize, 0)
    
    	return nil
    }
    
    // pin pins the current goroutine to P, disables preemption and
    // returns poolLocal pool for the P and the P's id.
    // Caller must call runtime_procUnpin() when done with the pool.
    func (p *Pool) pin() (*poolLocal, int) {
    	// Check whether p is nil to get a panic.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (1)
  9. src/runtime/mgc.go

    		// Preemption must not occur here, or another G might see
    		// p.gcMarkWorkerMode.
    
    		// Disable preemption so we can use the gcw. If the
    		// scheduler wants to preempt us, we'll stop draining,
    		// dispose the gcw, and then preempt.
    		node.m.set(acquirem())
    		pp := gp.m.p.ptr() // P can't change with preemption disabled.
    
    		if gcBlackenEnabled == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  10. 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)
Back to top