Merge pull request #2356 from weaveworks/issues/2322-awsvpc-enhance

Transfer IPAM ranges to UnknownPeer if no peer is found during Shutdown
This commit is contained in:
Bryan Boreham authored and GitHub committed 2016-06-10 14:00:36 +01:00
commit bf8c8833e5
1 file changed
+4 -3
+4 -3
View File
@@ -443,10 +443,11 @@ func (alloc *Allocator) Shutdown() {
alloc.cancelOps(&alloc.pendingClaims)
alloc.cancelOps(&alloc.pendingAllocates)
alloc.cancelOps(&alloc.pendingPrimes)
if heir := alloc.pickPeerForTransfer(); heir != mesh.UnknownPeerName {
alloc.ring.Transfer(alloc.ourName, heir)
heir := alloc.pickPeerForTransfer()
alloc.ring.Transfer(alloc.ourName, heir)
alloc.space.Clear()
if heir != mesh.UnknownPeerName {
alloc.persistRing()
alloc.space.Clear()
alloc.gossip.GossipBroadcast(alloc.Gossip())
}
doneChan <- struct{}{}