/******************************************************************************
 * Copyright (c) 2006 Eric Petit
 *
 * 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"

#ifdef SYS_BEOS
#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        = calloc( sizeof( 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(p,c)  sortPeers(p,c,0)
#define sortPeersDescending(p,c) sortPeers(p,c,1)
static inline void sortPeers( tr_peer_t ** peers, int count, int order )
{
    int i, j, sorted;
    float rate1, rate2;
    tr_peer_t * tmp;

    for( i = count - 1; i > 0; i-- )
    {
        sorted = 1;
        for( j = 0; j < i; j++ )
        {
            rate1 = tr_peerDownloadRate( peers[j] );
            rate2 = tr_peerDownloadRate( peers[j+1] );
            if( order ? ( rate1 < rate2 ) : ( rate1 > rate2 ) )
            {
                tmp        = peers[j];
                peers[j]   = peers[j+1];
                peers[j+1] = tmp;
                sorted     = 0;
            }
        }
        if( sorted )
            break;
    }
}

void tr_chokingPulse( tr_choking_t * c )
{
    int i, j, peersTotalCount;
    tr_peer_t * peer;
    tr_peer_t ** peersCanChoke, ** peersCanUnchoke;
    int peersCanChokeCount, peersCanUnchokeCount, unchokedCount;
    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( i = 0; i < c->h->torrentCount; i++ )
    {
        tor = c->h->torrents[i];
        tr_lockLock( &tor->lock );
        peersTotalCount += tor->peerCount;
    }

    peersCanChoke   = malloc( peersTotalCount * sizeof( tr_peer_t * ) );
    peersCanUnchoke = malloc( peersTotalCount * sizeof( tr_peer_t * ) );
    peersCanChokeCount   = 0;
    peersCanUnchokeCount = 0;
    unchokedCount        = 0;

    for( i = 0; i < c->h->torrentCount; i++ )
    {
        tor = c->h->torrents[i];
        for( j = 0; j < tor->peerCount; j++ )
        {
            peer = tor->peers[j];

            if( !tr_peerIsConnected( peer ) )
                continue;

            /* Choke peers who have lost their interest in us */
            if( !tr_peerIsInterested( peer ) )
            {
                if( tr_peerIsUnchoked( peer ) )
                    tr_peerChoke( peer );
                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_peerIsUnchoked( peer ) )
            {
                unchokedCount++;
                if( tr_peerLastChoke( peer ) + 10000 < now )
                    peersCanChoke[peersCanChokeCount++] = peer;
            }
            else
            {
                if( tr_peerLastChoke( peer ) + 10000 < now )
                    peersCanUnchoke[peersCanUnchokeCount++] = peer;
            }
        }
    }

    /* Sort peers by the rate we are downloading from them. */
    sortPeersDescending( peersCanChoke, peersCanChokeCount );
    sortPeersAscending( peersCanUnchoke, peersCanUnchokeCount );

    if( unchokedCount > c->slots && peersCanChokeCount > 0 )
    {
        /* 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. */
        int willChoke;
        willChoke = MIN( peersCanChokeCount, unchokedCount - c->slots );
        for( i = 0; i < willChoke; i++ )
            tr_peerChoke( peersCanChoke[--peersCanChokeCount] );
    }
    else if( unchokedCount < c->slots && peersCanUnchokeCount > 0 )
    {
        /* We have unused open slots. Let's unchoke some people. */
        int willUnchoke;
        willUnchoke = MIN( peersCanUnchokeCount, c->slots - unchokedCount );
        for( i = 0; i < willUnchoke; i++ )
            tr_peerUnchoke( peersCanUnchoke[--peersCanUnchokeCount] );
    }

    while( peersCanChokeCount > 0 && peersCanUnchokeCount > 0 )
    {
        /* All slots are used and more peers are waiting. If
           applicable, choke some peers in favor of others who are
           uploading more to us. */
        if( tr_peerDownloadRate( peersCanUnchoke[peersCanUnchokeCount - 1] )
                < tr_peerDownloadRate( peersCanChoke[peersCanChokeCount - 1] ) )
            break;

        tr_peerChoke( peersCanChoke[--peersCanChokeCount] );
        tr_peerUnchoke( peersCanUnchoke[--peersCanUnchokeCount] );
    }

    free( peersCanChoke );
    free( peersCanUnchoke );

    /* Unlock all torrents */
    for( i = 0; i < c->h->torrentCount; i++ )
    {
        tr_lockUnlock( &c->h->torrents[i]->lock );
    }

    tr_lockUnlock( &c->lock );
}

void tr_chokingClose( tr_choking_t * c )
{
    tr_lockClose( &c->lock );
    free( c );
}