- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for termination (0.2 sec)
-
src/runtime/mgc.go
func GC() { // We consider a cycle to be: sweep termination, mark, mark // termination, and sweep. This function shouldn't return // until a full cycle has been completed, from beginning to // end. Hence, we always want to finish up the current cycle // and start a new one. That means: // // 1. In sweep termination, mark, or mark termination of cycle // N, wait until mark termination N completes and transitions // to sweep N. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// Intended for use by subsystem sync loops to avoid performing background setup // after termination has been requested for a pod. Callers must ensure that the // syncPod method is non-blocking when their data is absent. ShouldPodBeFinished(uid types.UID) bool // IsPodTerminationRequested returns true when pod termination has been requested // until the termination completes and the pod is removed from config. This should
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
return fmt.Sprintf("Error on reading termination message from logs: %v", err) } return buf.String() } func (m *kubeGenericRuntimeManager) convertToKubeContainerStatus(status *runtimeapi.ContainerStatus) (cStatus *kubecontainer.Status) { cStatus = toKubeContainerStatus(status, m.runtimeName) if status.State == runtimeapi.ContainerState_CONTAINER_EXITED { // Populate the termination message if needed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
src/runtime/mprof.go
// snapshot as of the last mark termination without advancing the heap // profile cycle. func mProf_PostSweep() { // Flush cycle C+1 to the active profile so everything as of // the last mark termination becomes visible. *Don't* advance // the cycle, since we're still accumulating allocs in cycle // C+2, which have to become C+1 in the next mark termination // and so on. cycle := mProfCycle.read() + 1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
if !podWorkers.ShouldPodContainersBeTerminating(types.UID("0")) { t.Errorf("Expected pod to be terminating") } if !podWorkers.ShouldPodContainersBeTerminating(types.UID("1")) { t.Errorf("Expected pod to be terminating") } if podWorkers.ShouldPodContainersBeTerminating(types.UID("2")) { t.Errorf("Expected pod to not be terminating") } if !podWorkers.IsPodTerminationRequested(types.UID("0")) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/apis/core/v1/defaults_test.go
".Spec.Containers[0].StartupProbe.SuccessThreshold": "1", ".Spec.Containers[0].StartupProbe.TimeoutSeconds": "1", ".Spec.Containers[0].TerminationMessagePath": `"/dev/termination-log"`, ".Spec.Containers[0].TerminationMessagePolicy": `"File"`, ".Spec.Containers[0].LivenessProbe.ProbeHandler.GRPC.Service": `""`,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// Defines a time budget that can be spend on waiting for not-ready watchers // while dispatching event before shutting them down. dispatchTimeoutBudget timeBudget // Handling graceful termination. stopLock sync.RWMutex stopped bool stopCh chan struct{} stopWg sync.WaitGroup clock clock.Clock // timer is used to avoid unnecessary allocations in underlying watchers. timer *time.Timer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission_test.go
if err != nil { t.Errorf("Should have ignored calls to any subresource of pod %v", err) } // a pod that is undergoing termination should never be blocked terminatingPod := validPod("terminatingPod", 1, api.ResourceRequirements{}) now := metav1.Now() terminatingPod.DeletionTimestamp = &now
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 51.5K bytes - Viewed (0) -
src/runtime/mgcpacer.go
// that is scannable. globalsScan atomic.Uint64 // heapMarked is the number of bytes marked by the previous // GC. After mark termination, heapLive == heapMarked, but // unlike heapLive, heapMarked does not change until the // next mark termination. heapMarked uint64 // heapScanWork is the total heap scan work performed this cycle. // stackScanWork is the total stack scan work performed this cycle.
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/controller/job/job_controller.go
if err != nil { return err } var terminating *int32 if feature.DefaultFeatureGate.Enabled(features.JobPodReplacementPolicy) { terminating = ptr.To(controller.CountTerminatingPods(pods)) } jobCtx := &syncJobCtx{ job: &job, pods: pods, activePods: controller.FilterActivePods(logger, pods), terminating: terminating,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)