linuxkit/alpine/packages/proxy/libproxy/udp_encapsulation.go

package libproxy

import (
	"bytes"
	"encoding/binary"
	"io"
	"net"
	"sync"

	"github.com/Sirupsen/logrus"
)

type udpListener interface {
  ReadFromUDP(b []byte) (int, *net.UDPAddr, error)
	WriteToUDP(b []byte, addr *net.UDPAddr) (int, error)
	Close() error
}

type udpEncapsulator struct {
	conn     *net.Conn
	listener net.Listener
	m        *sync.Mutex
	r        *sync.Mutex
	w        *sync.Mutex
}

func (u *udpEncapsulator) getConn() (net.Conn, error) {
	u.m.Lock()
	defer u.m.Unlock()
	if u.conn != nil {
		return *u.conn, nil
	}
	conn, err := u.listener.Accept()
	if err != nil {
		logrus.Printf("Failed to accept connection: %#v", err)
		return nil, err
	}
	u.conn = &conn
	return conn, nil
}

func (u *udpEncapsulator) ReadFromUDP(b []byte) (int, *net.UDPAddr, error) {
	conn, err := u.getConn()
	if err != nil {
		return 0, nil, err
	}
	u.r.Lock()
	defer u.r.Unlock()
	datagram := &udpDatagram{payload: b}
	err = datagram.Unmarshal(conn)
	if err != nil {
		return 0, nil, err
	}
	return len(datagram.payload), &net.UDPAddr{IP: *datagram.IP, Port: int(datagram.Port), Zone: datagram.Zone}, nil
}

func (u *udpEncapsulator) WriteToUDP(b []byte, addr *net.UDPAddr) (int, error) {
	conn, err := u.getConn()
	if err != nil {
		return 0, err
	}
	u.w.Lock()
	defer u.w.Unlock()
	datagram := &udpDatagram{payload: b, IP: &addr.IP, Port: uint16(addr.Port), Zone: addr.Zone}
	return len(b), datagram.Marshal(conn)
}

func (u *udpEncapsulator) Close() error {
	if u.conn != nil {
		conn := *u.conn
		conn.Close()
	}
	u.listener.Close()
	return nil
}

func NewUDPListener(listener net.Listener) udpListener {
	var m sync.Mutex;
	return &udpEncapsulator{
		conn: nil,
		listener: listener,
		m: &m,
	}
}

type udpDatagram struct {
	payload []byte
	IP      *net.IP
	Port    uint16
	Zone    string
}

func (u *udpDatagram) Marshal(conn net.Conn) error {
	var length uint16
	length = uint16(len(*u.IP))
	if err := binary.Write(conn, binary.LittleEndian, &length); err != nil {
		return err
	}
	if err := binary.Write(conn, binary.LittleEndian, &u.IP); err != nil {
		return err
	}
	if err := binary.Write(conn, binary.LittleEndian, &u.Port); err != nil {
		return err
	}
	length = uint16(len(u.Zone))
	if err := binary.Write(conn, binary.LittleEndian, &length); err != nil {
		return err
	}
	if err := binary.Write(conn, binary.LittleEndian, &u.Zone); err != nil {
		return nil
	}
	length = uint16(len(u.payload))
	if err := binary.Write(conn, binary.LittleEndian, &length); err != nil {
		return nil
	}
	payload := bytes.NewBuffer(u.payload)
	_, err := io.Copy(conn, payload)
	if err != nil {
		return err
	}
	return nil
}

func (u *udpDatagram) Unmarshal(conn net.Conn) error {
	var length uint16
	if err := binary.Read(conn, binary.LittleEndian, &length); err != nil {
		return err
	}
	var IP net.IP
	IP = make([]byte, length)
	if err := binary.Read(conn, binary.LittleEndian, &IP); err != nil {
		return err
	}
	u.IP = &IP
	if err := binary.Read(conn, binary.LittleEndian, &u.Port); err != nil {
		return err
	}
	if err := binary.Read(conn, binary.LittleEndian, &length); err != nil {
		return err
	}
	Zone := make([]byte, length)
	if err := binary.Read(conn, binary.LittleEndian, &Zone); err != nil {
		return err
	}
	u.Zone = string(Zone)
	if err := binary.Read(conn, binary.LittleEndian, &length); err != nil {
		return err
	}
	u.payload = make([]byte, length)
	if err := binary.Read(conn, binary.LittleEndian, &u.payload); err != nil {
		return err
	}
	return nil
}