github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-30 06:54:01 +00:00
Code Issues Projects Releases Wiki Activity

More intuitive TopologyHints - socketmask.go

Browse Source
This commit is contained in:
nolancon 2019-05-08 04:22:39 +01:00
parent ce56956409
commit 7c525ffaa8
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/kubelet/cm/topologymanager/socketmask/socketmask.go
View File

@ -33,18 +33,13 @@ func NewSocketMask(Mask []int64) SocketMask {
}
// GetSocketMask calculates the socket mask.
func (sm SocketMask) GetSocketMask(socketMask []SocketMask, maskHolder []string, count int) (SocketMask, []string) {
var socketAffinityInt64 [][]int64
for r := range socketMask {
socketAffinityVals := []int64(socketMask[r])
socketAffinityInt64 = append(socketAffinityInt64, socketAffinityVals)
}
func (sm SocketMask) GetSocketMask(socketMaskInt64 [][]int64, maskHolder []string, count int) (SocketMask, []string) {
if count == 0 {
maskHolder = buildMaskHolder(socketAffinityInt64)
maskHolder = buildMaskHolder(socketMaskInt64)
}
klog.V(4).Infof("[socketmask] MaskHolder : %v", maskHolder)
klog.V(4).Infof("[socketmask] %v is passed into arrange function", socketMask)
arrangedMask := arrangeMask(socketAffinityInt64)
arrangedMask := arrangeMask(socketMaskInt64)
newMask := getTopologyAffinity(arrangedMask, maskHolder)
klog.V(4).Infof("[socketmask] New Mask after getTopologyAffinity (new mask) : %v ", newMask)
finalMaskValue := parseMask(newMask)