[vlc-commits] stream: rename p_source to s (refs #18504)

Rémi Denis-Courmont git at videolan.org
Sat Dec 2 22:26:55 CET 2017


vlc | branch: master | Rémi Denis-Courmont <remi at remlab.net> | Sat Dec  2 23:22:35 2017 +0200| [7902c7a65613b0ccd0b07aada4d42dbc3438537c] | committer: Rémi Denis-Courmont

stream: rename p_source to s (refs #18504)

> http://git.videolan.org/gitweb.cgi/vlc.git/?a=commit;h=7902c7a65613b0ccd0b07aada4d42dbc3438537c
---

 include/vlc_stream.h                 |  2 +-
 modules/demux/mpeg/ts.c              |  2 +-
 modules/demux/playlist/asx.c         |  8 ++++----
 modules/demux/playlist/b4s.c         |  4 ++--
 modules/demux/playlist/dvb.c         |  4 ++--
 modules/demux/playlist/ifo.c         |  4 ++--
 modules/demux/playlist/itml.c        |  4 ++--
 modules/demux/playlist/m3u.c         | 10 +++++-----
 modules/demux/playlist/playlist.h    |  2 +-
 modules/demux/playlist/pls.c         |  4 ++--
 modules/demux/playlist/podcast.c     | 12 ++++++------
 modules/demux/playlist/qtl.c         |  2 +-
 modules/demux/playlist/ram.c         |  6 +++---
 modules/demux/playlist/sgimb.c       |  4 ++--
 modules/demux/playlist/shoutcast.c   |  2 +-
 modules/demux/playlist/wpl.c         |  6 +++---
 modules/demux/playlist/xspf.c        |  4 ++--
 modules/lua/demux.c                  |  8 ++++----
 modules/stream_filter/accesstweaks.c | 12 ++++++------
 modules/stream_filter/adf.c          |  8 ++++----
 modules/stream_filter/aribcam.c      |  8 ++++----
 modules/stream_filter/cache_block.c  | 20 ++++++++++----------
 modules/stream_filter/cache_read.c   | 17 ++++++++---------
 modules/stream_filter/decomp.c       | 19 ++++++++-----------
 modules/stream_filter/hds/hds.c      |  4 ++--
 modules/stream_filter/inflate.c      |  6 +++---
 modules/stream_filter/prefetch.c     | 26 ++++++++++++--------------
 modules/stream_filter/record.c       |  6 +++---
 modules/stream_filter/skiptags.c     |  8 ++++----
 src/input/stream.c                   |  2 +-
 src/input/stream_filter.c            | 10 +++++-----
 31 files changed, 114 insertions(+), 120 deletions(-)

diff --git a/include/vlc_stream.h b/include/vlc_stream.h
index 789545e16e..2edabca03f 100644
--- a/include/vlc_stream.h
+++ b/include/vlc_stream.h
@@ -57,7 +57,7 @@ struct stream_t
     bool         b_preparsing; /**< True if this access is used to preparse */
 
     /* Stream source for stream filter */
-    stream_t *p_source;
+    stream_t    *s;
 
     /**
      * Read data.
diff --git a/modules/demux/mpeg/ts.c b/modules/demux/mpeg/ts.c
index 282fc20738..d2964de435 100644
--- a/modules/demux/mpeg/ts.c
+++ b/modules/demux/mpeg/ts.c
@@ -560,7 +560,7 @@ static void Close( vlc_object_t *p_this )
 
     if ( p_sys->arib.b25stream )
     {
-        p_sys->arib.b25stream->p_source = NULL; /* don't chain kill demuxer's source */
+        p_sys->arib.b25stream->s = NULL; /* don't chain kill demuxer's source */
         vlc_stream_Delete( p_sys->arib.b25stream );
     }
 
diff --git a/modules/demux/playlist/asx.c b/modules/demux/playlist/asx.c
index 9ea34fe929..83397f87ff 100644
--- a/modules/demux/playlist/asx.c
+++ b/modules/demux/playlist/asx.c
@@ -135,7 +135,7 @@ static void ReadElement( xml_reader_t *p_xml_reader, char **ppsz_txt )
 static bool PeekASX( stream_t *s )
 {
     const uint8_t *p_peek;
-    return ( vlc_stream_Peek( s->p_source, &p_peek, 12 ) == 12
+    return ( vlc_stream_Peek( s->s, &p_peek, 12 ) == 12
              && !memcmp( p_peek, "<asx version", 12 ) );
 }
 
@@ -149,7 +149,7 @@ int Import_ASX( vlc_object_t *p_this )
 
     CHECK_FILE(p_demux);
 
-    char *type = stream_MimeType( p_demux->p_source );
+    char *type = stream_MimeType( p_demux->s );
 
     if( stream_HasExtension( p_demux, ".asx" )
      || stream_HasExtension( p_demux, ".wax" )
@@ -320,7 +320,7 @@ end:
 
 static stream_t* UTF8Stream( stream_t *p_demux )
 {
-    stream_t *s = p_demux->p_source;
+    stream_t *s = p_demux->s;
     uint64_t streamSize;
 
      if (vlc_stream_GetSize( s, &streamSize ) != VLC_SUCCESS)
@@ -380,7 +380,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
     int i_n_entry = 0;
 
     p_xml_reader = xml_ReaderCreate( p_demux, p_stream ? p_stream
-                                                       : p_demux->p_source );
+                                                       : p_demux->s );
     if( !p_xml_reader )
     {
         msg_Err( p_demux, "Cannot parse ASX input file as XML");
diff --git a/modules/demux/playlist/b4s.c b/modules/demux/playlist/b4s.c
index dd886463e5..8ad764f963 100644
--- a/modules/demux/playlist/b4s.c
+++ b/modules/demux/playlist/b4s.c
@@ -72,9 +72,9 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
 
     input_item_t *p_current_input = GetCurrentItem(p_demux);
 
-    free( vlc_stream_ReadLine( p_demux->p_source ) );
+    free( vlc_stream_ReadLine( p_demux->s ) );
 
-    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->p_source );
+    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->s );
     if( !p_xml_reader )
         return -1;
 
diff --git a/modules/demux/playlist/dvb.c b/modules/demux/playlist/dvb.c
index 12d9873009..5d5ea507c4 100644
--- a/modules/demux/playlist/dvb.c
+++ b/modules/demux/playlist/dvb.c
@@ -52,7 +52,7 @@ int Import_DVB(vlc_object_t *p_this)
 
     /* Check if this really is a channels file */
     const uint8_t *peek;
-    int len = vlc_stream_Peek(demux->p_source, &peek, 1023);
+    int len = vlc_stream_Peek(demux->s, &peek, 1023);
     if (len <= 0)
         return VLC_EGENERIC;
 
@@ -82,7 +82,7 @@ static int ReadDir(stream_t *s, input_item_node_t *subitems)
 {
     char *line;
 
-    while ((line = vlc_stream_ReadLine(s->p_source)) != NULL)
+    while ((line = vlc_stream_ReadLine(s->s)) != NULL)
     {
         input_item_t *item = ParseLine(line);
         free(line);
diff --git a/modules/demux/playlist/ifo.c b/modules/demux/playlist/ifo.c
index 204a06180e..183a17a558 100644
--- a/modules/demux/playlist/ifo.c
+++ b/modules/demux/playlist/ifo.c
@@ -64,7 +64,7 @@ int Import_IFO( vlc_object_t *p_this )
         && !strcasecmp( psz_file + strlen( "VTS_00_0" ) , ".IFO" ) ) ) )
     {
         const uint8_t *p_peek;
-        ssize_t i_peek = vlc_stream_Peek( p_demux->p_source, &p_peek, 8 );
+        ssize_t i_peek = vlc_stream_Peek( p_demux->s, &p_peek, 8 );
 
         if( i_peek != 8 || memcmp( p_peek, "DVDVIDEO", 8 ) )
             return VLC_EGENERIC;
@@ -75,7 +75,7 @@ int Import_IFO( vlc_object_t *p_this )
     else if( len >= 12 && !strcmp( &p_demux->psz_filepath[len-12], "VR_MANGR.IFO" ) )
     {
         const uint8_t *p_peek;
-        ssize_t i_peek = vlc_stream_Peek( p_demux->p_source, &p_peek, 8 );
+        ssize_t i_peek = vlc_stream_Peek( p_demux->s, &p_peek, 8 );
 
         if( i_peek != 8 || memcmp( p_peek, "DVD_RTR_", 8 ) )
             return VLC_EGENERIC;
diff --git a/modules/demux/playlist/itml.c b/modules/demux/playlist/itml.c
index 36341d36e6..2f4b24cb42 100644
--- a/modules/demux/playlist/itml.c
+++ b/modules/demux/playlist/itml.c
@@ -52,7 +52,7 @@ int Import_iTML( vlc_object_t *p_this )
         return VLC_EGENERIC;
 
     const uint8_t *p_peek;
-    const ssize_t i_peek = vlc_stream_Peek( p_demux->p_source, &p_peek, 128 );
+    const ssize_t i_peek = vlc_stream_Peek( p_demux->s, &p_peek, 128 );
     if ( i_peek < 32 ||
          !strnstr( (const char *) p_peek, "<!DOCTYPE plist ", i_peek ) )
         return VLC_EGENERIC;
@@ -76,7 +76,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
     p_demux->p_sys = (void *)(uintptr_t)0;
 
     /* create new xml parser from stream */
-    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->p_source );
+    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->s );
     if( !p_xml_reader )
         goto end;
 
diff --git a/modules/demux/playlist/m3u.c b/modules/demux/playlist/m3u.c
index d95440a948..fa52fde951 100644
--- a/modules/demux/playlist/m3u.c
+++ b/modules/demux/playlist/m3u.c
@@ -82,7 +82,7 @@ int Import_M3U( vlc_object_t *p_this )
     int offset = 0;
 
     CHECK_FILE(p_stream);
-    i_peek = vlc_stream_Peek( p_stream->p_source, &p_peek, 1024 );
+    i_peek = vlc_stream_Peek( p_stream->s, &p_peek, 1024 );
     if( i_peek < 8 )
         return VLC_EGENERIC;
 
@@ -104,7 +104,7 @@ int Import_M3U( vlc_object_t *p_this )
     }
 
     /* File type: playlist, or not (HLS manifest or whatever else) */
