- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,402 for finalizer (0.29 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) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/tasks/controlling_task_execution.adoc
==== include::sample[dir="snippets/tasks/finalizers/kotlin",files="build.gradle.kts[]"] include::sample[dir="snippets/tasks/finalizers/groovy",files="build.gradle[]"] ---- $ gradle -q taskX include::{snippetsPath}/tasks/finalizers/tests/taskFinalizers.out[] ---- ==== Finalizer tasks are executed even if the finalized task fails or if the finalized task is considered `UP-TO-DATE`: ====
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Mar 23 22:37:03 UTC 2024 - 14.2K bytes - Viewed (0) -
src/crypto/internal/boring/ecdsa.go
if err != nil { return nil, err } k := &PublicKeyECDSA{key} // Note: Because of the finalizer, any time k.key is passed to cgo, // that call must be followed by a call to runtime.KeepAlive(k), // to make sure k is not collected (and finalized) before the cgo // call returns. runtime.SetFinalizer(k, (*PublicKeyECDSA).finalize) return k, nil } func newECKey(curve string, X, Y BigInt) (*C.GO_EC_KEY, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 17:51:31 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/controller/job/tracking_utils.go
type uidSet struct { sync.RWMutex set sets.Set[string] key string } // uidTrackingExpectations tracks the UIDs of Pods the controller is waiting to // observe tracking finalizer deletions. type uidTrackingExpectations struct { store cache.Store } // GetUIDs is a convenience method to avoid exposing the set of expected uids.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0) -
src/runtime/debug/heapdump_test.go
// bug 9172: WriteHeapDump couldn't handle more than one finalizer println("allocating objects") x := &Obj{} runtime.SetFinalizer(x, objfin) y := &Obj{} runtime.SetFinalizer(y, objfin) // Trigger collection of x and y, queueing of their finalizers. println("starting gc") runtime.GC() // Make sure WriteHeapDump doesn't fail with multiple queued finalizers. println("starting dump") WriteHeapDump(f.Fd())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 12 00:32:29 UTC 2022 - 2K bytes - Viewed (0) -
test/fixedbugs/issue30476.go
// Issue 30476: KeepAlive didn't keep stack object alive. package main import "runtime" func main() { x := new([10]int) runtime.SetFinalizer(x, func(*[10]int) { panic("FAIL: finalizer runs") }) p := &T{x, 0} use(p) runtime.GC() runtime.GC() runtime.GC() runtime.KeepAlive(p) } type T struct { x *[10]int y int } //go:noinline
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 01 15:36:52 UTC 2019 - 525 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
}, "no existing finalizers, PropagationPolicy=Default, orphanDeleteStrategy": { options: &metav1.DeleteOptions{PropagationPolicy: nil}, strategy: orphanDeleteStrategy, expectedFinalizers: []string{metav1.FinalizerOrphanDependents}, }, // all cases in the following block have "existing orphan finalizer"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/AbstractCommandLineOrderTaskIntegrationTest.groovy
TaskFixture shouldRunAfter(TaskFixture dependency) { shouldRunAfter.add(dependency) return this } TaskFixture finalizedBy(TaskFixture finalizer) { finalizers.add(finalizer) return this } TaskFixture mustRunAfter(TaskFixture task) { mustRunAfter.add(task) return this }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controller/namespace/deletion/status_condition_utils.go
} if len(contentTotals.finalizersToNumRemaining) != 0 { remainingByFinalizer := []string{} for finalizer, numRemaining := range contentTotals.finalizersToNumRemaining { if numRemaining == 0 { continue } remainingByFinalizer = append(remainingByFinalizer, fmt.Sprintf("%s in %d resource instances", finalizer, numRemaining)) } // sort for stable updates sort.Strings(remainingByFinalizer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 06 13:58:41 UTC 2019 - 8.1K bytes - Viewed (0) -
pkg/cache/ttlCache.go
c.stopEvicter = make(chan bool, 1) c.evicterTerminated.Add(1) go c.evicter(evictionInterval) // We return a 'see-through' wrapper for the real object such that // the finalizer can trigger on the wrapper. We can't set a finalizer // on the main cache object because it would never fire, since the // evicter goroutine is keeping it alive result := &ttlWrapper{c} runtime.SetFinalizer(result, func(w *ttlWrapper) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.8K bytes - Viewed (0)