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

Signed-off-by: Krisztian Litkey <krisztian.litkey@intel.com>

diff --git a/internal/cri/nri/nri_api_linux.go b/internal/cri/nri/nri_api_linux.go
index 63432f2a7689ea69e79b74b5d45b5fafdcf24b9f..5ce42dffbb867231b47f8714957b87e9eea411b5 100644 (file)
--- 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
index c7b0117e35d94fefd176797c42626ae3519a7bca..e1cced6a12516483a42e06e2d4e33b2407752ba3 100644 (file)
--- 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
index 59b9e025f249d3627531fefd0185a511fa3978f6..a6b62f7370d8e522c1dcd4066aac2d98235ff214 100644 (file)
--- 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
 }