From e25ccb017a78929e5e03907923640db30f17a607 Mon Sep 17 00:00:00 2001 From: yanghaichao12 Date: Fri, 12 Apr 2019 01:27:57 -0400 Subject: [PATCH] make consistent receiver name --- pkg/proxy/service.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/proxy/service.go b/pkg/proxy/service.go index 2d5bd352f53..eab394a9258 100644 --- a/pkg/proxy/service.go +++ b/pkg/proxy/service.go @@ -284,15 +284,15 @@ func (sct *ServiceChangeTracker) serviceToServiceMap(service *v1.Service) Servic // apply the changes to ServiceMap and update the stale udp cluster IP set. The UDPStaleClusterIP argument is passed in to store the // udp protocol service cluster ip when service is deleted from the ServiceMap. -func (serviceMap *ServiceMap) apply(changes *ServiceChangeTracker, UDPStaleClusterIP sets.String) { +func (sm *ServiceMap) apply(changes *ServiceChangeTracker, UDPStaleClusterIP sets.String) { changes.lock.Lock() defer changes.lock.Unlock() for _, change := range changes.items { - serviceMap.merge(change.current) + sm.merge(change.current) // filter out the Update event of current changes from previous changes before calling unmerge() so that can // skip deleting the Update events. change.previous.filter(change.current) - serviceMap.unmerge(change.previous, UDPStaleClusterIP) + sm.unmerge(change.previous, UDPStaleClusterIP) } // clear changes after applying them to ServiceMap. changes.items = make(map[types.NamespacedName]*serviceChange)