improve streamer performance by using static buffers

bluenviron · Jul 4, 2020 · eab4efe · eab4efe
1 parent adb3909
commit eab4efe
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/streamer.go b/streamer.go
@@ -590,9 +590,15 @@ outer:
 	chanConnError := make(chan struct{})
 	go func() {
 		for {
-			frame := &gortsplib.InterleavedFrame{
-				Content: make([]byte, 512*1024),
+			if !s.readCurBuf {
+				frame.Content = s.readBuf1
+			} else {
+				frame.Content = s.readBuf2
 			}
+
+			frame.Content = frame.Content[:cap(frame.Content)]
+			s.readCurBuf = !s.readCurBuf
+
 			err := conn.ReadInterleavedFrame(frame)
 			if err != nil {
 				s.log("ERR: %s", err)