]> git.sesse.net Git - vlc/blobdiff - extras/libdvdcss/libdvdcss.c
Use of an environment variable to choose libdvdcss method.
[vlc] / extras / libdvdcss / libdvdcss.c
index e9b8f19f6f4ad4420fffff64ccd2fc376caffbe2..f698209eab5fc2622055ac2aeded8c764e643d96 100644 (file)
@@ -2,10 +2,11 @@
  * libdvdcss.c: DVD reading library.
  *****************************************************************************
  * Copyright (C) 1998-2001 VideoLAN
- * $Id: libdvdcss.c,v 1.8 2001/07/25 00:23:40 sam Exp $
+ * $Id: libdvdcss.c,v 1.17 2001/10/14 03:26:20 stef Exp $
  *
  * Authors: Stéphane Borel <stef@via.ecp.fr>
  *          Samuel Hocevar <sam@zoy.org>
+ *          Håkan Hjort <d95hjort@dtek.chalmers.se>
  *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
@@ -29,6 +30,7 @@
 
 #include <stdio.h>
 #include <stdlib.h>
+#include <string.h>
 #include <sys/types.h>
 #include <sys/stat.h>
 #include <fcntl.h>
@@ -38,8 +40,7 @@
 #endif
 
 #if defined( WIN32 )
-#   include <io.h>
-#   include "input_iovec.h"
+#   include <io.h>                                                 /* read() */
 #else
 #   include <sys/uio.h>                                      /* struct iovec */
 #endif
 #include "config.h"
 #include "common.h"
 
+#if defined( WIN32 )
+#   include "input_iovec.h"
+#endif
+
 #include "videolan/dvdcss.h"
 #include "libdvdcss.h"
 #include "ioctl.h"
@@ -65,7 +70,7 @@ static int _dvdcss_readv ( dvdcss_handle, struct iovec *p_iovec, int i_blocks );
  *****************************************************************************/
 #if defined( WIN32 )
 static int _win32_dvdcss_readv  ( int i_fd, struct iovec *p_iovec,
-                                  int i_num_buffers );
+                                  int i_num_buffers, char *p_tmp_buffer );
 static int _win32_dvdcss_aopen  ( char c_drive, dvdcss_handle dvdcss );
 static int _win32_dvdcss_aclose ( int i_fd );
 static int _win32_dvdcss_aseek  ( int i_fd, int i_blocks, int i_method );
