318 lines
10 KiB
C
318 lines
10 KiB
C
/******************************************************************************
|
|
* $Id$
|
|
*
|
|
* Copyright (c) 2006 Transmission authors and contributors
|
|
*
|
|
* Permission is hereby granted, free of charge, to any person obtaining a
|
|
* copy of this software and associated documentation files (the "Software"),
|
|
* to deal in the Software without restriction, including without limitation
|
|
* the rights to use, copy, modify, merge, publish, distribute, sublicense,
|
|
* and/or sell copies of the Software, and to permit persons to whom the
|
|
* Software is furnished to do so, subject to the following conditions:
|
|
*
|
|
* The above copyright notice and this permission notice shall be included in
|
|
* all copies or substantial portions of the Software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
|
* DEALINGS IN THE SOFTWARE.
|
|
*****************************************************************************/
|
|
|
|
#include <math.h>
|
|
#include "transmission.h"
|
|
#include "choking.h"
|
|
|
|
#ifndef HAVE_LRINTF
|
|
# define lrintf(a) ((int)(0.5+(a)))
|
|
#endif
|
|
|
|
struct tr_choking_s
|
|
{
|
|
tr_lock_t lock;
|
|
tr_handle_t * h;
|
|
int slots;
|
|
};
|
|
|
|
tr_choking_t * tr_chokingInit( tr_handle_t * h )
|
|
{
|
|
tr_choking_t * c;
|
|
|
|
c = tr_new0( tr_choking_t, 1 );
|
|
c->h = h;
|
|
c->slots = 4242;
|
|
tr_lockInit( &c->lock );
|
|
|
|
return c;
|
|
}
|
|
|
|
void tr_chokingSetLimit( tr_choking_t * c, int limit )
|
|
{
|
|
tr_lockLock( &c->lock );
|
|
if( limit < 0 )
|
|
c->slots = 4242;
|
|
else
|
|
/* Reckon a number of slots from the upload limit. There is no
|
|
official right way to do this, the formula below e.g. gives:
|
|
10 KB/s -> 4 * 2.50 KB/s
|
|
20 KB/s -> 6 * 3.33 KB/s
|
|
50 KB/s -> 10 * 5.00 KB/s
|
|
100 KB/s -> 14 * 7.14 KB/s */
|
|
c->slots = lrintf( sqrt( 2 * limit ) );
|
|
tr_lockUnlock( &c->lock );
|
|
}
|
|
|
|
#define sortPeersAscending(a,ac,z,zc,n,nc) sortPeers(a,ac,z,zc,n,nc,0)
|
|
#define sortPeersDescending(a,ac,z,zc,n,nc) sortPeers(a,ac,z,zc,n,nc,1)
|
|
static void sortPeers( tr_peer_t ** all, int allCount,
|
|
tr_peer_t ** zero, int * zeroCount,
|
|
tr_peer_t ** nonZero, int * nonZeroCount,
|
|
int order )
|
|
{
|
|
int i, shuffle;
|
|
|
|
/* Seperate uploaders from non-uploaders */
|
|
*zeroCount = 0;
|
|
*nonZeroCount = 0;
|
|
for( i = 0; i < allCount; i++ )
|
|
{
|
|
if( tr_peerDownloadRate( all[i] ) < 0.1 )
|
|
zero[(*zeroCount)++] = all[i];
|
|
else
|
|
nonZero[(*nonZeroCount)++] = all[i];
|
|
}
|
|
|
|
/* Randomly shuffle non-uploaders, so they are treated equally */
|
|
if( *zeroCount && ( shuffle = tr_rand( *zeroCount ) ) )
|
|
{
|
|
tr_peer_t ** bak = tr_new( tr_peer_t*, shuffle );;
|
|
memcpy( bak, zero, shuffle * sizeof( tr_peer_t * ) );
|
|
memmove( zero, &zero[shuffle],
|
|
( *zeroCount - shuffle ) * sizeof( tr_peer_t * ) );
|
|
memcpy( &zero[*zeroCount - shuffle], bak,
|
|
shuffle * sizeof( tr_peer_t * ) );
|
|
tr_free( bak );
|
|
}
|
|
|
|
/* Sort uploaders by download rate */
|
|
for( i = *nonZeroCount - 1; i > 0; i-- )
|
|
{
|
|
float rate1, rate2;
|
|
tr_peer_t * tmp;
|
|
int j, sorted;
|
|
|
|
sorted = 1;
|
|
for( j = 0; j < i; j++ )
|
|
{
|
|
rate1 = tr_peerDownloadRate( nonZero[j] );
|
|
rate2 = tr_peerDownloadRate( nonZero[j+1] );
|
|
if( order ? ( rate1 < rate2 ) : ( rate1 > rate2 ) )
|
|
{
|
|
tmp = nonZero[j];
|
|
nonZero[j] = nonZero[j+1];
|
|
nonZero[j+1] = tmp;
|
|
sorted = 0;
|
|
}
|
|
}
|
|
if( sorted )
|
|
break;
|
|
}
|
|
}
|
|
|
|
void tr_chokingPulse( tr_choking_t * c )
|
|
{
|
|
int peersTotalCount, unchoked, mustOptimistic = 1;
|
|
tr_peer_t ** canChoke, ** canUnchoke;
|
|
tr_peer_t ** canChokeZero, ** canUnchokeZero;
|
|
tr_peer_t ** canChokeNonZero, ** canUnchokeNonZero;
|
|
int canChokeCount, canUnchokeCount;
|
|
int canChokeZeroCount, canUnchokeZeroCount;
|
|
int canChokeNonZeroCount, canUnchokeNonZeroCount;
|
|
tr_torrent_t * tor;
|
|
uint64_t now = tr_date();
|
|
|
|
tr_lockLock( &c->lock );
|
|
|
|
/* Lock all torrents and get the total number of peers */
|
|
peersTotalCount = 0;
|
|
for( tor = c->h->torrentList; tor; tor = tor->next )
|
|
{
|
|
tr_torrentWriterLock( tor );
|
|
peersTotalCount += tor->peerCount;
|
|
}
|
|
|
|
canChoke = tr_new( tr_peer_t*, peersTotalCount );
|
|
canUnchoke = tr_new( tr_peer_t*, peersTotalCount );
|
|
canChokeCount = 0;
|
|
canUnchokeCount = 0;
|
|
unchoked = 0;
|
|
|
|
for( tor = c->h->torrentList; tor; tor = tor->next )
|
|
{
|
|
tr_peer_t * peer;
|
|
int i;
|
|
|
|
for( i = 0; i < tor->peerCount; i++ )
|
|
{
|
|
peer = tor->peers[i];
|
|
|
|
if( !tr_peerIsConnected( peer ) )
|
|
continue;
|
|
|
|
/* Choke peers who have lost their interest in us */
|
|
if( !tr_peerIsInterested( peer ) )
|
|
{
|
|
if( !tr_peerIsChokedByUs( peer ) )
|
|
{
|
|
tr_peerChoke( peer );
|
|
tr_peerSetOptimistic( peer, 0 );
|
|
}
|
|
continue;
|
|
}
|
|
|
|
/* Build two lists of interested peers: those we may choke,
|
|
those we may unchoke. Whatever happens, we never choke a
|
|
peer less than 10 seconds after the time we unchoked him
|
|
(or the other way around). */
|
|
if( tr_peerIsChokedByUs( peer ) )
|
|
{
|
|
if( !tr_peerTimesChoked(peer) || tr_peerLastChoke( peer ) + 10000 < now )
|
|
canUnchoke[canUnchokeCount++] = peer;
|
|
}
|
|
else
|
|
{
|
|
if( tr_peerIsOptimistic( peer ) )
|
|
{
|
|
if( tr_peerLastChoke( peer ) + 30000 < now )
|
|
{
|
|
/* He got his 30 seconds, now we see him like
|
|
any other unchoked peer */
|
|
tr_peerSetOptimistic( peer, 0 );
|
|
}
|
|
else
|
|
{
|
|
/* Keep him unchoked for 30 seconds */
|
|
mustOptimistic = 0;
|
|
continue;
|
|
}
|
|
}
|
|
|
|
unchoked++;
|
|
if( tr_peerLastChoke( peer ) + 10000 < now )
|
|
canChoke[canChokeCount++] = peer;
|
|
}
|
|
}
|
|
}
|
|
|
|
canChokeZero = tr_new( tr_peer_t*, canChokeCount );
|
|
canChokeNonZero = tr_new( tr_peer_t*, canChokeCount );
|
|
canUnchokeZero = tr_new( tr_peer_t*, canUnchokeCount );
|
|
canUnchokeNonZero = tr_new( tr_peer_t*, canUnchokeCount );
|
|
|
|
sortPeersDescending( canChoke, canChokeCount,
|
|
canChokeZero, &canChokeZeroCount,
|
|
canChokeNonZero, &canChokeNonZeroCount);
|
|
sortPeersAscending( canUnchoke, canUnchokeCount,
|
|
canUnchokeZero, &canUnchokeZeroCount,
|
|
canUnchokeNonZero, &canUnchokeNonZeroCount);
|
|
|
|
tr_free( canChoke );
|
|
tr_free( canUnchoke );
|
|
|
|
if( mustOptimistic )
|
|
{
|
|
tr_peer_t * peer;
|
|
|
|
/* Open an extra slot for optimistic choking */
|
|
if( canUnchokeZeroCount )
|
|
{
|
|
/* TODO: prefer peers with no pieces at all */
|
|
peer = canUnchokeZero[--canUnchokeZeroCount];
|
|
tr_peerUnchoke( peer );
|
|
tr_peerSetOptimistic( peer, 1 );
|
|
}
|
|
else if( canUnchokeNonZeroCount )
|
|
{
|
|
peer = canUnchokeNonZero[--canUnchokeNonZeroCount];
|
|
tr_peerUnchoke( peer );
|
|
tr_peerSetOptimistic( peer, 1 );
|
|
}
|
|
}
|
|
|
|
/* If we have more open slots than what we should have (the user has
|
|
just lowered his upload limit), we need to choke some of the
|
|
peers we are uploading to. We start with the peers who aren't
|
|
uploading to us, then those we upload the least. */
|
|
while( unchoked > c->slots && canChokeZeroCount > 0 )
|
|
{
|
|
tr_peerChoke( canChokeZero[--canChokeZeroCount] );
|
|
unchoked--;
|
|
}
|
|
while( unchoked > c->slots && canChokeNonZeroCount > 0 )
|
|
{
|
|
tr_peerChoke( canChokeNonZero[--canChokeNonZeroCount] );
|
|
unchoked--;
|
|
}
|
|
|
|
/* If we have unused open slots, let's unchoke some people. We start
|
|
with the peers who are uploading to us the most. */
|
|
while( unchoked < c->slots && canUnchokeNonZeroCount > 0 )
|
|
{
|
|
tr_peerUnchoke( canUnchokeNonZero[--canUnchokeNonZeroCount] );
|
|
unchoked++;
|
|
}
|
|
while( unchoked < c->slots && canUnchokeZeroCount > 0 )
|
|
{
|
|
tr_peerUnchoke( canUnchokeZero[--canUnchokeZeroCount] );
|
|
unchoked++;
|
|
}
|
|
|
|
/* Choke peers who aren't uploading if there are good peers waiting
|
|
for an unchoke */
|
|
while( canChokeZeroCount > 0 && canUnchokeNonZeroCount > 0 )
|
|
{
|
|
tr_peerChoke( canChokeZero[--canChokeZeroCount] );
|
|
tr_peerUnchoke( canUnchokeNonZero[--canUnchokeNonZeroCount] );
|
|
}
|
|
|
|
/* Choke peers who aren't uploading that much if there are choked
|
|
peers who are uploading more */
|
|
while( canChokeNonZeroCount > 0 && canUnchokeNonZeroCount > 0 )
|
|
{
|
|
if( tr_peerDownloadRate( canUnchokeNonZero[canUnchokeNonZeroCount - 1] )
|
|
< tr_peerDownloadRate( canChokeNonZero[canChokeNonZeroCount - 1] ) )
|
|
break;
|
|
|
|
tr_peerChoke( canChokeNonZero[--canChokeNonZeroCount] );
|
|
tr_peerUnchoke( canUnchokeNonZero[--canUnchokeNonZeroCount] );
|
|
}
|
|
|
|
/* Some unchoked peers still aren't uploading to us, let's give a
|
|
chance to other non-uploaders */
|
|
while( canChokeZeroCount > 0 && canUnchokeZeroCount > 0 )
|
|
{
|
|
tr_peerChoke( canChokeZero[--canChokeZeroCount] );
|
|
tr_peerUnchoke( canUnchokeZero[--canUnchokeZeroCount] );
|
|
}
|
|
|
|
tr_free( canChokeZero );
|
|
tr_free( canChokeNonZero );
|
|
tr_free( canUnchokeZero );
|
|
tr_free( canUnchokeNonZero );
|
|
|
|
/* Unlock all torrents */
|
|
for( tor = c->h->torrentList; tor; tor = tor->next )
|
|
tr_torrentWriterUnlock( tor );
|
|
|
|
tr_lockUnlock( &c->lock );
|
|
}
|
|
|
|
void tr_chokingClose( tr_choking_t * c )
|
|
{
|
|
tr_lockClose( &c->lock );
|
|
tr_free( c );
|
|
}
|