Broadcast initial ring after persisting it, in case we die between those operations

This commit is contained in:
Bryan Boreham committed 2016-05-03 17:23:00 +01:00
1 parent 6847a3551d
commit 3252a25e00
2 files changed
+2 -1

No files matched your search

+1 -1
View File
@@ -650,8 +650,8 @@ func (alloc *Allocator) establishRing() {
func (alloc *Allocator) createRing(peers []mesh.PeerName) {
alloc.debugln("Paxos consensus:", peers)
alloc.ring.ClaimForPeers(normalizeConsensus(peers))
alloc.gossip.GossipBroadcast(alloc.Gossip())
alloc.ringUpdated()
alloc.gossip.GossipBroadcast(alloc.Gossip())
}
func (alloc *Allocator) ringUpdated() {
+1
View File
@@ -176,6 +176,7 @@ func TestAllocatorClaim(t *testing.T) {
alloc.Prime()
// Do an allocate on the other peer, which we will try to claim later
addrx, err := allocs[0].Allocate(container1, subnet, true, returnFalse)
router.Flush()
// Now try the claim again
err = alloc.Claim(container3, addr1, true, true)