Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for numaNodes (0.19 sec)

  1. cluster/gce/config-common.sh

    # limitations under the License.
    
    # Returns the total number of Linux and Windows nodes in the cluster.
    #
    # Vars assumed:
    #   NUM_NODES
    #   NUM_WINDOWS_NODES
    function get-num-nodes {
      echo "$((NUM_NODES + NUM_WINDOWS_NODES))"
    }
    
    # Vars assumed:
    #   NUM_NODES
    #   NUM_WINDOWS_NODES
    function get-master-size {
      local suggested_master_size=2
      if [[ "$(get-num-nodes)" -gt "10" ]]; then
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 20:06:08 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. tensorflow/cc/client/client_session.cc

                 nullptr);
    }
    
    Status ClientSession::Impl::MaybeExtendGraph() const {
      mutex_lock l(mu_);
      int num_nodes = graph_->num_node_ids();
      if (num_nodes > last_num_graph_nodes_) {
        GraphDef graph_def;
        graph_->ToGraphDefSubRange(&graph_def, last_num_graph_nodes_);
        last_num_graph_nodes_ = num_nodes;
        return session_->Extend(graph_def);
      }
      return absl::OkStatus();
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Feb 28 09:04:10 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/monitor.go

    // NewMonitor returns a monitor with defaults.
    func NewMonitor(ctx context.Context, numNodes uint64) *Monitor {
    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    		bucketsThrottle:       make(map[BucketOptions]*bucketThrottle),
    		bucketMovingAvgTicker: time.NewTicker(2 * time.Second),
    		ctx:                   ctx,
    		NodeCount:             numNodes,
    	}
    	go m.trackEWMA()
    	return m
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. hack/ginkgo-e2e.sh

      --prepull-images="${PREPULL_IMAGES:-false}" \
      ${MASTER_OS_DISTRIBUTION:+"--master-os-distro=${MASTER_OS_DISTRIBUTION}"} \
      ${NODE_OS_DISTRIBUTION:+"--node-os-distro=${NODE_OS_DISTRIBUTION}"} \
      ${NUM_NODES:+"--num-nodes=${NUM_NODES}"} \
      ${E2E_REPORT_DIR:+"--report-dir=${E2E_REPORT_DIR}"} \
      ${E2E_REPORT_PREFIX:+"--report-prefix=${E2E_REPORT_PREFIX}"} \
      "${suite_args[@]:+${suite_args[@]}}" \
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 13:25:50 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/imagelocality/image_locality.go

    // a few nodes due to image locality.
    func scaledImageScore(imageState *framework.ImageStateSummary, totalNumNodes int) int64 {
    	spread := float64(imageState.NumNodes) / float64(totalNumNodes)
    	return int64(float64(imageState.Size) * spread)
    }
    
    // normalizedImageName returns the CRI compliant name for a given image.
    // TODO: cover the corner cases of missed matches, e.g,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 06:17:57 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/container_manager.go

    				respDevs = append(respDevs, &podresourcesapi.ContainerDevices{
    					ResourceName: resourceName,
    					DeviceIds:    []string{devID},
    					Topology: &podresourcesapi.TopologyInfo{
    						Nodes: []*podresourcesapi.NUMANode{
    							{
    								ID: node.GetID(),
    							},
    						},
    					},
    				})
    			}
    		}
    	}
    
    	return respDevs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top