Commit 3d21a798 authored by Juliusz Chroboczek's avatar Juliusz Chroboczek

Don't carry up tracks explicitly.

Left over from the old data structure.
parent 51c31ab7
...@@ -345,7 +345,7 @@ func delDownConnHelper(c *webClient, id string) *rtpDownConnection { ...@@ -345,7 +345,7 @@ func delDownConnHelper(c *webClient, id string) *rtpDownConnection {
var errUnexpectedTrackType = errors.New("unexpected track type, this shouldn't happen") var errUnexpectedTrackType = errors.New("unexpected track type, this shouldn't happen")
func addDownTrackUnlocked(conn *rtpDownConnection, remoteTrack *rtpUpTrack, remoteConn conn.Up) error { func addDownTrackUnlocked(conn *rtpDownConnection, remoteTrack *rtpUpTrack) error {
for _, t := range conn.tracks { for _, t := range conn.tracks {
tt, ok := t.remote.(*rtpUpTrack) tt, ok := t.remote.(*rtpUpTrack)
if !ok { if !ok {
...@@ -367,7 +367,7 @@ func addDownTrackUnlocked(conn *rtpDownConnection, remoteTrack *rtpUpTrack, remo ...@@ -367,7 +367,7 @@ func addDownTrackUnlocked(conn *rtpDownConnection, remoteTrack *rtpUpTrack, remo
msid := remoteTrack.track.StreamID() msid := remoteTrack.track.StreamID()
if msid == "" { if msid == "" {
log.Println("Got track with empty msid") log.Println("Got track with empty msid")
msid = remoteConn.Label() msid = remoteTrack.conn.Label()
} }
if msid == "" { if msid == "" {
msid = "dummy" msid = "dummy"
...@@ -446,7 +446,7 @@ func delDownTrackUnlocked(conn *rtpDownConnection, track *rtpDownTrack) error { ...@@ -446,7 +446,7 @@ func delDownTrackUnlocked(conn *rtpDownConnection, track *rtpDownTrack) error {
return os.ErrNotExist return os.ErrNotExist
} }
func replaceTracks(conn *rtpDownConnection, remote []conn.UpTrack, remoteConn conn.Up) (bool, error) { func replaceTracks(conn *rtpDownConnection, remote []conn.UpTrack) (bool, error) {
conn.mu.Lock() conn.mu.Lock()
defer conn.mu.Unlock() defer conn.mu.Unlock()
...@@ -501,7 +501,7 @@ outer2: ...@@ -501,7 +501,7 @@ outer2:
} }
for _, rt := range add { for _, rt := range add {
err := addDownTrackUnlocked(conn, rt, remoteConn) err := addDownTrackUnlocked(conn, rt)
if err != nil { if err != nil {
return false, err return false, err
} }
...@@ -1031,7 +1031,7 @@ func pushDownConn(c *webClient, id string, up conn.Up, tracks []conn.UpTrack, re ...@@ -1031,7 +1031,7 @@ func pushDownConn(c *webClient, id string, up conn.Up, tracks []conn.UpTrack, re
} }
return err return err
} }
done, err := replaceTracks(down, requested, up) done, err := replaceTracks(down, requested)
if err != nil || !done { if err != nil || !done {
return err return err
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment