This commit is contained in:
kony
2025-12-08 17:47:32 +08:00
parent 6d74050726
commit 113c8d883e
2 changed files with 4 additions and 4 deletions

View File

@@ -34,8 +34,8 @@ func ForwardTCPConn(originConn *TcpConn, stun_quic_conn quic.Connection) {
binary.BigEndian.PutUint16(portBytes, originConn.ID().LocalPort) binary.BigEndian.PutUint16(portBytes, originConn.ID().LocalPort)
new_quic_stream.Write(portBytes) new_quic_stream.Write(portBytes)
go proxy.ForwardQ2T(new_quic_stream, originConn, stun_quic_conn) go proxy.ForwardQ2T(new_quic_stream, originConn)
go proxy.ForwardT2Q(originConn, new_quic_stream, stun_quic_conn) go proxy.ForwardT2Q(originConn, new_quic_stream)
} }
func NewTcpForwarder(s *stack.Stack, stun_quic_conn quic.Connection) *tcp.Forwarder { func NewTcpForwarder(s *stack.Stack, stun_quic_conn quic.Connection) *tcp.Forwarder {

View File

@@ -33,8 +33,8 @@ func ForwardUdpConn(originConn *udpConn, stun_quic_conn quic.Connection) {
binary.BigEndian.PutUint16(portBytes, originConn.ID().LocalPort) binary.BigEndian.PutUint16(portBytes, originConn.ID().LocalPort)
new_quic_stream.Write(portBytes) new_quic_stream.Write(portBytes)
go proxy.ForwardQ2T(new_quic_stream, originConn, stun_quic_conn) go proxy.ForwardQ2T(new_quic_stream, originConn)
go proxy.ForwardT2Q(originConn, new_quic_stream, stun_quic_conn) go proxy.ForwardT2Q(originConn, new_quic_stream)
} }
func NewUdpForwarder(s *stack.Stack, stun_quic_conn quic.Connection) *udp.Forwarder { func NewUdpForwarder(s *stack.Stack, stun_quic_conn quic.Connection) *udp.Forwarder {