12 NetNs NetType = "netns"
17 type NetConfig struct {
18 Configure func() error
22 type NetTopology []NetConfig
24 func (t *NetTopology) Configure() error {
25 for _, c := range *t {
34 func (t *NetTopology) Unconfigure() {
35 for _, c := range *t {
40 func newConfigFn(cfg NetDevConfig) func() error {
43 return func() error { return AddNetns(cfg["name"].(string)) }
44 } else if t == "veth" {
47 peer := cfg["peer"].(NetDevConfig)
48 peerName := peer["name"].(string)
49 err := AddVethPair(cfg["name"].(string), peerName)
54 if peer["netns"] != nil {
55 peerNs = peer["netns"].(string)
57 err := LinkSetNetns(peerName, peerNs)
63 if peer["ip4"] != nil {
64 err = AddAddress(peerName, peer["ip4"].(string), peerNs)
66 return fmt.Errorf("failed to add configure address for %s: %v", peerName, err)
71 } else if t == "bridge" {
72 return func() error { return configureBridge(cfg) }
73 } else if t == "tap" {
74 return func() error { return configureTap(cfg) }
79 func newUnconfigFn(cfg NetDevConfig) func() {
81 name := cfg["name"].(string)
84 return func() { DelLink(name) }
85 } else if t == "netns" {
86 return func() { DelNetns(name) }
87 } else if t == "veth" {
88 return func() { DelLink(name) }
89 } else if t == "bridge" {
90 return func() { DelBridge(name, cfg["netns"].(string)) }
95 func NewNetConfig(cfg NetDevConfig) NetConfig {
98 nc.Configure = newConfigFn(cfg)
99 nc.Unconfigure = newUnconfigFn(cfg)
104 func DelBridge(brName, ns string) error {
105 err := SetDevDown(brName, ns)
110 err = addDelBridge(brName, ns, false)
118 func configureBridge(dev NetDevConfig) error {
120 for _, v := range dev["interfaces"].([]interface{}) {
121 ifs = append(ifs, v.(string))
123 return AddBridge(dev["name"].(string), ifs, dev["netns"].(string))
126 func configureTap(dev NetDevConfig) error {
127 return AddTap(dev["name"].(string), dev["ip4"].(string))
130 func SetDevUp(dev, ns string) error {
131 return setDevUpDown(dev, ns, true)
134 func SetDevDown(dev, ns string) error {
135 return setDevUpDown(dev, ns, false)
138 func AddTap(ifName, ifAddress string) error {
139 cmd := exec.Command("ip", "tuntap", "add", ifName, "mode", "tap")
140 o, err := cmd.CombinedOutput()
142 s := fmt.Sprintf("error creating tap %s: %v: %s", ifName, err, string(o))
146 cmd = exec.Command("ip", "addr", "add", ifAddress, "dev", ifName)
150 s := fmt.Sprintf("error setting addr for tap %s: %v", ifName, err)
154 err = SetDevUp(ifName, "")
162 func DelLink(ifName string) {
163 cmd := exec.Command("ip", "link", "del", ifName)
167 func setDevUpDown(dev, ns string, isUp bool) error {
174 c := []string{"ip", "link", "set", "dev", dev, op}
175 cmd := appendNetns(c, ns)
178 s := fmt.Sprintf("error bringing %s device %s!", dev, op)
184 func AddVethPair(ifName, peerName string) error {
185 cmd := exec.Command("ip", "link", "add", ifName, "type", "veth", "peer", "name", peerName)
188 return fmt.Errorf("creating veth pair failed: %v", err)
190 err = SetDevUp(ifName, "")
192 return fmt.Errorf("set link up failed: %v", err)
197 func addDelNetns(name string, isAdd bool) error {
204 cmd := exec.Command("ip", "netns", op, name)
205 _, err := cmd.CombinedOutput()
207 return errors.New("add/del netns failed")
212 func AddNetns(nsName string) error {
213 return addDelNetns(nsName, true)
216 func DelNetns(nsName string) error {
217 return addDelNetns(nsName, false)
220 func LinkSetNetns(ifName, ns string) error {
221 cmd := exec.Command("ip", "link", "set", "dev", ifName, "up", "netns", ns)
224 return fmt.Errorf("error setting device '%s' to netns '%s: %v", ifName, ns, err)
229 func NewCommand(s []string, ns string) *exec.Cmd {
230 return appendNetns(s, ns)
233 func appendNetns(s []string, ns string) *exec.Cmd {
236 // use default namespace
237 cmd = exec.Command(s[0], s[1:]...)
239 var args = []string{"netns", "exec", ns}
240 args = append(args, s[:]...)
241 cmd = exec.Command("ip", args...)
246 func addDelBridge(brName, ns string, isAdd bool) error {
253 var c = []string{"brctl", op, brName}
254 cmd := appendNetns(c, ns)
257 s := fmt.Sprintf("%s %s failed!", op, brName)
263 func AddBridge(brName string, ifs []string, ns string) error {
264 err := addDelBridge(brName, ns, true)
269 for _, v := range ifs {
270 c := []string{"brctl", "addif", brName, v}
271 cmd := appendNetns(c, ns)
274 s := fmt.Sprintf("error adding %s to bridge %s: %v", v, brName, err)
278 err = SetDevUp(brName, ns)