vbatts/pkg
1
0
Fork 0
Code Pull requests Releases Activity

Create veth pair via netlink

Browse source 
Docker-DCO-1.1-Signed-off-by: Michael Crosby <michael@crosbymichael.com> (github: crosbymichael)
This commit is contained in:
Michael Crosby 2014-02-10 13:37:16 -08:00
parent 4b4a12a4c3
commit f62dcac1c5
1 changed files with 41 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
netlink/netlink_linux.go
View file

@ -14,6 +14,8 @@ const (
IFNAMSIZ = 16 IFNAMSIZ = 16
DEFAULT_CHANGE = 0xFFFFFFFF DEFAULT_CHANGE = 0xFFFFFFFF
IFLA_INFO_KIND = 1 IFLA_INFO_KIND = 1
IFLA_INFO_DATA = 2
VETH_PEER = 1
) )
var nextSeqNr int var nextSeqNr int
@ -197,7 +199,9 @@ func (rr *NetlinkRequest) ToWireFormat() []byte {
} }
func (rr *NetlinkRequest) AddData(data NetlinkRequestData) { func (rr *NetlinkRequest) AddData(data NetlinkRequestData) {
if data != nil {
rr.Data = append(rr.Data, data) rr.Data = append(rr.Data, data)
}
} }
func newNetlinkRequest(proto, flags int) *NetlinkRequest { func newNetlinkRequest(proto, flags int) *NetlinkRequest {
@ -676,6 +680,41 @@ func NetworkChangeName(oldName, newName string) error {
if _, _, errno := syscall.Syscall(syscall.SYS_IOCTL, uintptr(fd), syscall.SIOCSIFNAME, uintptr(unsafe.Pointer(&data[0]))); errno != 0 { if _, _, errno := syscall.Syscall(syscall.SYS_IOCTL, uintptr(fd), syscall.SIOCSIFNAME, uintptr(unsafe.Pointer(&data[0]))); errno != 0 {
return errno return errno
} }
return nil return nil
} }
func NetworkCreateVethPair(name1, name2 string) error {
s, err := getNetlinkSocket()
if err != nil {
return err
}
defer s.Close()
wb := newNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_CREATE|syscall.NLM_F_EXCL|syscall.NLM_F_ACK)
msg := newIfInfomsg(syscall.AF_UNSPEC)
wb.AddData(msg)
kindData := newRtAttr(IFLA_INFO_KIND, nonZeroTerminated("veth"))
info := newRtAttr(syscall.IFLA_LINKINFO, kindData.ToWireFormat())
// wb.AddData(info)
peerName := newRtAttr(syscall.IFLA_IFNAME, nonZeroTerminated(name2))
peer := newRtAttr(VETH_PEER, peerName.ToWireFormat())
// wb.AddData(peer)
b := []byte{}
b = append(b, peer.ToWireFormat()...)
b = append(b, info.ToWireFormat()...)
infoData := newRtAttr(IFLA_INFO_DATA, b)
wb.AddData(infoData)
nameData := newRtAttr(syscall.IFLA_IFNAME, zeroTerminated(name1))
wb.AddData(nameData)
if err := s.Send(wb); err != nil {
return err
}
return s.HandleAck(wb.Seq)
}