in grpc-xds/control-plane-go/pkg/xds/grpc_server_listener_cache.go [34:50]
func (c *GRPCServerListenerCache) Add(nodeHash string, newAddresses []EndpointAddress) bool {
c.mu.Lock()
defer c.mu.Unlock()
addresses, exists := c.cache[nodeHash]
if !exists {
addresses = make(map[EndpointAddress]bool, len(newAddresses))
c.cache[nodeHash] = addresses
}
added := false
for _, address := range newAddresses {
if !addresses[address] {
addresses[address] = true
added = true
}
}
return added
}