cff4f20c44
The github.com/containerd/containerd/log package was moved to a separate module, which will also be used by upcoming (patch) releases of containerd. This patch moves our own uses of the package to use the new module. Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
86 lines
2.6 KiB
Go
86 lines
2.6 KiB
Go
package windowsipam
|
|
|
|
import (
|
|
"context"
|
|
"net"
|
|
|
|
"github.com/containerd/log"
|
|
"github.com/docker/docker/libnetwork/ipamapi"
|
|
"github.com/docker/docker/libnetwork/types"
|
|
)
|
|
|
|
const (
|
|
localAddressSpace = "LocalDefault"
|
|
globalAddressSpace = "GlobalDefault"
|
|
)
|
|
|
|
// DefaultIPAM defines the default ipam-driver for local-scoped windows networks
|
|
const DefaultIPAM = "windows"
|
|
|
|
var defaultPool, _ = types.ParseCIDR("0.0.0.0/0")
|
|
|
|
type allocator struct{}
|
|
|
|
// Register registers the built-in ipam service with libnetwork
|
|
func Register(ipamName string, r ipamapi.Registerer) error {
|
|
return r.RegisterIpamDriver(ipamName, &allocator{})
|
|
}
|
|
|
|
func (a *allocator) GetDefaultAddressSpaces() (string, string, error) {
|
|
return localAddressSpace, globalAddressSpace, nil
|
|
}
|
|
|
|
// RequestPool returns an address pool along with its unique id. This is a null ipam driver. It allocates the
|
|
// subnet user asked and does not validate anything. Doesn't support subpool allocation
|
|
func (a *allocator) RequestPool(addressSpace, requestedPool, requestedSubPool string, options map[string]string, v6 bool) (string, *net.IPNet, map[string]string, error) {
|
|
log.G(context.TODO()).Debugf("RequestPool(%s, %s, %s, %v, %t)", addressSpace, requestedPool, requestedSubPool, options, v6)
|
|
if requestedSubPool != "" || v6 {
|
|
return "", nil, nil, types.InternalErrorf("This request is not supported by null ipam driver")
|
|
}
|
|
|
|
var ipNet *net.IPNet
|
|
var err error
|
|
|
|
if requestedPool != "" {
|
|
_, ipNet, err = net.ParseCIDR(requestedPool)
|
|
if err != nil {
|
|
return "", nil, nil, err
|
|
}
|
|
} else {
|
|
ipNet = defaultPool
|
|
}
|
|
|
|
return ipNet.String(), ipNet, nil, nil
|
|
}
|
|
|
|
// ReleasePool releases the address pool - always succeeds
|
|
func (a *allocator) ReleasePool(poolID string) error {
|
|
log.G(context.TODO()).Debugf("ReleasePool(%s)", poolID)
|
|
return nil
|
|
}
|
|
|
|
// RequestAddress returns an address from the specified pool ID.
|
|
// Always allocate the 0.0.0.0/32 ip if no preferred address was specified
|
|
func (a *allocator) RequestAddress(poolID string, prefAddress net.IP, opts map[string]string) (*net.IPNet, map[string]string, error) {
|
|
log.G(context.TODO()).Debugf("RequestAddress(%s, %v, %v)", poolID, prefAddress, opts)
|
|
_, ipNet, err := net.ParseCIDR(poolID)
|
|
if err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
if prefAddress != nil {
|
|
return &net.IPNet{IP: prefAddress, Mask: ipNet.Mask}, nil, nil
|
|
}
|
|
|
|
return nil, nil, nil
|
|
}
|
|
|
|
// ReleaseAddress releases the address - always succeeds
|
|
func (a *allocator) ReleaseAddress(poolID string, address net.IP) error {
|
|
log.G(context.TODO()).Debugf("ReleaseAddress(%s, %v)", poolID, address)
|
|
return nil
|
|
}
|
|
|
|
func (a *allocator) IsBuiltIn() bool {
|
|
return true
|
|
}
|