Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 124 for oldObj (1.23 sec)

  1. pkg/controller/servicecidrs/servicecidrs_controller.go

    	if !ok {
    		return
    	}
    	c.queue.Add(cidr.Name)
    	for _, key := range c.overlappingServiceCIDRs(cidr) {
    		c.queue.Add(key)
    	}
    }
    
    func (c *Controller) updateServiceCIDR(oldObj, obj interface{}) {
    	key, err := cache.MetaNamespaceKeyFunc(obj)
    	if err == nil {
    		c.queue.Add(key)
    	}
    }
    
    // deleteServiceCIDR
    func (c *Controller) deleteServiceCIDR(obj interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    	}
    
    	if _, err := jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			jm.addJob(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			jm.updateJob(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			jm.deleteJob(logger, obj)
    		},
    	}); err != nil {
    		return nil, fmt.Errorf("adding Job event handler: %w", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  3. pkg/controller/garbagecollector/garbagecollector_test.go

    						if !reflect.DeepEqual(e.obj, a.obj) {
    							objectDiff = "\nobjectDiff:\n" + cmp.Diff(e.obj, a.obj)
    						}
    						oldObjectDiff := ""
    						if !reflect.DeepEqual(e.oldObj, a.oldObj) {
    							oldObjectDiff = "\noldObjectDiff:\n" + cmp.Diff(e.oldObj, a.oldObj)
    						}
    						ctx.t.Errorf("graphChanges[%d]: expected\n%#v\ngot\n%#v%s%s", i, e, a, objectDiff, oldObjectDiff)
    					}
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    		return
    	}
    	r.removeStorage_locked(crd.UID)
    }
    
    // updateCustomResourceDefinition removes potentially stale storage so it gets re-created
    func (r *crdHandler) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	oldCRD := oldObj.(*apiextensionsv1.CustomResourceDefinition)
    	newCRD := newObj.(*apiextensionsv1.CustomResourceDefinition)
    
    	r.customStorageLock.Lock()
    	defer r.customStorageLock.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    			t.Fatalf("unexpected error: %v", err)
    		}
    
    		transformer := func(ctx context.Context, newObj runtime.Object, oldObj runtime.Object) (transformedNewObj runtime.Object, err error) {
    			<-ready
    			pod, ok := newObj.(*example.Pod)
    			if !ok {
    				t.Fatalf("unexpected object %v", newObj)
    			}
    			pod.Labels = map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  6. src/runtime/runtime-gdb.py

    			bp = buckets + bucket
    			if oldbuckets:
    				oldbucket = bucket & (2 ** (B - 1) - 1)
    				oldbp = oldbuckets + oldbucket
    				oldb = oldbp.dereference()
    				if (oldb['overflow'].cast(inttype) & 1) == 0:  # old bucket not evacuated yet
    					if bucket >= 2 ** (B - 1):
    						continue    # already did old bucket
    					bp = oldbp
    			while bp:
    				b = bp.dereference()
    				for i in xrange(MapBucketCount):
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 10 12:59:20 UTC 2023
    - 15.4K bytes
    - Viewed (0)
  7. src/runtime/map_faststr.go

    	if c := h.oldbuckets; c != nil {
    		if !h.sameSizeGrow() {
    			// There used to be half as many buckets; mask down one more power of two.
    			m >>= 1
    		}
    		oldb := (*bmap)(add(c, (hash&m)*uintptr(t.BucketSize)))
    		if !evacuated(oldb) {
    			b = oldb
    		}
    	}
    	top := tophash(hash)
    	for ; b != nil; b = b.overflow(t) {
    		for i, kptr := uintptr(0), b.keys(); i < abi.MapBucketCount; i, kptr = i+1, add(kptr, 2*goarch.PtrSize) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/cel/common/equality_test.go

    			RootOldObject: []interface{}{
    				"a",
    				"oldB",
    			},
    			Schema: mustSchema(`
                    items:
                        type: string
                `),
    			KeyPath: []interface{}{1},
    		},
    		{
    			Name: "Changed Index In Nested Old Object",
    			RootObject: []interface{}{
    				"a",
    				"b",
    			},
    			RootOldObject: []interface{}{
    				"a",
    				"oldB",
    			},
    			Schema: mustSchema(`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 13 21:36:46 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  9. src/runtime/map_fast64.go

    		if c := h.oldbuckets; c != nil {
    			if !h.sameSizeGrow() {
    				// There used to be half as many buckets; mask down one more power of two.
    				m >>= 1
    			}
    			oldb := (*bmap)(add(c, (hash&m)*uintptr(t.BucketSize)))
    			if !evacuated(oldb) {
    				b = oldb
    			}
    		}
    	}
    	for ; b != nil; b = b.overflow(t) {
    		for i, k := uintptr(0), b.keys(); i < abi.MapBucketCount; i, k = i+1, add(k, 8) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  10. src/runtime/map_fast32.go

    		if c := h.oldbuckets; c != nil {
    			if !h.sameSizeGrow() {
    				// There used to be half as many buckets; mask down one more power of two.
    				m >>= 1
    			}
    			oldb := (*bmap)(add(c, (hash&m)*uintptr(t.BucketSize)))
    			if !evacuated(oldb) {
    				b = oldb
    			}
    		}
    	}
    	for ; b != nil; b = b.overflow(t) {
    		for i, k := uintptr(0), b.keys(); i < abi.MapBucketCount; i, k = i+1, add(k, 4) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top