fanhuadesenlinnn/kube-vip
1
0
Fork 0
mirror of https://hubproxy.babadafafafafa.cn/https://github.com/kube-vip/kube-vip.git synced 2026-09-20 08:03:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: regression on tests as we moved to context

Browse Source 
Signed-off-by: Marcel Fest <marcel.fest@telekom.de>
This commit is contained in:
Marcel Fest
2026-09-15 17:12:16 +02:00
committed by GitHub
parent b405be8c84
commit e2ef46221c
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/services/services_test.go
View File

@@ -26,7 +26,8 @@ type testDHCPClient struct {
}
func newTestDHCPClient() *testDHCPClient {
return &testDHCPClient{ips: make(chan string, 1), errors: make(chan error)}
// Unbuffered so a send only completes once the watcher has taken the address.
return &testDHCPClient{ips: make(chan string), errors: make(chan error)}
}
func (c *testDHCPClient) ErrorChannel() chan error { return c.errors }
@@ -209,13 +210,15 @@ func TestConfigureServiceWatchesBothDHCPFamilies(t *testing.T) {
}
wg := &sync.WaitGroup{}
if err := processor.configureService(context.Background(), serviceInstance, service, wg); err != nil {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
if err := processor.configureService(ctx, serviceInstance, service, wg); err != nil {
t.Fatalf("configureService() error = %v", err)
}
dhcpv4.ips <- "192.0.2.10"
dhcpv6.ips <- "2001:db8::10"
close(dhcpv4.ips)
close(dhcpv6.ips)
cancel()
wg.Wait()
if got := serviceInstance.DHCPInterfaceIPv4; got != "192.0.2.10" {