mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-22 11:21:47 +00:00
Merge pull request #99102 from justinsb/avoid_multiple_calls_to_done
proxy/config tests: avoid multiple calls to done
This commit is contained in:
commit
4ef5d1402d
@ -152,8 +152,9 @@ func newSvcHandler(t *testing.T, svcs []*v1.Service, done func()) ServiceHandler
|
||||
shm := &ServiceHandlerMock{
|
||||
state: make(map[types.NamespacedName]*v1.Service),
|
||||
}
|
||||
var callDoneOnce sync.Once
|
||||
shm.process = func(services []*v1.Service) {
|
||||
defer done()
|
||||
defer callDoneOnce.Do(done)
|
||||
if !reflect.DeepEqual(services, svcs) {
|
||||
t.Errorf("Unexpected services: %#v, expected: %#v", services, svcs)
|
||||
}
|
||||
@ -165,8 +166,9 @@ func newEpsHandler(t *testing.T, eps []*v1.Endpoints, done func()) EndpointsHand
|
||||
ehm := &EndpointsHandlerMock{
|
||||
state: make(map[types.NamespacedName]*v1.Endpoints),
|
||||
}
|
||||
var callDoneOnce sync.Once
|
||||
ehm.process = func(endpoints []*v1.Endpoints) {
|
||||
defer done()
|
||||
defer callDoneOnce.Do(done)
|
||||
if !reflect.DeepEqual(eps, endpoints) {
|
||||
t.Errorf("Unexpected endpoints: %#v, expected: %#v", endpoints, eps)
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user