From 8c6376f5866ce4e9e3023ba796d634cb7f4d9b34 Mon Sep 17 00:00:00 2001 From: Fernando Giorgetti Date: Thu, 14 Dec 2023 18:59:02 -0300 Subject: [PATCH] Keep site record controller channel opened on podman (#1315) --- pkg/flow/controller.go | 1 - pkg/flow/controller_test.go | 3 --- 2 files changed, 4 deletions(-) diff --git a/pkg/flow/controller.go b/pkg/flow/controller.go index 1d70ffe35..989647b27 100644 --- 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 index 9b3856c8c..90e136f5b 100644 --- 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, },