60 lines
1.5 KiB
Go
60 lines
1.5 KiB
Go
package udp
|
|
|
|
import (
|
|
"io"
|
|
"net"
|
|
|
|
"github.com/traefik/traefik/v2/pkg/log"
|
|
)
|
|
|
|
// Proxy is a reverse-proxy implementation of the Handler interface.
|
|
type Proxy struct {
|
|
// TODO: maybe optimize by pre-resolving it at proxy creation time
|
|
target string
|
|
}
|
|
|
|
// NewProxy creates a new Proxy.
|
|
func NewProxy(address string) (*Proxy, error) {
|
|
return &Proxy{target: address}, nil
|
|
}
|
|
|
|
// ServeUDP implements the Handler interface.
|
|
func (p *Proxy) ServeUDP(conn *Conn) {
|
|
log.WithoutContext().Debugf("Handling UDP stream from %s to %s", conn.rAddr, p.target)
|
|
|
|
// needed because of e.g. server.trackedConnection
|
|
defer conn.Close()
|
|
|
|
connBackend, err := net.Dial("udp", p.target)
|
|
if err != nil {
|
|
log.WithoutContext().Errorf("Error while dialing backend: %v", err)
|
|
return
|
|
}
|
|
|
|
// maybe not needed, but just in case
|
|
defer connBackend.Close()
|
|
|
|
errChan := make(chan error)
|
|
go connCopy(conn, connBackend, errChan)
|
|
go connCopy(connBackend, conn, errChan)
|
|
|
|
err = <-errChan
|
|
if err != nil {
|
|
log.WithoutContext().Errorf("Error while handling UDP stream: %v", err)
|
|
}
|
|
|
|
<-errChan
|
|
}
|
|
|
|
func connCopy(dst io.WriteCloser, src io.Reader, errCh chan error) {
|
|
// The buffer is initialized to the maximum UDP datagram size,
|
|
// to make sure that the whole UDP datagram is read or written atomically (no data is discarded).
|
|
buffer := make([]byte, maxDatagramSize)
|
|
|
|
_, err := io.CopyBuffer(dst, src, buffer)
|
|
errCh <- err
|
|
|
|
if err := dst.Close(); err != nil {
|
|
log.WithoutContext().Debugf("Error while terminating UDP stream: %v", err)
|
|
}
|
|
}
|