- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Preemptable (0.63 sec)
-
pkg/kubelet/types/pod_update_test.go
preemptee: getTestPod(configSourceAnnotation(FileSource), &systemPriority, ""), expected: false, }, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { isPreemtable := Preemptable(test.preemptor, test.preemptee) assert.Equal(t, test.expected, isPreemtable) }) } } func TestIsCriticalPodBasedOnPriority(t *testing.T) { tests := []struct { priority int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 21 08:20:50 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
// 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) case v1.PodQOSBurstable: burstable = append(burstable, 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) -
src/runtime/preempt.go
// // This must be called from the system stack and the user goroutine on // the current M (if any) must be in a preemptible state. This // prevents deadlocks where two goroutines attempt to suspend each // other and both are in non-preemptible states. There are other ways // to resolve this deadlock, but this seems simplest. // // TODO(austin): What if we instead required this to be called from a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0) -
cluster/gce/config-test.sh
NODE_LABELS="${NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NODE_LABELS="${WINDOWS_NODE_LABELS},cloud.google.com/gke-preemptible=true" elif [[ "${PREEMPTIBLE_NODE}" = 'true' ]]; then NON_MASTER_NODE_LABELS="${NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NON_MASTER_NODE_LABELS="${WINDOWS_NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" fi # Optional: Enable netd.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 17:20:24 UTC 2024 - 29.8K bytes - Viewed (0) -
cluster/gce/config-default.sh
NODE_LABELS="${NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NODE_LABELS="${WINDOWS_NODE_LABELS},cloud.google.com/gke-preemptible=true" elif [[ "${PREEMPTIBLE_NODE}" == "true" ]]; then NON_MASTER_NODE_LABELS="${NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" WINDOWS_NON_MASTER_NODE_LABELS="${WINDOWS_NON_MASTER_NODE_LABELS},cloud.google.com/gke-preemptible=true" fi
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 20:16:32 UTC 2024 - 26.9K bytes - Viewed (0) -
src/runtime/mcache.go
}) } // getMCache is a convenience function which tries to obtain an mcache. // // Returns nil if we're not bootstrapping or we don't have a P. The caller's // P must not change, so we must be in a non-preemptible state. func getMCache(mp *m) *mcache { // Grab the mcache, since that's where stats live. pp := mp.p.ptr() var c *mcache if pp == nil { // We will be called without a P while bootstrapping,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10K bytes - Viewed (0) -
src/runtime/mgclimit.go
// Drain the pool of idle time. idleTime := l.idleTimePool.Load() if idleTime != 0 { l.idleTimePool.Add(-idleTime) } if !l.test { // Consume time from in-flight events. Make sure we're not preemptible so allp can't change. // // The reason we do this instead of just waiting for those events to finish and push updates // is to ensure that all the time we're accounting for happened sometime between lastUpdate
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K bytes - Viewed (0) -
src/runtime/mgcwork.go
// true if it should be called again to free more. func freeSomeWbufs(preemptible bool) bool { const batchSize = 64 // ~1–2 µs per span. lock(&work.wbufSpans.lock) if gcphase != _GCoff || work.wbufSpans.free.isEmpty() { unlock(&work.wbufSpans.lock) return false } systemstack(func() { gp := getg().m.curg for i := 0; i < batchSize && !(preemptible && gp.preempt); i++ { span := work.wbufSpans.free.first
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 12.9K bytes - Viewed (0) -
src/runtime/arena.go
} // setUserArenaChunkToFault sets the address space for the user arena chunk to fault // and releases any underlying memory resources. // // Must be in a non-preemptible state to ensure the consistency of statistics // exported to MemStats. func (s *mspan) setUserArenaChunkToFault() { if !s.isUserArenaChunk { throw("invalid span in heapArena for user arena") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:44:56 UTC 2024 - 37.9K bytes - Viewed (0) -
hack/make-rules/test-e2e-node.sh
--image-config-file="${image_config_file}" --system-spec-name="${system_spec_name}" \ --runtime-config="${runtime_config}" --preemptible-instances="${preemptible_instances}" \ --ssh-user="${ssh_user}" --ssh-key="${ssh_key}" --ssh-options="${ssh_options}" \ --image-config-dir="${image_config_dir}" --node-env="${node_env}" \
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 09:46:28 UTC 2024 - 10.7K bytes - Viewed (0)