-    char *type = stream_MimeType(p_stream->p_source);
+    char *type = stream_MimeType(p_stream->s);
     bool match;
 
     if (p_stream->obj.force)
@@ -137,7 +137,7 @@ int Import_M3U( vlc_object_t *p_this )
     if (!match)
         return VLC_EGENERIC;
 
-    if (offset != 0 && vlc_stream_Seek(p_stream->p_source, offset))
+    if (offset != 0 && vlc_stream_Seek(p_stream->s, offset))
         return VLC_EGENERIC;
 
     msg_Dbg( p_stream, "found valid M3U playlist" );
@@ -226,7 +226,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
 
     input_item_t *p_current_input = GetCurrentItem(p_demux);
 
-    psz_line = vlc_stream_ReadLine( p_demux->p_source );
+    psz_line = vlc_stream_ReadLine( p_demux->s );
     while( psz_line )
     {
         char *psz_parse = psz_line;
@@ -327,7 +327,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
 
         /* Fetch another line */
         free( psz_line );
-        psz_line = vlc_stream_ReadLine( p_demux->p_source );
+        psz_line = vlc_stream_ReadLine( p_demux->s );
         if( !psz_line ) b_cleanup = true;
 
         if( b_cleanup )
diff --git a/modules/demux/playlist/playlist.h b/modules/demux/playlist/playlist.h
index d9a6d7c478..30c8003d74 100644
--- a/modules/demux/playlist/playlist.h
+++ b/modules/demux/playlist/playlist.h
@@ -58,7 +58,7 @@ int Import_WPL ( vlc_object_t * );
 void Close_WPL ( vlc_object_t * );
 
 #define GetCurrentItem(obj) input_GetItem((obj)->p_input)
-#define GetSource(obj) ((obj)->p_source)
+#define GetSource(obj) ((obj)->s)
 
 #define CHECK_FILE(obj) \
 do { \
diff --git a/modules/demux/playlist/pls.c b/modules/demux/playlist/pls.c
index c4474c13e7..8ea3202b70 100644
--- a/modules/demux/playlist/pls.c
+++ b/modules/demux/playlist/pls.c
@@ -49,7 +49,7 @@ int Import_PLS( vlc_object_t *p_this )
 
     CHECK_FILE(p_demux);
 
-    if( vlc_stream_Peek( p_demux->p_source , &p_peek, 10 ) < 10 ) {
+    if( vlc_stream_Peek( p_demux->s, &p_peek, 10 ) < 10 ) {
         msg_Dbg( p_demux, "not enough data" );
         return VLC_EGENERIC;
     }
@@ -79,7 +79,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
 
     input_item_t *p_current_input = GetCurrentItem(p_demux);
 
-    while( ( psz_line = vlc_stream_ReadLine( p_demux->p_source ) ) )
+    while( ( psz_line = vlc_stream_ReadLine( p_demux->s ) ) )
     {
         if( !strncasecmp( psz_line, "[playlist]", sizeof("[playlist]")-1 ) ||
             !strncasecmp( psz_line, "[Reference]", sizeof("[Reference]")-1 ) )
diff --git a/modules/demux/playlist/podcast.c b/modules/demux/playlist/podcast.c
index 9be1b08823..d7bce48549 100644
--- a/modules/demux/playlist/podcast.c
+++ b/modules/demux/playlist/podcast.c
@@ -49,19 +49,19 @@ int Import_podcast( vlc_object_t *p_this )
     stream_t *p_demux = (stream_t *)p_this;
 
     CHECK_FILE(p_demux);
-    if( stream_IsMimeType( p_demux->p_source, "text/xml" )
-     || stream_IsMimeType( p_demux->p_source, "application/xml" ) )
+    if( stream_IsMimeType( p_demux->s, "text/xml" )
+     || stream_IsMimeType( p_demux->s, "application/xml" ) )
     {
         /* XML: check if the root node is "rss". Use a specific peeked
          * probestream in order to not modify the source state while probing.
          * */
         const uint8_t *p_peek;
-        ssize_t i_peek = vlc_stream_Peek( p_demux->p_source, &p_peek, 2048 );
+        ssize_t i_peek = vlc_stream_Peek( p_demux->s, &p_peek, 2048 );
         if( unlikely( i_peek <= 0 ) )
             return VLC_EGENERIC;
 
         stream_t *p_probestream =
-            vlc_stream_MemoryNew( p_demux->p_source, (uint8_t *)p_peek, i_peek, true );
+            vlc_stream_MemoryNew( p_demux, (uint8_t *)p_peek, i_peek, true );
         if( unlikely( !p_probestream ) )
             return VLC_EGENERIC;
 
@@ -86,7 +86,7 @@ int Import_podcast( vlc_object_t *p_this )
         vlc_stream_Delete( p_probestream );
         /* SUCCESS: this text/xml is a rss file */
     }
-    else if( !stream_IsMimeType( p_demux->p_source, "application/rss+xml" ) )
+    else if( !stream_IsMimeType( p_demux->s, "application/rss+xml" ) )
         return VLC_EGENERIC;
 
     p_demux->pf_readdir = ReadDir;
@@ -122,7 +122,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
 
     input_item_t *p_current_input = GetCurrentItem(p_demux);
 
-    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->p_source );
+    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->s );
     if( !p_xml_reader )
         goto error;
 
diff --git a/modules/demux/playlist/qtl.c b/modules/demux/playlist/qtl.c
index d24e8b9ea5..e0c84645c4 100644
--- a/modules/demux/playlist/qtl.c
+++ b/modules/demux/playlist/qtl.c
@@ -117,7 +117,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
     char *psz_mimetype = NULL;
     int i_volume = 100;
 
-    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->p_source );
+    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->s );
     if( !p_xml_reader )
         goto error;
 
