Set kernel specific config on linux
On linux systems bump up gc_thresholds so to lower the probability of running with neighbor table overflow issues Signed-off-by: Flavio Crisciani <flavio.crisciani@docker.com>
This commit is contained in:
parent
59994bbb15
commit
4abd54d419
3 changed files with 39 additions and 1 deletions
30
libnetwork/drivers/overlay/ostweaks_linux.go
Normal file
30
libnetwork/drivers/overlay/ostweaks_linux.go
Normal file
|
@ -0,0 +1,30 @@
|
||||||
|
package overlay
|
||||||
|
|
||||||
|
import (
|
||||||
|
"io/ioutil"
|
||||||
|
"path"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"github.com/Sirupsen/logrus"
|
||||||
|
)
|
||||||
|
|
||||||
|
var sysctlConf = map[string]string{
|
||||||
|
"net.ipv4.neigh.default.gc_thresh1": "8192",
|
||||||
|
"net.ipv4.neigh.default.gc_thresh2": "49152",
|
||||||
|
"net.ipv4.neigh.default.gc_thresh3": "65536",
|
||||||
|
}
|
||||||
|
|
||||||
|
// writeSystemProperty writes the value to a path under /proc/sys as determined from the key.
|
||||||
|
// For e.g. net.ipv4.ip_forward translated to /proc/sys/net/ipv4/ip_forward.
|
||||||
|
func writeSystemProperty(key, value string) error {
|
||||||
|
keyPath := strings.Replace(key, ".", "/", -1)
|
||||||
|
return ioutil.WriteFile(path.Join("/proc/sys", keyPath), []byte(value), 0644)
|
||||||
|
}
|
||||||
|
|
||||||
|
func applyOStweaks() {
|
||||||
|
for k, v := range sysctlConf {
|
||||||
|
if err := writeSystemProperty(k, v); err != nil {
|
||||||
|
logrus.Errorf("error setting the kernel parameter %s = %s, err: %s", k, v, err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
5
libnetwork/drivers/overlay/ostweaks_unsupported.go
Normal file
5
libnetwork/drivers/overlay/ostweaks_unsupported.go
Normal file
|
@ -0,0 +1,5 @@
|
||||||
|
// +build !linux
|
||||||
|
|
||||||
|
package overlay
|
||||||
|
|
||||||
|
func applyOStweaks() {}
|
|
@ -46,7 +46,7 @@ type driver struct {
|
||||||
store datastore.DataStore
|
store datastore.DataStore
|
||||||
localStore datastore.DataStore
|
localStore datastore.DataStore
|
||||||
vxlanIdm *idm.Idm
|
vxlanIdm *idm.Idm
|
||||||
once sync.Once
|
initOS sync.Once
|
||||||
joinOnce sync.Once
|
joinOnce sync.Once
|
||||||
localJoinOnce sync.Once
|
localJoinOnce sync.Once
|
||||||
keys []*key
|
keys []*key
|
||||||
|
@ -188,6 +188,9 @@ func (d *driver) configure() error {
|
||||||
return d.initializeVxlanIdm()
|
return d.initializeVxlanIdm()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Apply OS specific kernel configs if needed
|
||||||
|
d.initOS.Do(applyOStweaks)
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue