Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 899 for finalizerB (0.3 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/test/integration/finalization_test.go

    	// Trying to delete it again to confirm it will not remove the object because finalizer is still there.
    	err = noxuResourceClient.Delete(context.TODO(), name, metav1.DeleteOptions{
    		Preconditions: &metav1.Preconditions{
    			UID: &uid,
    		},
    	})
    	require.NoError(t, err)
    
    	// Removing the finalizers to allow the following delete remove the object.
    	// This step will fail if previous delete wrongly removed the object. The
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 02 19:34:41 UTC 2021
    - 5.8K bytes
    - Viewed (0)
  2. test/fixedbugs/issue5493.go

    			run()
    			wg.Done()
    		}()
    	}
    	wg.Wait()
    	for i := 0; i < 2*N; i++ {
    		time.Sleep(10 * time.Millisecond)
    		runtime.GC()
    	}
    	if count != 0 {
    		println(count, "out of", N, "finalizer are not called")
    		panic("not all finalizers are called")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 05 21:11:31 UTC 2021
    - 953 bytes
    - Viewed (0)
  3. test/deferfin.go

    			})
    			defer f()
    		}()
    	}
    	wg.Wait()
    	for i := 0; i < 3; i++ {
    		time.Sleep(10 * time.Millisecond)
    		runtime.GC()
    	}
    	if count != 0 {
    		println(count, "out of", N, "finalizer are not called")
    		panic("not all finalizers are called")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 05 21:11:31 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  4. src/go/parser/testdata/chans.go2

    // been closed and no more values will be received.
    func (r *Receiver[T]) Next() (T, bool) {
    	v, ok := <-r.values
    	return v, ok
    }
    
    // finalize is a finalizer for the receiver.
    func (r *Receiver[T]) finalize() {
    	close(r.done)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 24 19:44:06 UTC 2020
    - 1.7K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/syntax/testdata/chans.go

    // been closed and no more values will be received.
    func (r *Receiver[T]) Next() (T, bool) {
    	v, ok := <-r.values
    	return v, ok
    }
    
    // finalize is a finalizer for the receiver.
    func (r *Receiver[T]) finalize() {
    	close(r.done)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 30 18:02:18 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  6. 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)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/etcd.go

    					now := metav1.Now()
    					existingCRD.DeletionTimestamp = &now
    				}
    
    				if !apiextensions.CRDHasFinalizer(existingCRD, apiextensions.CustomResourceCleanupFinalizer) {
    					existingCRD.Finalizers = append(existingCRD.Finalizers, apiextensions.CustomResourceCleanupFinalizer)
    				}
    				// update the status condition too
    				apiextensions.SetCRDCondition(existingCRD, apiextensions.CustomResourceDefinitionCondition{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 09:21:19 UTC 2022
    - 8K bytes
    - Viewed (0)
  8. pkg/fuzz/util.go

    //
    //	 fuzz.BaseCases(f)
    //		f.Fuzz(func(...) {
    //		   defer fuzz.Finalizer()
    //		}
    //
    // To avoid needing to call BaseCases and Finalize everywhere.
    func Fuzz(f test.Fuzzer, ff func(fg Helper)) {
    	BaseCases(f)
    	f.Fuzz(func(t *testing.T, data []byte) {
    		defer Finalize()
    		fg := New(t, data)
    		ff(fg)
    	})
    }
    
    // Finalize works around an issue in the oss-fuzz logic that doesn't allow using Skip()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Nov 30 15:31:14 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  9. pkg/registry/rbac/helpers_test.go

    			},
    			old: func() runtime.Object {
    				return newPod()
    			},
    			expected: true,
    		},
    		{
    			name: "ownerRef and finalizer",
    			obj: func() runtime.Object {
    				obj := newPod()
    				obj.OwnerReferences = append(obj.OwnerReferences, metav1.OwnerReference{Name: "foo"})
    				obj.Finalizers = []string{"final"}
    				return obj
    			},
    			old: func() runtime.Object {
    				return newPod()
    			},
    			expected: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 05 20:12:50 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/base/base.go

    func forEachGC(fn func() bool) {
    	type T [32]byte // large enough to avoid runtime's tiny object allocator
    
    	var finalizer func(*T)
    	finalizer = func(p *T) {
    		if fn() {
    			runtime.SetFinalizer(p, finalizer)
    		}
    	}
    
    	finalizer(new(T))
    }
    
    // AdjustStartingHeap modifies GOGC so that GC should not occur until the heap
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 22 19:18:34 UTC 2023
    - 8K bytes
    - Viewed (0)
Back to top