]> git.sesse.net Git - vlc/blobdiff - modules/access/mms/mmsh.c
Remove legacy casts
[vlc] / modules / access / mms / mmsh.c
index fe31cc4f6265a51e4cd2fdb21fb17ec99e797347..e191b2a48f3b527096fddab344618ce59d4d011f 100644 (file)
@@ -62,7 +62,7 @@ static int  Start( access_t *, uint64_t );
 static void Stop( access_t * );
 
 static int  GetPacket( access_t *, chunk_t * );
-static void GetHeader( access_t *p_access );
+static void GetHeader( access_t *p_access, int i_content_length );
 
 static int Restart( access_t * );
 static int Reset( access_t * );
@@ -137,7 +137,7 @@ int MMSHOpen( access_t *p_access )
     }
 
     /* open a tcp connection */
-    vlc_UrlParse( &p_sys->url, p_access->psz_path, 0 );
+    vlc_UrlParse( &p_sys->url, p_access->psz_location, 0 );
     if( ( p_sys->url.psz_host == NULL ) ||
         ( *p_sys->url.psz_host == '\0' ) )
     {
@@ -250,7 +250,7 @@ static int Control( access_t *p_access, int i_query, va_list args )
         /* */
         case ACCESS_GET_PTS_DELAY:
             pi_64 = (int64_t*)va_arg( args, int64_t * );
-            *pi_64 = (int64_t)var_GetInteger( p_access, "mms-caching" ) * INT64_C(1000);
+            *pi_64 = var_GetInteger( p_access, "mms-caching" ) * INT64_C(1000);
             break;
 
         case ACCESS_GET_PRIVATE_ID_STATE:
@@ -451,7 +451,7 @@ static int Reset( access_t *p_access )
     p_sys->p_packet = NULL;
 
     /* Get the next header FIXME memory loss ? */
-    GetHeader( p_access );
+    GetHeader( p_access, -1 );
     if( p_sys->i_header <= 0 )
         return VLC_EGENERIC;
 
@@ -462,10 +462,10 @@ static int Reset( access_t *p_access )
              p_sys->asfh.i_min_data_packet_size );
 
     asf_StreamSelect( &p_sys->asfh,
-                       var_CreateGetInteger( p_access, "mms-maxbitrate" ),
-                       var_CreateGetBool( p_access, "mms-all" ),
-                       var_CreateGetInteger( p_access, "audio" ),
-                       var_CreateGetInteger( p_access, "video" ) );
+                       var_InheritInteger( p_access, "mms-maxbitrate" ),
+                       var_InheritBool( p_access, "mms-all" ),
+                       var_InheritBool( p_access, "audio" ),
+                       var_InheritBool( p_access, "video" ) );
 
     /* Check we have comptible asfh */
     for( i = 1; i < 128; i++ )
@@ -548,6 +548,8 @@ static int Describe( access_t  *p_access, char **ppsz_location )
 {
     access_sys_t *p_sys = p_access->p_sys;
     char         *psz_location = NULL;
+    int          i_content_length = -1;
+    bool         b_keepalive = false;
     char         *psz;
     int          i_code;
 
@@ -656,6 +658,20 @@ static int Describe( access_t  *p_access, char **ppsz_location )
         {
             psz_location = strdup( p );
         }
+        else if( !strcasecmp( psz, "Content-Length" ) )
+        {
+            i_content_length = atoi( p );
+            msg_Dbg( p_access, "content-length = %d", i_content_length );
+        }
+        else if( !strcasecmp( psz, "Connection" ) )
+        {
+            if( strcasestr( p, "Keep-Alive" ) )
+            {
+                msg_Dbg( p_access, "Keep-Alive header found" );
+                b_keepalive = true;
+            }
+        }
+
 
         free( psz );
     }
@@ -674,7 +690,7 @@ static int Describe( access_t  *p_access, char **ppsz_location )
     free( psz_location );
 
     /* Read the asf header */
-    GetHeader( p_access );
+    GetHeader( p_access, b_keepalive ? i_content_length : -1);
     if( p_sys->i_header <= 0 )
     {
         msg_Err( p_access, "header size == 0" );
@@ -699,10 +715,10 @@ static int Describe( access_t  *p_access, char **ppsz_location )
         goto error;
 
     asf_StreamSelect( &p_sys->asfh,
-                       var_CreateGetInteger( p_access, "mms-maxbitrate" ),
-                       var_CreateGetBool( p_access, "mms-all" ),
-                       var_CreateGetInteger( p_access, "audio" ),
-                       var_CreateGetInteger( p_access, "video" ) );
+                       var_InheritInteger( p_access, "mms-maxbitrate" ),
+                       var_InheritBool( p_access, "mms-all" ),
+                       var_InheritBool( p_access, "audio" ),
+                       var_InheritBool( p_access, "video" ) );
     return VLC_SUCCESS;
 
 error:
@@ -714,9 +730,10 @@ error:
     return VLC_EGENERIC;
 }
 
-static void GetHeader( access_t *p_access )
+static void GetHeader( access_t *p_access, int i_content_length )
 {
     access_sys_t *p_sys = p_access->p_sys;
+    int i_read_content = 0;
 
     /* Read the asf header */
     p_sys->i_header = 0;
@@ -725,9 +742,11 @@ static void GetHeader( access_t *p_access )
     for( ;; )
     {
         chunk_t ck;
-        if( GetPacket( p_access, &ck ) || ck.i_type != 0x4824 )
+        if( (i_content_length >= 0 && i_read_content >= i_content_length) || GetPacket( p_access, &ck ) || ck.i_type != 0x4824 )
             break;
 
+        i_read_content += (4+ck.i_size);
+
         if( ck.i_data > 0 )
         {
             p_sys->i_header += ck.i_data;