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

Fixed #16 explicit passing of participant id

Browse Source
This commit is contained in:
David Zhao
2021-02-12 23:53:46 -08:00
parent 090f8d0664
commit e342ea2155
2 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/mediatrack.go
+1 -2
View File
@@ -239,8 +239,7 @@ func (t *MediaTrack) AddReceiver(receiver *webrtc.RTPReceiver, track *webrtc.Tra
defer t.lock.Unlock()
if t.receiver == nil {
// pack ID to identify all publishedTracks
packedId := PackTrackId(t.participantId, t.ID())
t.receiver = NewWrappedReceiver(sfu.NewWebRTCReceiver(receiver, track, t.participantId), packedId)
t.receiver = NewWrappedReceiver(sfu.NewWebRTCReceiver(receiver, track, t.participantId), t.ID(), t.participantId)
t.receiver.SetRTCPCh(t.rtcpCh)
t.receiver.OnCloseHandler(func() {
t.lock.Lock()
pkg/rtc/wrappedreceiver.go
+8 -2
View File
@@ -8,16 +8,22 @@ import (
type WrappedReceiver struct {
sfu.Receiver
trackId string
trackId string
streamId string
}
func NewWrappedReceiver(receiver sfu.Receiver, trackId string) WrappedReceiver {
func NewWrappedReceiver(receiver sfu.Receiver, trackId string, streamId string) WrappedReceiver {
return WrappedReceiver{
Receiver: receiver,
trackId: trackId,
streamId: streamId,
}
}
func (r WrappedReceiver) TrackID() string {
return r.trackId
}
func (r WrappedReceiver) StreamID() string {
return r.streamId
}