- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 72 for steady (0.14 sec)
-
src/runtime/mgcpacer.go
// is based on a steady-state scannable heap size, we assume this means our // heap is growing. Compute a new heap goal that takes our existing runway // computed for scanWorkExpected and extrapolates it to maxScanWork, the worst-case // scan work. This keeps our assist ratio stable if the heap continues to grow. // // The effect of this mechanism is that assists stay flat in the face of heap
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
originalCallback(resourceName, devices) updateChan <- new(interface{}) } activePods := func() []*v1.Pod { return []*v1.Pod{} } // test steady state, initialization where sourcesReady, containerMap and containerRunningSet // are relevant will be tested with a different flow err = w.Start(activePods, &sourcesReadyStub{}, containermap.NewContainerMap(), sets.New[string]())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
}, }, "Verify we do not create a pod sandbox if no ready sandbox for pod with RestartPolicy=Never and all containers exited": { mutatePodFn: func(pod *v1.Pod) { pod.Spec.RestartPolicy = v1.RestartPolicyNever }, mutateStatusFn: func(status *kubecontainer.PodStatus) { // no ready sandbox status.SandboxStatuses[0].State = runtimeapi.PodSandboxState_SANDBOX_NOTREADY
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
throw("tried to park scavenger from another goroutine") } s.parked = true goparkunlock(&s.lock, waitReasonGCScavengeWait, traceBlockSystemGoroutine, 2) } // ready signals to sysmon that the scavenger should be awoken. func (s *scavengerState) ready() { s.sysmonWake.Store(1) } // wake immediately unparks the scavenger if necessary. // // Safe to run without a P. func (s *scavengerState) wake() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
return p } func addPods(store cache.Store, namespace string, nPods int, nPorts int, nNotReady int, ipFamilies []v1.IPFamily) { for i := 0; i < nPods+nNotReady; i++ { isReady := i < nPods pod := testPod(namespace, i, nPorts, isReady, ipFamilies) store.Add(pod) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// IsLocal is part of proxy.Endpoint interface. func (info *endpointInfo) IsLocal() bool { return info.isLocal } // IsReady returns true if an endpoint is ready and not terminating. func (info *endpointInfo) IsReady() bool { return info.ready } // IsServing returns true if an endpoint is ready, regardless of it's terminating state. func (info *endpointInfo) IsServing() bool { return info.serving }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
name: "even zones, uneven endpoint distribution but within threshold, no sync required", nodes: []nodeInfo{ {zoneLabel: &zoneB, ready: &readyTrue, cpu: &cpu2000}, {zoneLabel: &zoneB, ready: &readyTrue, cpu: &cpu2000}, {zoneLabel: &zoneC, ready: &readyTrue, cpu: &cpu2000}, {zoneLabel: &zoneC, ready: &readyTrue, cpu: &cpu2000}, }, topologyCacheEnabled: true, endpointZoneInfo: map[string]topologycache.EndpointZoneInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
// - both saved and current statuses have Ready Conditions, different LastProbeTimes and different Ready Condition State - // Ready Condition changed it state since we last seen it, so we update both probeTimestamp and readyTransitionTimestamp. // TODO: things to consider: // - if 'LastProbeTime' have gone back in time its probably an error, currently we ignore it,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// Before accessing the cacher's cache, wait for the ready to be ok. // This is necessary to prevent users from accessing structures that are // uninitialized or are being repopulated right now. // ready needs to be set to false when the cacher is paused or stopped. // ready needs to be set to true when the cacher is ready to use after // initialization. ready *ready // Underlying storage.Interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/api/apps/v1/types.go
// the previous pod is ready or terminated. At most one pod will be changed // at any time. OrderedReadyPodManagement PodManagementPolicyType = "OrderedReady" // ParallelPodManagement will create and delete pods as soon as the stateful set // replica count is changed, and will not wait for pods to be ready or complete // termination. ParallelPodManagement PodManagementPolicyType = "Parallel"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 49.1K bytes - Viewed (0)