mirror/transmission
1
0
Fork 0
mirror of https://github.com/transmission/transmission synced 2025-03-04 10:38:13 +00:00
Code Issues Releases Wiki Activity

don't allow duplicate requests to the same peer, even during endgame. (alus)

Browse source
This commit is contained in:
Charles Kerr 2007-10-05 00:16:47 +00:00
parent 17743d8d04
commit b6483cbf3f
3 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
libtransmission/peer-mgr.c
View file

@ -725,6 +725,7 @@ refillPulse( void * vtorrent )
break;
case TR_ADDREQ_MISSING:
case TR_ADDREQ_DUPLICATE:
++j;
break;

13
libtransmission/peer-msgs.c
View file

@ -482,7 +482,7 @@ tr_peerMsgsAddRequest( tr_peermsgs * msgs,
uint32_t offset,
uint32_t length )
{
struct peer_request * req;
struct peer_request tmp, *req;
int maxSize;
assert( msgs != NULL );
@ -499,6 +499,13 @@ tr_peerMsgsAddRequest( tr_peermsgs * msgs,
if( tr_list_size( msgs->clientAskedFor) >= maxSize )
return TR_ADDREQ_FULL;
/* have we already asked for this piece? */
tmp.index = index;
tmp.offset = offset;
tmp.length = length;
if( tr_list_remove( &msgs->clientAskedFor, &tmp, peer_request_compare ) != NULL )
return TR_ADDREQ_DUPLICATE;
dbgmsg( msgs, "w00t peer has a max request queue size of %d... adding request for piece %d, offset %d", maxSize, (int)index, (int)offset );
/* queue the request */
@ -510,9 +517,7 @@ tr_peerMsgsAddRequest( tr_peermsgs * msgs,
/* add it to our `requests sent' list */
req = tr_new( struct peer_request, 1 );
req->index = index;
req->offset = offset;
req->length = length;
*req = tmp;
req->time_requested = msgs->lastReqAddedAt = time( NULL );
tr_list_append( &msgs->clientAskedFor, req );
pulse( msgs );

1
libtransmission/peer-msgs.h
View file

@ -45,6 +45,7 @@ void tr_peerMsgsFree( tr_peermsgs* );
enum {
TR_ADDREQ_OK=0,
TR_ADDREQ_FULL,
TR_ADDREQ_DUPLICATE,
TR_ADDREQ_MISSING,
TR_ADDREQ_CLIENT_CHOKED
};