diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-06-02 22:13:47 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-06-02 22:13:47 +0900 |
| commit | 482cf6aca45bdc8733c88db24058eca59143f923 (patch) | |
| tree | afd3f0641fe38dfe5ad4b63cee43803cd341a661 /src/PeerInteractionCommand.cc | |
| parent | a0706f5a44ccc171e5b861e4649a7ba861a218b3 (diff) | |
Fasten seed/download on fast connection
Diffstat (limited to 'src/PeerInteractionCommand.cc')
| -rw-r--r-- | src/PeerInteractionCommand.cc | 30 |
1 files changed, 12 insertions, 18 deletions
diff --git a/src/PeerInteractionCommand.cc b/src/PeerInteractionCommand.cc index 9d2898bc..d2eec424 100644 --- a/src/PeerInteractionCommand.cc +++ b/src/PeerInteractionCommand.cc @@ -347,29 +347,23 @@ bool PeerInteractionCommand::executeInternal() if (btInteractive_->countReceivedMessageInIteration() > 0) { updateKeepAlive(); } - if ((getPeer()->amInterested() && !getPeer()->peerChoking()) || - btInteractive_->countOutstandingRequest() || - (getPeer()->peerInterested() && !getPeer()->amChoking())) { - // Writable check to avoid slow seeding - if (btInteractive_->isSendingMessageInProgress()) { - setWriteCheckSocket(getSocket()); - } + // Writable check to avoid slow seeding + if (btInteractive_->isSendingMessageInProgress()) { + setWriteCheckSocket(getSocket()); + } - if (getDownloadEngine() - ->getRequestGroupMan() - ->doesOverallDownloadSpeedExceed() || - requestGroup_->doesDownloadSpeedExceed()) { - disableReadCheckSocket(); - setNoCheck(true); - } - else { - setReadCheckSocket(getSocket()); - } + if (getDownloadEngine() + ->getRequestGroupMan() + ->doesOverallDownloadSpeedExceed() || + requestGroup_->doesDownloadSpeedExceed()) { + disableReadCheckSocket(); + setNoCheck(true); } else { - disableReadCheckSocket(); + setReadCheckSocket(getSocket()); } + done = true; break; } |
