resctrl

Documentation

Index

• Constants
• Variables
• func Commit(r *ResAssociation, group string) error
• func CommitAll(mRes map[string]*ResAssociation) error
• func DestroyResAssociation(group string) error
• func DisableRdt() bool
• func EnableCat() bool
• func EnableCdp() bool
• func GetRdtCosInfo() map[string]*RdtCosInfo
• func GetResAssociation() map[string]*ResAssociation
• func IsIntelRdtMounted() bool
• func IsNotFound(err error) bool
• func NewNotFoundError(res string) error
• func RemoveTasks(tasks []string) error
• type CPUsTask
  • func (t CPUsTask) Rollback() error
  • func (t CPUsTask) Run() error
• type CacheCos
• type GroupTask
  • func (t GroupTask) Rollback() error
  • func (t GroupTask) Run() error
• type NotFoundError
  • func (e *NotFoundError) Error() string
• type RdtCosInfo
• type ResAssociation
  • func NewResAssociation() *ResAssociation
• type SchemataTask
  • func (t SchemataTask) Rollback() error
  • func (t SchemataTask) Run() error
• type Task
  • func (t Task) Name() string
  • func (t Task) Rollback() error
  • func (t Task) Run() error
• type TasksTask
  • func (t TasksTask) Rollback() error
  • func (t TasksTask) Run() error

Constants

const (
	// SysResctrl is the patch to resctrl
	SysResctrl = "/sys/fs/resctrl"
)

Variables

var (

	// RdtInfo is global immutable variable
	RdtInfo *map[string]*RdtCosInfo
)

Functions

func Commit

func Commit(r *ResAssociation, group string) error

Commit resources in resctrl FIXME Commit should be a transaction. So we use taskFlow to guarantee the consistency. Also we need a coarse granularity lock for IPC. We already has it. Also we need a file lock for consistency among different processes. In plan. After some test on taskFlow, we can remove these logic code and use taskFlow. The taskFlow need a snapshot of all ResAssociation for the transaction. It can be gotten by GetResAssociation.

func CommitAll

func CommitAll(mRes map[string]*ResAssociation) error

CommitAll change all resource group FIXME need to catch error

func DestroyResAssociation

func DestroyResAssociation(group string) error

DestroyResAssociation removes resource group

func DisableRdt

func DisableRdt() bool

DisableRdt unmount resctrl

func EnableCat

func EnableCat() bool

EnableCat mounts resctrl

func EnableCdp

func EnableCdp() bool

EnableCdp mounts resctrl with option -o

func GetRdtCosInfo

func GetRdtCosInfo() map[string]*RdtCosInfo

GetRdtCosInfo gives RDT info access the resctrl need flock to avoid race with other agent. Go does not support flock lib. That need cgo, please ref: https://gist.github.com/ericchiang/ce0fdcac5659d0a80b38 now we can use lib/flock/flock.go

func GetResAssociation

func GetResAssociation() map[string]*ResAssociation

GetResAssociation returns all resource groups access the resctrl need flock to avoid race with other agent. Go does not support flock lib. That need cgo, please ref: https://gist.github.com/ericchiang/ce0fdcac5659d0a80b38 now we can use lib/flock/flock.go

func IsIntelRdtMounted

func IsIntelRdtMounted() bool

IsIntelRdtMounted give true/false of RDT mounted or not

func IsNotFound

func IsNotFound(err error) bool

IsNotFound returns if notfound error happend

func NewNotFoundError

func NewNotFoundError(res string) error

NewNotFoundError returns new error of NotFoundError

func RemoveTasks

func RemoveTasks(tasks []string) error

RemoveTasks move tasks to default resctrl group Resctrl doesn't support remove tasks from sysfs, the way to remove tasks from resource group is to move them to default group

Types

type CPUsTask

type CPUsTask struct {
	Task
}

CPUsTask is the CPU task

func (CPUsTask) Rollback

func (t CPUsTask) Rollback() error

Rollback dos nothing for now

func (CPUsTask) Run

func (t CPUsTask) Run() error

Run to write CPU mask

type CacheCos

type CacheCos struct {
	ID   uint8
	Mask string
}

CacheCos is the COS of a cache

type GroupTask

type GroupTask struct {
	Task
}

GroupTask is task to create new group

func (GroupTask) Rollback

func (t GroupTask) Rollback() error

Rollback remove created resrouce group

func (GroupTask) Run

func (t GroupTask) Run() error

Run to create new resource group

type NotFoundError

type NotFoundError struct {
	ResourceControl string
}

NotFoundError represents not found error

func (*NotFoundError) Error

func (e *NotFoundError) Error() string

type RdtCosInfo

type RdtCosInfo struct {
	CbmMask    string
	MinCbmBits int
	NumClosids int
}

RdtCosInfo is from /sys/fs/resctrl/info

type ResAssociation

type ResAssociation struct {
	Tasks    []string
	CPUs     string
	Schemata map[string][]CacheCos
}

ResAssociation is the resource group in resctrl TODO need to paser the tag for field setting.

func NewResAssociation

func NewResAssociation() *ResAssociation

NewResAssociation gives new empty ResAssociation

type SchemataTask

type SchemataTask struct {
	Task
}

SchemataTask is the task to create schemata

func (SchemataTask) Rollback

func (t SchemataTask) Rollback() error

Rollback to revert it

func (SchemataTask) Run

func (t SchemataTask) Run() error

Run to commit schemata

type Task

type Task struct {
	TaskName string
	*ResAssociation
	RessSnapshot map[string]*ResAssociation
	Group        string
	Path         string
	Revert       bool // whether need to Revert after task faild
}

Task is task for resctrl

func (Task) Name

func (t Task) Name() string

Name returns name of the task

func (Task) Rollback

func (t Task) Rollback() error

Rollback task

func (Task) Run

func (t Task) Run() error

Run starts the task

type TasksTask

type TasksTask struct {
	Task
}

TasksTask is the task for add tasks

func (TasksTask) Rollback

func (t TasksTask) Rollback() error

Rollback tasks

func (TasksTask) Run

func (t TasksTask) Run() error

Run add tasks