kunmeng/vdk
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

add ICECandidates support

Browse Source
This commit is contained in:
BianJiang 2021-11-17 18:21:01 +08:00
parent 022deeb641
commit f9cbb924f6
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
format/webrtcv3/adapter.go
View File

@ -43,6 +43,8 @@ type Options struct {
ICEUsername string ICEUsername string
// ICECredential is an optional credential (i.e., password) for authenticating with the given ICEServers // ICECredential is an optional credential (i.e., password) for authenticating with the given ICEServers
ICECredential string ICECredential string
// ICECandidates sets a list of external IP addresses of 1:1
ICECandidates []string
// PortMin is an optional minimum (inclusive) ephemeral UDP port range for the ICEServers connections // PortMin is an optional minimum (inclusive) ephemeral UDP port range for the ICEServers connections
PortMin uint16 PortMin uint16
// PortMin is an optional maximum (inclusive) ephemeral UDP port range for the ICEServers connections // PortMin is an optional maximum (inclusive) ephemeral UDP port range for the ICEServers connections
@ -77,6 +79,10 @@ func (element *Muxer) NewPeerConnection(configuration webrtc.Configuration) (*we
s.SetEphemeralUDPPortRange(element.Options.PortMin, element.Options.PortMax) s.SetEphemeralUDPPortRange(element.Options.PortMin, element.Options.PortMax)
log.Println("Set UDP ports to", element.Options.PortMin, "..", element.Options.PortMax) log.Println("Set UDP ports to", element.Options.PortMin, "..", element.Options.PortMax)
} }
if len(element.Options.ICECandidates) > 0 {
s.SetNAT1To1IPs(element.Options.ICECandidates, webrtc.ICECandidateTypeHost)
log.Println("Set ICECandidates", element.Options.ICECandidates)
}
api := webrtc.NewAPI(webrtc.WithMediaEngine(m), webrtc.WithInterceptorRegistry(i), webrtc.WithSettingEngine(s)) api := webrtc.NewAPI(webrtc.WithMediaEngine(m), webrtc.WithInterceptorRegistry(i), webrtc.WithSettingEngine(s))
return api.NewPeerConnection(configuration) return api.NewPeerConnection(configuration)
} }