Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for nodeX (0.12 sec)

  1. tensorflow/compiler/jit/encapsulate_subgraphs_pass_test.cc

    std::vector<string> GraphNodes(const Graph& graph) {
      std::vector<string> nodes;
      for (const auto& node : graph.nodes()) {
        if (!node->IsSource() && !node->IsSink()) {
          nodes.push_back(node->name());
        }
      }
      std::sort(nodes.begin(), nodes.end());
      return nodes;
    }
    
    // Returns a sorted vector of (src, dst) edges in 'graph'.
    std::vector<std::pair<string, string>> GraphEdges(const Graph& graph) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 113.3K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_node_status_test.go

    			nodeLister := testNodeLister{[]*v1.Node{node.DeepCopy()}}
    			kubelet.nodeLister = nodeLister
    
    			callCount := 0
    			// The original node status functions turn the node ready.
    			nodeStatusFuncs := kubelet.setNodeStatusFuncs
    			kubelet.setNodeStatusFuncs = []func(context.Context, *v1.Node) error{func(ctx context.Context, node *v1.Node) error {
    				assert.False(t, kubelet.containerRuntimeReadyExpected)
    				callCount++
    				var lastErr error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier_test.go

    	assert.NotNil(t, fp.ipsetList["KUBE-HEALTH-CHECK-NODE-PORT"])
    	activeEntries1 := fp.ipsetList["KUBE-HEALTH-CHECK-NODE-PORT"].activeEntries
    	assert.Equal(t, 1, activeEntries1.Len(), "Expected 1 active entry in KUBE-HEALTH-CHECK-NODE-PORT")
    	assert.Equal(t, true, activeEntries1.Has("30000"), "Expected activeEntries to reference hc node port in spec")
    
    	// Update health check node port in the spec
    	newSvc := svc
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_generator.go

    		}
    
    		// Fetch current node object
    		node, fetchErr := og.kubeClient.CoreV1().Nodes().Get(context.TODO(), string(nodeName), metav1.GetOptions{})
    		if fetchErr != nil {
    			// On failure, return error. Caller will log and retry.
    			eventErr, detailedErr := volumeToMount.GenerateError("VerifyControllerAttachedVolume failed fetching node from API server", fetchErr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods.go

    				if utilnet.IPFamilyOfString(s.HostIP) != utilnet.IPFamilyOf(hostIPs[0]) {
    					kl.recorder.Eventf(pod, v1.EventTypeWarning, "HostIPsIPFamilyMismatch",
    						"Kubelet detected an IPv%s node IP (%s), but the cloud provider selected an IPv%s node IP (%s); pass an explicit `--node-ip` to kubelet to fix this.",
    						utilnet.IPFamilyOfString(s.HostIP), s.HostIP, utilnet.IPFamilyOf(hostIPs[0]), hostIPs[0].String())
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  6. src/cmd/vendor/github.com/ianlancetaylor/demangle/ast.go

    	precSpaceship
    	precRel
    	precEqual
    	precAnd
    	precXor
    	precOr
    	precLogicalAnd
    	precLogicalOr
    	precCond
    	precAssign
    	precComma
    	precDefault
    )
    
    // hasPrec matches the AST nodes that have a prec method that returns
    // the node's precedence.
    type hasPrec interface {
    	prec() precedence
    }
    
    // Name is an unqualified name.
    type Name struct {
    	Name string
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 105.8K bytes
    - Viewed (0)
  7. cmd/site-replication.go

    		if err != nil {
    			return wrapSRErr(err)
    		}
    		return nil
    	}
    
    	return nil
    }
    
    // PeerBucketMetadataUpdateHandler - merges the bucket metadata, save and ping other nodes
    func (c *SiteReplicationSys) PeerBucketMetadataUpdateHandler(ctx context.Context, item madmin.SRBucketMeta) error {
    	objectAPI := newObjectLayerFn()
    	if objectAPI == nil {
    		return errSRObjectLayerNotReady
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 184.3K bytes
    - Viewed (0)
Back to top