diff --git a/modules/demux/playlist/ram.c b/modules/demux/playlist/ram.c
index 322ba2a744..1204d3f3ba 100644
--- a/modules/demux/playlist/ram.c
+++ b/modules/demux/playlist/ram.c
@@ -80,7 +80,7 @@ int Import_RAM( vlc_object_t *p_this )
         return VLC_EGENERIC;
 
     /* Many Real Media Files are misdetected */
-    if( vlc_stream_Peek( p_demux->p_source, &p_peek, 4 ) < 4 )
+    if( vlc_stream_Peek( p_demux->s, &p_peek, 4 ) < 4 )
         return VLC_EGENERIC;
     if( !memcmp( p_peek, ".ra", 3 ) || !memcmp( p_peek, ".RMF", 4 ) )
     {
@@ -208,7 +208,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
     bool b_cleanup = false;
     input_item_t *p_input;
 
-    psz_line = vlc_stream_ReadLine( p_demux->p_source );
+    psz_line = vlc_stream_ReadLine( p_demux->s );
     while( psz_line )
     {
         char *psz_parse = psz_line;
@@ -346,7 +346,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *p_subitems )
  error:
         /* Fetch another line */
         free( psz_line );
-        psz_line = vlc_stream_ReadLine( p_demux->p_source );
+        psz_line = vlc_stream_ReadLine( p_demux->s );
         if( !psz_line ) b_cleanup = true;
 
         if( b_cleanup )
diff --git a/modules/demux/playlist/sgimb.c b/modules/demux/playlist/sgimb.c
index 529c9bff25..af4b3fe832 100644
--- a/modules/demux/playlist/sgimb.c
+++ b/modules/demux/playlist/sgimb.c
@@ -142,7 +142,7 @@ int Import_SGIMB( vlc_object_t * p_this )
 
     CHECK_FILE(p_demux);
     /* Lets check the content to see if this is a sgi mediabase file */
-    i_size = vlc_stream_Peek( p_demux->p_source, &p_peek, MAX_LINE );
+    i_size = vlc_stream_Peek( p_demux->s, &p_peek, MAX_LINE );
     i_size -= sizeof("sgiNameServerHost=") - 1;
     if ( i_size > 0 )
     {
@@ -324,7 +324,7 @@ static int ReadDir( stream_t *p_demux, input_item_node_t *node )
     input_item_t    *p_child = NULL;
     char            *psz_line;
 
-    while( ( psz_line = vlc_stream_ReadLine( p_demux->p_source ) ) )
+    while( ( psz_line = vlc_stream_ReadLine( p_demux->s ) ) )
     {
         ParseLine( p_demux, psz_line );
         free( psz_line );
diff --git a/modules/demux/playlist/shoutcast.c b/modules/demux/playlist/shoutcast.c
index 7432cac73c..d2b33e35b1 100644
--- a/modules/demux/playlist/shoutcast.c
+++ b/modules/demux/playlist/shoutcast.c
@@ -74,7 +74,7 @@ static int Demux( stream_t *p_demux, input_item_node_t *p_input_node )
     const char *node;
     int i_ret = VLC_EGENERIC;
 
-    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->p_source );
+    p_xml_reader = xml_ReaderCreate( p_demux, p_demux->s );
     if( !p_xml_reader )
         goto error;
 
diff --git a/modules/demux/playlist/wpl.c b/modules/demux/playlist/wpl.c
index 5db23be7f5..1effebd2fe 100644
--- a/modules/demux/playlist/wpl.c
+++ b/modules/demux/playlist/wpl.c
@@ -285,11 +285,11 @@ int Import_WPL( vlc_object_t* p_this )
         return VLC_EGENERIC;
 
     const uint8_t *p_peek;
-    ssize_t i_peek = vlc_stream_Peek( p_demux->p_source, &p_peek, 2048 );
+    ssize_t i_peek = vlc_stream_Peek( p_demux->s, &p_peek, 2048 );
     if( unlikely( i_peek <= 0 ) )
         return VLC_EGENERIC;
 
-    stream_t *p_probestream = vlc_stream_MemoryNew( p_demux->p_source, (uint8_t *)p_peek, i_peek, true );
+    stream_t *p_probestream = vlc_stream_MemoryNew( p_demux, (uint8_t *)p_peek, i_peek, true );
     if( unlikely( !p_probestream ) )
         return VLC_EGENERIC;
 
@@ -315,7 +315,7 @@ int Import_WPL( vlc_object_t* p_this )
         return VLC_EGENERIC;
     }
 
-    p_demux->p_sys = xml_ReaderReset( p_reader, p_demux->p_source );
+    p_demux->p_sys = xml_ReaderReset( p_reader, p_demux->s );
     vlc_stream_Delete( p_probestream );
     if( unlikely( p_demux->p_sys == NULL ) )
         return VLC_EGENERIC;
diff --git a/modules/demux/playlist/xspf.c b/modules/demux/playlist/xspf.c
index 72884d056d..97f9747596 100644
--- a/modules/demux/playlist/xspf.c
+++ b/modules/demux/playlist/xspf.c
@@ -92,7 +92,7 @@ int Import_xspf(vlc_object_t *p_this)
     CHECK_FILE(p_stream);
 
     if( !stream_HasExtension( p_stream, ".xspf" )
-     && !stream_IsMimeType( p_stream->p_source, "application/xspf+xml" ) )
+     && !stream_IsMimeType( p_stream->s, "application/xspf+xml" ) )
         return VLC_EGENERIC;
 
     xspf_sys_t *sys = calloc(1, sizeof (*sys));
