Updated HISTORY.

Prefer section pids.
Add a preliminary RTP-over-TCP support.
2023-10-10 11:37:42 +00:00 · 2016-12-18 17:28:41 +02:00 · 2016-12-16 08:18:41 +02:00 · 2016-12-15 23:48:22 +02:00 · 2016-12-15 08:11:34 +02:00 · 2016-12-14 00:39:22 +02:00
30 changed files with 200 additions and 719 deletions
--- a/37
+++ b/37
@@ -156,40 +156,3 @@ VDR Plugin 'satip' Revision History
 - Added multicast and RTP-over-TCP support.
 - Added support for activating/deactivating server on-the-fly.
 - Extended command-line parameters for setting server quirks.
-
-2017-08-15: Version 2.2.5
-
- Added Polish translation (Thanks to Tomasz Nowak).
- Updated Catalan and Spanish translations (Thanks to Gabriel Bonich).
- Added support for KATHREIN SatIP Server (Thanks to kavanu).
- Added support for FRITZ!Box 6490 Cable (Thanks to 9000h).
- Updated FRITZ!WLAN Repeater DVB-C detection for the latest firmware (Thanks to 9000h).
- Added GCC7 compatibility (Thanks to Sascha Kuehndel).
-
-
-===================================
-VDR Plugin 'satip' Revision History
-===================================
-
-2016-12-18: Version 2.3.0
-
- Updated for vdr-2.3.1.
- Updated German translation (Thanks to Frank Neumann).
- Fixed Panasonic CXW804 support (Thanks to Tobias Grimm).
- Fixed C++11 support (Thanks to Tobias Grimm).
- Fixed server assigment with source validation (Thanks to Patrick Boettcher).
- Added configurable RTP/RTCP ports (Thanks to chriszero).
- Added support for X-SATIP-RTSP-Port header.
- Added multicast and RTP-over-TCP support.
- Added support for activating/deactivating server on-the-fly.
- Extended command-line parameters for setting server quirks.
-
-2017-08-15: Version 2.3.1
-
- Updated for vdr-2.3.7 (Thanks to Klaus Schmidinger).
- Added Polish translation (Thanks to Tomasz Nowak).
- Updated Catalan and Spanish translations (Thanks to Gabriel Bonich).
- Added support for KATHREIN SatIP Server (Thanks to kavanu).
- Added support for FRITZ!Box 6490 Cable (Thanks to 9000h).
- Updated FRITZ!WLAN Repeater DVB-C detection for the latest firmware (Thanks to 9000h).
- Added GCC7 compatibility (Thanks to Sascha Kuehndel).
--- a/27
+++ b/27
@@ -88,15 +88,14 @@ all: $(SOFILE) i18n
 ### Implicit rules:

 %.o: %.c
-	@echo CC $@
-	$(Q)$(CXX) $(CXXFLAGS) -c $(DEFINES) $(INCLUDES) -o $@ $<
+	$(CXX) $(CXXFLAGS) -c $(DEFINES) $(INCLUDES) -o $@ $<

 ### Dependencies:

 MAKEDEP = $(CXX) -MM -MG
 DEPFILE = .dependencies
 $(DEPFILE): Makefile
-	$(Q)$(MAKEDEP) $(CXXFLAGS) $(DEFINES) $(INCLUDES) $(OBJS:%.o=%.c) > $@
+	@$(MAKEDEP) $(CXXFLAGS) $(DEFINES) $(INCLUDES) $(OBJS:%.o=%.c) > $@

 -include $(DEPFILE)

