dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-06-07 00:11:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

use the available peer connection

Browse Source
This commit is contained in:
boks1971
2025-08-18 08:55:48 +05:30
parent 435d883133
commit eb156d2f8c
1 changed files with 27 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/transportmanager.go
+27 -9
View File
@@ -649,20 +649,38 @@ func (t *TransportManager) GetICEConnectionInfo() []*types.ICEConnectionInfo {
}
func (t *TransportManager) getTransport(isPrimary bool) *PCTransport {
pcTransport := t.publisher
if (isPrimary && t.params.SubscriberAsPrimary) || (!isPrimary && !t.params.SubscriberAsPrimary) {
pcTransport = t.subscriber
}
switch {
case t.publisher == nil:
return t.subscriber
return pcTransport
case t.subscriber == nil:
return t.publisher
default:
pcTransport := t.publisher
if (isPrimary && t.params.SubscriberAsPrimary) || (!isPrimary && !t.params.SubscriberAsPrimary) {
pcTransport = t.subscriber
}
return pcTransport
}
}
func (t *TransportManager) getLowestPriorityConnectionType() types.ICEConnectionType {
ctype := t.publisher.GetICEConnectionType()
if stype := t.subscriber.GetICEConnectionType(); stype > ctype {
ctype = stype
switch {
case t.publisher == nil:
return t.subscriber.GetICEConnectionType()
case t.subscriber == nil:
return t.publisher.GetICEConnectionType()
default:
ctype := t.publisher.GetICEConnectionType()
if stype := t.subscriber.GetICEConnectionType(); stype > ctype {
ctype = stype
}
return ctype
}
return ctype
}
func (t *TransportManager) handleConnectionFailed(isShortLived bool) {