@@ -135,7 +135,7 @@ static int ReadDir(stream_t *p_stream, input_item_node_t *p_subitems)
     sys->psz_base = strdup(p_stream->psz_url);
 
     /* create new xml parser from stream */
-    p_xml_reader = xml_ReaderCreate(p_stream, p_stream->p_source);
+    p_xml_reader = xml_ReaderCreate(p_stream, p_stream->s);
     if (!p_xml_reader)
         goto end;
 
diff --git a/modules/lua/demux.c b/modules/lua/demux.c
index a4ea3af1aa..95bf40b7ae 100644
--- a/modules/lua/demux.c
+++ b/modules/lua/demux.c
@@ -55,7 +55,7 @@ static int vlclua_demux_peek( lua_State *L )
     int n = luaL_checkint( L, 1 );
     const uint8_t *p_peek;
 
-    ssize_t val = vlc_stream_Peek(s->p_source, &p_peek, n);
+    ssize_t val = vlc_stream_Peek(s->s, &p_peek, n);
     if (val > 0)
         lua_pushlstring(L, (const char *)p_peek, val);
     else
@@ -71,7 +71,7 @@ static int vlclua_demux_read( lua_State *L )
 
     if (buf != NULL)
     {
-        ssize_t val = vlc_stream_Read(s->p_source, buf, n);
+        ssize_t val = vlc_stream_Read(s->s, buf, n);
         if (val > 0)
             lua_pushlstring(L, buf, val);
         else
@@ -87,7 +87,7 @@ static int vlclua_demux_read( lua_State *L )
 static int vlclua_demux_readline( lua_State *L )
 {
     stream_t *s = (stream_t *)vlclua_get_this(L);
-    char *line = vlc_stream_ReadLine(s->p_source);
+    char *line = vlc_stream_ReadLine(s->s);
 
     if (line != NULL)
     {
@@ -279,7 +279,7 @@ int Import_LuaPlaylist(vlc_object_t *obj)
         return VLC_EGENERIC;
 
     stream_t *s = (stream_t *)obj;
-    if( !vlc_stream_Control( s->p_source, STREAM_IS_DIRECTORY ) )
+    if( !vlc_stream_Control( s->s, STREAM_IS_DIRECTORY ) )
         return VLC_EGENERIC;
 
     struct vlclua_playlist *sys = malloc(sizeof (*sys));
diff --git a/modules/stream_filter/accesstweaks.c b/modules/stream_filter/accesstweaks.c
index bea1b8087c..a64c8708c8 100644
--- a/modules/stream_filter/accesstweaks.c
+++ b/modules/stream_filter/accesstweaks.c
@@ -88,12 +88,12 @@ static int Control( stream_t *p_stream, int i_query, va_list args )
         break;
     }
 
-    return vlc_stream_vaControl( p_stream->p_source, i_query, args );
+    return vlc_stream_vaControl( p_stream->s, i_query, args );
 }
 
 static ssize_t Read( stream_t *s, void *buffer, size_t i_read )
 {
-    return vlc_stream_Read( s->p_source, buffer, i_read );
+    return vlc_stream_Read( s->s, buffer, i_read );
 }
 
 static int Seek( stream_t *s, uint64_t offset )
@@ -101,7 +101,7 @@ static int Seek( stream_t *s, uint64_t offset )
     stream_sys_t *p_sys = s->p_sys;
 
     assert( p_sys->b_seek );
-    return vlc_stream_Seek( s->p_source, offset );
+    return vlc_stream_Seek( s->s, offset );
 }
 
 static int Open( vlc_object_t *p_object )
