- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for NewBitMask (0.18 sec)
-
pkg/kubelet/cm/topologymanager/bitmask/bitmask_test.go
firstMask: []int{0, 1}, secondMask: []int{0, 1}, expectedEqual: true, }, } for _, tc := range tcases { firstMask, _ := NewBitMask(tc.firstMask...) secondMask, _ := NewBitMask(tc.secondMask...) isEqual := firstMask.IsEqual(secondMask) if isEqual != tc.expectedEqual { t.Errorf("Expected mask to be %v, got %v", tc.expectedEqual, isEqual) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 09:45:09 UTC 2022 - 16.2K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology_hints_test.go
cpuSetAcrossSocket, _ := cpuset.Parse("0-28,40-57") m0001, _ := bitmask.NewBitMask(0) m0011, _ := bitmask.NewBitMask(0, 1) m0101, _ := bitmask.NewBitMask(0, 2) m1001, _ := bitmask.NewBitMask(0, 3) m0111, _ := bitmask.NewBitMask(0, 1, 2) m1011, _ := bitmask.NewBitMask(0, 1, 3) m1101, _ := bitmask.NewBitMask(0, 2, 3) m1111, _ := bitmask.NewBitMask(0, 1, 2, 3) testCases := []struct { description string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 19K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/bitmask/bitmask.go
Count() int GetBits() []int } type bitMask uint64 // NewEmptyBitMask creates a new, empty BitMask func NewEmptyBitMask() BitMask { s := bitMask(0) return &s } // NewBitMask creates a new BitMask func NewBitMask(bits ...int) (BitMask, error) { s := bitMask(0) err := (&s).Add(bits...) if err != nil { return nil, err } return &s, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 09:45:09 UTC 2022 - 5.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/numa_info.go
if m1Distance < m2Distance { return m1 } return m2 } func (n NUMAInfo) DefaultAffinityMask() bitmask.BitMask { defaultAffinity, _ := bitmask.NewBitMask(n.Nodes...) return defaultAffinity } func (d NUMADistances) CalculateAverageFor(bm bitmask.BitMask) float64 { // This should never happen, but just in case make sure we do not divide by zero. if bm.Count() == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:14 UTC 2022 - 2.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static_test.go
expErr: nil, expCPUAlloc: true, expCSet: cpuset.New(1, 2, 3, 4, 5, 7, 8, 9, 10, 11), }, } newNUMAAffinity := func(bits ...int) bitmask.BitMask { affinity, _ := bitmask.NewBitMask(bits...) return affinity } alignBySocketOptionTestCases := []staticPolicyTest{ { description: "Align by socket: true, cpu's within same socket of numa in hint are part of allocation",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
return false } func isNUMAAffinitiesEqual(numaAffinity1, numaAffinity2 []int) bool { bitMask1, err := bitmask.NewBitMask(numaAffinity1...) if err != nil { klog.ErrorS(err, "failed to create bit mask", "numaAffinity1", numaAffinity1) return false } bitMask2, err := bitmask.NewBitMask(numaAffinity2...) if err != nil { klog.ErrorS(err, "failed to create bit mask", "numaAffinity2", numaAffinity2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/numa_info_test.go
{ name: "0 NUMA node, 0 set in bitmask", bm: []int{}, distance: NUMADistances{}, expectedAvg: 0, }, } for _, tcase := range tcases { bm, err := bitmask.NewBitMask(tcase.bm...) if err != nil { t.Errorf("no error expected got %v", err) } numaInfo := NUMAInfo{ Nodes: tcase.bm, NUMADistances: tcase.distance, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:14 UTC 2022 - 11.6K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/topology_manager_test.go
"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask" "k8s.io/kubernetes/pkg/kubelet/lifecycle" ) func NewTestBitMask(sockets ...int) bitmask.BitMask { s, _ := bitmask.NewBitMask(sockets...) return s } func TestNewManager(t *testing.T) { tcases := []struct { description string policyName string expectedPolicy string expectedError error topologyError error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 13:04:32 UTC 2023 - 13.8K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints_test.go
return pluginapi.Device{ ID: id, Topology: &pluginapi.TopologyInfo{Nodes: []*pluginapi.NUMANode{{ID: int64(numa)}}}, } } func makeSocketMask(sockets ...int) bitmask.BitMask { mask, _ := bitmask.NewBitMask(sockets...) return mask } func TestGetTopologyHints(t *testing.T) { tcases := getCommonTestCases() for _, tc := range tcases { m := ManagerImpl{ allDevices: NewResourceDeviceInstances(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 47.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
Nodes: []*pluginapi.NUMANode{ { ID: 2, }, }, }, }, "devwithouttopology": { ID: "dev5", }, }, } fakeAffinity, _ := bitmask.NewBitMask(2) fakeHint := topologymanager.TopologyHint{ NUMANodeAffinity: fakeAffinity, Preferred: true, } testManager := ManagerImpl{ topologyAffinityStore: topologymanager.NewFakeManagerWithHint(&fakeHint),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0)