cri,nri: pass any linux I/O priority to plugins.

klihub · mikebrow · commit e1824d2613d3 · 2025-12-17T15:03:51.000-06:00
Signed-off-by: Krisztian Litkey &lt;krisztian.litkey@intel.com&gt;
diff --git a/internal/cri/nri/nri_api_linux.go b/internal/cri/nri/nri_api_linux.go
@@ -868,6 +868,13 @@ func (c *criContainer) GetCgroupsPath() string {
 	return c.spec.Linux.CgroupsPath
 }
 
+func (c *criContainer) GetIOPriority() *api.LinuxIOPriority {
+	if c.spec.Process == nil {
+		return nil
+	}
+	return api.FromOCILinuxIOPriority(c.spec.Process.IOPriority)
+}
+
 func (c *criContainer) GetPid() uint32 {
 	return c.pid
 }
diff --git a/internal/nri/container.go b/internal/nri/container.go
@@ -45,6 +45,7 @@ type LinuxContainer interface {
 	GetLinuxResources() *nri.LinuxResources
 	GetOOMScoreAdj() *int
 	GetCgroupsPath() string
+	GetIOPriority() *nri.LinuxIOPriority
 }
 
 func commonContainerToNRI(ctr Container) *nri.Container {
diff --git a/internal/nri/container_linux.go b/internal/nri/container_linux.go
@@ -31,6 +31,7 @@ func containerToNRI(ctr Container) *nri.Container {
 		Resources:   lnxCtr.GetLinuxResources(),
 		OomScoreAdj: nri.Int(lnxCtr.GetOOMScoreAdj()),
 		CgroupsPath: lnxCtr.GetCgroupsPath(),
+		IoPriority:  lnxCtr.GetIOPriority(),
 	}
 	return nriCtr
 }

Original file line number	Diff line number	Diff line change
`@@ -868,6 +868,13 @@ func (c *criContainer) GetCgroupsPath() string {`
`868`	`868`	`return c.spec.Linux.CgroupsPath`
`869`	`869`	`}`
`870`	`870`
	`871`	`+func (c criContainer) GetIOPriority() api.LinuxIOPriority {`
	`872`	`+ if c.spec.Process == nil {`
	`873`	`+ return nil`
	`874`	`+ }`
	`875`	`+ return api.FromOCILinuxIOPriority(c.spec.Process.IOPriority)`
	`876`	`+}`
	`877`	`+`
`871`	`878`	`func (c *criContainer) GetPid() uint32 {`
`872`	`879`	`return c.pid`
`873`	`880`	`}`
Original file line number	Diff line number	Diff line change
`@@ -45,6 +45,7 @@ type LinuxContainer interface {`
`45`	`45`	`GetLinuxResources() *nri.LinuxResources`
`46`	`46`	`GetOOMScoreAdj() *int`
`47`	`47`	`GetCgroupsPath() string`
	`48`	`+ GetIOPriority() *nri.LinuxIOPriority`
`48`	`49`	`}`
`49`	`50`
`50`	`51`	`func commonContainerToNRI(ctr Container) *nri.Container {`
Original file line number	Diff line number	Diff line change
`@@ -31,6 +31,7 @@ func containerToNRI(ctr Container) *nri.Container {`
`31`	`31`	`Resources: lnxCtr.GetLinuxResources(),`
`32`	`32`	`OomScoreAdj: nri.Int(lnxCtr.GetOOMScoreAdj()),`
`33`	`33`	`CgroupsPath: lnxCtr.GetCgroupsPath(),`
	`34`	`+ IoPriority: lnxCtr.GetIOPriority(),`
`34`	`35`	`}`
`35`	`36`	`return nriCtr`
`36`	`37`	`}`