@@ -109,21 +108,17 @@ I18Nmsgs  = $(addprefix $(DESTDIR)$(LOCDIR)/, $(addsuffix /LC_MESSAGES/vdr-$(PLU
 I18Npot   = $(PODIR)/$(PLUGIN).pot

 %.mo: %.po
-	@echo MO $@
-	$(Q)msgfmt -c -o $@ $<
+	msgfmt -c -o $@ $<

 $(I18Npot): $(wildcard *.c)
-	@echo GT $@
-	$(Q)xgettext -C -cTRANSLATORS --no-wrap --no-location -k -ktr -ktrNOOP --package-name=vdr-$(PLUGIN) --package-version=$(VERSION) --msgid-bugs-address='<see README>' -o $@ `ls $^`
+	xgettext -C -cTRANSLATORS --no-wrap --no-location -k -ktr -ktrNOOP --package-name=vdr-$(PLUGIN) --package-version=$(VERSION) --msgid-bugs-address='<see README>' -o $@ `ls $^`

 %.po: $(I18Npot)
-	@echo PO $@
-	$(Q)msgmerge -U --no-wrap --no-location --backup=none -q -N $@ $<
+	msgmerge -U --no-wrap --no-location --backup=none -q -N $@ $<
 	@touch $@

 $(I18Nmsgs): $(DESTDIR)$(LOCDIR)/%/LC_MESSAGES/vdr-$(PLUGIN).mo: $(PODIR)/%.mo
-	@echo IN $@
-	$(Q)install -D -m644 $< $@
+	install -D -m644 $< $@

 .PHONY: i18n
 i18n: $(I18Nmo) $(I18Npot)
@@ -133,13 +128,11 @@ install-i18n: $(I18Nmsgs)
 ### Targets:

 $(SOFILE): $(OBJS)
-	@echo LD $@
-	$(Q)$(CXX) $(CXXFLAGS) $(LDFLAGS) -shared $(OBJS) $(LIBS) -o $@
-	$(Q)$(STRIP) $@
+	$(CXX) $(CXXFLAGS) $(LDFLAGS) -shared $(OBJS) $(LIBS) -o $@
+	@$(STRIP) $@

 install-lib: $(SOFILE)
-	@echo IN $(DESTDIR)$(LIBDIR)/$^.$(APIVERSION)
-	$(Q)install -D $^ $(DESTDIR)$(LIBDIR)/$^.$(APIVERSION)
+	install -D $^ $(DESTDIR)$(LIBDIR)/$^.$(APIVERSION)

 install-conf:
 	@mkdir -p $(DESTDIR)$(CFGDIR)/plugins/$(PLUGIN)
@@ -160,4 +153,4 @@ clean:

 .PHONY: cppcheck
 cppcheck:
-	$(Q)cppcheck --language=c++ --enable=all -v -f $(OBJS:%.o=%.c)
+	@cppcheck --language=c++ --enable=all -v -f $(OBJS:%.o=%.c)
--- a/15
+++ b/15
@@ -52,7 +52,7 @@ separated list of "<ipaddress>|<model>|<description>" entries. The model
 consists of a DVB system (DVBS2,DVBT2,DVBT,DVBC) and number of available
 frontends separated by a hyphen:

-vdr -P 'satip -s [<srcaddress>@]<ipaddress>[:<port>]|<model>[:<filter>]|<description>[:<quirk>];...'
+vdr -P 'satip -s <ipaddress>[:<port>]|<model>[:<filter>]|<description>[:<quirk>];...'
 vdr -P 'satip -s 192.168.0.1|DVBS2-2,DVBT2-2|OctopusNet'
 vdr -P 'satip -s 192.168.0.1|DVBS2-4|OctopusNet;192.168.0.2|DVBT2-4|minisatip:0x18'
 vdr -P 'satip -s 192.168.0.1:554|DVBS2-2:S19.2E|OctopusNet;192.168.0.2:8554|DVBS2-4:S19.2E,S1W|minisatip'
@@ -159,19 +159,6 @@ Notes:
  from their webpage: http://www.inverto.tv/support/
  An update to a newer firmware should be offered afterwards.

- If you are experiencing glitches in the video stream, one possible
-  reason can be buffer overflows in RTP receive sockets. You can verify
-  this by checking "receive buffer errors" counter by running "netstat -s"
-  command. If the counter increases every time a video glitch happens,
-  you should try to tweak the RTP receive buffer size with the "--rcvbuf"
-  (-r) plugin parameter.
-  A good starting point for the buffer size is to double the operating
-  system default value until errors disappear or the maximum value is
-  reached. You can check these values in Linux by checking the kernel
-  parameters:
-  $ cat /proc/sys/net/core/rmem_default
-  $ cat /proc/sys/net/core/rmem_max
-
 Acknowledgements:

 - Big thanks to Digital Devices GmbH for providing the Octopus Net
--- a/config.c
+++ b/config.c
@@ -22,8 +22,7 @@ cSatipConfig::cSatipConfig(void)
  transportModeM(eTransportModeUnicast),
  detachedModeM(false),
  disableServerQuirksM(false),
-  useSingleModelServersM(false),
-  rtpRcvBufSizeM(0)
+  useSingleModelServersM(false)
 {
  for (unsigned int i = 0; i < ELEMENTS(cicamsM); ++i)
      cicamsM[i] = 0;
--- a/config.h
+++ b/config.h
@@ -28,7 +28,6 @@ private:
  int cicamsM[MAX_CICAM_COUNT];
  int disabledSourcesM[MAX_DISABLED_SOURCES_COUNT];
  int disabledFiltersM[SECTION_FILTER_TABLE_SIZE];
-  size_t rtpRcvBufSizeM;

 public:
  enum eOperatingMode {
@@ -90,7 +89,6 @@ public:
  int GetDisabledFilters(unsigned int indexP) const;
  unsigned int GetPortRangeStart(void) const { return portRangeStartM; }
  unsigned int GetPortRangeStop(void) const { return portRangeStopM; }
-  size_t GetRtpRcvBufSize(void) const { return rtpRcvBufSizeM; }

  void SetOperatingMode(unsigned int operatingModeP) { operatingModeM = operatingModeP; }
  void SetTraceMode(unsigned int modeP) { traceModeM = (modeP & eTraceModeMask); }
@@ -106,7 +104,6 @@ public:
  void SetDisabledFilters(unsigned int indexP, int numberP);
  void SetPortRangeStart(unsigned int rangeStartP) { portRangeStartM = rangeStartP; }
  void SetPortRangeStop(unsigned int rangeStopP) { portRangeStopM = rangeStopP; }
-  void SetRtpRcvBufSize(size_t sizeP) { rtpRcvBufSizeM = sizeP; }
 };

 extern cSatipConfig SatipConfig;
--- a/detectsatip.py
+++ b/detectsatip.py
@@ -1,91 +0,0 @@
-#!/usr/bin/env python2
-# -*- coding: utf-8 -*-
-""" Simple tool to detect SAT>IP devices as JSON.
-"""
-import json
-import socket
-import sys
-import xml.etree.ElementTree as ET
-import requests
-
-SSDP_BIND = '0.0.0.0'
-SSDP_ADDR = '239.255.255.250'
-SSDP_PORT = 1900
-SSDP_MX = 1
-SSDP_ST = 'urn:ses-com:device:SatIPServer:1'
-SSDP_REQUEST = 'M-SEARCH * HTTP/1.1\r\n' + \
-               'HOST: %s:%d\r\n' % (SSDP_ADDR, SSDP_PORT) + \
-               'MAN: "ssdp:discover"\r\n' + \
-               'MX: %d\r\n' % (SSDP_MX, ) + \
-               'ST: %s\r\n' % (SSDP_ST, ) + \
-               '\r\n'
-
-
-def parse_satip_xml(data):
-    """ Parse SAT>IP XML data.
-
-    Args:
-        data (str): XML input data..
-
-    Returns:
-        dict: Parsed SAT>IP device name and frontend information.
-    """
-    result = {'name': '', 'frontends': {}}
-    if data:
-        root = ET.fromstring(data)
-        name = root.find('.//*/{urn:schemas-upnp-org:device-1-0}friendlyName')
-        result['name'] = name.text
-        satipcap = root.find('.//*/{urn:ses-com:satip}X_SATIPCAP')
-        caps = {}
-        for system in satipcap.text.split(","):
-            cap = system.split("-")
-            if cap:
-                count = int(cap[1])
-                if cap[0] in caps:
-                    count = count + caps[cap[0]]
-                caps[cap[0]] = count
-        result['frontends'] = caps
-    return result
-
-
-def detect_satip_devices():
-    """ Detect available SAT>IP devices by sending a broadcast message.
-
-    Returns:
-        list: Found SAT>IP devices.
-    """
-    urls = []
-    devices = []
-    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
-    sock.setblocking(0)
-    sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
-    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-    try:
-        sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
-    except BaseException:
-        pass
-    sock.settimeout(1)
-    sock.bind((SSDP_BIND, SSDP_PORT))
-    sock.sendto(SSDP_REQUEST, (SSDP_ADDR, SSDP_PORT))
-    try:
-        while 1:
-            data = sock.recv(1024)
-            if data:
-                for row in data.split('\r\n'):
-                    if 'LOCATION:' in row:
-                        url = row.replace('LOCATION:', '').strip()
-                        if url in urls:
-                            continue
-                        urls.append(url)
-                        info = requests.get(url, timeout=2)
-                        devices.append(parse_satip_xml(info.text))
-            else:
-                break
-    except BaseException:
-        pass
-    sock.close()
-    return devices
-
-
-if __name__ == '__main__':
-    json.dump(detect_satip_devices(), fp=sys.stdout, sort_keys=True, indent=2)
--- a/device.c
+++ b/device.c
@@ -15,17 +15,14 @@

 static cSatipDevice * SatipDevicesS[SATIP_MAX_DEVICES] = { NULL };

-cMutex cSatipDevice::mutexS = cMutex();
-
 cSatipDevice::cSatipDevice(unsigned int indexP)
 : deviceIndexM(indexP),
-  bytesDeliveredM(0),
+  isPacketDeliveredM(false),
  isOpenDvrM(false),
-  checkTsBufferM(false),
  deviceNameM(*cString::sprintf("%s %d", *DeviceType(), deviceIndexM)),
  channelM(),
  createdM(0),
-  tunedM()
+  mutexM()
 {
  unsigned int bufsize = (unsigned int)SATIP_BUFFER_SIZE;
  bufsize -= (bufsize % TS_SIZE);
@@ -45,8 +42,6 @@ cSatipDevice::cSatipDevice(unsigned int indexP)
 cSatipDevice::~cSatipDevice()
 {
  debug1("%s [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
-  // Release immediately any pending conditional wait
-  tunedM.Broadcast();
  // Stop section handler
  StopSectionHandler();
  DELETE_POINTER(pSectionFilterHandlerM);
@@ -108,8 +103,12 @@ cString cSatipDevice::GetSatipStatus(void)
         bool live = (device == cDevice::ActualDevice());
         bool lock = device->HasLock();
         const cChannel *channel = device->GetCurrentlyTunedTransponder();
+#if defined(APIVERSNUM) && APIVERSNUM >= 20301
         LOCK_TIMERS_READ;
         for (const cTimer *timer = Timers->First(); timer; timer = Timers->Next(timer)) {
+#else
+         for (cTimer *timer = Timers.First(); timer; timer = Timers.Next(timer)) {
+#endif
             if (timer->Recording()) {
                cRecordControl *control = cRecordControls::GetRecordControl(timer);
                if (control && control->Device() == device)
@@ -138,14 +137,20 @@ cString cSatipDevice::GetSatipStatus(void)
 cString cSatipDevice::GetGeneralInformation(void)
 {
  debug16("%s [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
+#if defined(APIVERSNUM) && APIVERSNUM >= 20301
  LOCK_CHANNELS_READ;
+#endif
  return cString::sprintf("SAT>IP device: %d\nCardIndex: %d\nStream: %s\nSignal: %s\nStream bitrate: %s\n%sChannel: %s\n",
                          deviceIndexM, CardIndex(),
                          pTunerM ? *pTunerM->GetInformation() : "",
                          pTunerM ? *pTunerM->GetSignalStatus() : "",
                          pTunerM ? *pTunerM->GetTunerStatistic() : "",
                          *GetBufferStatistic(),
+#if defined(APIVERSNUM) && APIVERSNUM >= 20301
                          *Channels->GetByNumber(cDevice::CurrentChannel())->ToText());
+#else
+                          *Channels.GetByNumber(cDevice::CurrentChannel())->ToText());
+#endif
 }

 cString cSatipDevice::GetPidsInformation(void)
@@ -216,21 +221,6 @@ bool cSatipDevice::AvoidRecording(void) const
  return SatipConfig.IsOperatingModeLow();
 }

-bool cSatipDevice::SignalStats(int &Valid, double *Strength, double *Cnr, double *BerPre, double *BerPost, double *Per, int *Status) const
-{
-  debug16("%s [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
-  Valid = DTV_STAT_VALID_NONE;
-  if (Strength && pTunerM) {
-     *Strength =  pTunerM->SignalStrengthDBm();
-     Valid |= DTV_STAT_VALID_STRENGTH;
-     }
-  if (Status) {
-     *Status = HasLock() ? (DTV_STAT_HAS_SIGNAL | DTV_STAT_HAS_CARRIER | DTV_STAT_HAS_VITERBI | DTV_STAT_HAS_SYNC | DTV_STAT_HAS_LOCK) : DTV_STAT_HAS_NONE;
-     Valid |= DTV_STAT_VALID_STATUS;
-     }
-  return Valid != DTV_STAT_VALID_NONE;
-}
-
 int cSatipDevice::SignalStrength(void) const
 {
  debug16("%s [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
@@ -349,7 +339,6 @@ bool cSatipDevice::MaySwitchTransponder(const cChannel *channelP) const

 bool cSatipDevice::SetChannelDevice(const cChannel *channelP, bool liveViewP)
 {
-  cMutexLock MutexLock(&mutexS);  // Global lock to prevent any simultaneous zapping
  debug9("%s (%d, %d) [device %u]", __PRETTY_FUNCTION__, channelP ? channelP->Number() : -1, liveViewP, deviceIndexM);
  if (channelP) {
     cDvbTransponderParameters dtp(channelP->Parameters());
@@ -367,8 +356,6 @@ bool cSatipDevice::SetChannelDevice(const cChannel *channelP, bool liveViewP)
     if (pTunerM && pTunerM->SetSource(server, channelP->Transponder(), *params, deviceIndexM)) {
        channelM = *channelP;
        deviceNameM = cString::sprintf("%s %d %s", *DeviceType(), deviceIndexM, *cSatipDiscover::GetInstance()->GetServerString(server));
-        // Wait for actual channel tuning to prevent simultaneous frontend allocation failures
-        tunedM.TimedWait(mutexS, eTuningTimeoutMs);
        return true;
        }
     }
@@ -380,13 +367,6 @@ bool cSatipDevice::SetChannelDevice(const cChannel *channelP, bool liveViewP)
  return false;
 }

-void cSatipDevice::SetChannelTuned(void)
-{
-  debug9("%s () [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
-  // Release immediately any pending conditional wait
-  tunedM.Broadcast();
-}
-
 bool cSatipDevice::SetPid(cPidHandle *handleP, int typeP, bool onP)
 {
  debug12("%s (%d, %d, %d) [device %u]", __PRETTY_FUNCTION__, handleP ? handleP->pid : -1, typeP, onP, deviceIndexM);
@@ -425,7 +405,7 @@ void cSatipDevice::CloseFilter(int handleP)
 bool cSatipDevice::OpenDvr(void)
 {
  debug9("%s [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
-  bytesDeliveredM = 0;
+  isPacketDeliveredM = false;
  tsBufferM->Clear();
  if (pTunerM)
     pTunerM->Open();
@@ -511,17 +491,13 @@ bool cSatipDevice::IsIdle(void)
  return !Receiving();
 }

-uchar *cSatipDevice::GetData(int *availableP, bool checkTsBuffer)
+uchar *cSatipDevice::GetData(int *availableP)
 {
  debug16("%s [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
  if (isOpenDvrM && tsBufferM) {
     int count = 0;
-     if (bytesDeliveredM) {
-        tsBufferM->Del(bytesDeliveredM);
-        bytesDeliveredM = 0;
-        }
-     if (checkTsBuffer && tsBufferM->Available() < TS_SIZE)
-        return NULL;
+     if (isPacketDeliveredM)
+        SkipData(TS_SIZE);
     uchar *p = tsBufferM->Get(count);
     if (p && count >= TS_SIZE) {
        if (*p != TS_SYNC_BYTE) {
@@ -535,7 +511,7 @@ uchar *cSatipDevice::GetData(int *availableP, bool checkTsBuffer)
           info("Skipped %d bytes to sync on TS packet", count);
           return NULL;
           }
-        bytesDeliveredM = TS_SIZE;
+        isPacketDeliveredM = true;
        if (availableP)
           *availableP = count;
        // Update pid statistics
@@ -549,7 +525,8 @@ uchar *cSatipDevice::GetData(int *availableP, bool checkTsBuffer)
 void cSatipDevice::SkipData(int countP)
 {
  debug16("%s [device %u]", __PRETTY_FUNCTION__, deviceIndexM);
-  bytesDeliveredM = countP;
+  tsBufferM->Del(countP);
+  isPacketDeliveredM = false;
  // Update buffer statistics
  AddBufferStatistic(countP, tsBufferM->Available());
 }
@@ -563,12 +540,11 @@ bool cSatipDevice::GetTSPacket(uchar *&dataP)
     if (cCamSlot *cs = CamSlot()) {
        if (cs->WantsTsData()) {
           int available;
-           dataP = GetData(&available, checkTsBufferM);
-           if (!dataP)
-              available = 0;
-           dataP = cs->Decrypt(dataP, available);
-           SkipData(available);
-           checkTsBufferM = dataP != NULL;
+           dataP = GetData(&available);
+           if (dataP) {
+              dataP = cs->Decrypt(dataP, available);
+              SkipData(available);
+              }
           return true;
           }
        }
--- a/device.h
+++ b/device.h
@@ -18,7 +18,7 @@
 class cSatipDevice : public cDevice, public cSatipPidStatistics, public cSatipBufferStatistics, public cSatipDeviceIf {
  // static ones
 public:
-  static cMutex mutexS;
+  static unsigned int deviceCount;
  static bool Initialize(unsigned int DeviceCount);
  static void Shutdown(void);
  static unsigned int Count(void);
@@ -28,20 +28,18 @@ public:
  // private parts
 private:
  enum {
-    eReadyTimeoutMs  = 2000, // in milliseconds
-    eTuningTimeoutMs = 1000  // in milliseconds
+    eReadyTimeoutMs = 2000 // in milliseconds
  };
  unsigned int deviceIndexM;
-  int bytesDeliveredM;
+  bool isPacketDeliveredM;
  bool isOpenDvrM;
-  bool checkTsBufferM;
  cString deviceNameM;
  cChannel channelM;
  cRingBufferLinear *tsBufferM;
  cSatipTuner *pTunerM;
  cSatipSectionFilterHandler *pSectionFilterHandlerM;
  cTimeMs createdM;
-  cCondVar tunedM;
+  cMutex mutexM;

  // constructor & destructor
 public:
@@ -65,7 +63,6 @@ public:
  virtual cString DeviceType(void) const;
  virtual cString DeviceName(void) const;
  virtual bool AvoidRecording(void) const;
-  virtual bool SignalStats(int &Valid, double *Strength = NULL, double *Cnr = NULL, double *BerPre = NULL, double *BerPost = NULL, double *Per = NULL, int *Status = NULL) const;
  virtual int SignalStrength(void) const;
  virtual int SignalQuality(void) const;

@@ -85,7 +82,7 @@ protected:

  // for recording
 private:
-  uchar *GetData(int *availableP = NULL, bool checkTsBuffer = false);
+  uchar *GetData(int *availableP = NULL);
  void SkipData(int countP);

 protected:
@@ -101,7 +98,7 @@ public:

  // for transponder lock
 public:
-  virtual bool HasLock(int timeoutMsP = 0) const;
+  virtual bool HasLock(int timeoutMsP) const;

  // for common interface
 public:
@@ -110,7 +107,6 @@ public:
  // for internal device interface
 public:
  virtual void WriteData(u_char *bufferP, int lengthP);
-  virtual void SetChannelTuned(void);
  virtual int GetId(void);
  virtual int GetPmtPid(void);
  virtual int GetCISlot(void);
--- a/deviceif.h
+++ b/deviceif.h
@@ -13,7 +13,6 @@ public:
  cSatipDeviceIf() {}
  virtual ~cSatipDeviceIf() {}
  virtual void WriteData(u_char *bufferP, int lengthP) = 0;
-  virtual void SetChannelTuned(void) = 0;
  virtual int GetId(void) = 0;
  virtual int GetPmtPid(void) = 0;
  virtual int GetCISlot(void) = 0;
--- a/discover.c
+++ b/discover.c
@@ -30,10 +30,10 @@ bool cSatipDiscover::Initialize(cSatipDiscoverServers *serversP)
 {
  debug1("%s", __PRETTY_FUNCTION__);
  if (instanceS) {
-     if (serversP) {
-        for (cSatipDiscoverServer *s = serversP->First(); s; s = serversP->Next(s))
-            instanceS->AddServer(s->SrcAddress(), s->IpAddress(), s->IpPort(), s->Model(), s->Filters(), s->Description(), s->Quirk());
-        }
+       if (serversP) {
+          for (cSatipDiscoverServer *s = serversP->First(); s; s = serversP->Next(s))
+              instanceS->AddServer(s->IpAddress(), s->IpPort(), s->Model(), s->Filters(), s->Description(), s->Quirk());
+          }
     else
        instanceS->Activate();
     }
@@ -271,12 +271,12 @@ void cSatipDiscover::ParseDeviceInfo(const char *addrP, const int portP)
        model = modelNode.text().as_string("DVBS2-1");
     }
 #endif
-  AddServer(NULL, addrP, portP, model, NULL, desc, cSatipServer::eSatipQuirkNone);
+  AddServer(addrP, portP, model, NULL, desc, cSatipServer::eSatipQuirkNone);
 }

-void cSatipDiscover::AddServer(const char *srcAddrP, const char *addrP, const int portP, const char *modelP, const char *filtersP, const char *descP, const int quirkP)
+void cSatipDiscover::AddServer(const char *addrP, const int portP, const char *modelP, const char *filtersP, const char *descP, const int quirkP)
 {
-  debug1("%s (%s, %s, %d, %s, %s, %s, %d)", __PRETTY_FUNCTION__, srcAddrP, addrP, portP, modelP, filtersP, descP, quirkP);
+  debug1("%s (%s, %d, %s, %s, %s, %d)", __PRETTY_FUNCTION__, addrP, portP, modelP, filtersP, descP, quirkP);
  cMutexLock MutexLock(&mutexM);
  if (SatipConfig.GetUseSingleModelServers() && modelP && !isempty(modelP)) {
     int n = 0;
@@ -285,9 +285,9 @@ void cSatipDiscover::AddServer(const char *srcAddrP, const char *addrP, const in
     while (r) {
           r = skipspace(r);
           cString desc = cString::sprintf("%s #%d", !isempty(descP) ? descP : "MyBrokenHardware", n++);
-           cSatipServer *tmp = new cSatipServer(srcAddrP, addrP, portP, r, filtersP, desc, quirkP);
+           cSatipServer *tmp = new cSatipServer(addrP, portP, r, filtersP, desc, quirkP);
           if (!serversM.Update(tmp)) {
-              info("Adding server '%s|%s|%s' Bind: %s Filters: %s CI: %s Quirks: %s", tmp->Address(), tmp->Model(), tmp->Description(), !isempty(tmp->SrcAddress()) ? tmp->SrcAddress() : "default", !isempty(tmp->Filters()) ? tmp->Filters() : "none", tmp->HasCI() ? "yes" : "no", tmp->HasQuirk() ? tmp->Quirks() : "none");
+              info("Adding server '%s|%s|%s' Filters: %s CI: %s Quirks: %s", tmp->Address(), tmp->Model(), tmp->Description(), !isempty(tmp->Filters()) ? tmp->Filters() : "none", tmp->HasCI() ? "yes" : "no", tmp->HasQuirk() ? tmp->Quirks() : "none");
              serversM.Add(tmp);
              }
           else
@@ -297,9 +297,9 @@ void cSatipDiscover::AddServer(const char *srcAddrP, const char *addrP, const in
     FREE_POINTER(p);
     }
  else {
-     cSatipServer *tmp = new cSatipServer(srcAddrP, addrP, portP, modelP, filtersP, descP, quirkP);
+     cSatipServer *tmp = new cSatipServer(addrP, portP, modelP, filtersP, descP, quirkP);
     if (!serversM.Update(tmp)) {
-        info("Adding server '%s|%s|%s' Bind: %s Filters: %s CI: %s Quirks: %s", tmp->Address(), tmp->Model(), tmp->Description(), !isempty(tmp->SrcAddress()) ? tmp->SrcAddress() : "default", !isempty(tmp->Filters()) ? tmp->Filters() : "none", tmp->HasCI() ? "yes" : "no", tmp->HasQuirk() ? tmp->Quirks() : "none");
+        info("Adding server '%s|%s|%s' Filters: %s CI: %s Quirks: %s", tmp->Address(), tmp->Model(), tmp->Description(), !isempty(tmp->Filters()) ? tmp->Filters() : "none", tmp->HasCI() ? "yes" : "no", tmp->HasQuirk() ? tmp->Quirks() : "none");
        serversM.Add(tmp);
        }
     else
@@ -391,13 +391,6 @@ bool cSatipDiscover::HasServerCI(cSatipServer *serverP)
  return serversM.HasCI(serverP);
 }

-cString cSatipDiscover::GetSourceAddress(cSatipServer *serverP)
-{
-  debug16("%s", __PRETTY_FUNCTION__);
-  cMutexLock MutexLock(&mutexM);
-  return serversM.GetSrcAddress(serverP);
-}
-
 cString cSatipDiscover::GetServerAddress(cSatipServer *serverP)
 {
  debug16("%s", __PRETTY_FUNCTION__);
--- a/discover.h
+++ b/discover.h
@@ -23,19 +23,17 @@ class cSatipDiscoverServer : public cListObject {
 private:
  int ipPortM;
  int quirkM;
-  cString srcAddressM;
  cString ipAddressM;
  cString descriptionM;
  cString modelM;
  cString filtersM;
 public:
-  cSatipDiscoverServer(const char *srcAddressP, const char *ipAddressP, const int ipPortP, const char *modelP, const char *filtersP, const char *descriptionP, const int quirkP)
+  cSatipDiscoverServer(const char *ipAddressP, const int ipPortP, const char *modelP, const char *filtersP, const char *descriptionP, const int quirkP)
  {
-     srcAddressM = srcAddressP; ipAddressM = ipAddressP; ipPortM = ipPortP; modelM = modelP; filtersM = filtersP; descriptionM = descriptionP; quirkM = quirkP;
+    ipAddressM = ipAddressP; ipPortM = ipPortP; modelM = modelP; filtersM = filtersP; descriptionM = descriptionP; quirkM = quirkP;
  }
  int IpPort(void)              { return ipPortM; }
  int Quirk(void)               { return quirkM; }
-  const char *SrcAddress(void)  { return *srcAddressM; }
  const char *IpAddress(void)   { return *ipAddressM; }
  const char *Model(void)       { return *modelM; }
  const char *Filters(void)     { return *filtersM; }
@@ -71,7 +69,7 @@ private:
  void Deactivate(void);
  int ParseRtspPort(void);
  void ParseDeviceInfo(const char *addrP, const int portP);
-  void AddServer(const char *srcAddrP, const char *addrP, const int portP, const char *modelP, const char *filtersP, const char *descP, const int quirkP);
+  void AddServer(const char *addrP, const int portP, const char *modelP, const char *filtersP, const char *descP, const int quirkP);
  void Fetch(const char *urlP);
  // constructor
  cSatipDiscover();
@@ -100,7 +98,6 @@ public:
  bool IsServerQuirk(cSatipServer *serverP, int quirkP);
  bool HasServerCI(cSatipServer *serverP);
  cString GetServerAddress(cSatipServer *serverP);
-  cString GetSourceAddress(cSatipServer *serverP);
  int GetServerPort(cSatipServer *serverP);
  cString GetServerList(void);
  int NumProvidedSystems(void);
--- a/param.c
+++ b/param.c
@@ -166,7 +166,6 @@ cString GetTransponderUrlParameters(const cChannel *channelP)
     if ((channelP->Rid() % 100) > 0)
                q += snprintf(q,       STBUFLEFT, "&fe=%d",           channelP->Rid() % 100);
     ST(" S *") q += snprintf(q,       STBUFLEFT, "src=%d&",          ((src > 0) && (src <= 255)) ? src : 1);
-     if (freq >= 0L)
                q += snprintf(q,       STBUFLEFT, "freq=%s",          *dtoa(freq, "%lg"));
     ST(" S *") q += snprintf(q,       STBUFLEFT, "&pol=%c",          tolower(dtp.Polarization()));
     ST(" S *") q += PrintUrlString(q, STBUFLEFT, dtp.RollOff(),      SatipRollOffValues);
--- a/po/ca_ES.po
+++ b/po/ca_ES.po
@@ -1,14 +1,14 @@
 # VDR plugin language source file.
-# Copyright (C) 2007-2017 Rolf Ahrenberg
+# Copyright (C) 2007-2016 Rolf Ahrenberg
 # This file is distributed under the same license as the satip package.
-# Gabriel Bonich, 2014-2017
+# Gabriel Bonich, 2014-2015
 #
 msgid ""
 msgstr ""
-"Project-Id-Version: vdr-satip 2.3.1\n"
+"Project-Id-Version: vdr-satip 2.2.4\n"
 "Report-Msgid-Bugs-To: <see README>\n"
-"POT-Creation-Date: 2017-08-15 08:15+0300\n"
-"PO-Revision-Date: 2017-08-15 08:15+0300\n"
+"POT-Creation-Date: 2016-12-18 12:18+0200\n"
+"PO-Revision-Date: 2016-12-18 12:18+0200\n"
 "Last-Translator: Gabriel Bonich <gbonich@gmail.com>\n"
 "Language-Team: Catalan <vdr@linuxtv.org>\n"
 "Language: ca\n"
@@ -86,13 +86,13 @@ msgid "high"
 msgstr "Alt"

 msgid "Unicast"
-msgstr "Unicast"
+msgstr ""

 msgid "Multicast"
-msgstr "Multicast"
+msgstr ""

 msgid "RTP-over-TCP"
-msgstr "RTP-per sobre-TCP"
+msgstr ""

 msgid "Button$Devices"
 msgstr "Dispositius"
@@ -188,7 +188,7 @@ msgid "Define an ill-behaving filter to be blacklisted."
 msgstr "Definir un filtre mal comportar a la llista negra."

 msgid "Transport mode"
-msgstr "Tipus de Transmissió"
+msgstr ""

 msgid ""
 "Define which transport mode shall be used.\n"
--- a/po/de_DE.po
+++ b/po/de_DE.po
@@ -1,14 +1,14 @@
 # VDR plugin language source file.
-# Copyright (C) 2007-2017 Rolf Ahrenberg
+# Copyright (C) 2007-2016 Rolf Ahrenberg
 # This file is distributed under the same license as the satip package.
-# Frank Neumann, 2014-2017
+# Frank Neumann, 2014-2016
 #
 msgid ""
 msgstr ""
-"Project-Id-Version: vdr-satip 2.3.1\n"
+"Project-Id-Version: vdr-satip 2.2.4\n"
 "Report-Msgid-Bugs-To: <see README>\n"
-"POT-Creation-Date: 2017-08-15 08:15+0300\n"
-"PO-Revision-Date: 2017-08-15 08:15+0300\n"
+"POT-Creation-Date: 2016-12-18 12:18+0200\n"
+"PO-Revision-Date: 2016-12-18 12:18+0200\n"
 "Last-Translator: Frank Neumann <fnu@yavdr.org>\n"
 "Language-Team: German <vdr@linuxtv.org>\n"
 "Language: de\n"
--- a/po/es_ES.po
+++ b/po/es_ES.po
@@ -1,14 +1,14 @@
 # VDR plugin language source file.
-# Copyright (C) 2007-2017 Rolf Ahrenberg
+# Copyright (C) 2007-2016 Rolf Ahrenberg
 # This file is distributed under the same license as the satip package.
-# Gabriel Bonich, 2014-2017
+# Gabriel Bonich, 2014-2015
 #
 msgid ""
 msgstr ""
-"Project-Id-Version: vdr-satip 2.3.1\n"
+"Project-Id-Version: vdr-satip 2.2.4\n"
 "Report-Msgid-Bugs-To: <see README>\n"
-"POT-Creation-Date: 2017-08-15 08:15+0300\n"
-"PO-Revision-Date: 2017-08-15 08:15+0300\n"
+"POT-Creation-Date: 2016-12-18 12:18+0200\n"
+"PO-Revision-Date: 2016-12-18 12:18+0200\n"
 "Last-Translator: Gabriel Bonich <gbonich@gmail.com>\n"
 "Language-Team: Spanish <vdr@linuxtv.org>\n"
 "Language: es\n"
@@ -86,13 +86,13 @@ msgid "high"
 msgstr "Alto"

 msgid "Unicast"
-msgstr "Unicast"
+msgstr ""

 msgid "Multicast"
-msgstr "Multicast"
+msgstr ""

 msgid "RTP-over-TCP"
-msgstr "RTP-antes que-TCP"
+msgstr ""

 msgid "Button$Devices"
 msgstr "Dispositivos"
@@ -188,7 +188,7 @@ msgid "Define an ill-behaving filter to be blacklisted."
 msgstr "Define un filtro para poner en la lista negra."

 msgid "Transport mode"
-msgstr "Tipo de Transmisión"
+msgstr ""

 msgid ""
 "Define which transport mode shall be used.\n"
--- a/po/fi_FI.po
+++ b/po/fi_FI.po
@@ -1,14 +1,14 @@
 # VDR plugin language source file.
-# Copyright (C) 2007-2017 Rolf Ahrenberg
+# Copyright (C) 2007-2016 Rolf Ahrenberg
 # This file is distributed under the same license as the satip package.
-# Rolf Ahrenberg, 2015-2017
+# Rolf Ahrenberg, 2015-2016
 #
 msgid ""
 msgstr ""
-"Project-Id-Version: vdr-satip 2.3.1\n"
+"Project-Id-Version: vdr-satip 2.2.4\n"
 "Report-Msgid-Bugs-To: <see README>\n"
-"POT-Creation-Date: 2017-08-15 08:15+0300\n"
-"PO-Revision-Date: 2017-08-15 08:15+0300\n"
+"POT-Creation-Date: 2016-12-18 12:18+0200\n"
+"PO-Revision-Date: 2016-12-18 12:18+0200\n"
 "Last-Translator: Rolf Ahrenberg\n"
 "Language-Team: Finnish <vdr@linuxtv.org>\n"
 "Language: fi\n"
--- a/po/pl_PL.po
+++ b/po/pl_PL.po
@@ -1,206 +0,0 @@
-# VDR plugin language source file.
-# Copyright (C) 2007-2017 Rolf Ahrenberg
-# This file is distributed under the same license as the vdr-satip package.
-# Tomasz Maciej Nowak, 2017
-#
-msgid ""
-msgstr ""
-"Project-Id-Version: vdr-satip 2.3.1\n"
-"Report-Msgid-Bugs-To: <see README>\n"
-"POT-Creation-Date: 2017-08-15 08:15+0300\n"
-"PO-Revision-Date: 2017-08-15 08:15+0300\n"
-"Last-Translator: Tomasz Maciej Nowak <tomek_n@o2.pl>\n"
-"Language-Team: Polish <vdr@linuxtv.org>\n"
-"Language: pl_PL\n"
-"MIME-Version: 1.0\n"
-"Content-Type: text/plain; charset=UTF-8\n"
-"Content-Transfer-Encoding: 8bit\n"
-"X-Generator: Poedit 1.8.11\n"
-
-msgid "PAT (0x00)"
-msgstr "PAT (0x00)"
-
-msgid "NIT (0x40)"
-msgstr "NIT (0x40)"
-
-msgid "SDT (0x42)"
-msgstr "SDT (0x42)"
-
-msgid "EIT (0x4E/0x4F/0x5X/0x6X)"
-msgstr "EIT (0x4E/0x4F/0x5X/0x6X)"
-
-msgid "TDT (0x70)"
-msgstr "TDT (0x70)"
-
-msgid "SAT>IP information not available!"
-msgstr "Informacja o SAT>IP niedostępna!"
-
-msgid "SAT>IP Devices"
-msgstr "Urządzenia SAT>IP"
-
-msgid "SAT>IP Server"
-msgstr "Serwer SAT>IP"
-
-msgid "Address"
-msgstr "Adres"
-
-msgid "Model"
-msgstr "Model"
-
-msgid "Description"
-msgstr "Opis"
-
-msgid "CI extension"
-msgstr "Rozszerzenie CI"
-
-msgid "Creation date"
-msgstr "Data produkcji"
-
-msgid "SAT>IP Device Status"
-msgstr "Status urządzenia SAT>IP"
-
-msgid "SAT>IP Information"
-msgstr "SAT>IP - informacje"
-
-msgid "General"
-msgstr "Główne"
-
-msgid "Pids"
-msgstr "Pidy"
-
-msgid "Filters"
-msgstr "Filtry"
-
-msgid "Bits/bytes"
-msgstr "Bity/bajty"
-
-msgid "off"
-msgstr "wyłączone"
-
-msgid "low"
-msgstr "niski"
-
-msgid "normal"
-msgstr "normalny"
-
-msgid "high"
-msgstr "wysoki"
-
-msgid "Unicast"
-msgstr "Unicast"
-
-msgid "Multicast"
-msgstr "Multicast"
-
-msgid "RTP-over-TCP"
-msgstr "RTP-over-TCP"
-
-msgid "Button$Devices"
-msgstr "Urządzenia"
-
-msgid "Operating mode"
-msgstr "Tryb pracy"
-
-msgid ""
-"Define the used operating mode for all SAT>IP devices:\n"
-"\n"
-"off - devices are disabled\n"
-"low - devices are working at the lowest priority\n"
-"normal - devices are working within normal parameters\n"
-"high - devices are working at the highest priority"
-msgstr ""
-"Określa tryb pracy wszystkich urządzeń SAT>IP:\n"
-"\n"
-"wyłączone - urządzenia są wyłączone\n"
-"niski - urządzenia pracują z najniższym priorytetem\n"
-"normalny - urządzenia pracują z normalnymi parametrami\n"
-"wysoki - urządzenia pracują z najwyższym priorytetem"
-
-msgid "Enable CI extension"
-msgstr "Włącz rozszerzenie CI"
-
-msgid ""
-"Define whether a CI extension shall be used.\n"
-"\n"
-"This setting enables integrated CI/CAM handling found in some SAT>IP hardware (e.g. Digital Devices OctopusNet)."
-msgstr ""
-"Określa czy korzystać z rozszerzenia CI.\n"
-"\n"
-"To ustawienie włącza obsługę dostępnego czytnika CI/CAM w niektórych urządzeniach SAT>IP (np. Digital Devices OctopusNet)."
-
-msgid "CI/CAM"
-msgstr "CI/CAM"
-
-msgid ""
-"Define a desired CAM type for the CI slot.\n"
-"\n"
-"The '---' option lets SAT>IP hardware do the auto-selection."
-msgstr ""
-"Określa typ modułu CAM w czytniku CI.\n"
-"\n"
-"Opcja '---' pozwala urządzeniu SAT>IP automatycznie wybrać typ."
-
-msgid "Enable EPG scanning"
-msgstr "Włącz skanowanie EPG"
-
-msgid ""
-"Define whether the EPG background scanning shall be used.\n"
-"\n"
-"This setting disables the automatic EIT scanning functionality for all SAT>IP devices."
-msgstr ""
-"Określa czy przeprowadzać skanowanie EPG w tle.\n"
-"\n"
-"To ustawienie wyłącza funkcję automatycznego skanowania EIT dla wszystkich urządzeń SAT>IP."
-
-msgid "Disabled sources"
-msgstr "Wyłączone źródła"
-
-msgid "none"
-msgstr "brak"
-
-msgid ""
-"Define number of sources to be disabled.\n"
-"\n"
-"SAT>IP servers might not have all satellite positions available and such sources can be blacklisted here."
-msgstr ""
-"Określa liczbę wyłączonych źródeł.\n"
-"\n"
-"Serwery SAT>IP mogą nie mieć dostępu do niektórych pozycji satelitarnych, więc tutaj można je wyłączyć."
-
-msgid "Define a source to be blacklisted."
-msgstr "Określ źródła do wyłączenia."
-
-msgid "Disabled filters"
-msgstr "Wyłączone filtry"
-
-msgid ""
-"Define number of section filters to be disabled.\n"
-"\n"
-"Certain section filters might cause some unwanted behaviour to VDR such as time being falsely synchronized. By blacklisting the filters here, useful section data can be left intact for VDR to process."
-msgstr ""
-"Określa liczbę wyłączonych filtrów sekcji.\n"
-"\n"
-"Niektóre filtry sekcji mogą powodować niezamierzone efekty w VDR, takie jak zły czas synchronizacji. Poprzez wyłączenie niektórych filtrów, użyteczne dane sekcji będą dostępne do przetworzenia dla VDR."
-
-msgid "Filter"
-msgstr "Filtr"
-
-msgid "Define an ill-behaving filter to be blacklisted."
-msgstr "Określa filtry powodujące zakłócenia, które mają być wyłączone."
-
-msgid "Transport mode"
-msgstr "Tryb"
-
-msgid ""
-"Define which transport mode shall be used.\n"
-"\n"
-"Unicast, Multicast, RTP-over-TCP"
-msgstr ""
-"Określa tryb transmisji.\n"
-"Unicast, Multicast, RTP-over-TCP."
-
-msgid "Active SAT>IP servers:"
-msgstr "Aktywne serwery SAT>IP:"
-
-msgid "Help"
-msgstr "Pomoc"
--- a/rtp.c
+++ b/rtp.c
@@ -14,8 +14,7 @@
 #include "rtp.h"

 cSatipRtp::cSatipRtp(cSatipTunerIf &tunerP)
-: cSatipSocket(SatipConfig.GetRtpRcvBufSize()),
-  tunerM(tunerP),
+: tunerM(tunerP),
  bufferLenM(eRtpPacketReadCount * eMaxUdpPacketSizeB),
  bufferM(MALLOC(unsigned char, bufferLenM)),
  lastErrorReportM(0),
@@ -46,7 +45,7 @@ void cSatipRtp::Close(void)

  sequenceNumberM = -1;
  if (packetErrorsM) {
-     info("Detected %d RTP packet error%s [device %d]", packetErrorsM, packetErrorsM == 1 ? "": "s", tunerM.GetId());
+     info("Detected %d RTP packet errors [device %d]", packetErrorsM, tunerM.GetId());
     packetErrorsM = 0;
     lastErrorReportM = time(NULL);
     }
@@ -81,7 +80,7 @@ int cSatipRtp::GetHeaderLength(unsigned char *bufferP, unsigned int lengthP)
        else if ((sequenceNumberM >= 0) && (((sequenceNumberM + 1) % 0xFFFF) != seq)) {
           packetErrorsM++;
           if (time(NULL) - lastErrorReportM > eReportIntervalS) {
-              info("Detected %d RTP packet error%s [device %d]", packetErrorsM, packetErrorsM == 1 ? "": "s", tunerM.GetId());
+              info("Detected %d RTP packet errors [device %d]", packetErrorsM, tunerM.GetId());
              packetErrorsM = 0;
              lastErrorReportM = time(NULL);
              }
--- a/rtsp.c
+++ b/rtsp.c
@@ -164,6 +164,9 @@ void cSatipRtsp::Create(void)
     SATIP_CURL_EASY_SETOPT(handleM, CURLOPT_TIMEOUT_MS, (long)eConnectTimeoutMs);
     SATIP_CURL_EASY_SETOPT(handleM, CURLOPT_CONNECTTIMEOUT_MS, (long)eConnectTimeoutMs);

+     // Limit download speed (bytes/s)
+     SATIP_CURL_EASY_SETOPT(handleM, CURLOPT_MAX_RECV_SPEED_LARGE, eMaxDownloadSpeedMBits * 131072L);
+
     // Set user-agent
     SATIP_CURL_EASY_SETOPT(handleM, CURLOPT_USERAGENT, *cString::sprintf("vdr-%s/%s (device %d)", PLUGIN_NAME_I18N, VERSION, tunerM.GetId()));
     }
@@ -190,22 +193,6 @@ void cSatipRtsp::Reset(void)
  Create();
 }

-bool cSatipRtsp::SetInterface(const char *bindAddrP)
-{
-  debug1("%s (%s) [device %d]", __PRETTY_FUNCTION__, bindAddrP, tunerM.GetId());
-  bool result = true;
-  CURLcode res = CURLE_OK;
-
-  if (handleM && !isempty(bindAddrP)) {
-     SATIP_CURL_EASY_SETOPT(handleM, CURLOPT_INTERFACE, *cString::sprintf("host!%s", bindAddrP));
-     }
-  else {
-     SATIP_CURL_EASY_SETOPT(handleM, CURLOPT_INTERFACE, NULL);
-     }
-
-  return result;
-}
-
 bool cSatipRtsp::Options(const char *uriP)
 {
  debug1("%s (%s) [device %d]", __PRETTY_FUNCTION__, uriP, tunerM.GetId());
--- a/rtsp.h
+++ b/rtsp.h
@@ -27,6 +27,7 @@ private:

  enum {
    eConnectTimeoutMs      = 1500,  // in milliseconds
+    eMaxDownloadSpeedMBits = 20,    // in megabits per second
  };

  cSatipTunerIf &tunerM;
@@ -58,7 +59,6 @@ public:
  cString GetActiveMode(void);
  cString RtspUnescapeString(const char *strP);
  void Reset(void);
-  bool SetInterface(const char *bindAddrP);
  bool Options(const char *uriP);
  bool Setup(const char *uriP, int rtpPortP, int rtcpPortP, bool useTcpP);
  bool SetSession(const char *sessionP);
--- a/satip.c
+++ b/satip.c
@@ -5,7 +5,6 @@
 *
 */

-#include <ctype.h>
 #include <getopt.h>
 #include <vdr/plugin.h>
 #include "common.h"
@@ -20,15 +19,15 @@
 #warning "CURL version >= 7.36.0 is recommended"
 #endif

-#if defined(APIVERSNUM) && APIVERSNUM < 20307
-#error "VDR-2.3.7 API version or greater is required!"
+#if defined(APIVERSNUM) && APIVERSNUM < 20200
+#error "VDR-2.2.0 API version or greater is required!"
 #endif

 #ifndef GITVERSION
 #define GITVERSION ""
 #endif

-       const char VERSION[]     = "2.3.1" GITVERSION;
+       const char VERSION[]     = "2.2.4" GITVERSION;
 static const char DESCRIPTION[] = trNOOP("SAT>IP Devices");

 class cPluginSatip : public cPlugin {
@@ -91,8 +90,7 @@ const char *cPluginSatip::CommandLineHelp(void)
         "  -S, --single                  set the single model server mode on\n"
         "  -n, --noquirks                disable autodetection of the server quirks\n"
         "  -p, --portrange=<start>-<end> set a range of ports used for the RT[C]P server\n"
-         "                                a minimum of 2 ports per device is required.\n"
-         "  -r, --rcvbuf                  override the size of the RTP receive buffer in bytes\n";
+         "                                a minimum of 2 ports per device is required.\n";
 }

 bool cPluginSatip::ProcessArgs(int argc, char *argv[])
@@ -104,7 +102,6 @@ bool cPluginSatip::ProcessArgs(int argc, char *argv[])
    { "trace",    required_argument, NULL, 't' },
    { "server",   required_argument, NULL, 's' },
    { "portrange",required_argument, NULL, 'p' },
-    { "rcvbuf",   required_argument, NULL, 'r' },
    { "detach",   no_argument,       NULL, 'D' },
    { "single",   no_argument,       NULL, 'S' },
    { "noquirks", no_argument,       NULL, 'n' },
@@ -114,7 +111,7 @@ bool cPluginSatip::ProcessArgs(int argc, char *argv[])
  cString server;
  cString portrange;
  int c;
-  while ((c = getopt_long(argc, argv, "d:t:s:p:r:DSn", long_options, NULL)) != -1) {
+  while ((c = getopt_long(argc, argv, "d:t:s:p:DSn", long_options, NULL)) != -1) {
    switch (c) {
      case 'd':
           deviceCountM = strtol(optarg, NULL, 0);
@@ -137,9 +134,6 @@ bool cPluginSatip::ProcessArgs(int argc, char *argv[])
      case 'p':
           portrange = optarg;
           break;
-      case 'r':
-           SatipConfig.SetRtpRcvBufSize(strtol(optarg, NULL, 0));
-           break;
      default:
           return false;
      }
@@ -238,7 +232,7 @@ void cPluginSatip::ParseServer(const char *paramP)
  while (r) {
        r = skipspace(r);
        debug3("%s server[%d]=%s", __PRETTY_FUNCTION__, n, r);
-        cString sourceAddr, serverAddr, serverModel, serverFilters, serverDescription;
+        cString serverAddr, serverModel, serverFilters, serverDescription;
        int serverQuirk = cSatipServer::eSatipQuirkNone;
        int serverPort = SATIP_DEFAULT_RTSP_PORT;
        int n2 = 0;
@@ -249,14 +243,8 @@ void cPluginSatip::ParseServer(const char *paramP)
              switch (n2++) {
                     case 0:
                          {
-                          char *r3 = strchr(r2, '@');
-                          if (r3) {
-                             *r3 = 0;
-                             sourceAddr = r2;
-                             r2 = r3 + 1;
-                             }
                          serverAddr = r2;
-                          r3 = strchr(r2, ':');
+                          char *r3 = strchr(r2, ':');
                          if (r3) {
                             serverPort = strtol(r3 + 1, NULL, 0);
                             serverAddr = serverAddr.Truncate(r3 - r2);
@@ -289,10 +277,10 @@ void cPluginSatip::ParseServer(const char *paramP)
              r2 = strtok_r(NULL, "|", &s2);
              }
        if (*serverAddr && *serverModel && *serverDescription) {
-           debug1("%s srcaddr=%s ipaddr=%s port=%d model=%s (%s) desc=%s (%d)", __PRETTY_FUNCTION__, *sourceAddr, *serverAddr, serverPort, *serverModel, *serverFilters, *serverDescription, serverQuirk);
+           debug1("%s ipaddr=%s port=%d model=%s (%s) desc=%s (%d)", __PRETTY_FUNCTION__, *serverAddr, serverPort, *serverModel, *serverFilters, *serverDescription, serverQuirk);
           if (!serversM)
              serversM = new cSatipDiscoverServers();
-           serversM->Add(new cSatipDiscoverServer(*sourceAddr, *serverAddr, serverPort, *serverModel, *serverFilters, *serverDescription, serverQuirk));
+           serversM->Add(new cSatipDiscoverServer(*serverAddr, serverPort, *serverModel, *serverFilters, *serverDescription, serverQuirk));
           }
        ++n;
        r = strtok_r(NULL, ";", &s);
--- a/sectionfilter.c
+++ b/sectionfilter.c
@@ -102,11 +102,8 @@ int cSatipSectionFilter::Filter(void)
     if (doneqM && !neq)
        return 0;

-     if (ringBufferM && (secLenM > 0)) {
-        cFrame* section = new cFrame(secBufM, secLenM);
-        if (!ringBufferM->Put(section))
-           DELETE_POINTER(section);
-        }
+     if (ringBufferM && (secLenM > 0))
+        ringBufferM->Put(new cFrame(secBufM, secLenM));
     }
  return 0;
 }
@@ -129,7 +126,7 @@ int cSatipSectionFilter::CopyDump(const uint8_t *bufP, uint8_t lenP)
  if (tsFeedpM + lenP > eDmxMaxSectionFeedSize)
     lenP = (uint8_t)(eDmxMaxSectionFeedSize - tsFeedpM);

-  if (lenP == 0)
+  if (lenP <= 0)
     return 0;

  memcpy(secBufBaseM + tsFeedpM, bufP, lenP);
@@ -144,7 +141,7 @@ int cSatipSectionFilter::CopyDump(const uint8_t *bufP, uint8_t lenP)

  for (n = 0; secBufpM + 2 < limit; ++n) {
      uint16_t seclen = GetLength(secBufM);
-      if ((seclen > eDmxMaxSectionSize) || ((seclen + secBufpM) > limit))
+      if ((seclen <= 0) || (seclen > eDmxMaxSectionSize) || ((seclen + secBufpM) > limit))
         return 0;
      secLenM = seclen;
      if (pusiSeenM)
@@ -212,28 +209,27 @@ void cSatipSectionFilter::Process(const uint8_t* dataP)
     }
 }

-void cSatipSectionFilter::Send(void)
+bool cSatipSectionFilter::Send(void)
 {
+  bool result = false;
  cFrame *section = ringBufferM->Get();
  if (section) {
     uchar *data = section->Data();
     int count = section->Count();
     if (data && (count > 0) && (socketM[1] >= 0) && (socketM[0] >= 0)) {
-        if (send(socketM[1], data, count, MSG_EOR) > 0) {
+        ssize_t len = send(socketM[1], data, count, MSG_EOR);
+        ERROR_IF(len < 0 && errno != EAGAIN, "send()");
+        if (len > 0) {
+           ringBufferM->Drop(section);
+           result = !!ringBufferM->Available();
           // Update statistics
-           AddSectionStatistic(count, 1);
+           AddSectionStatistic(len, 1);
           }
-        else if (errno != EAGAIN)
-          error("failed to send section data (%i bytes) [device=%d]", count, deviceIndexM);
        }
-     ringBufferM->Drop(section);
     }
+  return result;
 }

-int cSatipSectionFilter::Available(void) const
-{
-  return ringBufferM->Available();
-}

 cSatipSectionFilterHandler::cSatipSectionFilterHandler(int deviceIndexP, unsigned int bufferLenP)
 : cThread(cString::sprintf("SATIP#%d section handler", deviceIndexP)),
@@ -271,73 +267,54 @@ cSatipSectionFilterHandler::~cSatipSectionFilterHandler()
      Delete(i);
 }

-void cSatipSectionFilterHandler::SendAll(void)
-{
-  cMutexLock MutexLock(&mutexM);
-  bool pendingData;
-  do {
-     pendingData = false;
-
-     // zero polling structures
-     memset(pollFdsM, 0, sizeof(pollFdsM));
-
-     // assemble all handlers to poll (use -1 to ignore handlers)
-     for (unsigned int i = 0; i < eMaxSecFilterCount; ++i) {
-         if (filtersM[i] && filtersM[i]->Available() != 0) {
-            pollFdsM[i].fd = filtersM[i]->GetFd();
-            pollFdsM[i].events = POLLOUT;
-            pendingData = true;
-            }
-         else
-            pollFdsM[i].fd = -1;
-         }
-
-     // exit if there isn't any pending data or we time out
-     if (!pendingData || poll(pollFdsM, eMaxSecFilterCount, eSecFilterSendTimeoutMs) <= 0)
-        return;
-
-     // send data (if available)
-     for (unsigned int i = 0; i < eMaxSecFilterCount && pendingData; ++i) {
-         if (pollFdsM[i].revents & POLLOUT)
-            filtersM[i]->Send();
-         }
-  } while (pendingData);
-}
-
 void cSatipSectionFilterHandler::Action(void)
 {
  debug1("%s Entering [device %d]", __PRETTY_FUNCTION__, deviceIndexM);
+  bool processed = false;
  // Do the thread loop
  while (Running()) {
-        uchar *p = NULL;
-        int len = 0;
-        // Process all pending TS packets
-        while ((p  = ringBufferM->Get(len)) != NULL) {
-              if (p && (len >= TS_SIZE)) {
-                 if (*p != TS_SYNC_BYTE) {
-                    for (int i = 1; i < len; ++i) {
-                        if (p[i] == TS_SYNC_BYTE) {
-                           len = i;
-                           break;
-                           }
-                        }
-                    ringBufferM->Del(len);
-                    debug1("%s Skipped %d bytes to sync on TS packet [device %d]", __PRETTY_FUNCTION__, len, deviceIndexM);
-                    continue;
-                    }
-                    // Process TS packet through all filters
-                    mutexM.Lock();
-                    for (unsigned int i = 0; i < eMaxSecFilterCount; ++i) {
-                        if (filtersM[i])
-                           filtersM[i]->Process(p);
-                        }
-                    mutexM.Unlock();
-                    ringBufferM->Del(TS_SIZE);
-                    }
-                }
-
        // Send demuxed section packets through all filters
-        SendAll();
+        bool retry = false;
+        mutexM.Lock();
+        for (unsigned int i = 0; i < eMaxSecFilterCount; ++i) {
+            if (filtersM[i] && filtersM[i]->Send())
+               retry = true;
+            }
+        mutexM.Unlock();
+        if (retry)
+           continue;
+        // Read one TS packet
+        if (ringBufferM) {
+           int len = 0;
+           if (processed) {
+              ringBufferM->Del(TS_SIZE);
+              processed = false;
+              }
+           uchar *p = ringBufferM->Get(len);
+           if (p && (len >= TS_SIZE)) {
+              if (*p != TS_SYNC_BYTE) {
+                 for (int i = 1; i < len; ++i) {
+                     if (p[i] == TS_SYNC_BYTE) {
+                        len = i;
+                        break;
+                        }
+                     }
+                 ringBufferM->Del(len);
+                 debug1("%s Skipped %d bytes to sync on TS packet [device %d]", __PRETTY_FUNCTION__, len, deviceIndexM);
+                 continue;
+                 }
+              // Process TS packet through all filters
+              mutexM.Lock();
+              for (unsigned int i = 0; i < eMaxSecFilterCount; ++i) {
+                  if (filtersM[i])
+                     filtersM[i]->Process(p);
+                  }
+              mutexM.Unlock();
+              processed = true;
+              continue;
+              }
+           }
+        cCondWait::SleepMs(10); // to avoid busy loop and reduce cpu load
        }
  debug1("%s Exiting [device %d]", __PRETTY_FUNCTION__, deviceIndexM);
 }
--- a/sectionfilter.h
+++ b/sectionfilter.h
@@ -8,7 +8,6 @@
 #ifndef __SATIP_SECTIONFILTER_H
 #define __SATIP_SECTIONFILTER_H

-#include <poll.h>
 #include <vdr/device.h>

 #include "common.h"
@@ -56,27 +55,23 @@ public:
  cSatipSectionFilter(int deviceIndexP, uint16_t pidP, uint8_t tidP, uint8_t maskP);
  virtual ~cSatipSectionFilter();
  void Process(const uint8_t* dataP);
-  void Send(void);
+  bool Send(void);
  int GetFd(void) { return socketM[0]; }
  uint16_t GetPid(void) const { return pidM; }
-  int Available(void) const;
 };

 class cSatipSectionFilterHandler : public cThread {
 private:
  enum {
-    eMaxSecFilterCount = 32,
-    eSecFilterSendTimeoutMs = 10
+    eMaxSecFilterCount = 32
  };
  cRingBufferLinear *ringBufferM;
  cMutex mutexM;
  int deviceIndexM;
  cSatipSectionFilter *filtersM[eMaxSecFilterCount];
-  struct pollfd pollFdsM[eMaxSecFilterCount];

  bool Delete(unsigned int indexP);
  bool IsBlackListed(u_short pidP, u_char tidP, u_char maskP) const;
-  void SendAll(void);

 protected:
  virtual void Action(void);
--- a/server.c
+++ b/server.c
@@ -80,9 +80,8 @@ bool cSatipFrontends::Detach(int deviceIdP, int transponderP)

 // --- cSatipServer -----------------------------------------------------------

-cSatipServer::cSatipServer(const char *srcAddressP, const char *addressP, const int portP, const char *modelP, const char *filtersP, const char *descriptionP, const int quirkP)
-: srcAddressM((srcAddressP && *srcAddressP) ? srcAddressP : ""),
-  addressM((addressP && *addressP) ? addressP : "0.0.0.0"),
+cSatipServer::cSatipServer(const char *addressP, const int portP, const char *modelP, const char *filtersP, const char *descriptionP, const int quirkP)
+: addressM((addressP && *addressP) ? addressP : "0.0.0.0"),
  modelM((modelP && *modelP) ? modelP : "DVBS-1"),
  filtersM((filtersP && *filtersP) ? filtersP : ""),
  descriptionM(!isempty(descriptionP) ? descriptionP : "MyBrokenHardware"),
@@ -117,43 +116,42 @@ cSatipServer::cSatipServer(const char *srcAddressP, const char *addressP, const
     // These devices contain a session id bug:
     // Inverto Airscreen Server IDL 400 ?
     // Elgato EyeTV Netstream 4Sat ?
-     if (strstr(*descriptionM, "GSSBOX") ||                    // Grundig Sat Systems GSS.box DSI 400
-         strstr(*descriptionM, "DIGIBIT") ||                   // Telestar Digibit R1
-         strstr(*descriptionM, "Triax SatIP Converter")        // Triax TSS 400
+     if (strstr(*descriptionM, "GSSBOX") ||             // Grundig Sat Systems GSS.box DSI 400
+         strstr(*descriptionM, "DIGIBIT") ||            // Telestar Digibit R1
+         strstr(*descriptionM, "Triax SatIP Converter") // Triax TSS 400
        )
        quirkM |= eSatipQuirkSessionId;
     // These devices contain support for RTP over TCP:
-     if (strstr(*descriptionM, "minisatip") ||                 // minisatip server
-         strstr(*descriptionM, "DVBViewer")                    // DVBViewer Media Server
+     if (strstr(*descriptionM, "minisatip") ||          // minisatip server
+         strstr(*descriptionM, "DVBViewer") ||          // DVBViewer Media Server
+         strstr(*descriptionM, "GSSBOX") ||             // Grundig Sat Systems GSS.box DSI 400
+         strstr(*descriptionM, "DIGIBIT") ||            // Telestar Digibit R1
+         strstr(*descriptionM, "Triax SatIP Converter") // Triax TSS 400
        )
        quirkM |= eSatipQuirkRtpOverTcp;
     // These devices contain a play (add/delpids) parameter bug:
-     if (strstr(*descriptionM, "FRITZ!Box 6490 Cable") ||      // FRITZ!Box 6490 Cable
-         strstr(*descriptionM, "FRITZ!WLAN Repeater DVB-C") || // FRITZ!WLAN Repeater DVB-C
-         strstr(*descriptionM, "fritzdvbc")                    // FRITZ!WLAN Repeater DVB-C (old firmware)
+     if (strstr(*descriptionM, "fritzdvbc")             // Fritz!WLAN Repeater DVB-C
        )
        quirkM |= eSatipQuirkPlayPids;
     // These devices contain a frontend locking bug:
-     if (strstr(*descriptionM, "FRITZ!Box 6490 Cable") ||      // FRITZ!Box 6490 Cable
-         strstr(*descriptionM, "FRITZ!WLAN Repeater DVB-C") || // FRITZ!WLAN Repeater DVB-C
-         strstr(*descriptionM, "fritzdvbc") ||                 // FRITZ!WLAN Repeater DVB-C (old firmware)
-         strstr(*descriptionM, "Schwaiger Sat>IP Server")      // Schwaiger MS41IP
+     if (strstr(*descriptionM, "fritzdvbc") ||            // Fritz!WLAN Repeater DVB-C
+         strstr(*descriptionM, "Schwaiger Sat>IP Server") // Schwaiger MS41IP
        )
        quirkM |= eSatipQuirkForceLock;
     // These devices support the X_PMT protocol extension
-     if (strstr(*descriptionM, "OctopusNet") ||                // Digital Devices OctopusNet
-         strstr(*descriptionM, "minisatip")                    // minisatip server
+     if (strstr(*descriptionM, "OctopusNet") ||         // Digital Devices OctopusNet
+         strstr(*descriptionM, "minisatip")             // minisatip server
        )
        quirkM |= eSatipQuirkCiXpmt;
     // These devices support the TNR protocol extension
-     if (strstr(*descriptionM, "DVBViewer")                    // DVBViewer Media Server
+     if (strstr(*descriptionM, "DVBViewer")             // DVBViewer Media Server
        )
        quirkM |= eSatipQuirkCiTnr;
     // These devices don't support auto-detection of pilot tones
-     if (strstr(*descriptionM, "GSSBOX") ||                    // Grundig Sat Systems GSS.box DSI 400
-         strstr(*descriptionM, "DIGIBIT") ||                   // Telestar Digibit R1
-         strstr(*descriptionM, "Triax SatIP Converter") ||     // Triax TSS 400
-         strstr(*descriptionM, "KATHREIN SatIP Server")        // Kathrein ExIP 414/E
+     if (strstr(*descriptionM, "GSSBOX") ||             // Grundig Sat Systems GSS.box DSI 400
+         strstr(*descriptionM, "DIGIBIT") ||            // Telestar Digibit R1
+         strstr(*descriptionM, "Triax SatIP Converter") // Triax TSS 400
+                                                        // Kathrein ExIP 414/E
        )
        quirkM |= eSatipQuirkForcePilot;
     }
@@ -448,18 +446,6 @@ void cSatipServers::Cleanup(uint64_t intervalMsP)
      }
 }

-cString cSatipServers::GetSrcAddress(cSatipServer *serverP)
-{
-  cString address = "";
-  for (cSatipServer *s = First(); s; s = Next(s)) {
-      if (s == serverP) {
-         address = s->SrcAddress();
-         break;
-         }
-      }
-  return address;
-}
-
 cString cSatipServers::GetAddress(cSatipServer *serverP)
 {
  cString address = "";
@@ -500,10 +486,7 @@ cString cSatipServers::List(void)
 {
  cString list = "";
  for (cSatipServer *s = First(); s; s = Next(s))
-      if (isempty(s->SrcAddress()))
-         list = cString::sprintf("%s%c %s|%s|%s\n", *list, s->IsActive() ? '+' : '-', s->Address(), s->Model(), s->Description());
-      else
-         list = cString::sprintf("%s%c %s@%s|%s|%s\n", *list, s->IsActive() ? '+' : '-', s->SrcAddress(), s->Address(), s->Model(), s->Description());
+      list = cString::sprintf("%s%c %s|%s|%s\n", *list, s->IsActive() ? '+' : '-', s->Address(), s->Model(), s->Description());
  return list;
 }

--- a/server.h
+++ b/server.h
@@ -57,7 +57,6 @@ private:
  enum {
    eSatipMaxSourceFilters = 16
  };
-  cString srcAddressM;
  cString addressM;
  cString modelM;
  cString filtersM;
@@ -85,7 +84,7 @@ public:
    eSatipQuirkForcePilot = 0x40,
    eSatipQuirkMask       = 0xFF
  };
-  cSatipServer(const char *srcAddressP, const char *addressP, const int portP, const char *modelP, const char *filtersP, const char *descriptionP, const int quirkP);
+  cSatipServer(const char *addressP, const int portP, const char *modelP, const char *filtersP, const char *descriptionP, const int quirkP);
  virtual ~cSatipServer();
  virtual int Compare(const cListObject &listObjectP) const;
  bool Assign(int deviceIdP, int sourceP, int systemP, int transponderP);
@@ -99,7 +98,6 @@ public:
  int GetModulesDVBC(void);
  int GetModulesDVBC2(void);
  void Activate(bool onOffP)    { activeM = onOffP; }
-  const char *SrcAddress(void)  { return *srcAddressM; }
  const char *Address(void)     { return *addressM; }
  const char *Model(void)       { return *modelM; }
  const char *Filters(void)     { return *filtersM; }
@@ -130,7 +128,6 @@ public:
  bool HasCI(cSatipServer *serverP);
  void Cleanup(uint64_t intervalMsP = 0);
  cString GetAddress(cSatipServer *serverP);
-  cString GetSrcAddress(cSatipServer *serverP);
  cString GetString(cSatipServer *serverP);
  int GetPort(cSatipServer *serverP);
  cString List(void);
--- a/setup.c
+++ b/setup.c
@@ -105,7 +105,7 @@ cSatipServerInfo::cSatipServerInfo(cSatipServer *serverP)
 : cOsdMenu(tr("SAT>IP Server"), 20),
  serverM(serverP),
  activeM(serverP && serverP->IsActive()),
-  addressM(serverP ? (isempty(serverP->SrcAddress()) ? serverP->Address() : *cString::sprintf("%s@%s", serverP->SrcAddress(), serverP->Address())) : "---"),
+  addressM(serverP ? serverP->Address() : "---"),
  modelM(serverP ? serverP->Model() : "---"),
  descriptionM(serverP ? serverP->Description() : "---"),
  ciExtensionM(serverP && serverP->HasCI() ? trVDR("yes") : trVDR("no")),
@@ -167,7 +167,7 @@ cSatipServerItem::cSatipServerItem(cSatipServer *serverP)
 {
  SetSelectable(true);
  // Must begin with a '#' character!
-  SetText(*cString::sprintf("%s %s (%s)\t%s", serverM->IsActive() ? "+" : "-", isempty(serverM->SrcAddress()) ? serverM->Address() : *cString::sprintf("%s@%s", serverM->SrcAddress(), serverM->Address()), serverM->Model(), serverM->Description()));
+  SetText(*cString::sprintf("%s %s (%s)\t%s", serverM->IsActive() ? "+" : "-", serverM->Address(), serverM->Model(), serverM->Description()));
 }

 void cSatipServerItem::SetMenuItem(cSkinDisplayMenu *displayMenuP, int indexP, bool currentP, bool selectableP)
--- a/socket.c
+++ b/socket.c
@@ -19,35 +19,13 @@
 #include "log.h"
 #include "socket.h"

-#if defined(__GLIBC__)
-  #if defined(__GLIBC_PREREQ)
-    #if !__GLIBC_PREREQ(2,12)
-      #define __SATIP_DISABLE_RECVMMSG__
-    #endif
-  #endif
-#endif
-
 cSatipSocket::cSatipSocket()
 : socketPortM(0),
  socketDescM(-1),
  isMulticastM(false),
  useSsmM(false),
  streamAddrM(htonl(INADDR_ANY)),
-  sourceAddrM(htonl(INADDR_ANY)),
-  rcvBufSizeM(0)
-{
-  debug1("%s", __PRETTY_FUNCTION__);
-  memset(&sockAddrM, 0, sizeof(sockAddrM));
-}
-
-cSatipSocket::cSatipSocket(size_t rcvBufSizeP)
-: socketPortM(0),
-  socketDescM(-1),
-  isMulticastM(false),
-  useSsmM(false),
-  streamAddrM(htonl(INADDR_ANY)),
-  sourceAddrM(htonl(INADDR_ANY)),
-  rcvBufSizeM(rcvBufSizeP)
+  sourceAddrM(htonl(INADDR_ANY))
 {
  debug1("%s", __PRETTY_FUNCTION__);
  memset(&sockAddrM, 0, sizeof(sockAddrM));
@@ -92,11 +70,6 @@ bool cSatipSocket::Open(const int portP, const bool reuseP)
     ERROR_IF_FUNC(setsockopt(socketDescM, SOL_IP, IP_PKTINFO, &yes, sizeof(yes)) < 0,
                   "setsockopt(IP_PKTINFO)", Close(), return false);
 #endif // __FreeBSD__
-     // Tweak receive buffer size if requested
-     if (rcvBufSizeM > 0) {
-        ERROR_IF_FUNC(setsockopt(socketDescM, SOL_SOCKET, SO_RCVBUF, &rcvBufSizeM, sizeof(rcvBufSizeM)) < 0,
-                      "setsockopt(SO_RCVBUF)", Close(), return false);
-     }
     // Bind socket
     memset(&sockAddrM, 0, sizeof(sockAddrM));
     sockAddrM.sin_family = AF_INET;
@@ -128,7 +101,7 @@ bool cSatipSocket::OpenMulticast(const int portP, const char *streamAddrP, const

 void cSatipSocket::Close(void)
 {
-  debug1("%s socketPort=%d", __PRETTY_FUNCTION__, socketPortM);
+  debug1("%s sockerPort=%d", __PRETTY_FUNCTION__, socketPortM);
  // Check if socket exists
  if (socketDescM >= 0) {
     Leave();
@@ -316,7 +289,7 @@ int cSatipSocket::ReadMulti(unsigned char *bufferAddrP, unsigned int *elementRec
     error("%s Invalid parameter(s)", __PRETTY_FUNCTION__);
     return -1;
     }
-#ifndef __SATIP_DISABLE_RECVMMSG__
+#if defined(__GLIBC_PREREQ) && __GLIBC_PREREQ(2,12)
  // Initialize iov and msgh structures
  struct mmsghdr mmsgh[elementCountP];
  struct iovec iov[elementCountP];
--- a/socket.h
+++ b/socket.h
@@ -19,15 +19,12 @@ private:
  bool useSsmM;
  in_addr_t streamAddrM;
  in_addr_t sourceAddrM;
-  size_t rcvBufSizeM;
-
  bool CheckAddress(const char *addrP, in_addr_t *inAddrP);
  bool Join(void);
  bool Leave(void);

 public:
  cSatipSocket();
-  explicit cSatipSocket(size_t rcvBufSizeP);
  virtual ~cSatipSocket();
  bool Open(const int portP = 0, const bool reuseP = false);
  bool OpenMulticast(const int portP, const char *streamAddrP, const char *sourceAddrP);
--- a/tuner.c
+++ b/tuner.c
@@ -40,7 +40,6 @@ cSatipTuner::cSatipTuner(cSatipDeviceIf &deviceP, unsigned int packetLenP)
  externalStateM(),
  timeoutM(eMinKeepAliveIntervalMs),
  hasLockM(false),
-  signalStrengthDBmM(0.0),
  signalStrengthM(-1),
  signalQualityM(-1),
  frontendIdM(-1),
@@ -127,7 +126,6 @@ void cSatipTuner::Action(void)
               break;
          case tsTuned:
               debug4("%s: tsTuned [device %d]", __PRETTY_FUNCTION__, deviceIdM);
-               deviceM->SetChannelTuned();
               reConnectM.Set(eConnectTimeoutMs);
               idleCheck.Set(eIdleCheckTimeoutMs);
               lastIdleStatus = false;
@@ -136,7 +134,6 @@ void cSatipTuner::Action(void)
                  // Quirk for devices without valid reception data
                  if (currentServerM.IsQuirk(cSatipServer::eSatipQuirkForceLock)) {
                     hasLockM = true;
-                     signalStrengthDBmM = eDefaultSignalStrengthDBm;
                     signalStrengthM = eDefaultSignalStrength;
                     signalQualityM = eDefaultSignalQuality;
                     }
@@ -225,14 +222,12 @@ bool cSatipTuner::Connect(void)
           return true;
           }
        }
-     else if (rtspM.SetInterface(nextServerM.IsValid() ? *nextServerM.GetSrcAddress() : NULL) && rtspM.Options(*connectionUri)) {
+     else if (rtspM.Options(*connectionUri)) {
        cString uri = cString::sprintf("%s?%s", *connectionUri, *streamParamM);
        bool useTcp = SatipConfig.IsTransportModeRtpOverTcp() && nextServerM.IsValid() && nextServerM.IsQuirk(cSatipServer::eSatipQuirkRtpOverTcp);
        // Flush any old content
        //rtpM.Flush();
        //rtcpM.Flush();
-        if (useTcp)
-           debug1("%s Requesting TCP [device %d]", __PRETTY_FUNCTION__, deviceIdM);
        if (rtspM.Setup(*uri, rtpM.Port(), rtcpM.Port(), useTcp)) {
           keepAliveM.Set(timeoutM);
           if (nextServerM.IsValid()) {
@@ -266,7 +261,6 @@ bool cSatipTuner::Disconnect(void)

  // Reset signal parameters
  hasLockM = false;
-  signalStrengthDBmM = 0.0;
  signalStrengthM = -1;
  signalQualityM = -1;
  frontendIdM = -1;
@@ -336,9 +330,8 @@ void cSatipTuner::ProcessApplicationData(u_char *bufferP, int lengthP)
        // No signal corresponds to 0
        c = strstr(c, ",");
        value = min(atoi(++c), 255);
-        signalStrengthDBmM = (value >= 0) ? 40.0 * (value - 32) / 192.0 - 65.0 : 0.0;
        // Scale value to 0-100
-        signalStrengthM = (value >= 0) ? value * 100 / 255 : -1;
+        signalStrengthM = (value >= 0) ? (value * 100 / 255) : -1;

        // lock:
        // lock Set to one of the following values:
@@ -392,8 +385,8 @@ void cSatipTuner::SetupTransport(int rtpPortP, int rtcpPortP, const char *stream
  // Adapt RTP to any transport media change
  if (multicast != rtpM.IsMulticast() || rtpPortP != rtpM.Port()) {
     cSatipPoller::GetInstance()->Unregister(rtpM);
+     rtpM.Close();
     if (rtpPortP >= 0) {
-        rtpM.Close();
        if (multicast)
           rtpM.OpenMulticast(rtpPortP, streamAddrP, sourceAddrP);
        else
@@ -404,12 +397,12 @@ void cSatipTuner::SetupTransport(int rtpPortP, int rtcpPortP, const char *stream
  // Adapt RTCP to any transport media change
  if (multicast != rtcpM.IsMulticast() || rtcpPortP != rtcpM.Port()) {
     cSatipPoller::GetInstance()->Unregister(rtcpM);
+     rtcpM.Close();
     if (rtcpPortP >= 0) {
-        rtcpM.Close();
        if (multicast)
-           rtcpM.OpenMulticast(rtcpPortP, streamAddrP, sourceAddrP);
+           rtcpM.OpenMulticast(rtpPortP, streamAddrP, sourceAddrP);
        else
-           rtcpM.Open(rtcpPortP);
+           rtcpM.Open(rtpPortP);
        cSatipPoller::GetInstance()->Register(rtcpM);
        }
     }
@@ -674,12 +667,6 @@ int cSatipTuner::SignalStrength(void)
  return signalStrengthM;
 }

-double cSatipTuner::SignalStrengthDBm(void)
-{
-  debug16("%s [device %d]", __PRETTY_FUNCTION__, deviceIdM);
-  return signalStrengthDBmM;
-}
-
 int cSatipTuner::SignalQuality(void)
 {
  debug16("%s [device %d]", __PRETTY_FUNCTION__, deviceIdM);
--- a/tuner.h
+++ b/tuner.h
@@ -69,7 +69,6 @@ public:
  void Set(cSatipServer *serverP, const int transponderP) { serverM = serverP; transponderM = transponderP; }
  void Reset(void) { serverM = NULL; transponderM = 0; }
  cString GetAddress(void) { return serverM ? cSatipDiscover::GetInstance()->GetServerAddress(serverM) : ""; }
-  cString GetSrcAddress(void) { return serverM ? cSatipDiscover::GetInstance()->GetSourceAddress(serverM) : ""; }
  int GetPort(void) { return serverM ? cSatipDiscover::GetInstance()->GetServerPort(serverM) : SATIP_DEFAULT_RTSP_PORT; }
  cString GetInfo(void) { return cString::sprintf("server=%s deviceid=%d transponder=%d", serverM ? "assigned" : "null", deviceIdM, transponderM); }
 };
@@ -78,17 +77,16 @@ class cSatipTuner : public cThread, public cSatipTunerStatistics, public cSatipT
 {
 private:
  enum {
-    eDummyPid                 = 100,
-    eDefaultSignalStrengthDBm = -25,
-    eDefaultSignalStrength    = 224,
-    eDefaultSignalQuality     = 15,
-    eSleepTimeoutMs           = 250,   // in milliseconds
-    eStatusUpdateTimeoutMs    = 1000,  // in milliseconds
-    ePidUpdateIntervalMs      = 250,   // in milliseconds
-    eConnectTimeoutMs         = 5000,  // in milliseconds
-    eIdleCheckTimeoutMs       = 15000, // in milliseconds
-    eTuningTimeoutMs          = 20000, // in milliseconds
-    eMinKeepAliveIntervalMs   = 30000  // in milliseconds
+    eDummyPid               = 100,
+    eDefaultSignalStrength  = 15,
+    eDefaultSignalQuality   = 224,
+    eSleepTimeoutMs         = 250,   // in milliseconds
+    eStatusUpdateTimeoutMs  = 1000,  // in milliseconds
+    ePidUpdateIntervalMs    = 250,   // in milliseconds
+    eConnectTimeoutMs       = 5000,  // in milliseconds
+    eIdleCheckTimeoutMs     = 15000, // in milliseconds
+    eTuningTimeoutMs        = 20000, // in milliseconds
+    eMinKeepAliveIntervalMs = 30000  // in milliseconds
  };
  enum eTunerState { tsIdle, tsRelease, tsSet, tsTuned, tsLocked };
  enum eStateMode { smInternal, smExternal };
@@ -116,7 +114,6 @@ private:
  cVector<eTunerState> externalStateM;
  int timeoutM;
  bool hasLockM;
-  double signalStrengthDBmM;
  int signalStrengthM;
  int signalQualityM;
  int frontendIdM;
@@ -151,7 +148,6 @@ public:
  bool Close(void);
  int FrontendId(void);
  int SignalStrength(void);
-  double SignalStrengthDBm(void);
  int SignalQuality(void);
  bool HasLock(void);
  cString GetSignalStatus(void);
Author	SHA1	Message	Date
Rolf Ahrenberg	6573c38fb6	Updated HISTORY.	2016-12-18 17:28:41 +02:00
Rolf Ahrenberg	581ac4966d	Prefer section pids.	2016-12-16 08:18:41 +02:00
Rolf Ahrenberg	99e366b261	Add a preliminary RTP-over-TCP support.	2016-12-15 23:48:22 +02:00
Frank Neumann	3b89dd4b01	Update German translations.	2016-12-15 08:11:34 +02:00
Rolf Ahrenberg	ee6ac0d48a	Add a preliminary multicast support.	2016-12-14 00:39:22 +02:00
Rolf Ahrenberg	e6c9776ec9	Add a new ForcePilot quirk.	2016-11-10 16:54:12 +02:00
Rolf Ahrenberg	7aef2a3dff	Update README.	2016-11-10 16:52:08 +02:00
Rolf Ahrenberg	61b56db909	Add command-line support for setting server quirks.	2016-10-09 18:55:12 +03:00
Rolf Ahrenberg	4c45787541	Add preliminary support for DVBViewer CI.	2016-09-11 13:13:24 +03:00
Rolf Ahrenberg	f65dca2910	Handle Out-of-Range responses as a normal operation.	2016-09-11 13:12:59 +03:00
Rolf Ahrenberg	db0c18ba33	Check source validity also in server assign (Thanks to Patrick Boettcher).	2016-07-31 12:02:31 +03:00
Rolf Ahrenberg	0f9e0014df	Add support for source filtering.	2016-07-30 13:43:57 +03:00
Rolf Ahrenberg	6bb7fb511b	Fix command-line examples to match defined quirks.	2016-07-23 17:38:28 +03:00
Rolf Ahrenberg	7815821824	Fix active device check.	2016-06-23 15:38:36 +03:00
Rolf Ahrenberg	bc481bcc4d	Add support for activating/deactivating server on-the-fly.	2016-06-22 22:49:46 +03:00
Rolf Ahrenberg	7289da9f41	Add support for RTP-over-TCP.	2016-06-21 23:03:39 +03:00
Rolf Ahrenberg	d5e0106d8e	Change EINTR handling in poller.	2016-06-05 14:20:50 +03:00
Rolf Ahrenberg	fe532e2248	Use 2MB ringbuffer per device.	2016-05-12 23:48:01 +03:00
Rolf Ahrenberg	b5483b9d77	Set SO_REUSEPORT only if it's defined.	2016-05-07 21:45:28 +03:00
Rolf Ahrenberg	fd23b0483a	Re-enable to reuse address for msearch protocol.	2016-04-11 23:06:03 +03:00
Rolf Ahrenberg	18c9b79533	Reset device name when the device is idling.	2016-03-19 20:37:21 +02:00
Rolf Ahrenberg	e4f560c66e	Fix statistics output a bit more.	2016-02-28 18:24:29 +02:00
Rolf Ahrenberg	57ea119d03	Fix statistics output.	2016-02-28 15:36:12 +02:00
Rolf Ahrenberg	ae8298d19a	Added support for X-SATIP-RTSP-Port header.	2016-02-27 17:32:27 +02:00
Tobias Grimm	b755dbf318	C++11 requires a mandatory space when concatenating string literals	2016-01-30 21:52:12 +02:00
Rolf Ahrenberg	8f12ce6f55	Add a missing device name update.	2016-01-30 21:51:49 +02:00
chriszero	9d5f7cc703	Make it possible to specify the rtp and rtcp ports this makes it possible to use the satip through a NAT (e.g. a docker bridged network)	2016-01-08 20:26:02 +02:00
Rolf Ahrenberg	c1a881ba94	Reorder also terrestrial and cable query parameters as introduced in the satip specification 1.2.2, although the ordering shouldn't matter according to it.	2016-01-08 20:25:44 +02:00
Tobias Grimm	165fd5b14a	Reorderd the transponder URL parameter in a way the Panasonic CXW804 expects them (src/freq/pol/ro/msys/mtype/plts/sr/fec) This only applies to DVB-S. DVB-C and DVB-T might need further tweaking. It's actually a bug of the Panasonic TV to expect the transponder parameters in a specific order in the query string, but for now this seems to be the most pragmatic workaround.	2016-01-08 20:25:04 +02:00