Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getNodes (0.15 sec)

  1. pkg/kubelet/kubelet_pods.go

    // those pods during admission may still be in use. See
    // https://github.com/kubernetes/kubernetes/issues/104824
    func (kl *Kubelet) GetActivePods() []*v1.Pod {
    	allPods := kl.podManager.GetPods()
    	activePods := kl.filterOutInactivePods(allPods)
    	return activePods
    }
    
    // makeBlockVolumes maps the raw block devices specified in the path of the container
    // Experimental
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    			t.Errorf("unexpected error: %v", err)
    		}
    		if err := nodeController.monitorNodeHealth(ctx); err != nil {
    			t.Errorf("unexpected error: %v", err)
    		}
    		zones := testutil.GetZones(item.fakeNodeHandler)
    		logger, _ := ktesting.NewTestContext(t)
    		for _, zone := range zones {
    			nodeController.zoneNoExecuteTainter[zone].Try(logger, func(value scheduler.TimedValue) (bool, time.Duration) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_node_status_test.go

    			defer testKubelet.Cleanup()
    			kubelet := testKubelet.kubelet
    			// Ensure we capture actions on the heartbeat client only.
    			// We don't set it to nil or GetNode() doesn't read from nodeLister.
    			kubelet.kubeClient = &fake.Clientset{}
    			kubeClient := testKubelet.fakeKubeClient
    
    			node := &v1.Node{
    				ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  4. tensorflow/compiler/mlir/tensorflow/ir/tf_ops_n_z.cc

        new_result_types.push_back(valid_output_type);
    
        auto nmsv4 = CreateTfOp<TF::NonMaxSuppressionV4Op>(
            rewriter, nms_op, new_result_types, nms_op.getBoxes(),
            nms_op.getScores(), nms_op.getMaxOutputSize(), nms_op.getIouThreshold(),
            nms_op.getScoreThreshold());
        // Cannot replace the NMSv3 Op with NMSv4 since the outputs between the
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 09 22:07:10 UTC 2024
    - 170.8K bytes
    - Viewed (0)
  5. pkg/config/validation/validation.go

    		return errs.Unwrap()
    	})
    
    func validateSidecarOutboundTrafficPolicy(tp *networking.OutboundTrafficPolicy) (errs error) {
    	if tp == nil {
    		return
    	}
    	mode := tp.GetMode()
    	if tp.EgressProxy != nil {
    		if mode != networking.OutboundTrafficPolicy_ALLOW_ANY {
    			errs = appendErrors(errs, fmt.Errorf("sidecar: egress_proxy must be set only with ALLOW_ANY outbound_traffic_policy mode"))
    			return
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
  6. tensorflow/compiler/mlir/lite/flatbuffer_export.cc

        return translator->TranslateInternal();
      }
      return ret;
    }
    
    bool Translator::CheckGpuDelegateCompatibility(uint8_t* model_buffer_pointer) {
      bool gpu_compatibile = true;
      auto model = tflite::GetModel(model_buffer_pointer);
      auto subgraphs = model->subgraphs();
    
      for (int i = 0; i < subgraphs->Length(); ++i) {
        const tflite::SubGraph* subgraph = subgraphs->Get(i);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Jun 12 21:41:49 UTC 2024
    - 164.5K bytes
    - Viewed (0)
Back to top