Fixed root not passing itself

iotaledger · Feb 2, 2023 · 807f642 · 807f642
1 parent 5238c17
commit 807f642
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/core/workerpool/group.go b/core/workerpool/group.go
@@ -6,6 +6,7 @@ import (
 	"strings"
 	"sync"
 
+	"github.com/iotaledger/hive.go/core/generics/lo"
 	"github.com/iotaledger/hive.go/core/generics/orderedmap"
 	"github.com/iotaledger/hive.go/core/syncutils"
 )
@@ -100,7 +101,7 @@ func (g *Group) Pools() (pools map[string]*UnboundedWorkerPool) {
 }
 
 func (g *Group) CreateGroup(name string) (group *Group) {
-	group = newGroupWithRoot(name, g.root)
+	group = newGroupWithRoot(name, lo.Cond(g.root != nil, g.root, g))
 	group.PendingChildrenCounter.Subscribe(func(oldValue, newValue int) {
 		if oldValue == 0 {
 			g.PendingChildrenCounter.Increase()

diff --git a/core/workerpool/group_test.go b/core/workerpool/group_test.go
@@ -7,7 +7,7 @@ import (
 )
 
 func Test(t *testing.T) {
-	group := NewGroup("protocol")
+	group := NewGroup(t.Name())
 	_ = group.CreatePool("poolA")
 
 	subgroup1 := group.CreateGroup("sub1")