github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-19 08:40:42 +00:00
Code Issues Projects Releases Wiki Activity

Make cpuManagerCheckpoint exported

Browse Source
This commit is contained in:
Klaudiusz Dembler 2018-02-09 10:37:18 +01:00 committed by Klaudiusz Dembler
parent cc3fa67bda
commit 0b1a73e94b
No known key found for this signature in database
GPG Key ID: 14B9FB649EE34C35
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/kubelet/cm/cpumanager/state/checkpoint.go
View File

@ -25,10 +25,10 @@ import (
hashutil "k8s.io/kubernetes/pkg/util/hash" hashutil "k8s.io/kubernetes/pkg/util/hash"
) )
var _ checkpointmanager.Checkpoint = &cpuManagerCheckpoint{} var _ checkpointmanager.Checkpoint = &CPUManagerCheckpoint{}
// cpuManagerCheckpoint struct is used to store cpu/pod assignments in a checkpoint // CPUManagerCheckpoint struct is used to store cpu/pod assignments in a checkpoint
type cpuManagerCheckpoint struct { type CPUManagerCheckpoint struct {
PolicyName string PolicyName string
DefaultCPUSet string DefaultCPUSet string
Entries map[string]string Entries map[string]string
@ -36,17 +36,17 @@ type cpuManagerCheckpoint struct {
} }
// NewCPUManagerCheckpoint returns an instance of Checkpoint // NewCPUManagerCheckpoint returns an instance of Checkpoint
func NewCPUManagerCheckpoint() *cpuManagerCheckpoint { func NewCPUManagerCheckpoint() *CPUManagerCheckpoint {
return &cpuManagerCheckpoint{Entries: make(map[string]string)} return &CPUManagerCheckpoint{Entries: make(map[string]string)}
} }
// MarshalCheckpoint returns marshalled checkpoint // MarshalCheckpoint returns marshalled checkpoint
func (cp *cpuManagerCheckpoint) MarshalCheckpoint() ([]byte, error) { func (cp *CPUManagerCheckpoint) MarshalCheckpoint() ([]byte, error) {
return json.Marshal(*cp) return json.Marshal(*cp)
} }
// UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint // UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint
func (cp *cpuManagerCheckpoint) UnmarshalCheckpoint(blob []byte) error { func (cp *CPUManagerCheckpoint) UnmarshalCheckpoint(blob []byte) error {
if err := json.Unmarshal(blob, cp); err != nil { if err := json.Unmarshal(blob, cp); err != nil {
return err return err
} }
@ -57,7 +57,7 @@ func (cp *cpuManagerCheckpoint) UnmarshalCheckpoint(blob []byte) error {
} }
// GetChecksum returns calculated checksum of checkpoint // GetChecksum returns calculated checksum of checkpoint
func (cp *cpuManagerCheckpoint) GetChecksum() uint64 { func (cp *CPUManagerCheckpoint) GetChecksum() uint64 {
orig := cp.Checksum orig := cp.Checksum
cp.Checksum = 0 cp.Checksum = 0
hash := fnv.New32a() hash := fnv.New32a()
@ -67,6 +67,6 @@ func (cp *cpuManagerCheckpoint) GetChecksum() uint64 {
} }
// UpdateChecksum calculates and updates checksum of the checkpoint // UpdateChecksum calculates and updates checksum of the checkpoint
func (cp *cpuManagerCheckpoint) UpdateChecksum() { func (cp *CPUManagerCheckpoint) UpdateChecksum() {
cp.Checksum = cp.GetChecksum() cp.Checksum = cp.GetChecksum()
} }