Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for NewBitMask (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top