diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index aa1c571e74a..2983cdd0e32 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -901,7 +901,7 @@ type Kubelet struct { iptClient utilipt.Interface rootDirectory string - lastObservedNodeAddressesMux sync.Mutex + lastObservedNodeAddressesMux sync.RWMutex lastObservedNodeAddresses []v1.NodeAddress // onRepeatedHeartbeatFailure is called when a heartbeat operation fails more than once. optional. diff --git a/pkg/kubelet/kubelet_node_status.go b/pkg/kubelet/kubelet_node_status.go index cb13ec735fe..c1d1d499e2b 100644 --- a/pkg/kubelet/kubelet_node_status.go +++ b/pkg/kubelet/kubelet_node_status.go @@ -510,8 +510,8 @@ func (kl *Kubelet) setLastObservedNodeAddresses(addresses []v1.NodeAddress) { kl.lastObservedNodeAddresses = addresses } func (kl *Kubelet) getLastObservedNodeAddresses() []v1.NodeAddress { - kl.lastObservedNodeAddressesMux.Lock() - defer kl.lastObservedNodeAddressesMux.Unlock() + kl.lastObservedNodeAddressesMux.RLock() + defer kl.lastObservedNodeAddressesMux.RUnlock() return kl.lastObservedNodeAddresses }