Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 91 for updateStats (0.83 sec)

  1. tensorflow/cc/framework/scope.h

      /// Note: The status object is shared between all children of this scope.
      /// If the resulting status is not OkStatus() and exit_on_error_ is set on
      /// this scope, this function exits by calling LOG(FATAL).
      void UpdateStatus(const Status& s) const;
    
      // START_SKIP_DOXYGEN
    
      /// Update the builder with properties accumulated in this scope. Does not set
      /// status().
      // TODO(skyewm): NodeBuilder is not part of public API
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Sat Apr 13 09:08:33 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_test.go

    	time.Sleep(1200 * time.Millisecond)
    
    	_, _ = client.CoreV1().Nodes().UpdateStatus(context.TODO(),
    		makeNodeWithAddress("node1", "192.168.0.1"),
    		metav1.UpdateOptions{},
    	)
    	_, _ = client.CoreV1().Nodes().UpdateStatus(context.TODO(),
    		makeNodeWithAddress("node2", "192.168.0.2"),
    		metav1.UpdateOptions{},
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

    	apiextensionshelpers.SetCRDCondition(crd, namingCondition)
    	apiextensionshelpers.SetCRDCondition(crd, establishedCondition)
    
    	updatedObj, err := c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
    	if apierrors.IsNotFound(err) || apierrors.IsConflict(err) {
    		// deleted or changed in the meantime, we'll get called again
    		return nil
    	}
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/reconciler/reconstruct_common.go

    		outerVolumeSpecName: volume.volumeSpecName,
    		pod:                 pod,
    		deviceMounter:       deviceMounter,
    		volumeGidValue:      "",
    		// devicePath is updated during updateStates() by checking node status's VolumesAttached data.
    		// TODO: get device path directly from the volume mount path.
    		devicePath:          "",
    		mounter:             volumeMounter,
    		blockVolumeMapper:   volumeMapper,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  5. tensorflow/cc/gradients/array_grad.cc

              .Input(::tensorflow::ops::AsNodeOutList(scope, shapes.output));
      scope.UpdateBuilder(&builder);
      ::tensorflow::Node* concat_offset_node;
      scope.UpdateStatus(builder.Finalize(scope.graph(), &concat_offset_node));
      scope.UpdateStatus(scope.DoShapeInference(concat_offset_node));
      if (concat_offset_node->num_outputs() != inputs.size()) {
        return errors::Internal("ConcatOffset has invalid output count");
      }
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Oct 10 23:33:32 UTC 2023
    - 31.7K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/pod.go

    func (pc *PodCache) onEvent(_, pod *v1.Pod, ev model.Event) error {
    	ip := pod.Status.PodIP
    	// PodIP will be empty when pod is just created, but before the IP is assigned
    	// via UpdateStatus.
    	if len(ip) == 0 {
    		return nil
    	}
    
    	key := config.NamespacedName(pod)
    	switch ev {
    	case model.EventAdd:
    		if shouldPodBeInEndpoints(pod) && IsPodReady(pod) {
    			pc.addPod(pod, ip, key)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  7. pilot/pkg/config/kube/ingress/controller.go

    	return "", errUnsupportedOp
    }
    
    func (c *controller) Update(_ config.Config) (string, error) {
    	return "", errUnsupportedOp
    }
    
    func (c *controller) UpdateStatus(config.Config) (string, error) {
    	return "", errUnsupportedOp
    }
    
    func (c *controller) Patch(_ config.Config, _ config.PatchFunc) (string, error) {
    	return "", errUnsupportedOp
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 03:53:05 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    	node0.Status = newNodeStatus
    	node1.Status = healthyNodeNewStatus
    	_, err = fakeNodeHandler.UpdateStatus(ctx, node0, metav1.UpdateOptions{})
    	if err != nil {
    		t.Errorf(err.Error())
    		return
    	}
    	_, err = fakeNodeHandler.UpdateStatus(ctx, node1, metav1.UpdateOptions{})
    	if err != nil {
    		t.Errorf(err.Error())
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  9. pilot/pkg/config/kube/gateway/controller.go

    	return "", errUnsupportedOp
    }
    
    func (c *Controller) Update(config config.Config) (newRevision string, err error) {
    	return "", errUnsupportedOp
    }
    
    func (c *Controller) UpdateStatus(config config.Config) (newRevision string, err error) {
    	return "", errUnsupportedOp
    }
    
    func (c *Controller) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	return "", errUnsupportedOp
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 05:26:03 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/serviceregistry_test.go

    		setPodUnready(pod)
    		_, err := kube.CoreV1().Pods(pod.Namespace).UpdateStatus(context.TODO(), pod, metav1.UpdateOptions{})
    		if err != nil {
    			t.Fatal(err)
    		}
    		expectServiceEndpoints(t, fx, expectedSvc, 80, []EndpointResponse{})
    
    		setPodReady(pod)
    		_, err = kube.CoreV1().Pods(pod.Namespace).UpdateStatus(context.TODO(), pod, metav1.UpdateOptions{})
    		if err != nil {
    			t.Fatal(err)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
Back to top