- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for finalizer (0.25 sec)
-
pkg/controller/job/job_controller.go
} return string(batch.NonIndexedCompletion) } func appendJobCompletionFinalizerIfNotFound(finalizers []string) []string { for _, fin := range finalizers { if fin == batch.JobTrackingFinalizer { return finalizers } } return append(finalizers, batch.JobTrackingFinalizer) } func removeTrackingFinalizerPatch(pod *v1.Pod) []byte { if !hasJobTrackingFinalizer(pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
claim.Finalizers = append(claim.Finalizers, resourcev1alpha2.Finalizer) if _, err := pl.clientset.ResourceV1alpha2().ResourceClaims(claim.Namespace).Update(ctx, claim, metav1.UpdateOptions{}); err != nil { return nil, fmt.Errorf("add finalizer: %v", err) } } } // The claim might be stale, for example because the claim can get shared and some // other goroutine has updated it in the meantime. We therefore cannot use
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
src/runtime/pprof/pprof_test.go
}) } wg.Wait() }) // The finalizer goroutine should not show up in most profiles, since it's // marked as a system goroutine when idle. t.Run("finalizer not present", func(t *testing.T) { var w strings.Builder goroutineProf.WriteTo(&w, 1) prof := w.String() if includesFinalizer(prof) { t.Errorf("profile includes finalizer (but finalizer should be marked as system):\n%s", prof) } })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 68.8K bytes - Viewed (0) -
src/runtime/mgcmark.go
// //go:nowritebarrier func markrootSpans(gcw *gcWork, shard int) { // Objects with finalizers have two GC-related invariants: // // 1) Everything reachable from the object must be marked. // This ensures that when we pass the object to its finalizer, // everything the finalizer can reach will be retained. // // 2) Finalizer specials (which are not in the garbage // collected heap) are roots. In practice, this means the fn
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
src/runtime/mheap.go
// so it's retained for the finalizer. if !span.spanclass.noscan() { scanobject(base, gcw) } // Mark the finalizer itself, since the // special isn't part of the GC'd heap. scanblock(uintptr(unsafe.Pointer(&s.fn)), goarch.PtrSize, &oneptrmask[0], gcw, nil) releasem(mp) } return true } // There was an old finalizer lock(&mheap_.speciallock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
src/runtime/mprof.go
// goroutineProfileState will be "InProgress" and it will not be able to run // until the capture completes and the state moves to "Satisfied". // // Some goroutines (the finalizer goroutine, which at various times can be // either a "system" or a "user" goroutine, and the goroutine that is // coordinating the profile, any goroutines created during the profile) move // directly to the "Satisfied" state.
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/controller/volume/persistentvolume/pv_controller.go
if err != nil { return fmt.Errorf("persistent volume controller can't update finalizer: %v", err) } _, err = ctrl.storeVolumeUpdate(logger, volumeClone) if err != nil { return fmt.Errorf("persistent Volume Controller can't anneal migration finalizer: %v", err) } logger.V(2).Info("PV in-tree protection finalizer removed from volume", "volumeName", volume.Name) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
src/runtime/mgc.go
// so they are empty. When a goroutine grabs a new span into mcache, it sweeps it. // When a goroutine explicitly frees an object or sets a finalizer, it ensures that // the span is swept (either by sweeping it, or by waiting for the concurrent sweep to finish). // The finalizer goroutine is kicked off only when all spans are swept. // When the next GC starts, it sweeps all not-yet-swept spans (if any). // GC rate.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
expectedErr: true, }, "skip-adding-finalizer": { pod: podWithClaimName, claims: []*resourcev1alpha2.ResourceClaim{pendingImmediateClaim}, oldObj: pendingImmediateClaim, newObj: func() *resourcev1alpha2.ResourceClaim { claim := pendingImmediateClaim.DeepCopy() claim.Finalizers = append(claim.Finalizers, "foo") return claim }(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
src/runtime/traceback.go
// runtime.handleAsyncEvent (wasm only) and sometimes runtime.runfinq. // // If fixed is true, any goroutine that can vary between user and // system (that is, the finalizer goroutine) is considered a user // goroutine. func isSystemGoroutine(gp *g, fixed bool) bool { // Keep this in sync with internal/trace.IsSystemGoroutine. f := findfunc(gp.startpc) if !f.valid() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 55.1K bytes - Viewed (0)