Avoid reallocating the list of local tracks at each packet.

2020-04-28 16:50:43 +02:00
parent 87f70c4345
commit d9a7f3d6c0
1 changed files with 8 additions and 1 deletions
@@ -288,7 +288,15 @@ func addUpConn(c *client, id string) (*upConnection, error) {
 		go func() {
 			buf := make([]byte, 1500)
 			var packet rtp.Packet
+			var local []*downTrack
+			var localTime time.Time
 			for {
+				now := time.Now()
+				if now.Sub(localTime) > time.Second/2 {
+					local = track.getLocal()
+					localTime = now
+				}
+
 				i, err := remote.Read(buf)
 				if err != nil {
 					if err != io.EOF {
@@ -303,7 +311,6 @@ func addUpConn(c *client, id string) (*upConnection, error) {
 					continue
 				}

-				local := track.getLocal()
 				for _, l := range local {
 					if l.muted() {
 						continue