- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for numa_node (0.16 sec)
-
tensorflow/c/experimental/stream_executor/stream_executor.cc
if (device_.pci_bus_id != nullptr) { builder.set_pci_bus_id(device_.pci_bus_id); } if (device_fns_->get_numa_node != nullptr) { int32_t numa_node = device_fns_->get_numa_node(&device_); if (numa_node >= 0) { builder.set_numa_node(numa_node); } } if (device_fns_->get_memory_bandwidth != nullptr) { int64_t memory_bandwidth = device_fns_->get_memory_bandwidth(&device_);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_test.cc
ASSERT_EQ(description.name(), "TestName"); ASSERT_EQ(description.device_vendor(), "TestVendor"); ASSERT_EQ(description.pci_bus_id(), "TestPCIBusId"); ASSERT_EQ(description.numa_node(), 123); ASSERT_EQ(description.memory_bandwidth(), 54); } TEST_F(StreamExecutorTest, DeviceDescriptionNumaNodeNotSet) { static const char* hardware_name = "TestName";
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 19:54:04 UTC 2024 - 26.5K bytes - Viewed (0) -
tensorflow/c/kernels_experimental.cc
// DT_VARIANT tensors must be allocated on CPU since they wrap C++ // objects which can not be efficiently represented in GPU memory. int numa_node = cc_ctx->device()->NumaNode(); Tensor out(::tensorflow::cpu_allocator(numa_node), ::tensorflow::DT_VARIANT, ::tensorflow::TensorShape({})); Variant* out_v = &(out.scalar<Variant>()());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 23 06:12:29 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/kubelet/cm/internal_container_lifecycle_linux.go
containerConfig.Linux.Resources.CpusetCpus = allocatedCPUs.String() } } if i.memoryManager != nil { numaNodes := i.memoryManager.GetMemoryNUMANodes(pod, container) if numaNodes.Len() > 0 { var affinity []string for _, numaNode := range sets.List(numaNodes) { affinity = append(affinity, strconv.Itoa(numaNode)) } containerConfig.Linux.Resources.CpusetMems = strings.Join(affinity, ",") } } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology/topology.go
} } return result } // NUMANodes returns all of the NUMANode IDs associated with the CPUs in this // CPUDetails. func (d CPUDetails) NUMANodes() cpuset.CPUSet { var numaNodeIDs []int for _, info := range d { numaNodeIDs = append(numaNodeIDs, info.NUMANodeID) } return cpuset.New(numaNodeIDs...) } // NUMANodesInSockets returns all of the logical NUMANode IDs associated with
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager.go
numaNodes := map[int]bool{} for _, numaNode := range machineInfo.Topology { numaNodes[numaNode.Id] = true } for _, reservation := range reservedMemory { if !numaNodes[int(reservation.NumaNode)] { return nil, fmt.Errorf("the reserved memory configuration references a NUMA node %d that does not exist on this machine", reservation.NumaNode) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/devicemanager/topology_hints.go
// Initialize minAffinitySize to include all NUMA Nodes minAffinitySize := len(m.numaNodes) // Iterate through all combinations of NUMA Nodes and build hints from them. hints := []topologymanager.TopologyHint{} bitmask.IterateBitMasks(m.numaNodes, func(mask bitmask.BitMask) { // First, update minAffinitySize for the current request size. devicesInMask := 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology/topology_test.go
2: {NUMANodeID: 1}, 3: {NUMANodeID: 2}, } tests := []struct { name string ids []int want cpuset.CPUSet }{{ name: "NUMANode IDs is in CPUDetails.", ids: []int{0, 1}, want: cpuset.New(0, 1, 2), }, { name: "NUMANode IDs is not in CPUDetails.", ids: []int{3}, want: cpuset.New(), }} for _, tt := range tests { t.Run(tt.name, func(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 31.7K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1_test.go
Topology: &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}}, }, } cpus := []int64{12, 23, 30} memory := []*podresourcesapi.ContainerMemory{ { MemoryType: "memory", Size_: 1073741824, Topology: &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}}, }, { MemoryType: "hugepages-1Gi", Size_: 1073741824,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
if numaid != nodeWithoutTopology { NUMANodes := []*pluginapi.NUMANode{{ID: numaid}} if pDev, ok := devicePluginMap[devID]; ok && pDev.Topology != nil { if nodes := pDev.Topology.GetNodes(); nodes != nil { NUMANodes = append(NUMANodes, nodes...) } } // ID and Healthy are not relevant here. topology = &pluginapi.TopologyInfo{Nodes: NUMANodes} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0)