<div dir="ltr"><div dir="ltr">for latency, maximum bandwidth, etc.<br>---<br> modules/access/srt.c        | 132 ++++++++++++++++++-----------------<br> modules/access_output/srt.c | 133 ++++++++++++++++++++----------------<br> 2 files changed, 142 insertions(+), 123 deletions(-)<br><br>diff --git a/modules/access/srt.c b/modules/access/srt.c<br>index d8d8cbe659..2cf800a914 100644<br>--- a/modules/access/srt.c<br>+++ b/modules/access/srt.c<br>@@ -1,5 +1,5 @@<br> /*****************************************************************************<br>- * srt.c: SRT (Secure Reliable Transport) input module<br>+ * srt.c: SRT (Secure Reliable Transport) access module<br>  *****************************************************************************<br>  * Copyright (C) 2017-2018, Collabora Ltd.<br>  * Copyright (C) 2018, Haivision Systems Inc.<br>@@ -21,43 +21,17 @@<br>  * along with this program; if not, write to the Free Software Foundation,<br>  * Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.<br>  *****************************************************************************/<br>+#include "srt_common.h"<br> <br>-#ifdef HAVE_CONFIG_H<br>-# include "config.h"<br>-#endif<br>-<br>-#include <vlc_common.h><br>-#include <vlc_interrupt.h><br> #include <vlc_fs.h><br> #include <vlc_plugin.h><br> #include <vlc_access.h><br>+#include <vlc_interrupt.h><br> <br> #include <vlc_network.h><br> #include <vlc_url.h><br> <br>-#include <srt/srt.h><br>-<br>-/* libsrt defines default packet size as 1316 internally<br>- * so srt module takes same value. */<br>-#define SRT_DEFAULT_CHUNK_SIZE 1316<br>-/* Minimum/Maximum chunks to allow reading at a time from libsrt */<br>-#define SRT_MIN_CHUNKS_TRYREAD 10<br>-#define SRT_MAX_CHUNKS_TRYREAD 100<br>-/* The default timeout is -1 (infinite) */<br>-#define SRT_DEFAULT_POLL_TIMEOUT -1<br>-/* The default latency is 125<br>- * which uses srt library internally */<br>-#define SRT_DEFAULT_LATENCY 125<br>-/* Crypto key length in bytes. */<br>-#define SRT_KEY_LENGTH_TEXT N_("Crypto key length in bytes")<br>-#define SRT_DEFAULT_KEY_LENGTH 16<br>-static const int srt_key_lengths[] = {<br>-    16, 24, 32,<br>-};<br>-<br>-static const char *const srt_key_length_names[] = {<br>-    N_("16 bytes"), N_("24 bytes"), N_("32 bytes"),<br>-};<br>+<br> <br> typedef struct<br> {<br>@@ -70,6 +44,8 @@ typedef struct<br>     int         i_chunks; /* Number of chunks to allocate in the next read */<br> } stream_sys_t;<br> <br>+<br>+<br> static void srt_wait_interrupted(void *p_data)<br> {<br>     stream_t *p_stream = p_data;<br>@@ -115,10 +91,14 @@ static int Control(stream_t *p_stream, int i_query, va_list args)<br> <br> static bool srt_schedule_reconnect(stream_t *p_stream)<br> {<br>-    int         i_latency;<br>-    int         stat;<br>-    char        *psz_passphrase = NULL;<br>-<br>+    vlc_object_t *strm_obj = (vlc_object_t *) p_stream;<br>+    int i_latency=var_InheritInteger( p_stream, SRT_PARAM_LATENCY );<br>+    int i_payload_size = var_InheritInteger( p_stream, SRT_PARAM_PAYLOAD_SIZE );<br>+    int stat;<br>+    char *psz_passphrase = var_InheritString( p_stream, SRT_PARAM_PASSPHRASE );<br>+    bool passphrase_needs_free = true;<br>+    char *url = NULL;<br>+    srt_params_t params;<br>     struct addrinfo hints = {<br>         .ai_socktype = SOCK_DGRAM,<br>     }, *res = NULL;<br>@@ -153,6 +133,21 @@ static bool srt_schedule_reconnect(stream_t *p_stream)<br>         goto out;<br>     }<br> <br>+    if (p_stream->psz_url) {<br>+        url = strdup( p_stream->psz_url );<br>+        if (srt_parse_url( url, &params )) {<br>+            if (params.latency != -1)<br>+                i_latency = params.latency;<br>+            if (params.payload_size != -1)<br>+                i_payload_size = params.payload_size;<br>+            if (params.passphrase != NULL) {<br>+                free( psz_passphrase );<br>+                passphrase_needs_free = false;<br>+                psz_passphrase = (char *) params.passphrase;<br>+            }<br>+        }<br>+    }<br>+<br>     /* Make SRT non-blocking */<br>     srt_setsockopt( p_sys->sock, 0, SRTO_SNDSYN,<br>         &(bool) { false }, sizeof( bool ) );<br>@@ -168,20 +163,25 @@ static bool srt_schedule_reconnect(stream_t *p_stream)<br>         &(int) { 0 }, sizeof( int ) );<br> <br>     /* Set latency */<br>-    i_latency = var_InheritInteger( p_stream, "latency" );<br>-    srt_setsockopt( p_sys->sock, 0, SRTO_TSBPDDELAY,<br>-        &i_latency, sizeof( int ) );<br>+    srt_set_socket_option( strm_obj, SRT_PARAM_LATENCY, p_sys->sock,<br>+            SRTO_TSBPDDELAY, &i_latency, sizeof(i_latency) );<br> <br>-    psz_passphrase = var_InheritString( p_stream, "passphrase" );<br>-    if ( psz_passphrase != NULL && psz_passphrase[0] != '\0')<br>-    {<br>-        int i_key_length = var_InheritInteger( p_stream, "key-length" );<br>-        srt_setsockopt( p_sys->sock, 0, SRTO_PASSPHRASE,<br>-            psz_passphrase, strlen( psz_passphrase ) );<br>-        srt_setsockopt( p_sys->sock, 0, SRTO_PBKEYLEN,<br>-            &i_key_length, sizeof( int ) );<br>+    /* set passphrase */<br>+    if (psz_passphrase != NULL && psz_passphrase[0] != '\0') {<br>+        int i_key_length = var_InheritInteger( p_stream, SRT_PARAM_KEY_LENGTH );<br>+<br>+        srt_set_socket_option( strm_obj, SRT_PARAM_KEY_LENGTH, p_sys->sock,<br>+                SRTO_PBKEYLEN, &i_key_length, sizeof(i_key_length) );<br>+<br>+        srt_set_socket_option( strm_obj, SRT_PARAM_PASSPHRASE, p_sys->sock,<br>+                SRTO_PASSPHRASE, &psz_passphrase, sizeof(psz_passphrase) );<br>     }<br> <br>+    /* set maximum payload size */<br>+    srt_set_socket_option( strm_obj, SRT_PARAM_PAYLOAD_SIZE, p_sys->sock,<br>+            SRTO_PAYLOADSIZE, &i_payload_size, sizeof(i_payload_size) );<br>+<br>+<br>     srt_epoll_add_usock( p_sys->i_poll_id, p_sys->sock,<br>         &(int) { SRT_EPOLL_ERR | SRT_EPOLL_IN });<br> <br>@@ -189,11 +189,10 @@ static bool srt_schedule_reconnect(stream_t *p_stream)<br>     msg_Dbg( p_stream, "Schedule SRT connect (dest addresss: %s, port: %d).",<br>         p_sys->psz_host, p_sys->i_port);<br> <br>-    stat = srt_connect( p_sys->sock, res->ai_addr, res->ai_addrlen);<br>-    if ( stat == SRT_ERROR )<br>-    {<br>+    stat = srt_connect( p_sys->sock, res->ai_addr, res->ai_addrlen );<br>+    if (stat == SRT_ERROR) {<br>         msg_Err( p_stream, "Failed to connect to server (reason: %s)",<br>-                 srt_getlasterror_str() );<br>+                srt_getlasterror_str() );<br>         failed = true;<br>     }<br> <br>@@ -210,8 +209,10 @@ out:<br>         p_sys->sock = SRT_INVALID_SOCK;<br>     }<br> <br>+    if (passphrase_needs_free)<br>+        free( psz_passphrase );<br>     freeaddrinfo( res );<br>-    free( psz_passphrase );<br>+    free( url );<br> <br>     return !failed;<br> }<br>@@ -413,23 +414,28 @@ static void Close(vlc_object_t *p_this)<br> <br> /* Module descriptor */<br> vlc_module_begin ()<br>-    set_shortname( N_("SRT") )<br>-    set_description( N_("SRT input") )<br>+    set_shortname( N_( "SRT" ) )<br>+    set_description( N_( "SRT input" ) )<br>     set_category( CAT_INPUT )<br>     set_subcategory( SUBCAT_INPUT_ACCESS )<br> <br>-    add_integer( "chunk-size", SRT_DEFAULT_CHUNK_SIZE,<br>-            N_("SRT chunk size (bytes)"), NULL, true )<br>-    add_integer( "poll-timeout", SRT_DEFAULT_POLL_TIMEOUT,<br>-            N_("Return poll wait after timeout milliseconds (-1 = infinite)"), NULL, true )<br>-    add_integer( "latency", SRT_DEFAULT_LATENCY, N_("SRT latency (ms)"), NULL, true )<br>-    add_password("passphrase", "", N_("Password for stream encryption"), NULL)<br>-    add_integer( "key-length", SRT_DEFAULT_KEY_LENGTH,<br>+    add_integer( SRT_PARAM_CHUNK_SIZE, SRT_DEFAULT_CHUNK_SIZE,<br>+            N_( "SRT chunk size (bytes)" ), NULL, true )<br>+    add_integer( SRT_PARAM_POLL_TIMEOUT, SRT_DEFAULT_POLL_TIMEOUT,<br>+            N_( "Return poll wait after timeout milliseconds (-1 = infinite)" ),<br>+            NULL, true )<br>+    add_integer( SRT_PARAM_LATENCY, SRT_DEFAULT_LATENCY,<br>+            N_( "SRT latency (ms)" ), NULL, true )<br>+    add_password( SRT_PARAM_PASSPHRASE, "",<br>+            N_( "Password for stream encryption" ), NULL )<br>+    add_integer( SRT_PARAM_PAYLOAD_SIZE, SRT_DEFAULT_PAYLOAD_SIZE,<br>+            N_( "SRT maximum payload size (bytes)" ), NULL, true )<br>+    add_integer( SRT_PARAM_KEY_LENGTH, SRT_DEFAULT_KEY_LENGTH,<br>             SRT_KEY_LENGTH_TEXT, SRT_KEY_LENGTH_TEXT, false )<br>-        change_integer_list( srt_key_lengths, srt_key_length_names )<br>+    change_integer_list( srt_key_lengths, srt_key_length_names )<br> <br>-    set_capability( "access", 0 )<br>-    add_shortcut( "srt" )<br>+    set_capability("access", 0)<br>+    add_shortcut("srt")<br> <br>-    set_callbacks( Open, Close )<br>+    set_callbacks(Open, Close)<br> vlc_module_end ()<br>diff --git a/modules/access_output/srt.c b/modules/access_output/srt.c<br>index c3fdce42b1..5b23f6c994 100644<br>--- a/modules/access_output/srt.c<br>+++ b/modules/access_output/srt.c<br>@@ -1,5 +1,5 @@<br> /*****************************************************************************<br>- * srt.c: SRT (Secure Reliable Transport) output module<br>+ * srt.c: SRT (Secure Reliable Transport) access_output module<br>  *****************************************************************************<br>  * Copyright (C) 2017-2018, Collabora Ltd.<br>  * Copyright (C) 2018, Haivision Systems Inc.<br>@@ -21,11 +21,6 @@<br>  * along with this program; if not, write to the Free Software Foundation,<br>  * Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.<br>  *****************************************************************************/<br>-<br>-#ifdef HAVE_CONFIG_H<br>-# include "config.h"<br>-#endif<br>-<br> #include <vlc_common.h><br> #include <vlc_interrupt.h><br> #include <vlc_fs.h><br>@@ -34,28 +29,7 @@<br> #include <vlc_block.h><br> #include <vlc_network.h><br> <br>-#include <srt/srt.h><br>-<br>-/* libsrt defines default packet size as 1316 internally<br>- * so srt module takes same value. */<br>-#define SRT_DEFAULT_CHUNK_SIZE 1316<br>-/* libsrt tutorial uses 9000 as a default binding port */<br>-#define SRT_DEFAULT_PORT 9000<br>-/* The default timeout is -1 (infinite) */<br>-#define SRT_DEFAULT_POLL_TIMEOUT 100<br>-/* The default latency is 125<br>- * which uses srt library internally */<br>-#define SRT_DEFAULT_LATENCY 125<br>-/* Crypto key length in bytes. */<br>-#define SRT_KEY_LENGTH_TEXT N_("Crypto key length in bytes")<br>-#define SRT_DEFAULT_KEY_LENGTH 16<br>-static const int srt_key_lengths[] = {<br>-    16, 24, 32,<br>-};<br>-<br>-static const char *const srt_key_length_names[] = {<br>-    N_("16 bytes"), N_("24 bytes"), N_("32 bytes"),<br>-};<br>+#include <srt_common.h><br> <br> typedef struct<br> {<br>@@ -86,12 +60,18 @@ static void srt_wait_interrupted(void *p_data)<br> <br> static bool srt_schedule_reconnect(sout_access_out_t *p_access)<br> {<br>-    char                    *psz_dst_addr = NULL;<br>-    int                      i_dst_port;<br>-    int                      i_latency;<br>-    int                      stat;<br>-    char                    *psz_passphrase = NULL;<br>-<br>+    vlc_object_t *access_obj = (vlc_object_t *) p_access;<br>+    int stat;<br>+    char *psz_dst_addr = NULL;<br>+    int i_dst_port;<br>+    int i_latency=var_InheritInteger( p_access, SRT_PARAM_LATENCY );<br>+    int i_payload_size = var_InheritInteger( p_access, SRT_PARAM_PAYLOAD_SIZE );<br>+    char *psz_passphrase = var_InheritString( p_access, SRT_PARAM_PASSPHRASE );<br>+    bool passphrase_needs_free = true;<br>+    int i_max_bandwidth_limit =<br>+    var_InheritInteger( p_access, SRT_PARAM_BANDWIDTH_OVERHEAD_LIMIT );<br>+    char *url = NULL;<br>+    srt_params_t params;<br>     struct addrinfo hints = {<br>         .ai_socktype = SOCK_DGRAM,<br>     }, *res = NULL;<br>@@ -99,8 +79,6 @@ static bool srt_schedule_reconnect(sout_access_out_t *p_access)<br>     sout_access_out_sys_t *p_sys = p_access->p_sys;<br>     bool failed = false;<br> <br>-    psz_passphrase = var_InheritString( p_access, "passphrase" );<br>-<br>     i_dst_port = SRT_DEFAULT_PORT;<br>     char *psz_parser = psz_dst_addr = strdup( p_access->psz_path );<br>     if( !psz_dst_addr )<br>@@ -146,6 +124,21 @@ static bool srt_schedule_reconnect(sout_access_out_t *p_access)<br>         goto out;<br>     }<br> <br>+    if (psz_dst_addr) {<br>+        url = strdup( psz_dst_addr );<br>+        if (srt_parse_url( url, &params )) {<br>+            if (params.latency != -1)<br>+                i_latency = params.latency;<br>+            if (params.payload_size != -1)<br>+                i_payload_size = params.payload_size;<br>+            if (params.passphrase != NULL) {<br>+                free( psz_passphrase );<br>+                passphrase_needs_free = false;<br>+                psz_passphrase = (char *) params.passphrase;<br>+            }<br>+        }<br>+    }<br>+<br>     /* Make SRT non-blocking */<br>     srt_setsockopt( p_sys->sock, 0, SRTO_SNDSYN,<br>         &(bool) { false }, sizeof( bool ) );<br>@@ -161,19 +154,29 @@ static bool srt_schedule_reconnect(sout_access_out_t *p_access)<br>         &(int) { 1 }, sizeof( int ) );<br> <br>     /* Set latency */<br>-    i_latency = var_InheritInteger( p_access, "latency" );<br>-    srt_setsockopt( p_sys->sock, 0, SRTO_TSBPDDELAY,<br>-        &i_latency, sizeof( int ) );<br>+    srt_set_socket_option( access_obj, SRT_PARAM_LATENCY, p_sys->sock,<br>+            SRTO_TSBPDDELAY, &i_latency, sizeof(i_latency) );<br> <br>-    if ( psz_passphrase != NULL && psz_passphrase[0] != '\0')<br>-    {<br>-        int i_key_length = var_InheritInteger( p_access, "key-length" );<br>-        srt_setsockopt( p_sys->sock, 0, SRTO_PASSPHRASE,<br>-            psz_passphrase, strlen( psz_passphrase ) );<br>-        srt_setsockopt( p_sys->sock, 0, SRTO_PBKEYLEN,<br>-            &i_key_length, sizeof( int ) );<br>+    /* set passphrase */<br>+    if (psz_passphrase != NULL && psz_passphrase[0] != '\0') {<br>+        int i_key_length = var_InheritInteger( access_obj, SRT_PARAM_KEY_LENGTH );<br>+<br>+        srt_set_socket_option( access_obj, SRT_PARAM_KEY_LENGTH, p_sys->sock,<br>+                SRTO_PBKEYLEN, &i_key_length, sizeof(i_key_length) );<br>+<br>+        srt_set_socket_option( access_obj, SRT_PARAM_PASSPHRASE, p_sys->sock,<br>+                SRTO_PASSPHRASE, &psz_passphrase, sizeof(psz_passphrase) );<br>     }<br> <br>+    /* set maximumu payload size */<br>+    srt_set_socket_option( access_obj, SRT_PARAM_PAYLOAD_SIZE, p_sys->sock,<br>+            SRTO_PAYLOADSIZE, &i_payload_size, sizeof(i_payload_size) );<br>+<br>+    /* set maximum bandwidth limit*/<br>+    srt_set_socket_option( access_obj, SRT_PARAM_BANDWIDTH_OVERHEAD_LIMIT,<br>+            p_sys->sock, SRTO_OHEADBW, &i_max_bandwidth_limit,<br>+            sizeof(i_max_bandwidth_limit) );<br>+<br>     srt_setsockopt( p_sys->sock, 0, SRTO_SENDER, &(int) { 1 }, sizeof(int) );<br> <br>     srt_epoll_add_usock( p_sys->i_poll_id, p_sys->sock,<br>@@ -199,8 +202,10 @@ out:<br>         p_sys->sock = SRT_INVALID_SOCK;<br>     }<br> <br>-    free( psz_passphrase );<br>+    if (passphrase_needs_free)<br>+        free( psz_passphrase );<br>     free( psz_dst_addr );<br>+    free( url );<br>     freeaddrinfo( res );<br> <br>     return !failed;<br>@@ -210,8 +215,8 @@ static ssize_t Write( sout_access_out_t *p_access, block_t *p_buffer )<br> {<br>     sout_access_out_sys_t *p_sys = p_access->p_sys;<br>     int i_len = 0;<br>-    size_t i_chunk_size = var_InheritInteger( p_access, "chunk-size" );<br>-    int i_poll_timeout = var_InheritInteger( p_access, "poll-timeout" );<br>+    size_t i_chunk_size = var_InheritInteger( p_access, SRT_PARAM_CHUNK_SIZE);<br>+    int i_poll_timeout = var_InheritInteger( p_access, SRT_PARAM_POLL_TIMEOUT );<br>     bool b_interrupted = false;<br> <br>     vlc_interrupt_register( srt_wait_interrupted, p_access);<br>@@ -421,20 +426,28 @@ static void Close( vlc_object_t * p_this )<br> <br> /* Module descriptor */<br> vlc_module_begin()<br>-    set_shortname( N_("SRT") )<br>-    set_description( N_("SRT stream output") )<br>+    set_shortname( N_( "SRT" ) )<br>+    set_description( N_( "SRT stream output" ) )<br>     set_category( CAT_SOUT )<br>     set_subcategory( SUBCAT_SOUT_ACO )<br> <br>-    add_integer( "chunk-size", SRT_DEFAULT_CHUNK_SIZE,<br>-            N_("SRT chunk size (bytes)"), NULL, true )<br>-    add_integer( "poll-timeout", SRT_DEFAULT_POLL_TIMEOUT,<br>-            N_("Return poll wait after timeout milliseconds (-1 = infinite)"), NULL, true )<br>-    add_integer( "latency", SRT_DEFAULT_LATENCY, N_("SRT latency (ms)"), NULL, true )<br>-    add_password("passphrase", "", N_("Password for stream encryption"), NULL)<br>-    add_integer( "key-length", SRT_DEFAULT_KEY_LENGTH,<br>-            SRT_KEY_LENGTH_TEXT, SRT_KEY_LENGTH_TEXT, false )<br>-        change_integer_list( srt_key_lengths, srt_key_length_names )<br>+    add_integer( SRT_PARAM_CHUNK_SIZE, SRT_DEFAULT_CHUNK_SIZE,<br>+            N_( "SRT chunk size (bytes)" ), NULL, true )<br>+    add_integer( SRT_PARAM_POLL_TIMEOUT, SRT_DEFAULT_POLL_TIMEOUT,<br>+            N_( "Return poll wait after timeout milliseconds (-1 = infinite)" ),<br>+            NULL, true )<br>+    add_integer( SRT_PARAM_LATENCY, SRT_DEFAULT_LATENCY, N_( "SRT latency (ms)" ),<br>+            NULL, true )<br>+    add_password( SRT_PARAM_PASSPHRASE, "", N_( "Password for stream encryption" ),<br>+            NULL )<br>+    add_integer( SRT_PARAM_PAYLOAD_SIZE, SRT_DEFAULT_PAYLOAD_SIZE,<br>+            N_( "SRT maximum payload size (bytes)" ), NULL, true )<br>+    add_integer( SRT_PARAM_BANDWIDTH_OVERHEAD_LIMIT,<br>+            SRT_DEFAULT_BANDWIDTH_OVERHEAD_LIMIT,<br>+            N_( "SRT maximum bandwidth ceiling (bytes)" ), NULL, true )<br>+    add_integer( SRT_PARAM_KEY_LENGTH, SRT_DEFAULT_KEY_LENGTH, SRT_KEY_LENGTH_TEXT,<br>+            SRT_KEY_LENGTH_TEXT, false )<br>+    change_integer_list( srt_key_lengths, srt_key_length_names )<br> <br>     set_capability( "sout access", 0 )<br>     add_shortcut( "srt" )<br>-- <br>2.17.1<br><br></div></div>