Method Update

net2/http2/load_balanced_pool.go:173–217

(instanceInfos []LBPoolInstanceInfo)

}

func (pool *LoadBalancedPool) Update(instanceInfos []LBPoolInstanceInfo) {

	pool.lock.Lock()
	defer pool.lock.Unlock()
	newInstances := make(map[string]*instancePool)
	var newInstanceList instancePoolSlice
	for _, instanceInfo := range instanceInfos {
		if _, ok := newInstances[instanceInfo.Addr]; !ok {
			var instance *instancePool
			if instance, ok = pool.instances[instanceInfo.Addr]; !ok {
				instance = pool.newInstancePool(instanceInfo)
			} else {
				// Update `instanceId` for given instance since same host:port address
				// might have a new `instanceId` now.
				instance.instanceId = instanceInfo.InstanceId
			}
			newInstances[instanceInfo.Addr] = instance
			newInstanceList = append(newInstanceList, instance)
		}
	}

	var instanceHashes []uint32
	if pool.strategy == LBConsistentHashing {
		// we need to recompute the new hashes
		instanceHashes = make([]uint32, len(newInstanceList))
		for i, instance := range newInstanceList {
			instanceHashes[i] = hashInstance(pool.hashSeed, pool.hashFunction, instance)
		}
	}

	// Each strategy has a specific sorter that knows how to sort the instances
	pool.sortInstances(newInstanceList, instanceHashes)

	for addr, instancePool := range pool.instances {
		// Close out all InstancePools that are not needed anymore.
		if _, ok := newInstances[addr]; !ok {
			instancePool.Close()
		}
	}
	pool.instances = newInstances
	pool.instanceList = newInstanceList
	pool.instanceHashes = instanceHashes
	pool.markDownUntil = make([]int64, len(newInstanceList))

}

//
// Pool interface methods