Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for oldpod (0.12 sec)

  1. pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go

    			oldPod:       st.MakePod().Node("fake-node").Label("service", "bbb").Obj(),
    			expectedHint: framework.QueueSkip,
    		},
    		{
    			name:         "delete a pod which doesn't match pod's anti-affinity",
    			pod:          st.MakePod().Name("p").PodAntiAffinityIn("service", "region", []string{"securityscan", "value2"}, st.PodAntiAffinityWithRequiredReq).Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. plugin/pkg/auth/authorizer/node/graph_populator.go

    }
    
    func (g *graphPopulator) addPod(obj interface{}) {
    	g.updatePod(nil, obj)
    }
    
    func (g *graphPopulator) updatePod(oldObj, obj interface{}) {
    	pod := obj.(*corev1.Pod)
    	if len(pod.Spec.NodeName) == 0 {
    		// No node assigned
    		klog.V(5).Infof("updatePod %s/%s, no node", pod.Namespace, pod.Name)
    		return
    	}
    	if oldPod, ok := oldObj.(*corev1.Pod); ok && oldPod != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. pkg/registry/core/node/strategy.go

    	newNode := obj.(*api.Node)
    	oldNode := old.(*api.Node)
    	newNode.Status = oldNode.Status
    
    	dropDisabledFields(newNode, oldNode)
    }
    
    func dropDisabledFields(node *api.Node, oldNode *api.Node) {
    	// Nodes allow *all* fields, including status, to be set on create.
    	// for create
    	if oldNode == nil {
    		node.Spec.ConfigSource = nil
    		node.Status.Config = nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:06:39 UTC 2024
    - 9K bytes
    - Viewed (0)
  4. tensorflow/compiler/mlir/lite/stablehlo/transforms/composite_utils.cc

      if (auto bool_attr = mlir::dyn_cast_or_null<BoolAttr>(attr)) {
        return bool_attr.getValue();
      }
      return std::nullopt;
    }
    
    ShapedType GetNhwcReturnTypeFromNchw(Operation* old_op) {
      auto composite_result_shape =
          mlir::cast<ShapedType>(old_op->getResults().front().getType()).getShape();
      std::array<int64_t, 4> output_shape;
      // NHWC <- NCHW
      output_shape[0] = composite_result_shape[0];
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed May 29 18:33:05 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. pkg/kubelet/pod/testing/mock_manager.go

    	return m.recorder
    }
    
    // AddPod mocks base method.
    func (m *MockManager) AddPod(pod *v1.Pod) {
    	m.ctrl.T.Helper()
    	m.ctrl.Call(m, "AddPod", pod)
    }
    
    // AddPod indicates an expected call of AddPod.
    func (mr *MockManagerMockRecorder) AddPod(pod any) *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "AddPod", reflect.TypeOf((*MockManager)(nil).AddPod), pod)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. pilot/pkg/controllers/untaint/nodeuntainter_test.go

    		})
    		s.nc.Create(node)
    	}
    }
    
    func (s *nodeTainterTestServer) addCniPod(t *testing.T, node string, markReady bool) {
    	s.addPod(t, node, markReady, cniPodLabels, systemNS)
    }
    
    func (s *nodeTainterTestServer) addPod(t *testing.T, node string, markReady bool, labels map[string]string, ns string) {
    	t.Helper()
    	ip := "1.2.3.4"
    	name := "istio-cni-" + node
    	if ns == "" {
    		ns = systemNS
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 00:50:31 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. src/math/big/floatmarsh.go

    		return errors.New("Float.GobDecode: buffer too small")
    	}
    
    	if buf[0] != floatGobVersion {
    		return fmt.Errorf("Float.GobDecode: encoding version %d not supported", buf[0])
    	}
    
    	oldPrec := z.prec
    	oldMode := z.mode
    
    	b := buf[1]
    	z.mode = RoundingMode((b >> 5) & 7)
    	z.acc = Accuracy((b>>3)&3) - 1
    	z.form = form((b >> 1) & 3)
    	z.neg = b&1 != 0
    	z.prec = byteorder.BeUint32(buf[2:])
    
    	if z.form == finite {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 21:31:58 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. tensorflow/compiler/mlir/lite/stablehlo/transforms/composite_utils.h

    // returns the return type of the tfl.average_pool_2d emitted. Note that the
    // aten.avg_pool2d works with the NCHW layout while tfl.average_pool_2d assumes
    // NHWC.
    ShapedType GetNhwcReturnTypeFromNchw(Operation* old_op);
    
    }  // namespace odml
    
    }  // namespace mlir
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed May 29 18:33:05 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  9. pkg/controller/volume/attachdetach/metrics/metrics_test.go

    	volumeName := v1.UniqueVolumeName("volume-name")
    	volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName)
    	nodeName := k8stypes.NodeName("node-name")
    
    	dsw.AddNode(nodeName)
    	_, err := dsw.AddPod(types.UniquePodName(podName), controllervolumetesting.NewPod(podName, podName), volumeSpec, nodeName)
    	if err != nil {
    		t.Fatalf("Expected no error, got %v", err)
    	}
    	logger, _ := ktesting.NewTestContext(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top