Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for oldObj (1.21 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation.go

    }
    
    func (s *Validator) validateExpressions(ctx context.Context, fldPath *field.Path, obj, oldObj interface{}, correlation ratchetingOptions, costBudget int64) (errs field.ErrorList, remainingBudget int64) {
    	sts := s.Schema
    
    	// guard against oldObj being a non-nil interface with a nil value
    	if oldObj != nil {
    		v := reflect.ValueOf(oldObj)
    		switch v.Kind() {
    		case reflect.Map, reflect.Pointer, reflect.Interface, reflect.Slice:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 18:21:31 UTC 2024
    - 32.2K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    		pod            *v1.Pod
    		oldObj, newObj interface{}
    		expectedHint   framework.QueueingHint
    		expectedErr    bool
    	}{
    		"backoff-wrong-new-object": {
    			pod:          &v1.Pod{},
    			newObj:       "not-a-pod",
    			expectedHint: framework.Queue,
    			expectedErr:  true,
    		},
    		"backoff-wrong-old-object": {
    			pod:          &v1.Pod{},
    			oldObj:       "not-a-pod",
    			newObj:       &v1.Pod{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/fit.go

    // that change made a previously unschedulable pod schedulable.
    func (f *Fit) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	originalPod, modifiedPod, err := schedutil.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	if modifiedPod == nil {
    		if originalPod.Spec.NodeName == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  4. pkg/controller/endpointslice/endpointslice_controller.go

    	logger := klog.FromContext(ctx)
    	endpointSliceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: c.onEndpointSliceAdd,
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			c.onEndpointSliceUpdate(logger, oldObj, newObj)
    		},
    		DeleteFunc: c.onEndpointSliceDelete,
    	})
    
    	c.endpointSliceLister = endpointSliceInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/types.go

    // - `oldObj` `newObj`: the object involved in that event.
    //   - For example, the given event is "Node deleted", the `oldObj` will be that deleted Node.
    //   - `oldObj` is nil if the event is add event.
    //   - `newObj` is nil if the event is delete event.
    type QueueingHintFn func(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (QueueingHint, error)
    
    type QueueingHint int
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    	}
    }
    
    func (pl *CSILimits) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	deletedPod, _, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, fmt.Errorf("unexpected objects in isSchedulableAfterPodDeleted: %w", err)
    	}
    
    	if len(deletedPod.Spec.Volumes) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set.go

    		// lookup the statefulset and enqueue
    		AddFunc: func(obj interface{}) {
    			ssc.addPod(logger, obj)
    		},
    		// lookup current and old statefulset if labels changed
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			ssc.updatePod(logger, oldObj, newObj)
    		},
    		// lookup statefulset accounting for deletion tombstones
    		DeleteFunc: func(obj interface{}) {
    			ssc.deletePod(logger, obj)
    		},
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  8. 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)
  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