Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for preemption (0.14 sec)

  1. 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)
  2. 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)
  3. src/runtime/mgcmark.go

    	// most this size. Since we can scan 1–2 MB/ms, 128 KB bounds
    	// scan preemption at ~100 µs.
    	//
    	// This must be > _MaxSmallSize so that the object base is the
    	// span base.
    	maxObletBytes = 128 << 10
    
    	// drainCheckThreshold specifies how many units of work to do
    	// between self-preemption checks in gcDrain. Assuming a scan
    	// rate of 1 MB/ms, this is ~100 µs. Lower values have higher
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  4. src/runtime/malloc.go

    	// Objects can be zeroed late in a context where preemption can occur.
    	// If the object contains pointers, its pointer data must be cleared
    	// or otherwise indicate that the GC shouldn't scan it.
    	// x will keep the memory alive.
    	if delayedZeroing {
    		// N.B. size == fullSize always in this case.
    		memclrNoHeapPointersChunked(size, x) // This is a possible preemption point: see #47302
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/runtime/framework.go

    			s.SetPlugin(pl.Name())
    			if s.Code() == framework.UnschedulableAndUnresolvable {
    				// In this case, the preemption shouldn't happen in this scheduling cycle.
    				// So, no need to execute all PreFilter.
    				return nil, s
    			}
    			if s.Code() == framework.Unschedulable {
    				// In this case, the preemption should happen later in this scheduling cycle.
    				// So we need to execute all PreFilter.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  6. src/runtime/mheap.go

    	// then release mheap_.lock.
    	allArenas []arenaIdx
    
    	// sweepArenas is a snapshot of allArenas taken at the
    	// beginning of the sweep cycle. This can be read safely by
    	// simply blocking GC (by disabling preemption).
    	sweepArenas []arenaIdx
    
    	// markArenas is a snapshot of allArenas taken at the beginning
    	// of the mark cycle. Because allArenas is append-only, neither
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
  7. src/runtime/mprof.go

    			yield()
    			continue
    		}
    
    		// While we have gp1.goroutineProfiled set to
    		// goroutineProfileInProgress, gp1 may appear _Grunnable but will not
    		// actually be able to run. Disable preemption for ourselves, to make
    		// sure we finish profiling gp1 right away instead of leaving it stuck
    		// in this limbo.
    		mp := acquirem()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  8. src/cmd/internal/obj/mips/asm0.go

    }
    
    // isUnsafePoint returns whether p is an unsafe point.
    func (c *ctxt0) isUnsafePoint(p *obj.Prog) bool {
    	// If p explicitly uses REGTMP, it's unsafe to preempt, because the
    	// preemption sequence clobbers REGTMP.
    	return p.From.Reg == REGTMP || p.To.Reg == REGTMP || p.Reg == REGTMP
    }
    
    // isRestartable returns whether p is a multi-instruction sequence that,
    // if preempted, can be restarted.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 16 17:46:09 UTC 2024
    - 53.6K bytes
    - Viewed (0)
  9. src/cmd/internal/obj/loong64/asm.go

    }
    
    // isUnsafePoint returns whether p is an unsafe point.
    func (c *ctxt0) isUnsafePoint(p *obj.Prog) bool {
    	// If p explicitly uses REGTMP, it's unsafe to preempt, because the
    	// preemption sequence clobbers REGTMP.
    	return p.From.Reg == REGTMP || p.To.Reg == REGTMP || p.Reg == REGTMP
    }
    
    // isRestartable returns whether p is a multi-instruction sequence that,
    // if preempted, can be restarted.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 02:04:54 UTC 2024
    - 61.8K bytes
    - Viewed (0)
  10. operator/pkg/apis/istio/v1alpha1/values_types.proto

      google.protobuf.BoolValue operatorManageWebhooks = 41;
    
      // Specifies the k8s priorityClassName for the istio control plane components.
      //
      // See https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/#priorityclass
      string priorityClassName = 27 [deprecated = true];
    
      // Specifies how proxies are configured within Istio.
      ProxyConfig proxy = 28;
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 01:55:05 UTC 2024
    - 57.2K bytes
    - Viewed (0)
Back to top