@@ -79,6 +84,8 @@ extern dvdcss_handle dvdcss_open ( char *psz_target, int i_flags )
 {
     int i_ret;
 
+    char    psz_method[16] = "dvdcss_method";
+
     dvdcss_handle dvdcss;
 
     /* Allocate the library structure */
@@ -99,6 +106,23 @@ extern dvdcss_handle dvdcss_open ( char *psz_target, int i_flags )
     dvdcss->b_errors = !(i_flags & DVDCSS_INIT_QUIET);
     dvdcss->psz_error = "no error";
 
+
+
+    /* find method from DVDCSS_METHOD environment variable */
+    dvdcss->i_method = DVDCSS_TITLE;
+
+    if( getenv( psz_method ) )
+    {
+        if( !strncmp( getenv( psz_method ), "key", 3 ) )
+        {
+            dvdcss->i_method = DVDCSS_KEY;
+        }
+        else if( !strncmp( getenv( psz_method ), "disc", 4 ) )
+        {
+            dvdcss->i_method = DVDCSS_DISC;
+        }
+    }
+
     i_ret = _dvdcss_open( dvdcss, psz_target );
     if( i_ret < 0 )
     {
@@ -109,18 +133,21 @@ extern dvdcss_handle dvdcss_open ( char *psz_target, int i_flags )
     i_ret = CSSTest( dvdcss );
     if( i_ret < 0 )
     {
-        _dvdcss_error( dvdcss, "css test failed" );
-        _dvdcss_close( dvdcss );
-        free( dvdcss );
-        return NULL;
+        _dvdcss_error( dvdcss, "CSS test failed" );
+        /* Disable the CSS ioctls and hope that it works? */
+        dvdcss->b_ioctls = 0;
+        dvdcss->b_encrypted = 1;
+    }
+    else
+    {
+        dvdcss->b_ioctls = 1;
+        dvdcss->b_encrypted = i_ret;
     }
 
-    dvdcss->b_encrypted = i_ret;
-
-    /* If drive is encrypted, crack its key */
-    if( dvdcss->b_encrypted )
+    /* If disc is CSS protected and the ioctls work, authenticate the drive */
+    if( dvdcss->b_encrypted && dvdcss->b_ioctls )
     {
-        i_ret = CSSInit( dvdcss );
+        i_ret = CSSGetDiscKey( dvdcss );
 
         if( i_ret < 0 )
         {
@@ -144,19 +171,30 @@ extern char * dvdcss_error ( dvdcss_handle dvdcss )
 /*****************************************************************************
  * dvdcss_seek: seek into the device
  *****************************************************************************/
-extern int dvdcss_seek ( dvdcss_handle dvdcss, int i_blocks )
+extern int dvdcss_seek ( dvdcss_handle dvdcss, int i_blocks, int i_flags )
 {
+    /* title cracking method is too slow to be used at each seek */
+    if( ( ( i_flags & DVDCSS_SEEK_MPEG ) && ( dvdcss->i_method != DVDCSS_TITLE ) )
+       || ( i_flags & DVDCSS_SEEK_INI ) )
+    {
+        /* check the title key */
+        dvdcss_title( dvdcss, i_blocks );
+    }
+
     return _dvdcss_seek( dvdcss, i_blocks );
 }
 
 /*****************************************************************************
- * dvdcss_crack: crack the current title key
+ * dvdcss_title: crack or decrypt the current title key if needed
+ *****************************************************************************
+ * This function should only be called by dvdcss_seek and should eventually
+ * not be external if possible.
  *****************************************************************************/
-extern int dvdcss_crack ( dvdcss_handle dvdcss, int i_block )
+extern int dvdcss_title ( dvdcss_handle dvdcss, int i_block )
 {
     dvd_title_t *p_title;
-    dvd_key_t p_key;
-    int i_ret;
+    dvd_title_t *p_newtitle;
+    int          i_ret;
 
     if( ! dvdcss->b_encrypted )
     {
@@ -176,11 +214,12 @@ extern int dvdcss_crack ( dvdcss_handle dvdcss, int i_block )
          && p_title->i_startlb == i_block )
     {
         /* We've already cracked this key, nothing to do */
+        memcpy( dvdcss->css.p_title_key, p_title->p_key, sizeof(dvd_key_t) );
         return 0;
     }
 
-    /* Crack CSS title key for current VTS */
-    i_ret = CSSGetKey( dvdcss, i_block, p_key );
+    /* Crack or decrypt CSS title key for current VTS */
+    i_ret = CSSGetTitleKey( dvdcss, i_block );
 
     if( i_ret < 0 )
     {
@@ -193,45 +232,39 @@ extern int dvdcss_crack ( dvdcss_handle dvdcss, int i_block )
         return -1;
     }
 
-    /* Add key to keytable if it isn't empty */
-    if( p_key[0] | p_key[1] | p_key[2] | p_key[3] | p_key[4] )
+    /* Find our spot in the list */
+    p_newtitle = NULL;
+    p_title = dvdcss->p_titles;
+    while( ( p_title != NULL ) && ( p_title->i_startlb < i_block ) )
     {
-        dvd_title_t *p_newtitle;
-
-        /* Find our spot in the list */
-        p_newtitle = NULL;
-        p_title = dvdcss->p_titles;
-        while( p_title != NULL
-                && p_title->i_startlb < i_block )
-        {
-            p_newtitle = p_title;
-            p_title = p_title->p_next;
-        }
+        p_newtitle = p_title;
+        p_title = p_title->p_next;
+    }
 
-        /* Save the found title */
-        p_title = p_newtitle;
+    /* Save the found title */
+    p_title = p_newtitle;
 
-        /* Write in the new title and its key */
-        p_newtitle = malloc( sizeof( dvd_title_t ) );
-        p_newtitle->i_startlb = i_block;
-        memcpy( p_newtitle->p_key, p_key, KEY_SIZE );
+    /* Write in the new title and its key */
+    p_newtitle = malloc( sizeof( dvd_title_t ) );
+    p_newtitle->i_startlb = i_block;
+    memcpy( p_newtitle->p_key, dvdcss->css.p_title_key, KEY_SIZE );
 
-        /* Link the new title, either at the beginning or inside the list */
-        if( p_title == NULL )
-        {
-            dvdcss->p_titles = p_newtitle;
-            p_newtitle->p_next = NULL;
-        }
-        else
-        {
-            p_newtitle->p_next = p_title->p_next;
-            p_title->p_next = p_newtitle;
-        }
+    /* Link the new title, either at the beginning or inside the list */
+    if( p_title == NULL )
+    {
+        dvdcss->p_titles = p_newtitle;
+        p_newtitle->p_next = NULL;
+    }
+    else
+    {
+        p_newtitle->p_next = p_title->p_next;
+        p_title->p_next = p_newtitle;
     }
 
     return 0;
 }
 
+#define Pkey dvdcss->css.p_title_key
 /*****************************************************************************
  * dvdcss_read: read data from the device, decrypt if requested
  *****************************************************************************/
@@ -239,7 +272,6 @@ extern int dvdcss_read ( dvdcss_handle dvdcss, void *p_buffer,
                                                int i_blocks,
                                                int i_flags )
 {
-    dvd_title_t *p_title;
     int i_ret, i_index;
 
     i_ret = _dvdcss_read( dvdcss, p_buffer, i_blocks );
@@ -251,25 +283,27 @@ extern int dvdcss_read ( dvdcss_handle dvdcss, void *p_buffer,
         return i_ret;
     }
 
-    /* find our key */
-    p_title = dvdcss->p_titles;
-    while( p_title != NULL
-            && p_title->p_next
-            && p_title->p_next->i_startlb < dvdcss->i_seekpos )
-    {
-        p_title = p_title->p_next;
-    }
-
-    if( p_title == NULL )
+    /* For what we believe is an unencrypted title, 
+       check that there are no encrypted blocks */
+    if( !( Pkey[0] | Pkey[1] | Pkey[2] | Pkey[3] | Pkey[4] ) ) 
     {
-        /* no css key found to use, so no decryption to do */
-        return 0;
+        for( i_index = i_ret; i_index; i_index-- )
+        {
+            if( ((u8*)p_buffer)[0x14] & 0x30 )
+            {
+                _dvdcss_error( dvdcss, "no key but found encrypted block" );
+                /* Only return the initial range of unscrambled blocks? */
+                i_ret = i_index;
+                /* or fail completely? return 0; */
+            }
+            (u8*)p_buffer += DVDCSS_BLOCK_SIZE;
+        }
     }
 
     /* Decrypt the blocks we managed to read */
     for( i_index = i_ret; i_index; i_index-- )
     {
-        CSSDescrambleSector( p_title->p_key, p_buffer );
+        CSSDescrambleSector( dvdcss->css.p_title_key, p_buffer );
         ((u8*)p_buffer)[0x14] &= 0x8f;
         (u8*)p_buffer += DVDCSS_BLOCK_SIZE;
     }
@@ -278,14 +312,13 @@ extern int dvdcss_read ( dvdcss_handle dvdcss, void *p_buffer,
 }
 
 /*****************************************************************************
- * dvdcss_readv: read data to an iovec structure, decrypt if reaquested
+ * dvdcss_readv: read data to an iovec structure, decrypt if requested
  *****************************************************************************/
 extern int dvdcss_readv ( dvdcss_handle dvdcss, void *p_iovec,
                                                 int i_blocks,
                                                 int i_flags )
 {
 #define P_IOVEC ((struct iovec*)p_iovec)
-    dvd_title_t *p_title;
     int i_ret, i_index;
     void *iov_base;
     size_t iov_len;
@@ -299,20 +332,6 @@ extern int dvdcss_readv ( dvdcss_handle dvdcss, void *p_iovec,
         return i_ret;
     }
 
-    /* Find our key */
-    p_title = dvdcss->p_titles;
-    while( p_title != NULL
-            && p_title->p_next != NULL
-            && p_title->p_next->i_startlb < dvdcss->i_seekpos )
-    {
-        p_title = p_title->p_next;
-    }
-
-    if( p_title == NULL )
-    {
-        /* no css key found to use, so no decryption to do */
-        return 0;
-    }
 
     /* Initialize loop for decryption */
     iov_base = P_IOVEC->iov_base;
@@ -334,7 +353,7 @@ extern int dvdcss_readv ( dvdcss_handle dvdcss, void *p_iovec,
             iov_len = P_IOVEC->iov_len;
         }
 
-        CSSDescrambleSector( p_title->p_key, iov_base );
+        CSSDescrambleSector( dvdcss->css.p_title_key, iov_base );
         ((u8*)iov_base)[0x14] &= 0x8f;
 
         (u8*)iov_base += DVDCSS_BLOCK_SIZE;
@@ -344,6 +363,7 @@ extern int dvdcss_readv ( dvdcss_handle dvdcss, void *p_iovec,
     return i_ret;
 #undef P_IOVEC
 }
+#undef Pkey
 
 /*****************************************************************************
  * dvdcss_close: close the DVD device and clean up the library
@@ -403,6 +423,10 @@ static int _dvdcss_open ( dvdcss_handle dvdcss, char *psz_target )
         }
     }
 
+    /* initialise readv temporary buffer */
+    dvdcss->p_readv_buffer   = NULL;
+    dvdcss->i_readv_buf_size = 0;
+
 #else
     dvdcss->i_fd = open( psz_target, 0 );
 
@@ -428,8 +452,18 @@ static int _dvdcss_close ( dvdcss_handle dvdcss )
     {
         _win32_dvdcss_aclose( dvdcss->i_fd );
     }
+
+    /* Free readv temporary buffer */
+    if( dvdcss->p_readv_buffer )
+    {
+        free( dvdcss->p_readv_buffer );
+        dvdcss->p_readv_buffer   = NULL;
+        dvdcss->i_readv_buf_size = 0;
+    }
+
 #else
     close( dvdcss->i_fd );
+
 #endif
 
     return 0;
@@ -438,6 +472,8 @@ static int _dvdcss_close ( dvdcss_handle dvdcss )
 static int _dvdcss_seek ( dvdcss_handle dvdcss, int i_blocks )
 {
 #if defined( WIN32 )
+    dvdcss->i_seekpos = i_blocks;
+
     if( WIN2K )
     {
         LARGE_INTEGER li_read;
@@ -513,14 +549,36 @@ static int _dvdcss_readv ( dvdcss_handle dvdcss, struct iovec *p_iovec,
     int i_read;
 
 #if defined( WIN32 )
-    i_read = _win32_dvdcss_readv( dvdcss->i_fd, p_iovec, i_blocks );
+    /* Check the size of the readv temp buffer, just in case we need to
+     * realloc something bigger */
+    if( dvdcss->i_readv_buf_size < i_blocks * DVDCSS_BLOCK_SIZE )
+    {
+        dvdcss->i_readv_buf_size = i_blocks * DVDCSS_BLOCK_SIZE;
+
+        if( dvdcss->p_readv_buffer ) free( dvdcss->p_readv_buffer );
+
+        /* Allocate a buffer which will be used as a temporary storage
+         * for readv */
+        dvdcss->p_readv_buffer = malloc( dvdcss->i_readv_buf_size );
+        if( !dvdcss->p_readv_buffer )
+        {
+            _dvdcss_error( dvdcss, " failed (readv)" );
+            return -1;
+        }
+    }
+
+    i_read = _win32_dvdcss_readv( dvdcss->i_fd, p_iovec, i_blocks,
+                                  dvdcss->p_readv_buffer );
     return i_read;
+
 #else
     i_read = readv( dvdcss->i_fd, p_iovec, i_blocks );
     return i_read / DVDCSS_BLOCK_SIZE;
+
 #endif
 }
 
+
 #if defined( WIN32 )
 
 /*****************************************************************************
@@ -528,75 +586,58 @@ static int _dvdcss_readv ( dvdcss_handle dvdcss, struct iovec *p_iovec,
  *                      _win32_dvdcss_aread for win9x
  *****************************************************************************/
 static int _win32_dvdcss_readv( int i_fd, struct iovec *p_iovec,
-                                int i_num_buffers )
+                                int i_num_buffers, char *p_tmp_buffer )
 {
-    int i_index, i_len, i_total = 0;
-    unsigned char *p_base;
-    int i_blocks;
+    int i_index;
+    int i_blocks, i_blocks_total = 0;
 
-    if( WIN2K )
+    for( i_index = i_num_buffers; i_index; i_index-- )
     {
-        for( i_index = i_num_buffers; i_index; i_index-- )
-        {
-            i_len  = p_iovec->iov_len;
-            p_base = p_iovec->iov_base;
+        i_blocks_total += p_iovec[i_index-1].iov_len; 
+    }
 
-            if( i_len > 0 )
-            {
-                unsigned long int i_bytes;
-                if( !ReadFile( (HANDLE) i_fd, p_base, i_len, &i_bytes, NULL ) )
-                {
-                    return -1;
-                    /* One of the reads failed, too bad.
-                       We won't even bother returning the reads that went well,
-                       and like in the posix spec the file postition is left
-                       unspecified after a failure */
-                }
-                i_blocks = i_bytes / DVDCSS_BLOCK_SIZE;
-
-                i_total += i_blocks;
-
-                if( i_blocks != (i_len / DVDCSS_BLOCK_SIZE) )
-                {
-                    /* we reached the end of the file */
-                    return i_total;
-                }
+    if( i_blocks_total <= 0 ) return 0;
 
-            }
+    i_blocks_total /= DVDCSS_BLOCK_SIZE;
 
-            p_iovec++;
+    if( WIN2K )
+    {
+        unsigned long int i_bytes;
+        if( !ReadFile( (HANDLE)i_fd, p_tmp_buffer,
+                       i_blocks_total * DVDCSS_BLOCK_SIZE, &i_bytes, NULL ) )
+        {
+            return -1;
+            /* The read failed... too bad.
+               As in the posix spec the file postition is left
+               unspecified after a failure */
         }
+        i_blocks = i_bytes / DVDCSS_BLOCK_SIZE;
     }
     else /* Win9x */
     {
-        for( i_index = i_num_buffers; i_index; i_index-- )
+        i_blocks = _win32_dvdcss_aread( i_fd, p_tmp_buffer, i_blocks_total );
+        if( i_blocks < 0 )
         {
-            i_len  = p_iovec->iov_len / DVDCSS_BLOCK_SIZE;
-            p_base = p_iovec->iov_base;
-
-            if( i_len > 0 )
-            {
-                i_blocks = _win32_dvdcss_aread( i_fd, p_base, i_len );
-                if( i_blocks < 0 )
-                {
-                    return -1;  /* idem */
-                }
-
-                i_total += i_blocks;
-
-                if( i_blocks != i_len )
-                {
-                    /* we reached the end of the file or a signal interrupted
-                       the read */
-                    return i_total;
-                }
-            }
-
-            p_iovec++;
+            return -1;  /* idem */
         }
     }
 
-    return i_total;
+    /* We just have to copy the content of the temp buffer into the iovecs */
+    i_index = 0;
+    i_blocks_total = i_blocks;
+    while( i_blocks_total > 0 )
+    {
+        memcpy( p_iovec[i_index].iov_base,
+                &p_tmp_buffer[(i_blocks - i_blocks_total) * DVDCSS_BLOCK_SIZE],
+                p_iovec[i_index].iov_len );
+        /* if we read less blocks than asked, we'll just end up copying
+           garbage, this isn't an issue as we return the number of
+           blocks actually read */
+        i_blocks_total -= ( p_iovec[i_index].iov_len / DVDCSS_BLOCK_SIZE );
+        i_index++;
+    } 
+
+    return i_blocks;
 }
 
 /*****************************************************************************
@@ -611,7 +652,7 @@ static int _win32_dvdcss_aopen( char c_drive, dvdcss_handle dvdcss )
     int i, j, i_hostadapters;
     long (*lpGetSupport)( void );
     long (*lpSendCommand)( void* );
-    
+     
     hASPI = LoadLibrary( "wnaspi32.dll" );
     if( hASPI == NULL )
     {
@@ -621,7 +662,7 @@ static int _win32_dvdcss_aopen( char c_drive, dvdcss_handle dvdcss )
 
     (FARPROC) lpGetSupport = GetProcAddress( hASPI, "GetASPI32SupportInfo" );
     (FARPROC) lpSendCommand = GetProcAddress( hASPI, "SendASPI32Command" );
-    
     if(lpGetSupport == NULL || lpSendCommand == NULL )
     {
         _dvdcss_debug( dvdcss, "unable to get aspi function pointers" );
@@ -680,8 +721,8 @@ static int _win32_dvdcss_aopen( char c_drive, dvdcss_handle dvdcss )
 
             lpSendCommand( (void*) &srbDiskInfo );
 
-            if( srbDiskInfo.SRB_Status == SS_COMP &&
-                srbDiskInfo.SRB_Int13HDriveInfo == c_drive )
+            if( (srbDiskInfo.SRB_Status == SS_COMP) &&
+                (srbDiskInfo.SRB_Int13HDriveInfo == c_drive) )
             {
                 fd->i_sid = MAKEWORD( i, j );
                 return (int) fd;
@@ -692,8 +733,7 @@ static int _win32_dvdcss_aopen( char c_drive, dvdcss_handle dvdcss )
     free( (void*) fd );
     FreeLibrary( hASPI );
     _dvdcss_debug( dvdcss, "unable to get haid and target (aspi)" );
-
-    return( -1 );
+    return( -1 );        
 }
 
 /*****************************************************************************
@@ -743,56 +783,78 @@ static int _win32_dvdcss_aseek( int i_fd, int i_blocks, int i_method )
 static int _win32_dvdcss_aread( int i_fd, void *p_data, int i_blocks )
 {
     HANDLE hEvent;
-    DWORD dwStart, dwLen;
     struct SRB_ExecSCSICmd ssc;
     struct w32_aspidev *fd = (struct w32_aspidev *) i_fd;
 
-    memset( &ssc, 0, sizeof( ssc ) );
-
-    dwStart = fd->i_blocks;
-    dwLen = i_blocks;
-
+    /* Create the transfer completion event */
     hEvent = CreateEvent( NULL, TRUE, FALSE, NULL );
     if( hEvent == NULL )
     {
         return -1;
     }
 
+    memset( &ssc, 0, sizeof( ssc ) );
+
     ssc.SRB_Cmd         = SC_EXEC_SCSI_CMD;
     ssc.SRB_Flags       = SRB_DIR_IN | SRB_EVENT_NOTIFY;
     ssc.SRB_HaId        = LOBYTE( fd->i_sid );
     ssc.SRB_Target      = HIBYTE( fd->i_sid );
     ssc.SRB_SenseLen    = SENSE_LEN;
-    ssc.SRB_PostProc    = (LPVOID) hEvent;
-
-    ssc.SRB_BufLen      = dwLen * DVDCSS_BLOCK_SIZE;
+    
+    ssc.SRB_PostProc = (LPVOID) hEvent;
     ssc.SRB_BufPointer  = p_data;
     ssc.SRB_CDBLen      = 12;
-
+    
     ssc.CDBByte[0]      = 0xA8; /* RAW */
-    ssc.CDBByte[2]      = (UCHAR) dwStart >> 24;
-    ssc.CDBByte[3]      = (UCHAR) (dwStart >> 16) & 0xff;
-    ssc.CDBByte[4]      = (UCHAR) (dwStart >> 8) & 0xff;
-    ssc.CDBByte[5]      = (UCHAR) (dwStart) & 0xff;
-    ssc.CDBByte[6]      = (UCHAR) dwLen >> 24;
-    ssc.CDBByte[7]      = (UCHAR) (dwLen >> 16) & 0xff;
-    ssc.CDBByte[8]      = (UCHAR) (dwLen >> 8) & 0xff;
-    ssc.CDBByte[9]      = (UCHAR) (dwLen) & 0xff;
-
-    ResetEvent( hEvent );
-    if( fd->lpSendCommand( (void*) &ssc ) == SS_PENDING )
+    ssc.CDBByte[2]      = (UCHAR) (fd->i_blocks >> 24);
+    ssc.CDBByte[3]      = (UCHAR) (fd->i_blocks >> 16) & 0xff;
+    ssc.CDBByte[4]      = (UCHAR) (fd->i_blocks >> 8) & 0xff;
+    ssc.CDBByte[5]      = (UCHAR) (fd->i_blocks) & 0xff;
+    
+    /* We have to break down the reads into 64kb pieces (ASPI restriction) */
+    if( i_blocks > 32 )
     {
-        WaitForSingleObject( hEvent, INFINITE );
+        ssc.SRB_BufLen = 32 * DVDCSS_BLOCK_SIZE;
+        ssc.CDBByte[9] = 32;
+        fd->i_blocks  += 32;
+
+        /* Initiate transfer */  
+        ResetEvent( hEvent );
+        fd->lpSendCommand( (void*) &ssc );
+
+        /* transfer the next 64kb (_win32_dvdcss_aread is called recursively)
+         * We need to check the status of the read on return */
+        if( _win32_dvdcss_aread( i_fd, (u8*) p_data + 32 * DVDCSS_BLOCK_SIZE,
+                                 i_blocks - 32) < 0 )
+        {
+            return -1;
+        }
+    }
+    else
+    {
+        /* This is the last transfer */
+        ssc.SRB_BufLen   = i_blocks * DVDCSS_BLOCK_SIZE;
+        ssc.CDBByte[9]   = (UCHAR) i_blocks;
+        fd->i_blocks += i_blocks;
+
+        /* Initiate transfer */  
+        ResetEvent( hEvent );
+        fd->lpSendCommand( (void*) &ssc );
+
     }
 
+    /* If the command has still not been processed, wait until it's finished */
+    if( ssc.SRB_Status == SS_PENDING )
+    {
+        WaitForSingleObject( hEvent, INFINITE );
+    }
     CloseHandle( hEvent );
 
+    /* check that the transfer went as planned */
     if( ssc.SRB_Status != SS_COMP )
     {
-        return -1;
+      return -1;
     }
-        
-    fd->i_blocks += i_blocks;
 
     return i_blocks;
 }