]> git.sesse.net Git - vlc/blobdiff - modules/access/rtp/rtp.c
RTP: audio/MPA needs to be packetized
[vlc] / modules / access / rtp / rtp.c
index 5028aa101f38f37cb8309316e06cf89374099ec5..112847693f275ec8a85cac7dda56139950ed8f9c 100644 (file)
@@ -4,7 +4,7 @@
  */
 /*****************************************************************************
  * Copyright (C) 2001-2005 the VideoLAN team
- * Copyright © 2007-2008 Rémi Denis-Courmont
+ * Copyright © 2007-2009 Rémi Denis-Courmont
  *
  * This library is free software; you can redistribute it and/or
  * modify it under the terms of the GNU General Public License
 #define RTP_CACHING_LONGTEXT N_( \
     "How long to wait for late RTP packets (and delay the performance)." )
 
+#define RTCP_PORT_TEXT N_("RTCP (local) port")
+#define RTCP_PORT_LONGTEXT N_( \
+    "RTCP packets will be received on this transport protocol port. " \
+    "If zero, multiplexed RTP/RTCP is used.")
+
 #define SRTP_KEY_TEXT N_("SRTP key (hexadecimal)")
 #define SRTP_KEY_LONGTEXT N_( \
     "RTP packets will be authenticated and deciphered "\
@@ -76,30 +81,34 @@ static void Close (vlc_object_t *);
  * Module descriptor
  */
 vlc_module_begin ()
-    set_shortname (_("RTP"))
-    set_description (_("(Experimental) Real-Time Protocol demuxer"))
+    set_shortname (N_("RTP"))
+    set_description (N_("Real-Time Protocol (RTP) input"))
     set_category (CAT_INPUT)
     set_subcategory (SUBCAT_INPUT_DEMUX)
     set_capability ("access_demux", 0)
     set_callbacks (Open, Close)
 
     add_integer ("rtp-caching", 1000, NULL, RTP_CACHING_TEXT,
-                 RTP_CACHING_LONGTEXT, true);
+                 RTP_CACHING_LONGTEXT, true)
+        change_integer_range (0, 65535)
+    add_integer ("rtcp-port", 0, NULL, RTCP_PORT_TEXT,
+                 RTCP_PORT_LONGTEXT, false)
         change_integer_range (0, 65535)
+        change_safe ()
     add_string ("srtp-key", "", NULL,
-                SRTP_KEY_TEXT, SRTP_KEY_LONGTEXT, false);
+                SRTP_KEY_TEXT, SRTP_KEY_LONGTEXT, false)
     add_string ("srtp-salt", "", NULL,
-                SRTP_SALT_TEXT, SRTP_SALT_LONGTEXT, false);
+                SRTP_SALT_TEXT, SRTP_SALT_LONGTEXT, false)
     add_integer ("rtp-max-src", 1, NULL, RTP_MAX_SRC_TEXT,
-                 RTP_MAX_SRC_LONGTEXT, true);
+                 RTP_MAX_SRC_LONGTEXT, true)
         change_integer_range (1, 255)
     add_integer ("rtp-timeout", 5, NULL, RTP_TIMEOUT_TEXT,
-                 RTP_TIMEOUT_LONGTEXT, true);
+                 RTP_TIMEOUT_LONGTEXT, true)
     add_integer ("rtp-max-dropout", 3000, NULL, RTP_MAX_DROPOUT_TEXT,
-                 RTP_MAX_DROPOUT_LONGTEXT, true);
+                 RTP_MAX_DROPOUT_LONGTEXT, true)
         change_integer_range (0, 32767)
     add_integer ("rtp-max-misorder", 100, NULL, RTP_MAX_MISORDER_TEXT,
-                 RTP_MAX_MISORDER_LONGTEXT, true);
+                 RTP_MAX_MISORDER_LONGTEXT, true)
         change_integer_range (0, 32767)
 
     add_shortcut ("dccp")
@@ -114,7 +123,7 @@ vlc_module_end ()
  * - send RTCP-RR and RTCP-BYE
  * - dynamic payload types (need SDP parser)
  * - multiple medias (need SDP parser, and RTCP-SR parser for lip-sync)
- * - support for access_filter in case of stream_Demux (MPEG-TS)
+ * - support for stream_filter in case of stream_Demux (MPEG-TS)
  */
 
 #ifndef IPPROTO_DCCP
@@ -172,6 +181,8 @@ static int Open (vlc_object_t *obj)
     if (dport == 0)
         dport = 5004; /* avt-profile-1 port */
 
+    int rtcp_dport = var_CreateGetInteger (obj, "rtcp-port");
+
     /* Try to connect */
     int fd = -1, rtcp_fd = -1;
 
