return TR_CAN_KEEP;
}
-static void sortPeersByLivelinessReverse( tr_peer ** peers, void ** clientData, int n, uint64_t now );
-
static tr_peer **
getPeersToClose( Torrent * t, tr_close_type_t closeType,
- const uint64_t now_msec, const time_t now_sec,
+ const time_t now_sec,
int * setmeSize )
{
int i, peerCount, outsize;
if( shouldPeerBeClosed( t, peers[i], peerCount, now_sec ) == closeType )
ret[outsize++] = peers[i];
- sortPeersByLivelinessReverse ( ret, NULL, outsize, now_msec );
-
*setmeSize = outsize;
return ret;
}
}
static void
-closeBadPeers( Torrent * t, const uint64_t now_msec, const time_t now_sec )
+closeBadPeers( Torrent * t, const time_t now_sec )
{
if( !t->isRunning )
{
struct tr_peer ** mustClose;
/* disconnect the really bad peers */
- mustClose = getPeersToClose( t, TR_MUST_CLOSE, now_msec, now_sec, &mustCloseCount );
+ mustClose = getPeersToClose( t, TR_MUST_CLOSE, now_sec, &mustCloseCount );
for( i=0; i<mustCloseCount; ++i )
closePeer( t, mustClose[i] );
tr_free( mustClose );
return 0;
}
-static int
-comparePeerLivelinessReverse( const void * va, const void * vb )
-{
- return -comparePeerLiveliness (va, vb);
-}
-
static void
sortPeersByLivelinessImpl( tr_peer ** peers,
void ** clientData,
sortPeersByLivelinessImpl( peers, clientData, n, now, comparePeerLiveliness );
}
-static void
-sortPeersByLivelinessReverse( tr_peer ** peers, void ** clientData, int n, uint64_t now )
-{
- sortPeersByLivelinessImpl( peers, clientData, n, now, comparePeerLivelinessReverse );
-}
-
static void
enforceTorrentPeerLimit( Torrent * t, uint64_t now )
/* remove crappy peers */
tor = NULL;
while(( tor = tr_torrentNext( mgr->session, tor )))
- closeBadPeers( tor->torrentPeers, now_msec, now_sec );
+ closeBadPeers( tor->torrentPeers, now_sec );
/* try to make new peer connections */
makeNewPeerConnections( mgr, MAX_CONNECTIONS_PER_PULSE );