From: Jaroslav Kysela <perex@perex.cz>
Date: Tue, 5 Jan 2016 15:23:52 +0000 (+0100)
Subject: SAT>IP server: do not cancel RTP streaming when other TCP session is closed, fixes... 
X-Git-Tag: v4.2.1~1215
X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=2897cde28d0c4ba04606b372b75509bbfee4c002;p=thirdparty%2Ftvheadend.git

SAT>IP server: do not cancel RTP streaming when other TCP session is closed, fixes #3467
---

diff --git a/src/satip/rtsp.c b/src/satip/rtsp.c
index 8ee51e1d0..fcb695ab6 100644
--- a/src/satip/rtsp.c
+++ b/src/satip/rtsp.c
@@ -53,6 +53,7 @@ typedef struct session {
   int weight;
   int used_weight;
   http_connection_t *shutdown_on_close;
+  http_connection_t *tcp_data;
   int perm_lock;
   uint32_t nsession;
   char session[9];
@@ -595,6 +596,7 @@ pids:
                     rs->udp_rtcp ? rs->udp_rtcp->fd : -1,
                     rs->frontend, rs->findex, &rs->dmc_tuned,
                     &rs->pids, rs->perm_lock);
+    rs->tcp_data = rs->udp_rtp ? NULL : hc;
     if (!rs->pids.all && rs->pids.count == 0)
       mpegts_pid_add(&rs->pids, 0, MPS_WEIGHT_RAW);
     svc = (mpegts_service_t *)rs->subs->ths_raw_service;
@@ -1480,9 +1482,10 @@ rtsp_flush_requests(http_connection_t *hc)
     if (rs->shutdown_on_close == hc) {
       rtsp_close_session(rs);
       rtsp_free_session(rs);
-    } else {
-      if (rs->rtp_peer_port == RTSP_TCP_DATA)
-        satip_rtp_close((void *)(intptr_t)rs->stream);
+    }
+    if (rs->tcp_data == hc) {
+      satip_rtp_close((void *)(intptr_t)rs->stream);
+      rs->tcp_data = NULL;
     }
   }
   pthread_mutex_unlock(&rtsp_lock);
@@ -1556,6 +1559,8 @@ rtsp_close_session(session_t *rs)
   rs->udp_rtp = NULL;
   udp_close(rs->udp_rtcp);
   rs->udp_rtcp = NULL;
+  rs->shutdown_on_close = NULL;
+  rs->tcp_data = NULL;
   pthread_mutex_lock(&global_lock);
   mpegts_pid_reset(&rs->pids);
   rtsp_clean(rs);