@@ -179,12 +190,13 @@ static int Open (vlc_object_t *obj)
     {
         case IPPROTO_UDP:
         case IPPROTO_UDPLITE:
-            fd = net_OpenDgram (obj, dhost, (dport + 1) & ~1,
-                                shost, (sport + 1) & ~1, AF_UNSPEC, tp);
+            fd = net_OpenDgram (obj, dhost, dport,
+                                shost, sport, AF_UNSPEC, tp);
             if (fd == -1)
                 break;
-            rtcp_fd = net_OpenDgram (obj, dhost, dport | 1, shost,
-                                     sport ? (sport | 1) : 0, AF_UNSPEC, tp);
+            if (rtcp_dport > 0) /* XXX: source port is unknown */
+                rtcp_fd = net_OpenDgram (obj, dhost, rtcp_dport, shost, 0,
+                                         AF_UNSPEC, tp);
             break;
 
          case IPPROTO_DCCP:
@@ -196,14 +208,14 @@ static int Open (vlc_object_t *obj)
 #ifdef SOCK_DCCP
             var_Create (obj, "dccp-service", VLC_VAR_STRING);
             var_SetString (obj, "dccp-service", "RTPV"); /* FIXME: RTPA? */
-            fd = net_Connect (obj, shost, (sport + 1) & ~1, SOCK_DCCP, tp);
+            fd = net_Connect (obj, shost, sport, SOCK_DCCP, tp);
 #else
             msg_Err (obj, "DCCP support not included");
 #endif
             break;
 
         case IPPROTO_TCP:
-            fd = net_Connect (obj, shost, (sport + 1) & ~1, SOCK_STREAM, tp);
+            fd = net_Connect (obj, shost, sport, SOCK_STREAM, tp);
             break;
     }
 
@@ -234,6 +246,7 @@ static int Open (vlc_object_t *obj)
     p_sys->max_misorder = var_CreateGetInteger (obj, "rtp-max-misorder");
     p_sys->autodetect   = true;
     p_sys->framed_rtp   = (tp == IPPROTO_TCP);
+    p_sys->dead         = false;
 
     demux->pf_demux   = Demux;
     demux->pf_control = Control;
@@ -414,7 +427,7 @@ static void *stream_init (demux_t *demux, const char *name)
 static void stream_destroy (demux_t *demux, void *data)
 {
     if (data)
-        stream_DemuxDelete ((stream_t *)data);
+        stream_Delete ((stream_t *)data);
     (void)demux;
 }
 
@@ -445,6 +458,19 @@ static void *pcmu_init (demux_t *demux)
     return codec_init (demux, &fmt);
 }
 
+/* PT=3
+ * GSM
+ */
+static void *gsm_init (demux_t *demux)
+{
+    es_format_t fmt;
+
+    es_format_Init (&fmt, AUDIO_ES, VLC_FOURCC ('g', 's', 'm', ' '));
+    fmt.audio.i_rate = 8000;
+    fmt.audio.i_channels = 1;
+    return codec_init (demux, &fmt);
+}
+
 /* PT=8
  * PCMA: G.711 A-law (RFC3551)
  */
@@ -481,6 +507,19 @@ static void *l16m_init (demux_t *demux)
     return codec_init (demux, &fmt);
 }
 
+/* PT=12
+ * QCELP
+ */
+static void *qcelp_init (demux_t *demux)
+{
+    es_format_t fmt;
+
+    es_format_Init (&fmt, AUDIO_ES, VLC_FOURCC ('Q', 'c', 'l', 'p'));
+    fmt.audio.i_rate = 8000;
+    fmt.audio.i_channels = 1;
+    return codec_init (demux, &fmt);
+}
+
 /* PT=14
  * MPA: MPEG Audio (RFC2250, §3.4)
  */
@@ -490,6 +529,7 @@ static void *mpa_init (demux_t *demux)
 
     es_format_Init (&fmt, AUDIO_ES, VLC_FOURCC ('m', 'p', 'g', 'a'));
     fmt.audio.i_channels = 2;
+    fmt.b_packetized = false;
     return codec_init (demux, &fmt);
 }
 
@@ -563,6 +603,7 @@ int rtp_autodetect (demux_t *demux, rtp_session_t *session,
         .number = ptype,
     };
 
+    /* Remember to keep this in sync with modules/services_discovery/sap.c */
     switch (ptype)
     {
       case 0:
@@ -571,6 +612,12 @@ int rtp_autodetect (demux_t *demux, rtp_session_t *session,
         pt.frequency = 8000;
         break;
 
+      case 3:
+        msg_Dbg (demux, "detected GSM");
+        pt.init = gsm_init;
+        pt.frequency = 8000;
+        break;
+
       case 8:
         msg_Dbg (demux, "detected G.711 A-law");
         pt.init = pcma_init;
@@ -589,6 +636,12 @@ int rtp_autodetect (demux_t *demux, rtp_session_t *session,
         pt.frequency = 44100;
         break;
 
+      case 12:
+        msg_Dbg (demux, "detected QCELP");
+        pt.init = qcelp_init;
+        pt.frequency = 8000;
+        break;
+
       case 14:
         msg_Dbg (demux, "detected MPEG Audio");
         pt.init = mpa_init;
@@ -628,6 +681,5 @@ int rtp_autodetect (demux_t *demux, rtp_session_t *session,
  */
 static int Demux (demux_t *demux)
 {
-    rtp_process (demux);
-    return 1;
+    return rtp_process (demux) ? 0 : 1;
 }