Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,365 for finalizerB (0.76 sec)

  1. pkg/controller/volume/pvprotection/pv_protection_controller.go

    		logger.V(3).Info("Error adding protection finalizer to PV", "PV", klog.KObj(pv), "err", err)
    		return err
    	}
    	logger.V(3).Info("Added protection finalizer to PV", "PV", klog.KObj(pv))
    	return nil
    }
    
    func (c *Controller) removeFinalizer(ctx context.Context, pv *v1.PersistentVolume) error {
    	pvClone := pv.DeepCopy()
    	pvClone.ObjectMeta.Finalizers = slice.RemoveString(pvClone.ObjectMeta.Finalizers, volumeutil.PVProtectionFinalizer, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. subprojects/core/src/main/java/org/gradle/execution/plan/edges/ComplexDependentNodesSet.java

            return this;
        }
    
        @Override
        public SortedSet<Node> getFinalizers() {
            return finalizers;
        }
    
        @Override
        public DependentNodesSet addFinalizer(Node finalizer) {
            finalizers.add(finalizer);
            return this;
        }
    
        @Override
        public Set<Node> getMustPredecessors() {
            return mustPredecessors;
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Sep 12 20:17:10 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  3. test/tinyfin.go

    		runtime.SetFinalizer(x, func(p *int32) {
    			finalized <- *p
    		})
    	}
    	runtime.GC()
    	count := 0
    	done := make([]bool, N)
    	timeout := time.After(5*time.Second)
    	for {
    		select {
    		case <-timeout:
    			println("timeout,", count, "finalized so far")
    			panic("not all finalizers are called")
    		case x := <-finalized:
    			// Check that p points to the correct subobject of the tiny allocation.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 03 18:57:18 UTC 2015
    - 1.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/api/validation/objectmeta.go

    	hasFinalizerOrphanDependents := false
    	hasFinalizerDeleteDependents := false
    	for _, finalizer := range finalizers {
    		allErrs = append(allErrs, ValidateFinalizerName(finalizer, fldPath)...)
    		if finalizer == metav1.FinalizerOrphanDependents {
    			hasFinalizerOrphanDependents = true
    		}
    		if finalizer == metav1.FinalizerDeleteDependents {
    			hasFinalizerDeleteDependents = true
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 07 03:12:31 UTC 2022
    - 12K bytes
    - Viewed (0)
  5. platforms/core-configuration/model-core/src/testFixtures/groovy/org/gradle/api/internal/provider/PropertySpec.groovy

            then:
            0 * _
    
            and:
            value == someValue()
        }
    
        def "replaces provider with fixed value when value finalized after value implicitly finalized but not read yet"() {
            def property = propertyWithNoValue()
            def function = Mock(Callable)
            def provider = new DefaultProvider<T>(function)
    
            given:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri May 17 11:41:55 UTC 2024
    - 87.8K bytes
    - Viewed (0)
  6. plugin/pkg/admission/storage/storageobjectinuseprotection/admission_test.go

    		expectedObject runtime.Object
    		namespace      string
    	}{
    		{
    			"create -> add finalizer",
    			api.SchemeGroupVersion.WithResource("persistentvolumeclaims"),
    			claim,
    			claimWithFinalizer,
    			claim.Namespace,
    		},
    		{
    			"finalizer already exists -> no new finalizer",
    			api.SchemeGroupVersion.WithResource("persistentvolumeclaims"),
    			claimWithFinalizer,
    			claimWithFinalizer,
    			claimWithFinalizer.Namespace,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  7. subprojects/core/src/main/java/org/gradle/execution/plan/CompositeNodeGroup.java

            return new CompositeNodeGroup(original.isReachableFromEntryPoint() || finalizers.isReachableFromEntryPoint(), original, finalizers.getFinalizerGroups());
        }
    
        public static HasFinalizers mergeInto(HasFinalizers original, HasFinalizers finalizers) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jan 26 14:58:23 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. src/runtime/abi_test.go

    			runtime.SetFinalizer(x, test.fin)
    
    			runtime.KeepAlive(x)
    
    			// Queue the finalizer.
    			runtime.GC()
    			runtime.GC()
    
    			if !runtime.BlockUntilEmptyFinalizerQueue(int64(time.Second)) {
    				t.Fatal("finalizer failed to execute")
    			}
    			if got := int(regConfirmRun.Load()); got != test.confirmValue {
    				t.Fatalf("wrong finalizer executed? got %d, want %d", got, test.confirmValue)
    			}
    		})
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  9. operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go

    			finalizers = sets.New(iop.GetFinalizers()...)
    			finalizers.Delete(finalizer)
    			iop.SetFinalizers(sets.SortedList(finalizers))
    			finalizerError = r.client.Update(context.TODO(), iop)
    		}
    		if finalizerError != nil {
    			if errors.IsNotFound(finalizerError) {
    				scope.Infof("Did not remove finalizer from %s: the object was previously deleted.", iopName)
    				metrics.CRDeletionTotal.Increment()
    				return reconcile.Result{}, nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  10. pkg/controller/controller_ref_manager_test.go

    				}
    				for _, f := range test.manager.finalizers {
    					if !strings.Contains(patch, f) {
    						t.Errorf("Patch doesn't contain finalizer %s, %q", patch, f)
    					}
    				}
    			}
    		})
    	}
    }
    
    func TestGeneratePatchBytesForDelete(t *testing.T) {
    	tests := []struct {
    		name         string
    		ownerUID     []types.UID
    		dependentUID types.UID
    		finalizers   []string
    		want         []byte
    	}{
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 10 17:19:26 UTC 2021
    - 10.6K bytes
    - Viewed (0)
Back to top