Keep site record controller channel opened on podman (#1315)

skupperproject · Dec 14, 2023 · 8c6376f · 8c6376f
1 parent c841924
commit 8c6376f
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 4 deletions.
diff --git a/pkg/flow/controller.go b/pkg/flow/controller.go
@@ -265,7 +265,6 @@ func (c *siteRecordController) Start(stopCh <-chan struct{}) <-chan *SiteRecord
 	updates := make(chan *SiteRecord, 1)
 
 	go func() {
-		defer close(updates)
 		updates <- c.Record()
 
 		if c.Platform != string(types.PlatformKubernetes) {

diff --git a/pkg/flow/controller_test.go b/pkg/flow/controller_test.go
@@ -178,9 +178,6 @@ func TestSiteController(t *testing.T) {
 					assert.Equal(t, rec.StartTime, uint64(1_111_111))
 					assert.Equal(t, *rec.Policy, Disabled)
 				},
-				func(t *testing.T, rec *SiteRecord, ok bool) {
-					assert.Equal(t, ok, false) // expect closed
-				},
 			},
 			waitTimeout: time.Millisecond * 500,
 		},