@@ -120,7 +120,7 @@ static int Open( vlc_object_t *p_object )
 
     if (!p_sys->b_seek)
     {
-        if (vlc_stream_Control(p_stream->p_source, STREAM_CAN_SEEK, &b) == 0)
+        if (vlc_stream_Control(p_stream->s, STREAM_CAN_SEEK, &b) == 0)
             used = b;
 
         p_sys->b_fastseek = false;
@@ -129,12 +129,12 @@ static int Open( vlc_object_t *p_object )
     {
         p_sys->b_fastseek = var_InheritBool(p_stream, "fastseek");
         if (!p_sys->b_fastseek
-         && vlc_stream_Control(p_stream->p_source, STREAM_CAN_FASTSEEK,
+         && vlc_stream_Control(p_stream->s, STREAM_CAN_FASTSEEK,
                                &b) == 0)
             used = b;
     }
 
-    if (!p_sys->b_size && vlc_stream_GetSize(p_stream->p_source, &size) == 0)
+    if (!p_sys->b_size && vlc_stream_GetSize(p_stream->s, &size) == 0)
         used = true;
 
     if (!used) /* Nothing to do: skip this filter */
diff --git a/modules/stream_filter/adf.c b/modules/stream_filter/adf.c
index 5d3fb0a5bd..b02faf1a96 100644
--- a/modules/stream_filter/adf.c
+++ b/modules/stream_filter/adf.c
@@ -45,12 +45,12 @@ vlc_module_end()
 
 static int Control( stream_t *p_stream, int i_query, va_list args )
 {
-    return vlc_stream_vaControl( p_stream->p_source, i_query, args );
+    return vlc_stream_vaControl( p_stream->s, i_query, args );
 }
 
 static ssize_t Read( stream_t *s, void *buffer, size_t i_read )
 {
-    const ssize_t i_ret = vlc_stream_Read( s->p_source, buffer, i_read );
+    const ssize_t i_ret = vlc_stream_Read( s->s, buffer, i_read );
     if( i_ret < 1 ) return i_ret;
 
     uint8_t *p_buffer = buffer;
@@ -62,7 +62,7 @@ static ssize_t Read( stream_t *s, void *buffer, size_t i_read )
 
 static int Seek( stream_t *s, uint64_t offset )
 {
-    return vlc_stream_Seek( s->p_source, offset );
+    return vlc_stream_Seek( s->s, offset );
 }
 
 static int Open( vlc_object_t *p_object )
@@ -80,7 +80,7 @@ static int Open( vlc_object_t *p_object )
     }
 
     const uint8_t *peek;
-    if( vlc_stream_Peek( p_stream->p_source, &peek, 3 ) < 3 )
+    if( vlc_stream_Peek( p_stream->s, &peek, 3 ) < 3 )
         return VLC_EGENERIC;
 
     /* Probe for XOR'd ID3 tag. */
diff --git a/modules/stream_filter/aribcam.c b/modules/stream_filter/aribcam.c
index 0b8ada8a47..051a9152a3 100644
--- a/modules/stream_filter/aribcam.c
+++ b/modules/stream_filter/aribcam.c
@@ -182,7 +182,7 @@ static ssize_t Read( stream_t *p_stream, void *p_buf, size_t i_toread )
     while ( i_toread )
     {
         /* make use of the existing buffer, overwritten by decoder data later */
-        int i_srcread = vlc_stream_Read( p_stream->p_source, p_dst, i_toread );
+        int i_srcread = vlc_stream_Read( p_stream->s, p_dst, i_toread );
         if ( i_srcread > 0 )
         {
             ARIB_STD_B25_BUFFER putbuf = { p_dst, i_srcread };
@@ -233,7 +233,7 @@ static ssize_t Read( stream_t *p_stream, void *p_buf, size_t i_toread )
 
 static int Seek( stream_t *p_stream, uint64_t i_pos )
 {
-    int i_ret = vlc_stream_Seek( p_stream->p_source, i_pos );
+    int i_ret = vlc_stream_Seek( p_stream->s, i_pos );
     if ( i_ret == VLC_SUCCESS )
         RemainFlush( p_stream->p_sys );
     return i_ret;
@@ -244,14 +244,14 @@ static int Seek( stream_t *p_stream, uint64_t i_pos )
  */
 static int Control( stream_t *p_stream, int i_query, va_list args )
 {
-    return vlc_stream_vaControl( p_stream->p_source, i_query, args );
+    return vlc_stream_vaControl( p_stream->s, i_query, args );
 }
 
 static int Open( vlc_object_t *p_object )
 {
     stream_t *p_stream = (stream_t *) p_object;
 
-    int64_t i_stream_size = stream_Size( p_stream->p_source );
+    int64_t i_stream_size = stream_Size( p_stream->s );
     if ( i_stream_size > 0 && i_stream_size < ARIB_STD_B25_TS_PROBING_MIN_DATA )
         return VLC_EGENERIC;
 
diff --git a/modules/stream_filter/cache_block.c b/modules/stream_filter/cache_block.c
index 85c10203e1..9ed0f8301b 100644
--- a/modules/stream_filter/cache_block.c
+++ b/modules/stream_filter/cache_block.c
@@ -119,9 +119,9 @@ static int AStreamRefillBlock(stream_t *s)
             return VLC_EGENERIC;
 
         /* Fetch a block */
-        if ((b = vlc_stream_ReadBlock(s->p_source)))
+        if ((b = vlc_stream_ReadBlock(s->s)))
             break;
-        if (vlc_stream_Eof(s->p_source))
+        if (vlc_stream_Eof(s->s))
             return VLC_EGENERIC;
     }
 
@@ -176,10 +176,10 @@ static void AStreamPrebufferBlock(stream_t *s)
         }
 
         /* Fetch a block */
-        block_t *b = vlc_stream_ReadBlock(s->p_source);
+        block_t *b = vlc_stream_ReadBlock(s->s);
         if (b == NULL)
         {
-            if (vlc_stream_Eof(s->p_source))
+            if (vlc_stream_Eof(s->s))
                 break;
             continue;
         }
@@ -259,7 +259,7 @@ static int AStreamSeekBlock(stream_t *s, uint64_t i_pos)
     if (i_offset < 0)
     {
         bool b_aseek;
-        vlc_stream_Control(s->p_source, STREAM_CAN_SEEK, &b_aseek);
+        vlc_stream_Control(s->s, STREAM_CAN_SEEK, &b_aseek);
 
         if (!b_aseek)
         {
@@ -273,8 +273,8 @@ static int AStreamSeekBlock(stream_t *s, uint64_t i_pos)
     {
         bool b_aseek, b_aseekfast;
 
-        vlc_stream_Control(s->p_source, STREAM_CAN_SEEK, &b_aseek);
-        vlc_stream_Control(s->p_source, STREAM_CAN_FASTSEEK, &b_aseekfast);
+        vlc_stream_Control(s->s, STREAM_CAN_SEEK, &b_aseek);
+        vlc_stream_Control(s->s, STREAM_CAN_FASTSEEK, &b_aseekfast);
 
         if (!b_aseek)
         {
@@ -305,7 +305,7 @@ static int AStreamSeekBlock(stream_t *s, uint64_t i_pos)
     if (b_seek)
     {
         /* Do the access seek */
-        if (vlc_stream_Seek(s->p_source, i_pos)) return VLC_EGENERIC;
+        if (vlc_stream_Seek(s->s, i_pos)) return VLC_EGENERIC;
 
         /* Release data */
         block_ChainRelease(sys->p_first);
@@ -416,12 +416,12 @@ static int AStreamControl(stream_t *s, int i_query, va_list args)
         case STREAM_SET_PRIVATE_ID_STATE:
         case STREAM_SET_PRIVATE_ID_CA:
         case STREAM_GET_PRIVATE_ID_STATE:
-            return vlc_stream_vaControl(s->p_source, i_query, args);
+            return vlc_stream_vaControl(s->s, i_query, args);
 
         case STREAM_SET_TITLE:
         case STREAM_SET_SEEKPOINT:
         {
-            int ret = vlc_stream_vaControl(s->p_source, i_query, args);
+            int ret = vlc_stream_vaControl(s->s, i_query, args);
             if (ret == VLC_SUCCESS)
                 AStreamControlReset(s);
             return ret;
diff --git a/modules/stream_filter/cache_read.c b/modules/stream_filter/cache_read.c
index ed96776076..f860a14ea9 100644
--- a/modules/stream_filter/cache_read.c
+++ b/modules/stream_filter/cache_read.c
@@ -134,7 +134,7 @@ static int AStreamRefillStream(stream_t *s)
             return VLC_EGENERIC;
 
         i_read = __MIN(i_toread, STREAM_CACHE_TRACK_SIZE - i_off);
-        i_read = vlc_stream_Read(s->p_source, &tk->p_buffer[i_off], i_read);
+        i_read = vlc_stream_Read(s->s, &tk->p_buffer[i_off], i_read);
 
         /* msg_Dbg(s, "AStreamRefillStream: read=%d", i_read); */
         if (i_read <  0)
@@ -200,8 +200,7 @@ static void AStreamPrebufferStream(stream_t *s)
 
         i_read = STREAM_CACHE_TRACK_SIZE - i_buffered;
         i_read = __MIN((int)sys->i_read_size, i_read);
-        i_read = vlc_stream_Read(s->p_source, &tk->p_buffer[i_buffered],
-                                 i_read);
+        i_read = vlc_stream_Read(s->s, &tk->p_buffer[i_buffered], i_read);
         if (i_read <  0)
             continue;
         else if (i_read == 0)
@@ -307,7 +306,7 @@ static int AStreamSeekStream(stream_t *s, uint64_t i_pos)
 #endif
 
     bool   b_aseek;
-    vlc_stream_Control(s->p_source, STREAM_CAN_SEEK, &b_aseek);
+    vlc_stream_Control(s->s, STREAM_CAN_SEEK, &b_aseek);
     if (!b_aseek && i_pos < p_current->i_start)
     {
         msg_Warn(s, "AStreamSeekStream: can't seek");
@@ -315,7 +314,7 @@ static int AStreamSeekStream(stream_t *s, uint64_t i_pos)
     }
 
     bool   b_afastseek;
-    vlc_stream_Control(s->p_source, STREAM_CAN_FASTSEEK, &b_afastseek);
+    vlc_stream_Control(s->s, STREAM_CAN_FASTSEEK, &b_afastseek);
 
     /* FIXME compute seek cost (instead of static 'stupid' value) */
     uint64_t i_skip_threshold;
@@ -387,7 +386,7 @@ static int AStreamSeekStream(stream_t *s, uint64_t i_pos)
             /* Seek at the end of the buffer
              * TODO it is stupid to seek now, it would be better to delay it
              */
-            if (vlc_stream_Seek(s->p_source, tk->i_end))
+            if (vlc_stream_Seek(s->s, tk->i_end))
             {
                 msg_Err(s, "AStreamSeekStream: hard seek failed");
                 return VLC_EGENERIC;
@@ -416,7 +415,7 @@ static int AStreamSeekStream(stream_t *s, uint64_t i_pos)
         msg_Err(s, "AStreamSeekStream: hard seek");
 #endif
         /* Nothing good, seek and choose oldest segment */
-        if (vlc_stream_Seek(s->p_source, i_pos))
+        if (vlc_stream_Seek(s->s, i_pos))
         {
             msg_Err(s, "AStreamSeekStream: hard seek failed");
             return VLC_EGENERIC;
@@ -470,12 +469,12 @@ static int AStreamControl(stream_t *s, int i_query, va_list args)
         case STREAM_SET_PRIVATE_ID_STATE:
         case STREAM_SET_PRIVATE_ID_CA:
         case STREAM_GET_PRIVATE_ID_STATE:
-            return vlc_stream_vaControl(s->p_source, i_query, args);
+            return vlc_stream_vaControl(s->s, i_query, args);
 
         case STREAM_SET_TITLE:
         case STREAM_SET_SEEKPOINT:
         {
-            int ret = vlc_stream_vaControl(s->p_source, i_query, args);
+            int ret = vlc_stream_vaControl(s->s, i_query, args);
             if (ret == VLC_SUCCESS)
                 AStreamControlReset(s);
             return ret;
diff --git a/modules/stream_filter/decomp.c b/modules/stream_filter/decomp.c
index b253c02219..514a0aca36 100644
--- a/modules/stream_filter/decomp.c
+++ b/modules/stream_filter/decomp.c
@@ -137,7 +137,7 @@ static void *Thread (void *data)
         vlc_mutex_lock (&p_sys->lock);
         while (p_sys->paused) /* practically always false, but... */
             vlc_cond_wait (&p_sys->wait, &p_sys->lock);
-        len = vlc_stream_Read (stream->p_source, buf, bufsize);
+        len = vlc_stream_Read (stream->s, buf, bufsize);
         vlc_mutex_unlock (&p_sys->lock);
 
         vlc_restorecancel (canc);
@@ -229,8 +229,7 @@ static int Control (stream_t *stream, int query, va_list args)
             bool paused = va_arg (args, unsigned);
 
             vlc_mutex_lock (&p_sys->lock);
-            vlc_stream_Control(stream->p_source, STREAM_SET_PAUSE_STATE,
-                               paused);
+            vlc_stream_Control(stream->s, STREAM_SET_PAUSE_STATE, paused);
             p_sys->paused = paused;
             vlc_cond_signal (&p_sys->wait);
             vlc_mutex_unlock (&p_sys->lock);
@@ -257,11 +256,9 @@ static int Open (stream_t *stream, const char *path)
     vlc_mutex_init (&p_sys->lock);
     p_sys->paused = false;
     p_sys->pid = -1;
-    vlc_stream_Control(stream->p_source, STREAM_CAN_PAUSE, &p_sys->can_pause);
-    vlc_stream_Control(stream->p_source, STREAM_CAN_CONTROL_PACE,
-                       &p_sys->can_pace);
-    vlc_stream_Control(stream->p_source, STREAM_GET_PTS_DELAY,
-                       &p_sys->pts_delay);
+    vlc_stream_Control(stream->s, STREAM_CAN_PAUSE, &p_sys->can_pause);
+    vlc_stream_Control(stream->s, STREAM_CAN_CONTROL_PACE, &p_sys->can_pace);
+    vlc_stream_Control(stream->s, STREAM_GET_PTS_DELAY, &p_sys->pts_delay);
 
     /* I am not a big fan of the pyramid style, but I cannot think of anything
      * better here. There are too many failure cases. */
@@ -378,7 +375,7 @@ static int OpenGzip (vlc_object_t *obj)
     stream_t      *stream = (stream_t *)obj;
     const uint8_t *peek;
 
-    if (vlc_stream_Peek (stream->p_source, &peek, 3) < 3)
+    if (vlc_stream_Peek (stream->s, &peek, 3) < 3)
         return VLC_EGENERIC;
 
     if (memcmp (peek, "\x1f\x8b\x08", 3))
@@ -398,7 +395,7 @@ static int OpenBzip2 (vlc_object_t *obj)
     const uint8_t *peek;
 
     /* (Try to) parse the bzip2 header */
-    if (vlc_stream_Peek (stream->p_source, &peek, 10) < 10)
+    if (vlc_stream_Peek (stream->s, &peek, 10) < 10)
         return VLC_EGENERIC;
 
     if (memcmp (peek, "BZh", 3) || (peek[3] < '1') || (peek[3] > '9')
@@ -418,7 +415,7 @@ static int OpenXZ (vlc_object_t *obj)
     const uint8_t *peek;
 
     /* (Try to) parse the xz stream header */
-    if (vlc_stream_Peek (stream->p_source, &peek, 8) < 8)
+    if (vlc_stream_Peek (stream->s, &peek, 8) < 8)
         return VLC_EGENERIC;
 
     if (memcmp (peek, "\xfd\x37\x7a\x58\x5a", 6))
diff --git a/modules/stream_filter/hds/hds.c b/modules/stream_filter/hds/hds.c
index 1610868896..5dbd15a193 100644
--- a/modules/stream_filter/hds/hds.c
+++ b/modules/stream_filter/hds/hds.c
@@ -223,7 +223,7 @@ static inline bool isFQUrl( const char* url )
 static bool isHDS( stream_t *s )
 {
     const uint8_t *peek;
-    int i_size = vlc_stream_Peek( s->p_source, &peek, 200 );
+    int i_size = vlc_stream_Peek( s->s, &peek, 200 );
     if( i_size < 200 )
         return false;
 
@@ -1181,7 +1181,7 @@ static void* live_thread( void* p )
 static int init_Manifest( stream_t *s, manifest_t *m )
 {
     memset(m, 0, sizeof(*m));
-    stream_t *st = s->p_source;
+    stream_t *st = s->s;
 
     m->vlc_reader = xml_ReaderCreate( st, st );
     if( !m->vlc_reader )
diff --git a/modules/stream_filter/inflate.c b/modules/stream_filter/inflate.c
index 05f3a5c2ed..0388851ee6 100644
--- a/modules/stream_filter/inflate.c
+++ b/modules/stream_filter/inflate.c
@@ -56,7 +56,7 @@ static ssize_t Read(stream_t *stream, void *buf, size_t buflen)
 
     if (val > 0)
     {   /* Fill input buffer if there is space left */
-        val = vlc_stream_Read(stream->p_source,
+        val = vlc_stream_Read(stream->s,
                           sys->zstream.next_in + sys->zstream.avail_in, val);
         if (val >= 0)
             sys->zstream.avail_in += val;
@@ -121,7 +121,7 @@ static int Control(stream_t *stream, int query, va_list args)
         case STREAM_GET_CONTENT_TYPE:
         case STREAM_GET_SIGNAL:
         case STREAM_SET_PAUSE_STATE:
-            return vlc_stream_vaControl(stream->p_source, query, args);
+            return vlc_stream_vaControl(stream->s, query, args);
         case STREAM_IS_DIRECTORY:
         case STREAM_GET_SIZE:
         case STREAM_GET_TITLE_INFO:
@@ -147,7 +147,7 @@ static int Open(vlc_object_t *obj)
     int bits;
 
     /* See IETF RFC6713 */
-    if (vlc_stream_Peek(stream->p_source, &peek, 2) < 2)
+    if (vlc_stream_Peek(stream->s, &peek, 2) < 2)
         return VLC_EGENERIC;
 
     if ((peek[0] & 0xF) == 8 && (peek[0] >> 4) < 8 && (U16_AT(peek) % 31) == 0)
diff --git a/modules/stream_filter/prefetch.c b/modules/stream_filter/prefetch.c
index b1cb479f07..a3dc3a8c06 100644
--- a/modules/stream_filter/prefetch.c
+++ b/modules/stream_filter/prefetch.c
@@ -71,7 +71,7 @@ static ssize_t ThreadRead(stream_t *stream, void *buf, size_t length)
     vlc_mutex_unlock(&sys->lock);
     assert(length > 0);
 
-    ssize_t val = vlc_stream_ReadPartial(stream->p_source, buf, length);
+    ssize_t val = vlc_stream_ReadPartial(stream->s, buf, length);
 
     vlc_mutex_lock(&sys->lock);
     vlc_restorecancel(canc);
@@ -85,7 +85,7 @@ static int ThreadSeek(stream_t *stream, uint64_t seek_offset)
 
     vlc_mutex_unlock(&sys->lock);
 
-    int val = vlc_stream_Seek(stream->p_source, seek_offset);
+    int val = vlc_stream_Seek(stream->s, seek_offset);
     if (val != VLC_SUCCESS)
         msg_Err(stream, "cannot seek (to offset %"PRIu64")", seek_offset);
 
@@ -106,7 +106,7 @@ static int ThreadControl(stream_t *stream, int query, ...)
     int ret;
 
     va_start(ap, query);
-    ret = vlc_stream_vaControl(stream->p_source, query, ap);
+    ret = vlc_stream_vaControl(stream->s, query, ap);
     va_end(ap);
 
     vlc_mutex_lock(&sys->lock);
@@ -411,7 +411,7 @@ static int Open(vlc_object_t *obj)
      * caching/prefetching. Also, prefetching with this module could cause
      * undesirable high load at start-up. Lastly, local files may require
      * support for title/seekpoint and meta control requests. */
-    vlc_stream_Control(stream->p_source, STREAM_CAN_FASTSEEK, &fast_seek);
+    vlc_stream_Control(stream->s, STREAM_CAN_FASTSEEK, &fast_seek);
     if (fast_seek)
         return VLC_EGENERIC;
 
@@ -419,7 +419,7 @@ static int Open(vlc_object_t *obj)
      * suffer excessive latency to enable a PID. DVB would also require support
      * for the signal level and Conditional Access controls.
      * TODO? For seekable streams, a forced could work around the problem. */
-    if (vlc_stream_Control(stream->p_source, STREAM_GET_PRIVATE_ID_STATE, 0,
+    if (vlc_stream_Control(stream->s, STREAM_GET_PRIVATE_ID_STATE, 0,
                            &(bool){ false }) == VLC_SUCCESS)
         return VLC_EGENERIC;
 
@@ -431,15 +431,13 @@ static int Open(vlc_object_t *obj)
     stream->pf_seek = Seek;
     stream->pf_control = Control;
 
-    vlc_stream_Control(stream->p_source, STREAM_CAN_SEEK, &sys->can_seek);
-    vlc_stream_Control(stream->p_source, STREAM_CAN_PAUSE, &sys->can_pause);
-    vlc_stream_Control(stream->p_source, STREAM_CAN_CONTROL_PACE,
-                       &sys->can_pace);
-    if (vlc_stream_Control(stream->p_source, STREAM_GET_SIZE, &sys->size))
+    vlc_stream_Control(stream->s, STREAM_CAN_SEEK, &sys->can_seek);
+    vlc_stream_Control(stream->s, STREAM_CAN_PAUSE, &sys->can_pause);
+    vlc_stream_Control(stream->s, STREAM_CAN_CONTROL_PACE, &sys->can_pace);
+    if (vlc_stream_Control(stream->s, STREAM_GET_SIZE, &sys->size))
         sys->size = -1;
-    vlc_stream_Control(stream->p_source, STREAM_GET_PTS_DELAY,
-                       &sys->pts_delay);
-    if (vlc_stream_Control(stream->p_source, STREAM_GET_CONTENT_TYPE,
+    vlc_stream_Control(stream->s, STREAM_GET_PTS_DELAY, &sys->pts_delay);
+    if (vlc_stream_Control(stream->s, STREAM_GET_CONTENT_TYPE,
                            &sys->content_type))
         sys->content_type = NULL;
 
@@ -453,7 +451,7 @@ static int Open(vlc_object_t *obj)
     sys->read_size = var_InheritInteger(obj, "prefetch-read-size");
     sys->seek_threshold = var_InheritInteger(obj, "prefetch-seek-threshold");
 
-    uint64_t size = stream_Size(stream->p_source);
+    uint64_t size = stream_Size(stream->s);
     if (size > 0)
     {   /* No point allocating a buffer larger than the source stream */
         if (sys->buffer_size > size)
diff --git a/modules/stream_filter/record.c b/modules/stream_filter/record.c
index 5185d12d89..ced4e31271 100644
--- a/modules/stream_filter/record.c
+++ b/modules/stream_filter/record.c
@@ -117,7 +117,7 @@ static ssize_t Read( stream_t *s, void *p_read, size_t i_read )
 {
     stream_sys_t *p_sys = s->p_sys;
     void *p_record = p_read;
-    const ssize_t i_record = vlc_stream_Read( s->p_source, p_record, i_read );
+    const ssize_t i_record = vlc_stream_Read( s->s, p_record, i_read );
 
     /* Dump read data */
     if( p_sys->f )
@@ -131,13 +131,13 @@ static ssize_t Read( stream_t *s, void *p_read, size_t i_read )
 
 static int Seek( stream_t *s, uint64_t offset )
 {
-    return vlc_stream_Seek( s->p_source, offset );
+    return vlc_stream_Seek( s->s, offset );
 }
 
 static int Control( stream_t *s, int i_query, va_list args )
 {
     if( i_query != STREAM_SET_RECORD_STATE )
-        return vlc_stream_vaControl( s->p_source, i_query, args );
+        return vlc_stream_vaControl( s->s, i_query, args );
 
     stream_sys_t *sys = s->p_sys;
     bool b_active = (bool)va_arg( args, int );
diff --git a/modules/stream_filter/skiptags.c b/modules/stream_filter/skiptags.c
index b7479d3d35..5399cbb4e0 100644
--- a/modules/stream_filter/skiptags.c
+++ b/modules/stream_filter/skiptags.c
@@ -149,7 +149,7 @@ static bool SkipTag(stream_t *s, uint_fast32_t (*skipper)(stream_t *),
 
 static ssize_t Read(stream_t *stream, void *buf, size_t buflen)
 {
-    return vlc_stream_Read(stream->p_source, buf, buflen);
+    return vlc_stream_Read(stream->s, buf, buflen);
 }
 
 static int ReadDir(stream_t *stream, input_item_node_t *node)
@@ -164,7 +164,7 @@ static int Seek(stream_t *stream, uint64_t offset)
 
     if (unlikely(offset + sys->header_skip < offset))
         return -1;
-    return vlc_stream_Seek(stream->p_source, sys->header_skip + offset);
+    return vlc_stream_Seek(stream->s, sys->header_skip + offset);
 }
 
 static int Control(stream_t *stream, int query, va_list args)
@@ -179,13 +179,13 @@ static int Control(stream_t *stream, int query, va_list args)
         return VLC_SUCCESS;
     }
 
-    return vlc_stream_vaControl(stream->p_source, query, args);
+    return vlc_stream_vaControl(stream->s, query, args);
 }
 
 static int Open(vlc_object_t *obj)
 {
     stream_t *stream = (stream_t *)obj;
-    stream_t *s = stream->p_source;
+    stream_t *s = stream->s;
     struct skiptags_sys_t *sys;
 
     block_t *p_tags = NULL, *p_tag = NULL;
diff --git a/src/input/stream.c b/src/input/stream.c
index 07f3f886f7..d4d7c00745 100644
--- a/src/input/stream.c
+++ b/src/input/stream.c
@@ -75,7 +75,7 @@ stream_t *vlc_stream_CommonNew(vlc_object_t *parent,
 
     s->p_module = NULL;
     s->psz_url = NULL;
-    s->p_source = NULL;
+    s->s = NULL;
     s->pf_read = NULL;
     s->pf_block = NULL;
     s->pf_readdir = NULL;
diff --git a/src/input/stream_filter.c b/src/input/stream_filter.c
index eeae19faee..32442566e6 100644
--- a/src/input/stream_filter.c
+++ b/src/input/stream_filter.c
@@ -54,7 +54,7 @@ stream_t *vlc_stream_FilterNew( stream_t *p_source,
         if( unlikely(s->psz_url == NULL) )
             goto error;
     }
-    s->p_source = p_source;
+    s->s = p_source;
 
     /* */
     s->p_module = module_need( s, "stream_filter", psz_stream_filter, true );
@@ -111,12 +111,12 @@ static void StreamDelete( stream_t *s )
 {
     module_unneed( s, s->p_module );
 
-    if( s->p_source )
-        vlc_stream_Delete( s->p_source );
+    if( s->s != NULL )
+        vlc_stream_Delete( s->s );
 }
 
 int vlc_stream_FilterDefaultReadDir( stream_t *s, input_item_node_t *p_node )
 {
-    assert( s->p_source != NULL );
-    return vlc_stream_ReadDir( s->p_source, p_node );
+    assert( s->s != NULL );
+    return vlc_stream_ReadDir( s->s, p_node );
 }




More information about the vlc-commits mailing list