Added cgroup type

Add domain threaded and domain invalid cgroup type.

Signed-off-by: yaoyinnan <[email protected]>

cgroup2/manager.go

@@ -32,8 +32,6 @@ import (
 	"github.com/containerd/cgroups/v3/cgroup2/stats"
 
 	systemdDbus "github.com/coreos/go-systemd/v22/dbus"
-	"github.com/godbus/dbus/v5"
-	"github.com/opencontainers/runtime-spec/specs-go"
 	"github.com/sirupsen/logrus"
 	"golang.org/x/sys/unix"
 )
@@ -242,8 +240,10 @@ func setResources(path string, resources *Resources) error {
 type CgroupType string
 
 const (
-	Domain   CgroupType = "domain"
-	Threaded CgroupType = "threaded"
+	Domain         CgroupType = "domain"
+	DomainThreaded CgroupType = "domain threaded"
+	DomainInvalid  CgroupType = "domain invalid"
+	Threaded       CgroupType = "threaded"
 )
 
 func (c *Manager) GetType() (CgroupType, error) {

cgroup2/manager_test.go

@@ -24,7 +24,6 @@ import (
 	"testing"
 	"time"
 
-	"github.com/opencontainers/runtime-spec/specs-go"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 	"go.uber.org/goleak"
@@ -283,20 +282,40 @@ func TestCgroupType(t *testing.T) {
 	checkCgroupMode(t)
 	manager, err := NewManager(defaultCgroup2Path, "/test-type", ToResources(&specs.LinuxResources{}))
 	require.NoError(t, err)
-	t.Cleanup(func() {
-		_ = manager.Delete()
-	})
+	submanager, err := NewManager(defaultCgroup2Path, "/test-type/sub", ToResources(&specs.LinuxResources{}))
+	require.NoError(t, err)
 
+	// Check initial type is domain
 	cgType, err := manager.GetType()
 	require.NoError(t, err)
 	require.Equal(t, cgType, Domain)
 
-	// Swap to threaded
-	require.NoError(t, manager.SetType(Threaded))
+	// Swap sub cgroup to threaded
+	require.NoError(t, submanager.SetType(Threaded))
 
-	cgType, err = manager.GetType()
+	// Check sub cgroup type is threaded
+	cgType, err = submanager.GetType()
 	require.NoError(t, err)
 	require.Equal(t, cgType, Threaded)
+
+	// Check parent cgroup type is domain threaded
+	cgType, err = manager.GetType()
+	require.NoError(t, err)
+	require.Equal(t, cgType, DomainThreaded)
+
+	subsubmanager, err := NewManager(defaultCgroup2Path, "/test-type/sub/sub", ToResources(&specs.LinuxResources{}))
+	require.NoError(t, err)
+
+	// Check sub cgroup type is domain invalid
+	cgType, err = submanager.GetType()
+	require.NoError(t, err)
+	require.Equal(t, cgType, DomainInvalid)
+
+	t.Cleanup(func() {
+		_ = subsubmanager.Delete()
+		_ = submanager.Delete()
+		_ = manager.Delete()
+	})
 }
 
 func TestCgroupv2PSIStats(t *testing.T) {