package core import ( "context" "net" "strings" "sync" "time" log "github.com/sirupsen/logrus" "github.com/wencaiwulue/kubevpn/v2/pkg/config" "github.com/wencaiwulue/kubevpn/v2/pkg/util" ) type fakeUDPTunnelConnector struct { } func UDPOverTCPTunnelConnector() Connector { return &fakeUDPTunnelConnector{} } func (c *fakeUDPTunnelConnector) ConnectContext(ctx context.Context, conn net.Conn) (net.Conn, error) { //defer conn.SetDeadline(time.Time{}) switch con := conn.(type) { case *net.TCPConn: err := con.SetNoDelay(true) if err != nil { return nil, err } err = con.SetKeepAlive(true) if err != nil { return nil, err } err = con.SetKeepAlivePeriod(15 * time.Second) if err != nil { return nil, err } } return newFakeUDPTunnelConnOverTCP(ctx, conn) } type fakeUdpHandler struct { // map[srcIP]net.Conn routeMapTCP *sync.Map packetChan chan *datagramPacket } func TCPHandler() Handler { return &fakeUdpHandler{ routeMapTCP: RouteMapTCP, packetChan: TCPPacketChan, } } func (h *fakeUdpHandler) Handle(ctx context.Context, tcpConn net.Conn) { defer tcpConn.Close() log.Debugf("[TCP] %s -> %s", tcpConn.RemoteAddr(), tcpConn.LocalAddr()) defer func(addr net.Addr) { var keys []string h.routeMapTCP.Range(func(key, value any) bool { if value.(net.Conn) == tcpConn { keys = append(keys, key.(string)) } return true }) for _, key := range keys { h.routeMapTCP.Delete(key) } log.Debugf("[TCP] To %s by conn %s from globle route map TCP", strings.Join(keys, " "), addr) }(tcpConn.LocalAddr()) for { select { case <-ctx.Done(): return default: } buf := config.LPool.Get().([]byte)[:] dgram, err := readDatagramPacketServer(tcpConn, buf[:]) if err != nil { log.Errorf("[TCP] %s -> %s : %v", tcpConn.RemoteAddr(), tcpConn.LocalAddr(), err) config.LPool.Put(buf[:]) return } var src net.IP src, _, err = util.ParseIP(dgram.Data[:dgram.DataLength]) if err != nil { log.Errorf("[TCP] Unknown packet") config.LPool.Put(buf[:]) continue } value, loaded := h.routeMapTCP.LoadOrStore(src.String(), tcpConn) if loaded { if tcpConn != value.(net.Conn) { h.routeMapTCP.Store(src.String(), tcpConn) log.Debugf("[TCP] Replace route map TCP: %s -> %s-%s", src, tcpConn.LocalAddr(), tcpConn.RemoteAddr()) } } else { log.Debugf("[TCP] Add new route map TCP: %s -> %s-%s", src, tcpConn.LocalAddr(), tcpConn.RemoteAddr()) } util.SafeWrite(h.packetChan, dgram) } } // fake udp connect over tcp type fakeUDPTunnelConn struct { // tcp connection net.Conn ctx context.Context } func newFakeUDPTunnelConnOverTCP(ctx context.Context, conn net.Conn) (net.Conn, error) { return &fakeUDPTunnelConn{ctx: ctx, Conn: conn}, nil } func (c *fakeUDPTunnelConn) ReadFrom(b []byte) (int, net.Addr, error) { select { case <-c.ctx.Done(): return 0, nil, c.ctx.Err() default: dgram, err := readDatagramPacket(c.Conn, b) if err != nil { return 0, nil, err } return int(dgram.DataLength), dgram.Addr(), nil } } func (c *fakeUDPTunnelConn) WriteTo(b []byte, _ net.Addr) (int, error) { dgram := newDatagramPacket(b) if err := dgram.Write(c.Conn); err != nil { return 0, err } return len(b), nil } func (c *fakeUDPTunnelConn) Close() error { if cc, ok := c.Conn.(interface{ CloseRead() error }); ok { _ = cc.CloseRead() } if cc, ok := c.Conn.(interface{ CloseWrite() error }); ok { _ = cc.CloseWrite() } return c.Conn.Close() }