func()

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
}