From 8e6e16b0aaf96da648cd3ef0c6b1179d260eb5a2 Mon Sep 17 00:00:00 2001
From: aler9 <46489434+aler9@users.noreply.github.com>
Date: Sun, 19 Jul 2020 18:43:39 +0200
Subject: [PATCH] do not print error messages when a source is terminated

---
 source.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/source.go b/source.go
index 9a5717b5..763ed259 100644
--- a/source.go
+++ b/source.go
@@ -339,7 +339,7 @@ func (s *source) runTcp(conn *gortsplib.ConnClient) bool {
 
 	frame := &gortsplib.InterleavedFrame{}
 
-	chanConnError := make(chan struct{})
+	tcpConnDone := make(chan error, 1)
 	go func() {
 		for {
 			frame.Content = s.readBuf.swap()
@@ -347,9 +347,8 @@ func (s *source) runTcp(conn *gortsplib.ConnClient) bool {
 
 			err := conn.ReadFrame(frame)
 			if err != nil {
-				s.log("ERR: %s", err)
-				close(chanConnError)
-				break
+				tcpConnDone <- err
+				return
 			}
 
 			s.rtcpReceivers[frame.TrackId].OnFrame(frame.StreamType, frame.Content)
@@ -370,7 +369,8 @@ outer:
 			ret = false
 			break outer
 
-		case <-chanConnError:
+		case err := <-tcpConnDone:
+			s.log("ERR: %s", err)
 			ret = true
 			break outer