cri,nri: pass any linux scheduler attributes 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 5ce42dffbb867231b47f8714957b87e9eea411b5..21d4e3893547999a4503ebc98354ea63661ba1be 100644 (file)
--- a/internal/cri/nri/nri_api_linux.go
+++ b/internal/cri/nri/nri_api_linux.go
@@ -875,6 +875,13 @@ func (c *criContainer) GetIOPriority() *api.LinuxIOPriority {
        return api.FromOCILinuxIOPriority(c.spec.Process.IOPriority)
 }
 
+func (c *criContainer) GetScheduler() *api.LinuxScheduler {
+       if c.spec.Process == nil || c.spec.Process.Scheduler == nil {
+               return nil
+       }
+       return api.FromOCILinuxScheduler(c.spec.Process.Scheduler)
+}
+
 func (c *criContainer) GetPid() uint32 {
        return c.pid
 }

diff --git a/internal/nri/container.go b/internal/nri/container.go
index e1cced6a12516483a42e06e2d4e33b2407752ba3..13f82a67ccc38367365946897e48a558113264a2 100644 (file)
--- a/internal/nri/container.go
+++ b/internal/nri/container.go
@@ -46,6 +46,7 @@ type LinuxContainer interface {
        GetOOMScoreAdj() *int
        GetCgroupsPath() string
        GetIOPriority() *nri.LinuxIOPriority
+       GetScheduler() *nri.LinuxScheduler
 }
 
 func commonContainerToNRI(ctr Container) *nri.Container {

diff --git a/internal/nri/container_linux.go b/internal/nri/container_linux.go
index a6b62f7370d8e522c1dcd4066aac2d98235ff214..99333f88a6982d2b888cb029b2917adcfca50d37 100644 (file)
--- a/internal/nri/container_linux.go
+++ b/internal/nri/container_linux.go
@@ -32,6 +32,7 @@ func containerToNRI(ctr Container) *nri.Container {
                OomScoreAdj: nri.Int(lnxCtr.GetOOMScoreAdj()),
                CgroupsPath: lnxCtr.GetCgroupsPath(),
                IoPriority:  lnxCtr.GetIOPriority(),
+               Scheduler:   lnxCtr.GetScheduler(),
        }
        return nriCtr
 }