From b5263306071a34ce2de99c2d02e2a8a56d34d000 Mon Sep 17 00:00:00 2001
From: aler9 <46489434+aler9@users.noreply.github.com>
Date: Sat, 19 Sep 2020 00:46:28 +0200
Subject: [PATCH] decrease ram consumption

---
 client.go     | 2 +-
 server-udp.go | 2 +-
 source.go     | 6 +++---
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/client.go b/client.go
index ac4910b2..e06b512a 100644
--- a/client.go
+++ b/client.go
@@ -1162,7 +1162,7 @@ func (c *client) runRecordUDP() {
 
 func (c *client) runRecordTCP() {
 	frame := &gortsplib.InterleavedFrame{}
-	readBuf := newMultiBuffer(3, clientTCPReadBufferSize)
+	readBuf := newMultiBuffer(2, clientTCPReadBufferSize)
 
 	readRequest := make(chan readRequestPair)
 	defer close(readRequest)
diff --git a/server-udp.go b/server-udp.go
index 4b43e711..81cdaae8 100644
--- a/server-udp.go
+++ b/server-udp.go
@@ -35,7 +35,7 @@ func newServerUDP(p *program, port int, streamType gortsplib.StreamType) (*serve
 		p:          p,
 		pc:         pc,
 		streamType: streamType,
-		readBuf:    newMultiBuffer(3, clientUDPReadBufferSize),
+		readBuf:    newMultiBuffer(2, clientUDPReadBufferSize),
 		writec:     make(chan udpBufAddrPair),
 		done:       make(chan struct{}),
 	}
diff --git a/source.go b/source.go
index 719a5b8b..205d1902 100644
--- a/source.go
+++ b/source.go
@@ -225,7 +225,7 @@ func (s *source) runUDP(conn *gortsplib.ConnClient) bool {
 		go func(trackId int, rtpRead gortsplib.UDPReadFunc) {
 			defer wg.Done()
 
-			multiBuf := newMultiBuffer(3, sourceUDPReadBufferSize)
+			multiBuf := newMultiBuffer(2, sourceUDPReadBufferSize)
 			for {
 				buf := multiBuf.next()
 
@@ -246,7 +246,7 @@ func (s *source) runUDP(conn *gortsplib.ConnClient) bool {
 		go func(trackId int, rtcpRead gortsplib.UDPReadFunc) {
 			defer wg.Done()
 
-			multiBuf := newMultiBuffer(3, sourceUDPReadBufferSize)
+			multiBuf := newMultiBuffer(2, sourceUDPReadBufferSize)
 			for {
 				buf := multiBuf.next()
 
@@ -312,7 +312,7 @@ func (s *source) runTCP(conn *gortsplib.ConnClient) bool {
 	s.p.sourceReady <- s
 
 	frame := &gortsplib.InterleavedFrame{}
-	multiBuf := newMultiBuffer(3, sourceTCPReadBufferSize)
+	multiBuf := newMultiBuffer(2, sourceTCPReadBufferSize)
 
 	tcpConnDone := make(chan error)
 	go func() {