qt: playlist: use item title if available
[vlc.git] / modules / access_output / srt.c
index 5b23f6c..afd11dc 100644 (file)
@@ -21,7 +21,9 @@
  * along with this program; if not, write to the Free Software Foundation,
  * Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
  *****************************************************************************/
-#include <vlc_common.h>
+
+#include <srt_common.h>
+
 #include <vlc_interrupt.h>
 #include <vlc_fs.h>
 #include <vlc_plugin.h>
@@ -29,8 +31,6 @@
 #include <vlc_block.h>
 #include <vlc_network.h>
 
-#include <srt_common.h>
-
 typedef struct
 {
     SRTSOCKET     sock;
@@ -68,6 +68,8 @@ static bool srt_schedule_reconnect(sout_access_out_t *p_access)
     int i_payload_size = var_InheritInteger( p_access, SRT_PARAM_PAYLOAD_SIZE );
     char *psz_passphrase = var_InheritString( p_access, SRT_PARAM_PASSPHRASE );
     bool passphrase_needs_free = true;
+    char *psz_streamid = var_InheritString( p_access, SRT_PARAM_STREAMID );
+    bool streamid_needs_free = true;
     int i_max_bandwidth_limit =
     var_InheritInteger( p_access, SRT_PARAM_BANDWIDTH_OVERHEAD_LIMIT );
     char *url = NULL;
@@ -136,6 +138,11 @@ static bool srt_schedule_reconnect(sout_access_out_t *p_access)
                 passphrase_needs_free = false;
                 psz_passphrase = (char *) params.passphrase;
             }
+           if (params.streamid != NULL) {
+                free( psz_streamid );
+                streamid_needs_free = false;
+                psz_streamid = (char *) params.streamid;
+            }
         }
     }
 
@@ -155,7 +162,7 @@ static bool srt_schedule_reconnect(sout_access_out_t *p_access)
 
     /* Set latency */
     srt_set_socket_option( access_obj, SRT_PARAM_LATENCY, p_sys->sock,
-            SRTO_TSBPDDELAY, &i_latency, sizeof(i_latency) );
+            SRTO_LATENCY, &i_latency, sizeof(i_latency) );
 
     /* set passphrase */
     if (psz_passphrase != NULL && psz_passphrase[0] != '\0') {
@@ -165,7 +172,13 @@ static bool srt_schedule_reconnect(sout_access_out_t *p_access)
                 SRTO_PBKEYLEN, &i_key_length, sizeof(i_key_length) );
 
         srt_set_socket_option( access_obj, SRT_PARAM_PASSPHRASE, p_sys->sock,
-                SRTO_PASSPHRASE, &psz_passphrase, sizeof(psz_passphrase) );
+                SRTO_PASSPHRASE, psz_passphrase, strlen(psz_passphrase) );
+    }
+
+    /* set streamid */
+    if (psz_streamid != NULL && psz_streamid[0] != '\0') {
+        srt_set_socket_option( access_obj, SRT_PARAM_STREAMID, p_sys->sock,
+                SRTO_STREAMID, psz_streamid, strlen(psz_streamid) );
     }
 
     /* set maximumu payload size */
@@ -204,6 +217,8 @@ out:
 
     if (passphrase_needs_free)
         free( psz_passphrase );
+    if (streamid_needs_free)
+        free( psz_streamid );
     free( psz_dst_addr );
     free( url );
     freeaddrinfo( res );
@@ -402,8 +417,6 @@ static int Open( vlc_object_t *p_this )
     return VLC_SUCCESS;
 
 failed:
-    vlc_mutex_destroy( &p_sys->lock );
-
     if ( p_sys->sock != -1 ) srt_close( p_sys->sock );
     if ( p_sys->i_poll_id != -1 ) srt_epoll_release( p_sys->i_poll_id );
 
@@ -415,8 +428,6 @@ static void Close( vlc_object_t * p_this )
     sout_access_out_t     *p_access = (sout_access_out_t*)p_this;
     sout_access_out_sys_t *p_sys = p_access->p_sys;
 
-    vlc_mutex_destroy( &p_sys->lock );
-
     srt_epoll_remove_usock( p_sys->i_poll_id, p_sys->sock );
     srt_close( p_sys->sock );
     srt_epoll_release( p_sys->i_poll_id );
@@ -448,6 +459,9 @@ vlc_module_begin()
     add_integer( SRT_PARAM_KEY_LENGTH, SRT_DEFAULT_KEY_LENGTH, SRT_KEY_LENGTH_TEXT,
             SRT_KEY_LENGTH_TEXT, false )
     change_integer_list( srt_key_lengths, srt_key_length_names )
+    add_string(SRT_PARAM_STREAMID, "",
+            N_(" SRT Stream ID"), NULL, false)
+    change_safe()
 
     set_capability( "sout access", 0 )
     add_shortcut( "srt" )