Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for oldpod (0.45 sec)

  1. pkg/controller/daemon/update.go

    					oldPodsToDelete = append(oldPodsToDelete, oldPod.Name)
    					continue
    				}
    				// the old pod isn't available, allow it to become a replacement
    				logger.V(5).Info("Pod on node is out of date and not available, allowing replacement", "daemonset", klog.KObj(ds), "pod", klog.KObj(oldPod), "node", klog.KRef("", nodeName))
    				// record the replacement
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 16:53:53 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/informers.go

    		// For update, we just need to handle opt outs
    		newPod := event.New.(*corev1.Pod)
    		oldPod := event.Old.(*corev1.Pod)
    		ns := s.namespaces.Get(newPod.Namespace, "")
    		if ns == nil {
    			return fmt.Errorf("failed to find namespace %v", ns)
    		}
    		wasAnnotated := oldPod.Annotations != nil && oldPod.Annotations[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set.go

    	curPod := cur.(*v1.Pod)
    	oldPod := old.(*v1.Pod)
    	if curPod.ResourceVersion == oldPod.ResourceVersion {
    		// In the event of a re-list we may receive update events for all known pods.
    		// Two different versions of the same pod will always have different RVs.
    		return
    	}
    
    	labelChanged := !reflect.DeepEqual(curPod.Labels, oldPod.Labels)
    
    	curControllerRef := metav1.GetControllerOf(curPod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  4. pkg/kubelet/pleg/generic.go

    		fillCidSet(p.Sandboxes)
    	}
    	return containers
    }
    
    func computeEvents(oldPod, newPod *kubecontainer.Pod, cid *kubecontainer.ContainerID) []*PodLifecycleEvent {
    	var pid types.UID
    	if oldPod != nil {
    		pid = oldPod.ID
    	} else if newPod != nil {
    		pid = newPod.ID
    	}
    	oldState := getContainerState(oldPod, cid)
    	newState := getContainerState(newPod, cid)
    	return generateEvents(pid, cid.ID, oldState, newState)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  5. pkg/api/pod/util.go

    	)
    	if pod != nil {
    		podSpec = &pod.Spec
    		podStatus = &pod.Status
    		podAnnotations = pod.Annotations
    	}
    	if oldPod != nil {
    		oldPodSpec = &oldPod.Spec
    		oldPodStatus = &oldPod.Status
    		oldPodAnnotations = oldPod.Annotations
    	}
    	dropDisabledFields(podSpec, podAnnotations, oldPodSpec, oldPodAnnotations)
    	dropDisabledPodStatusFields(podStatus, oldPodStatus, podSpec, oldPodSpec)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41.3K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/interface.go

    	// DeleteNominatedPodIfExists deletes nominatedPod from internal cache. It's a no-op if it doesn't exist.
    	DeleteNominatedPodIfExists(pod *v1.Pod)
    	// UpdateNominatedPod updates the <oldPod> with <newPod>.
    	UpdateNominatedPod(logger klog.Logger, oldPod *v1.Pod, newPodInfo *PodInfo)
    	// NominatedPodsForNode returns nominatedPods on the given node.
    	NominatedPodsForNode(nodeName string) []*PodInfo
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  7. pkg/controller/endpointslice/endpointslice_controller.go

    func (c *Controller) deletePod(obj interface{}) {
    	pod := endpointsliceutil.GetPodFromDeleteAction(obj)
    	if pod != nil {
    		c.addPod(pod)
    	}
    }
    
    func (c *Controller) addNode() {
    	c.topologyQueue.Add(topologyQueueItemKey)
    }
    
    func (c *Controller) updateNode(old, cur interface{}) {
    	oldNode := old.(*v1.Node)
    	curNode := cur.(*v1.Node)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  8. pkg/kubelet/config/config.go

    		pods = make(map[types.UID]*v1.Pod)
    	}
    
    	// updatePodFunc is the local function which updates the pod cache *oldPods* with new pods *newPods*.
    	// After updated, new pod will be stored in the pod cache *pods*.
    	// Notice that *pods* and *oldPods* could be the same cache.
    	updatePodsFunc := func(newPods []*v1.Pod, oldPods, pods map[types.UID]*v1.Pod) {
    		filtered := filterInvalidPods(newPods, source, s.recorder)
    		for _, ref := range filtered {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  9. src/runtime/slice.go

    //
    //go:linkname growslice
    func growslice(oldPtr unsafe.Pointer, newLen, oldCap, num int, et *_type) slice {
    	oldLen := newLen - num
    	if raceenabled {
    		callerpc := getcallerpc()
    		racereadrangepc(oldPtr, uintptr(oldLen*int(et.Size_)), callerpc, abi.FuncPCABIInternal(growslice))
    	}
    	if msanenabled {
    		msanread(oldPtr, uintptr(oldLen*int(et.Size_)))
    	}
    	if asanenabled {
    		asanread(oldPtr, uintptr(oldLen*int(et.Size_)))
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/pod.go

    			pc.addPod(pod, ip, key)
    		} else {
    			return nil
    		}
    	case model.EventUpdate:
    		if !shouldPodBeInEndpoints(pod) || !IsPodReady(pod) {
    			// delete only if this pod was in the cache
    			if !pc.deleteIP(ip, key) {
    				return nil
    			}
    			ev = model.EventDelete
    		} else if shouldPodBeInEndpoints(pod) && IsPodReady(pod) {
    			pc.addPod(pod, ip, key)
    		} else {
    			return nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 10.8K bytes
    - Viewed (0)
Back to top