2006-03-21 14:12:51 +00:00
|
|
|
/* <!-- copyright */
|
|
|
|
/*
|
|
|
|
* aria2 - a simple utility for downloading files faster
|
|
|
|
*
|
|
|
|
* Copyright (C) 2006 Tatsuhiro Tsujikawa
|
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or modify
|
|
|
|
* it under the terms of the GNU General Public License as published by
|
|
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
|
|
* (at your option) any later version.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
* GNU General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License
|
|
|
|
* along with this program; if not, write to the Free Software
|
|
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
|
|
*/
|
|
|
|
/* copyright --> */
|
|
|
|
#include "PeerAbstractCommand.h"
|
|
|
|
#include "DlAbortEx.h"
|
|
|
|
#include "DlRetryEx.h"
|
|
|
|
#include "Util.h"
|
|
|
|
#include "message.h"
|
|
|
|
#include "prefs.h"
|
2006-04-17 16:17:20 +00:00
|
|
|
#include <sys/time.h>
|
2006-03-21 14:12:51 +00:00
|
|
|
|
2006-03-31 14:46:48 +00:00
|
|
|
PeerAbstractCommand::PeerAbstractCommand(int cuid, Peer* peer, TorrentDownloadEngine* e, const Socket* s):
|
2006-03-21 14:12:51 +00:00
|
|
|
Command(cuid), e(e), peer(peer), checkSocketIsReadable(false), checkSocketIsWritable(false) {
|
|
|
|
|
|
|
|
if(s != NULL) {
|
|
|
|
socket = new Socket(*s);
|
|
|
|
setReadCheckSocket(socket);
|
|
|
|
} else {
|
|
|
|
socket = NULL;
|
|
|
|
}
|
|
|
|
this->checkPoint.tv_sec = 0;
|
|
|
|
this->checkPoint.tv_usec = 0;
|
Added new class SendMessageQueue that includes PendingMessages
and
RequestSlotMan.
* src/SendMessageQueue.h: New class.
* src/SendMessageQueue.cc: New class.
* src/PendingMessage.h: Added new member variable blockIndex and
its
accessors.
(createRequestMessage): Updated.
* src/PendingMessage.cc (createRequestMessage): Updated.
* src/PeerInteractionCommand.cc (executeInternal): Updated with
SendMessageQueue.
(checkLongTimePeerChoking): Updated with SendMessageQueue.
(receiveMessage): Updated with SendMessageQueue.
(deletePendingPieceMessage): Removed.
(getNewPieceAndSendInterest): Updated with SendMessageQueue.
(sendInterest): Updated with SendMessageQueue.
(createRequestPendingMessage): Updated with SendMessageQueue.
(sendMessages): Updated with SendMessageQueue.
(onAbort): Updated with SendMessageQueue.
(keepAlive): Updated with SendMessageQueue.
(beforeSocketCheck): Updated SendMessageQueue.
* src/PeerInteractionCommand (sendMessages): Shuffle
missingBLockIndexes before using it.
Added its own timeout for peer connection.
* src/PeerAbstractCommand.h: Added member variable timeout and
its
setter.
* src/prefs.h: Added PREF_PEER_CONNECTION_TIMEOUT.
* src/PeerInteractionCommand.cc (PeerInteractionCommand):
Added setTimeout() call.
(executeInternal): Added setTimeout() call.
* src/PeerAbstractCommand.cc (PeerAbstractCommand):
Added timeout.
(isTimeoutDetected): Updated.
* src/main.cc (main): Added PREF_PEER_CONNECTION_TIMEOUT entry
to
option.
Added *simple* message flooding checker.
* src/PeerInteractionCommand.cc (executeInternal):
Added detectMessageFlooding() call.
(detectMessageFlooding): New function.
(receiveMessage): Count up CHOKE, UNCHOKE, HAVE message.
(beforeSocketCheck): Added detectMessageFlooding() call.
* src/PeerInteractionCommand.h: Added sendMessageQueue,
chokeUnchokeCount, haveCount, detectMessageFlooding().
Removed deletePendingPieceMessage(), getRequestSlot(),
deleteRequestSlot(), deleteAllRequestSlot().
* src/PeerInteractionCommand.cc (beforeSocketCheck):
Added checkLongTimePeerChoking() call.
* src/RequestSlotMan.h: Renamed deleteTimeoutRequestSlot().
* src/TorrentMan.cc (addPeer): Delete at most MAX_PEER_LIST_SIZE
peers
if duplicate == false.
The parameter "uploaded" and "downloaded" in the tracker request
are
the size since the client sent the "started" event to the
tracker.
* src/TorrentMan.cc (setup): Assigned saved downloaded Size and
uploaded size to preDownloadedSize, preUploadedSize
respectively.
* src/TorrentMan.h: Added preDownloadedSize, preUploadedSize,
getSessionDownloadedSize(), getSessionUploadedSize().
* src/TrackerInitCommand.cc (execute): Use
getSessionDownloadedSize(),
getSessionUploadedSize() instead of getDownloadedSize(),
getUploadedSize().
* src/PendingMessage.cc (processMessage): Do not send request
message
if the peer is choking the client.
* src/TrackerUpdateCommand.cc (execute): Check wtheher
minInterval is
less than interval.
2006-03-28 15:23:51 +00:00
|
|
|
timeout = e->option->getAsInt(PREF_TIMEOUT);
|
2006-03-21 14:12:51 +00:00
|
|
|
e->torrentMan->connections++;
|
|
|
|
}
|
|
|
|
|
|
|
|
PeerAbstractCommand::~PeerAbstractCommand() {
|
|
|
|
setReadCheckSocket(NULL);
|
|
|
|
setWriteCheckSocket(NULL);
|
|
|
|
if(socket != NULL) {
|
|
|
|
delete(socket);
|
|
|
|
}
|
|
|
|
e->torrentMan->connections--;
|
|
|
|
}
|
|
|
|
|
|
|
|
void PeerAbstractCommand::updateCheckPoint() {
|
|
|
|
gettimeofday(&checkPoint, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
bool PeerAbstractCommand::isTimeoutDetected() {
|
|
|
|
struct timeval now;
|
|
|
|
gettimeofday(&now, NULL);
|
|
|
|
if(checkPoint.tv_sec == 0 && checkPoint.tv_usec == 0) {
|
|
|
|
checkPoint = now;
|
|
|
|
return false;
|
|
|
|
} else {
|
|
|
|
long long int elapsed = Util::difftv(now, checkPoint);
|
Added new class SendMessageQueue that includes PendingMessages
and
RequestSlotMan.
* src/SendMessageQueue.h: New class.
* src/SendMessageQueue.cc: New class.
* src/PendingMessage.h: Added new member variable blockIndex and
its
accessors.
(createRequestMessage): Updated.
* src/PendingMessage.cc (createRequestMessage): Updated.
* src/PeerInteractionCommand.cc (executeInternal): Updated with
SendMessageQueue.
(checkLongTimePeerChoking): Updated with SendMessageQueue.
(receiveMessage): Updated with SendMessageQueue.
(deletePendingPieceMessage): Removed.
(getNewPieceAndSendInterest): Updated with SendMessageQueue.
(sendInterest): Updated with SendMessageQueue.
(createRequestPendingMessage): Updated with SendMessageQueue.
(sendMessages): Updated with SendMessageQueue.
(onAbort): Updated with SendMessageQueue.
(keepAlive): Updated with SendMessageQueue.
(beforeSocketCheck): Updated SendMessageQueue.
* src/PeerInteractionCommand (sendMessages): Shuffle
missingBLockIndexes before using it.
Added its own timeout for peer connection.
* src/PeerAbstractCommand.h: Added member variable timeout and
its
setter.
* src/prefs.h: Added PREF_PEER_CONNECTION_TIMEOUT.
* src/PeerInteractionCommand.cc (PeerInteractionCommand):
Added setTimeout() call.
(executeInternal): Added setTimeout() call.
* src/PeerAbstractCommand.cc (PeerAbstractCommand):
Added timeout.
(isTimeoutDetected): Updated.
* src/main.cc (main): Added PREF_PEER_CONNECTION_TIMEOUT entry
to
option.
Added *simple* message flooding checker.
* src/PeerInteractionCommand.cc (executeInternal):
Added detectMessageFlooding() call.
(detectMessageFlooding): New function.
(receiveMessage): Count up CHOKE, UNCHOKE, HAVE message.
(beforeSocketCheck): Added detectMessageFlooding() call.
* src/PeerInteractionCommand.h: Added sendMessageQueue,
chokeUnchokeCount, haveCount, detectMessageFlooding().
Removed deletePendingPieceMessage(), getRequestSlot(),
deleteRequestSlot(), deleteAllRequestSlot().
* src/PeerInteractionCommand.cc (beforeSocketCheck):
Added checkLongTimePeerChoking() call.
* src/RequestSlotMan.h: Renamed deleteTimeoutRequestSlot().
* src/TorrentMan.cc (addPeer): Delete at most MAX_PEER_LIST_SIZE
peers
if duplicate == false.
The parameter "uploaded" and "downloaded" in the tracker request
are
the size since the client sent the "started" event to the
tracker.
* src/TorrentMan.cc (setup): Assigned saved downloaded Size and
uploaded size to preDownloadedSize, preUploadedSize
respectively.
* src/TorrentMan.h: Added preDownloadedSize, preUploadedSize,
getSessionDownloadedSize(), getSessionUploadedSize().
* src/TrackerInitCommand.cc (execute): Use
getSessionDownloadedSize(),
getSessionUploadedSize() instead of getDownloadedSize(),
getUploadedSize().
* src/PendingMessage.cc (processMessage): Do not send request
message
if the peer is choking the client.
* src/TrackerUpdateCommand.cc (execute): Check wtheher
minInterval is
less than interval.
2006-03-28 15:23:51 +00:00
|
|
|
if(elapsed >= ((long long int)timeout)*1000000) {
|
2006-03-21 14:12:51 +00:00
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
bool PeerAbstractCommand::execute() {
|
|
|
|
try {
|
|
|
|
beforeSocketCheck();
|
|
|
|
if(checkSocketIsReadable && !readCheckTarget->isReadable(0)
|
|
|
|
|| checkSocketIsWritable && !writeCheckTarget->isWritable(0)) {
|
|
|
|
if(isTimeoutDetected()) {
|
|
|
|
// TODO
|
|
|
|
checkPoint.tv_sec = 0;
|
|
|
|
checkPoint.tv_usec = 0;
|
|
|
|
throw new DlRetryEx(EX_TIME_OUT);
|
|
|
|
}
|
|
|
|
e->commands.push(this);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
updateCheckPoint();
|
|
|
|
bool returnValue = executeInternal();
|
|
|
|
//e->torrentMan->updatePeer(peer);
|
|
|
|
return returnValue;
|
|
|
|
} catch(Exception* err) {
|
2006-04-17 16:17:20 +00:00
|
|
|
logger->error(MSG_DOWNLOAD_ABORTED, err, cuid);
|
2006-03-21 14:12:51 +00:00
|
|
|
onAbort(err);
|
|
|
|
delete(err);
|
|
|
|
return prepareForNextPeer(0);
|
2006-03-21 15:21:11 +00:00
|
|
|
}
|
|
|
|
/*catch(DlRetryEx* err) {
|
2006-04-17 16:17:20 +00:00
|
|
|
logger->error(MSG_RESTARTING_DOWNLOAD, err, cuid);
|
2006-03-21 14:12:51 +00:00
|
|
|
peer->tryCount++;
|
|
|
|
bool isAbort = e->option->getAsInt(PREF_MAX_TRIES) != 0 &&
|
|
|
|
peer->tryCount >= e->option->getAsInt(PREF_MAX_TRIES);
|
|
|
|
int tryCount = peer->tryCount;
|
|
|
|
if(isAbort) {
|
|
|
|
onAbort(err);
|
|
|
|
}
|
|
|
|
delete(err);
|
|
|
|
if(isAbort) {
|
2006-04-17 16:17:20 +00:00
|
|
|
logger->error(MSG_MAX_TRY, cuid, tryCount);
|
2006-03-21 14:12:51 +00:00
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
return prepareForRetry(e->option->getAsInt(PREF_RETRY_WAIT));
|
|
|
|
}
|
|
|
|
}
|
2006-03-21 15:21:11 +00:00
|
|
|
*/
|
2006-03-21 14:12:51 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// TODO this method removed when PeerBalancerCommand is implemented
|
|
|
|
bool PeerAbstractCommand::prepareForNextPeer(int wait) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool PeerAbstractCommand::prepareForRetry(int wait) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
void PeerAbstractCommand::onAbort(Exception* ex) {
|
2006-03-31 13:58:22 +00:00
|
|
|
if(peer->isSeeder()) {
|
|
|
|
peer->error++;
|
|
|
|
} else {
|
|
|
|
peer->error += MAX_PEER_ERROR;
|
|
|
|
}
|
2006-03-21 14:12:51 +00:00
|
|
|
peer->tryCount = 0;
|
|
|
|
peer->cuid = 0;
|
|
|
|
peer->amChocking = true;
|
|
|
|
peer->amInterested = false;
|
|
|
|
peer->peerChoking = true;
|
|
|
|
peer->peerInterested = false;
|
2006-04-17 16:17:20 +00:00
|
|
|
logger->debug("CUID#%d - peer %s:%d banned.", cuid, peer->ipaddr.c_str(), peer->port);
|
2006-03-21 14:12:51 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void PeerAbstractCommand::setReadCheckSocket(Socket* socket) {
|
|
|
|
if(socket == NULL) {
|
|
|
|
if(checkSocketIsReadable) {
|
|
|
|
e->deleteSocketForReadCheck(readCheckTarget);
|
|
|
|
checkSocketIsReadable = false;
|
|
|
|
readCheckTarget = NULL;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if(checkSocketIsReadable) {
|
|
|
|
if(readCheckTarget != socket) {
|
|
|
|
e->deleteSocketForReadCheck(readCheckTarget);
|
|
|
|
e->addSocketForReadCheck(socket);
|
|
|
|
readCheckTarget = socket;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
e->addSocketForReadCheck(socket);
|
|
|
|
checkSocketIsReadable = true;
|
|
|
|
readCheckTarget = socket;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void PeerAbstractCommand::setWriteCheckSocket(Socket* socket) {
|
|
|
|
if(socket == NULL) {
|
|
|
|
if(checkSocketIsWritable) {
|
|
|
|
e->deleteSocketForWriteCheck(writeCheckTarget);
|
|
|
|
checkSocketIsWritable = false;
|
|
|
|
writeCheckTarget = NULL;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if(checkSocketIsWritable) {
|
|
|
|
if(writeCheckTarget != socket) {
|
|
|
|
e->deleteSocketForWriteCheck(writeCheckTarget);
|
|
|
|
e->addSocketForWriteCheck(socket);
|
|
|
|
writeCheckTarget = socket;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
e->addSocketForWriteCheck(socket);
|
|
|
|
checkSocketIsWritable = true;
|
|
|
|
writeCheckTarget = socket;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|