apps/go2rtc
1
0
Fork 0
mirror of https://github.com/AlexxIT/go2rtc.git synced 2025-10-05 16:26:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add IPv6 support to WebRTC #721

Browse Source
This commit is contained in:
Alex X
2023-10-30 21:04:38 +03:00
parent 6a9ae93fa1
commit b4ed738d17
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/webrtc/api.go
View File

@@ -1,11 +1,12 @@
package webrtc package webrtc
import ( import (
"net"
"strings"
"github.com/pion/ice/v2" "github.com/pion/ice/v2"
"github.com/pion/interceptor" "github.com/pion/interceptor"
"github.com/pion/webrtc/v3" "github.com/pion/webrtc/v3"
"net"
"strings"
) )
// ReceiveMTU = Ethernet MTU (1500) - IP Header (20) - UDP Header (8) // ReceiveMTU = Ethernet MTU (1500) - IP Header (20) - UDP Header (8)
@@ -40,6 +41,7 @@ func NewAPI(address string) (*webrtc.API, error) {
// UDP6 may have problems with DNS resolving for STUN servers // UDP6 may have problems with DNS resolving for STUN servers
s.SetNetworkTypes([]webrtc.NetworkType{ s.SetNetworkTypes([]webrtc.NetworkType{
webrtc.NetworkTypeUDP4, webrtc.NetworkTypeTCP4, webrtc.NetworkTypeUDP4, webrtc.NetworkTypeTCP4,
webrtc.NetworkTypeUDP6, webrtc.NetworkTypeTCP6,
}) })
// fix https://github.com/pion/webrtc/pull/2407 // fix https://github.com/pion/webrtc/pull/2407
@@ -50,13 +52,13 @@ func NewAPI(address string) (*webrtc.API, error) {
if address != "" { if address != "" {
address, network, _ := strings.Cut(address, "/") address, network, _ := strings.Cut(address, "/")
if network == "" || network == "udp" { if network == "" || network == "udp" {
if ln, err := net.ListenPacket("udp4", address); err == nil { if ln, err := net.ListenPacket("udp", address); err == nil {
udpMux := webrtc.NewICEUDPMux(nil, ln) udpMux := webrtc.NewICEUDPMux(nil, ln)
s.SetICEUDPMux(udpMux) s.SetICEUDPMux(udpMux)
} }
} }
if network == "" || network == "tcp" { if network == "" || network == "tcp" {
if ln, err := net.Listen("tcp4", address); err == nil { if ln, err := net.Listen("tcp", address); err == nil {
tcpMux := webrtc.NewICETCPMux(nil, ln, 8) tcpMux := webrtc.NewICETCPMux(nil, ln, 8)
s.SetICETCPMux(tcpMux) s.SetICETCPMux(tcpMux)
} }