1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
//go:build !windows
package libnetwork
import (
"context"
"fmt"
"strconv"
"time"
"github.com/docker/docker/daemon/network"
"github.com/docker/docker/libnetwork/ipams/defaultipam"
"github.com/docker/docker/libnetwork/netlabel"
"github.com/docker/docker/libnetwork/osl"
)
type platformNetwork struct{} //nolint:nolintlint,unused // only populated on windows
// Stub implementations for DNS related functions
func (n *Network) startResolver() {
}
func addEpToResolver(
ctx context.Context,
netName, epName string,
config *containerConfig,
epIface *EndpointInterface,
resolvers []*Resolver,
) error {
return nil
}
func deleteEpFromResolver(epName string, epIface *EndpointInterface, resolvers []*Resolver) error {
return nil
}
func defaultIpamForNetworkType(networkType string) string {
return defaultipam.DriverName
}
func (n *Network) validatedAdvertiseAddrNMsgs() (*int, error) {
nMsgsStr, ok := n.DriverOptions()[netlabel.AdvertiseAddrNMsgs]
if !ok {
return nil, nil
}
nMsgs, err := strconv.Atoi(nMsgsStr)
if err != nil {
return nil, fmt.Errorf("value for option "+netlabel.AdvertiseAddrNMsgs+" %q must be an integer", nMsgsStr)
}
if nMsgs < osl.AdvertiseAddrNMsgsMin || nMsgs > osl.AdvertiseAddrNMsgsMax {
return nil, fmt.Errorf(netlabel.AdvertiseAddrNMsgs+" must be in the range %d to %d",
osl.AdvertiseAddrNMsgsMin, osl.AdvertiseAddrNMsgsMax)
}
return &nMsgs, nil
}
func (n *Network) validatedAdvertiseAddrInterval() (*time.Duration, error) {
intervalStr, ok := n.DriverOptions()[netlabel.AdvertiseAddrIntervalMs]
if !ok {
return nil, nil
}
msecs, err := strconv.Atoi(intervalStr)
if err != nil {
return nil, fmt.Errorf("value for option "+netlabel.AdvertiseAddrIntervalMs+" %q must be integer milliseconds", intervalStr)
}
interval := time.Duration(msecs) * time.Millisecond
if interval < osl.AdvertiseAddrIntervalMin || interval > osl.AdvertiseAddrIntervalMax {
return nil, fmt.Errorf(netlabel.AdvertiseAddrIntervalMs+" must be in the range %d to %d",
osl.AdvertiseAddrIntervalMin/time.Millisecond, osl.AdvertiseAddrIntervalMax/time.Millisecond)
}
return &interval, nil
}
// IsPruneable returns true if n can be considered for removal as part of a
// "docker network prune" (or system prune). The caller must still check that the
// network should be removed. For example, it may have active endpoints.
func (n *Network) IsPruneable() bool {
return !network.IsPredefined(n.Name())
}
|
