Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 100 for finalizer (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top