59 lines
1.3 KiB
Go
59 lines
1.3 KiB
Go
package ipam
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/weaveworks/weave/ipam/address"
|
|
)
|
|
|
|
type allocateResult struct {
|
|
addr address.Address
|
|
err error
|
|
}
|
|
|
|
type allocate struct {
|
|
resultChan chan<- allocateResult
|
|
hasBeenCancelled func() bool
|
|
ident string
|
|
}
|
|
|
|
// Try returns true if the request is completed, false if pending
|
|
func (g *allocate) Try(alloc *Allocator) bool {
|
|
if g.hasBeenCancelled() {
|
|
g.Cancel()
|
|
return true
|
|
}
|
|
|
|
// If we have previously stored an address for this container, return it.
|
|
if addr, found := alloc.owned[g.ident]; found {
|
|
g.resultChan <- allocateResult{addr, nil}
|
|
return true
|
|
}
|
|
|
|
if ok, addr := alloc.space.Allocate(); ok {
|
|
alloc.debugln("Allocated", addr, "for", g.ident)
|
|
alloc.addOwned(g.ident, addr)
|
|
g.resultChan <- allocateResult{addr, nil}
|
|
return true
|
|
}
|
|
|
|
// out of space
|
|
if donor, err := alloc.ring.ChoosePeerToAskForSpace(); err == nil {
|
|
alloc.debugln("Decided to ask peer", donor, "for space")
|
|
alloc.sendRequest(donor, msgSpaceRequest)
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func (g *allocate) Cancel() {
|
|
g.resultChan <- allocateResult{0, fmt.Errorf("Allocate request for %s cancelled", g.ident)}
|
|
}
|
|
|
|
func (g *allocate) String() string {
|
|
return fmt.Sprintf("Allocate for %s", g.ident)
|
|
}
|
|
|
|
func (g *allocate) ForContainer(ident string) bool {
|
|
return g.ident == ident
|
|
}
|