- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 100 for finalizer (0.16 sec)
-
guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java
GcFinalization.awaitClear(finalizableWeakReference); Field sepFrqUserFinalizedF = sepFrqUserC.getField("finalized"); Semaphore finalizeCount = (Semaphore) sepFrqUserFinalizedF.get(null); boolean finalized = finalizeCount.tryAcquire(5, TimeUnit.SECONDS); assertTrue(finalized); Field sepFrqUserFrqF = sepFrqUserC.getField("frq"); Closeable frq = (Closeable) sepFrqUserFrqF.get(null);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package finalizer import ( "context" "fmt" "reflect" "time" "k8s.io/klog/v2" apierrors "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/api/meta"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/controller/job/indexed_job_utils_test.go
}, Spec: batch.JobSpec{ Completions: ptr.To(tc.completions), }, } pods := hollowPodsWithIndexPhase(tc.pods) for _, p := range pods { p.Finalizers = append(p.Finalizers, batch.JobTrackingFinalizer) } gotStatusIntervals, gotIntervals := calculateSucceededIndexes(logger, job, pods) if diff := cmp.Diff(tc.wantStatusIntervals, gotStatusIntervals); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.9K bytes - Viewed (0) -
src/runtime/mgcsweep.go
// Two complications here: // 1. An object can have both finalizer and profile special records. // In such case we need to queue finalizer for execution, // mark the object as live and preserve the profile special. // 2. A tiny object can have several finalizers setup for different offsets. // If such object is not marked, we need to queue all finalizers at once. // Both 1 and 2 are possible at the same time.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:52:18 UTC 2024 - 32.9K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/Task.java
*/ void setFinalizedBy(Iterable<?> finalizedBy); /** * <p>Returns tasks that finalize this task.</p> * * @return The tasks that finalize this task. Returns an empty set if there are no finalising tasks for this task. */ @Internal TaskDependency getFinalizedBy(); /** * <p>Specifies that this task should run after all of the supplied tasks.</p> *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 17:25:12 UTC 2024 - 31.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
return hasFinalizer(accessor, metav1.FinalizerOrphanDependents) } func hasFinalizer(accessor metav1.Object, matchingFinalizer string) bool { finalizers := accessor.GetFinalizers() for _, finalizer := range finalizers { if finalizer == matchingFinalizer { return true } } return false } // this function takes newAccessor directly because the caller already
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
claim = claim.DeepCopy() // As far the controller is concerned, a claim was allocated by us if it has // this finalizer. For testing we don't need to update the allocation result. claim.Finalizers = append(claim.Finalizers, resourcev1alpha2.Finalizer) return claim } func reserveClaim(claim *resourcev1alpha2.ResourceClaim, pod *v1.Pod) *resourcev1alpha2.ResourceClaim { claim = claim.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
// the dependents, so set propagationPolicy based on existing finalizers. var policy metav1.DeletionPropagation switch { case hasOrphanFinalizer(latest): // if an existing orphan finalizer is already on the object, honor it. policy = metav1.DeletePropagationOrphan case hasDeleteDependentsFinalizer(latest): // if an existing foreground finalizer is already on the object, honor it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
return err } // Now also remove the finalizer if it is not needed anymore. // Note that the index may have changed as a result of the UpdateStatus call. builtinControllerFinalizer := slices.Index(claim.Finalizers, resourcev1alpha2.Finalizer) if builtinControllerFinalizer >= 0 && claim.Status.Allocation == nil { claim.Finalizers = slices.Delete(claim.Finalizers, builtinControllerFinalizer, builtinControllerFinalizer+1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
plugin/pkg/admission/certificates/ctbattest/admission_test.go
SignerName: "panda.com/foo", }, }, operation: admission.Update, }, allowed: true, }, { description: "should always allow finalizer update", clusterTrustBundleFeatureEnabled: true, authzErr: errors.New("broken"), attributes: &testAttributes{ resource: certificatesapi.Resource("clustertrustbundles"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.9K bytes - Viewed (0)