From e6e017756096d53417622c0a4048d1dfb4340f49 Mon Sep 17 00:00:00 2001 From: Tatsuhiro Tsujikawa Date: Fri, 31 Mar 2006 13:58:22 +0000 Subject: * src/PeerInteractionCommand.cc (checkInactiveConnection): New function (detectMessageFlooding): Updated. (checkLongTimePeerChoking): Updated. (getNewPieceAndSendInterest): Added debug log. * src/PeerInteractionCommand.h: New function checkInactiveConnection() * src/TorrentMan.cc (deleteOldErrorPeers): Updated. (getPeer): Updated. * src/TorrentMan.h: Added MAX_PEER_ERROR. * src/PeerAbstractCommand.cc (onAbort): Increment error counter. * src/PeerListenCommand.cc (execute): Close connection if incoming peer is localhost. * src/main.cc (main): Updated PREF_PEER_CONNECTION_TIMEOUT to 60. * src/PendingMessage.cc (processMessage): Not to send piece message if peer is not interested in the pieces localhost has. * src/Peer.cc (shouldChoke): Updated. * src/SendMessageQueue.cc (cancelAllRequest): Fixed. --- src/PeerAbstractCommand.cc | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'src/PeerAbstractCommand.cc') diff --git a/src/PeerAbstractCommand.cc b/src/PeerAbstractCommand.cc index 269d4411..384ae0e7 100644 --- a/src/PeerAbstractCommand.cc +++ b/src/PeerAbstractCommand.cc @@ -125,7 +125,11 @@ bool PeerAbstractCommand::prepareForRetry(int wait) { } void PeerAbstractCommand::onAbort(Exception* ex) { - peer->error = 1; + if(peer->isSeeder()) { + peer->error++; + } else { + peer->error += MAX_PEER_ERROR; + } peer->tryCount = 0; peer->cuid = 0; peer->amChocking = true; -- cgit