transmission/libtransmission/inout.c

333 lines
9.3 KiB
C
Raw Normal View History

/*
2010-01-04 21:00:47 +00:00
* This file Copyright (C) 2007-2010 Mnemosyne LLC
2006-07-16 19:39:23 +00:00
*
* This file is licensed by the GPL version 2. Works owned by the
* Transmission project are granted a special exemption to clause 2(b)
* so that the bulk of its code can remain under the MIT license.
* This exemption does not extend to derived works not owned by
* the Transmission project.
2007-08-18 17:19:49 +00:00
*
* $Id$
*/
2006-07-16 19:39:23 +00:00
#ifdef HAVE_LSEEK64
#define _LARGEFILE64_SOURCE
#endif
2007-11-09 20:07:52 +00:00
#include <assert.h>
2008-02-19 04:16:04 +00:00
#include <errno.h>
#include <stdlib.h> /* realloc */
2008-02-19 18:39:49 +00:00
#include <string.h> /* memcmp */
2007-07-12 17:51:45 +00:00
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <openssl/sha.h>
2006-07-16 19:39:23 +00:00
#include "transmission.h"
#include "cache.h"
#include "crypto.h"
2007-07-09 20:10:42 +00:00
#include "fdlimit.h"
#include "inout.h"
#include "peer-common.h" /* MAX_BLOCK_SIZE */
#include "platform.h"
2007-11-26 20:37:07 +00:00
#include "stats.h"
#include "torrent.h"
#include "utils.h"
2006-07-16 19:39:23 +00:00
/****
***** Low-level IO functions
****/
2006-07-16 19:39:23 +00:00
2007-09-09 01:32:59 +00:00
#ifdef WIN32
#if defined(read)
#undef read
2008-10-14 20:31:16 +00:00
#endif
#define read _read
#if defined(write)
#undef write
2008-10-14 20:31:16 +00:00
#endif
#define write _write
2007-09-09 01:32:59 +00:00
#endif
enum { TR_IO_READ, TR_IO_PREFETCH,
/* Any operations that require write access must follow TR_IO_WRITE. */
TR_IO_WRITE
};
2008-10-03 04:49:06 +00:00
/* returns 0 on success, or an errno on failure */
static int
readOrWriteBytes( tr_session * session,
const tr_torrent * tor,
int ioMode,
tr_file_index_t fileIndex,
uint64_t fileOffset,
void * buf,
size_t buflen )
{
const tr_info * info = &tor->info;
const tr_file * file = &info->files[fileIndex];
int fd = -1;
int err = 0;
const tr_bool doWrite = ioMode >= TR_IO_WRITE;
2006-07-16 19:39:23 +00:00
//if( doWrite )
// fprintf( stderr, "in file %s at offset %zu, writing %zu bytes; file length is %zu\n", file->name, (size_t)fileOffset, buflen, (size_t)file->length );
assert( fileIndex < info->fileCount );
assert( !file->length || ( fileOffset < file->length ) );
assert( fileOffset + buflen <= file->length );
2006-07-16 19:39:23 +00:00
if( !file->length )
2008-10-03 04:49:06 +00:00
return 0;
fd = tr_fdFileGetCached( session, tr_torrentId( tor ), fileIndex, doWrite );
if( fd < 0 )
{
/* the fd cache doesn't have this file...
* we'll need to open it and maybe create it */
char * subpath;
const char * base;
tr_bool fileExists;
tr_preallocation_mode preallocationMode;
fileExists = tr_torrentFindFile2( tor, fileIndex, &base, &subpath );
if( !fileExists )
{
base = tr_torrentGetCurrentDir( tor );
if( tr_sessionIsIncompleteFileNamingEnabled( tor->session ) )
subpath = tr_torrentBuildPartial( tor, fileIndex );
else
subpath = tr_strdup( file->name );
}
if( ( file->dnd ) || ( ioMode < TR_IO_WRITE ) )
preallocationMode = TR_PREALLOCATE_NONE;
else
preallocationMode = tor->session->preallocationMode;
if( ( ioMode < TR_IO_WRITE ) && !fileExists ) /* does file exist? */
{
err = ENOENT;
}
else
{
char * filename = tr_buildPath( base, subpath, NULL );
if( ( fd = tr_fdFileCheckout( session, tor->uniqueId, fileIndex, filename,
doWrite, preallocationMode, file->length ) ) < 0 )
{
err = errno;
tr_torerr( tor, "tr_fdFileCheckout failed for \"%s\": %s", filename, tr_strerror( err ) );
}
tr_free( filename );
}
if( doWrite && !err )
tr_statsFileCreated( tor->session );
tr_free( subpath );
}
2007-11-26 20:37:07 +00:00
if( !err )
{
if( ioMode == TR_IO_READ ) {
const int rc = tr_pread( fd, buf, buflen, fileOffset );
if( rc < 0 ) {
err = errno;
tr_torerr( tor, "read failed for \"%s\": %s",
file->name, tr_strerror( err ) );
}
} else if( ioMode == TR_IO_PREFETCH ) {
const int rc = tr_prefetch( fd, fileOffset, buflen );
if( rc < 0 ) {
tr_tordbg( tor, "prefetch failed for \"%s\": %s",
file->name, tr_strerror( err ) );
}
} else if( ioMode == TR_IO_WRITE ) {
const int rc = tr_pwrite( fd, buf, buflen, fileOffset );
if( rc < 0 ) {
err = errno;
tr_torerr( tor, "write failed for \"%s\": %s",
file->name, tr_strerror( err ) );
}
} else {
abort();
}
}
return err;
}
static int
compareOffsetToFile( const void * a,
const void * b )
{
const uint64_t offset = *(const uint64_t*)a;
const tr_file * file = b;
if( offset < file->offset ) return -1;
2008-04-20 22:06:05 +00:00
if( offset >= file->offset + file->length ) return 1;
return 0;
}
void
tr_ioFindFileLocation( const tr_torrent * tor,
tr_piece_index_t pieceIndex,
uint32_t pieceOffset,
tr_file_index_t * fileIndex,
uint64_t * fileOffset )
2006-07-16 19:39:23 +00:00
{
const uint64_t offset = tr_pieceOffset( tor, pieceIndex, pieceOffset, 0 );
const tr_file * file;
file = bsearch( &offset,
tor->info.files, tor->info.fileCount, sizeof( tr_file ),
compareOffsetToFile );
*fileIndex = file - tor->info.files;
*fileOffset = offset - file->offset;
assert( *fileIndex < tor->info.fileCount );
assert( *fileOffset < file->length );
assert( tor->info.files[*fileIndex].offset + *fileOffset == offset );
2006-07-16 19:39:23 +00:00
}
2008-10-03 04:49:06 +00:00
/* returns 0 on success, or an errno on failure */
static int
readOrWritePiece( tr_torrent * tor,
int ioMode,
tr_piece_index_t pieceIndex,
uint32_t pieceOffset,
uint8_t * buf,
size_t buflen )
{
2008-10-03 04:49:06 +00:00
int err = 0;
tr_file_index_t fileIndex;
uint64_t fileOffset;
const tr_info * info = &tor->info;
2007-05-27 23:32:26 +00:00
if( pieceIndex >= tor->info.pieceCount )
2008-10-03 04:49:06 +00:00
return EINVAL;
//if( pieceOffset + buflen > tr_torPieceCountBytes( tor, pieceIndex ) )
// return EINVAL;
2007-05-27 23:32:26 +00:00
tr_ioFindFileLocation( tor, pieceIndex, pieceOffset,
&fileIndex, &fileOffset );
2006-07-16 19:39:23 +00:00
while( buflen && !err )
2006-07-16 19:39:23 +00:00
{
const tr_file * file = &info->files[fileIndex];
const uint64_t bytesThisPass = MIN( buflen, file->length - fileOffset );
err = readOrWriteBytes( tor->session, tor, ioMode, fileIndex, fileOffset, buf, bytesThisPass );
buf += bytesThisPass;
buflen -= bytesThisPass;
//fprintf( stderr, "++fileIndex to %d\n", (int)fileIndex );
++fileIndex;
fileOffset = 0;
if( ( err != 0 ) && (ioMode == TR_IO_WRITE ) )
{
char * path = tr_buildPath( tor->downloadDir, file->name, NULL );
tr_torrentSetLocalError( tor, "%s (%s)", tr_strerror( err ), path );
tr_free( path );
}
2006-07-16 19:39:23 +00:00
}
return err;
2006-07-16 19:39:23 +00:00
}
2008-10-03 04:49:06 +00:00
int
tr_ioRead( tr_torrent * tor,
tr_piece_index_t pieceIndex,
uint32_t begin,
uint32_t len,
uint8_t * buf )
2006-07-16 19:39:23 +00:00
{
return readOrWritePiece( tor, TR_IO_READ, pieceIndex, begin, buf, len );
2006-07-16 19:39:23 +00:00
}
int
tr_ioPrefetch( tr_torrent * tor,
tr_piece_index_t pieceIndex,
uint32_t begin,
uint32_t len)
{
return readOrWritePiece( tor, TR_IO_PREFETCH, pieceIndex, begin,
NULL, len );
}
2008-10-03 04:49:06 +00:00
int
tr_ioWrite( tr_torrent * tor,
tr_piece_index_t pieceIndex,
uint32_t begin,
uint32_t len,
const uint8_t * buf )
2006-07-16 19:39:23 +00:00
{
return readOrWritePiece( tor, TR_IO_WRITE, pieceIndex, begin,
(uint8_t*)buf,
len );
2006-07-16 19:39:23 +00:00
}
/****
*****
****/
2006-07-16 19:39:23 +00:00
static tr_bool
recalculateHash( tr_torrent * tor,
tr_piece_index_t pieceIndex,
uint8_t * setme )
{
size_t bytesLeft;
uint32_t offset = 0;
tr_bool success = TRUE;
const size_t buflen = MAX_BLOCK_SIZE;
void * buffer = tr_valloc( buflen );
SHA_CTX sha;
2006-07-16 19:39:23 +00:00
assert( tor != NULL );
assert( pieceIndex < tor->info.pieceCount );
assert( buffer != NULL );
assert( buflen > 0 );
assert( setme != NULL );
2006-07-16 19:39:23 +00:00
SHA1_Init( &sha );
bytesLeft = tr_torPieceCountBytes( tor, pieceIndex );
2006-07-16 19:39:23 +00:00
tr_ioPrefetch( tor, pieceIndex, offset, bytesLeft );
while( bytesLeft )
{
const int len = MIN( bytesLeft, buflen );
success = !tr_cacheReadBlock( tor->session->cache, tor, pieceIndex, offset, len, buffer );
if( !success )
break;
SHA1_Update( &sha, buffer, len );
offset += len;
bytesLeft -= len;
}
if( success )
SHA1_Final( setme, &sha );
2006-07-16 19:39:23 +00:00
tr_free( buffer );
return success;
2006-07-16 19:39:23 +00:00
}
tr_bool
tr_ioTestPiece( tr_torrent * tor, tr_piece_index_t piece )
2006-07-16 19:39:23 +00:00
{
uint8_t hash[SHA_DIGEST_LENGTH];
return recalculateHash( tor, piece, hash )
&& !memcmp( hash, tor->info.pieces[piece].hash, SHA_DIGEST_LENGTH );
}