diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-06-04 22:11:51 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-06-04 22:11:51 +0900 |
| commit | b95d7fbfec4a7ea26a81db33d056ccafc8b809e5 (patch) | |
| tree | 60c421a33c0fb926dfb9e6cc3d64d60975ad03a3 /src | |
| parent | 6b8611885bf5f6c358b09ff4bb2711a13743e814 (diff) | |
Remove PeerStorage:scheduleForcedChokeRound since it is not effective
Diffstat (limited to 'src')
| -rw-r--r-- | src/DefaultBtInteractive.cc | 1 | ||||
| -rw-r--r-- | src/DefaultPeerStorage.cc | 10 | ||||
| -rw-r--r-- | src/DefaultPeerStorage.h | 4 | ||||
| -rw-r--r-- | src/PeerStorage.h | 5 |
4 files changed, 2 insertions, 18 deletions
diff --git a/src/DefaultBtInteractive.cc b/src/DefaultBtInteractive.cc index 4daae189..c74d8e7a 100644 --- a/src/DefaultBtInteractive.cc +++ b/src/DefaultBtInteractive.cc @@ -189,7 +189,6 @@ void DefaultBtInteractive::doPostHandshakeProcessing() if (!metadataGetMode_) { addAllowedFastMessageToQueue(); } - peerStorage_->scheduleForcedChokeRound(); sendPendingMessage(); } diff --git a/src/DefaultPeerStorage.cc b/src/DefaultPeerStorage.cc index 6047462a..dc5353f6 100644 --- a/src/DefaultPeerStorage.cc +++ b/src/DefaultPeerStorage.cc @@ -62,8 +62,7 @@ DefaultPeerStorage::DefaultPeerStorage() : maxPeerListSize_(MAX_PEER_LIST_SIZE), seederStateChoke_(make_unique<BtSeederStateChoke>()), leecherStateChoke_(make_unique<BtLeecherStateChoke>()), - lastTransferStatMapUpdated_(Timer::zero()), - forceChokeRound_(false) + lastTransferStatMapUpdated_(Timer::zero()) { } @@ -285,21 +284,16 @@ void DefaultPeerStorage::returnPeer(const std::shared_ptr<Peer>& peer) bool DefaultPeerStorage::chokeRoundIntervalElapsed() { constexpr auto CHOKE_ROUND_INTERVAL = 10_s; - auto forceChokeRound = forceChokeRound_; - forceChokeRound_ = false; if (pieceStorage_->downloadFinished()) { - auto interval = forceChokeRound ? 1_s : CHOKE_ROUND_INTERVAL; return seederStateChoke_->getLastRound().difference(global::wallclock()) >= - interval; + CHOKE_ROUND_INTERVAL; } return leecherStateChoke_->getLastRound().difference(global::wallclock()) >= CHOKE_ROUND_INTERVAL; } -void DefaultPeerStorage::scheduleForcedChokeRound() { forceChokeRound_ = true; } - void DefaultPeerStorage::executeChoke() { if (pieceStorage_->downloadFinished()) { diff --git a/src/DefaultPeerStorage.h b/src/DefaultPeerStorage.h index f2714f82..3fd60a91 100644 --- a/src/DefaultPeerStorage.h +++ b/src/DefaultPeerStorage.h @@ -74,8 +74,6 @@ private: std::map<std::string, Timer> badPeers_; Timer lastBadPeerCleaned_; - bool forceChokeRound_; - bool isPeerAlreadyAdded(const std::shared_ptr<Peer>& peer); void addUniqPeer(const std::shared_ptr<Peer>& peer); @@ -115,8 +113,6 @@ public: virtual bool chokeRoundIntervalElapsed() CXX11_OVERRIDE; - virtual void scheduleForcedChokeRound() CXX11_OVERRIDE; - virtual void executeChoke() CXX11_OVERRIDE; void deleteUnusedPeer(size_t delSize); diff --git a/src/PeerStorage.h b/src/PeerStorage.h index da546c06..08132b06 100644 --- a/src/PeerStorage.h +++ b/src/PeerStorage.h @@ -113,11 +113,6 @@ public: virtual bool chokeRoundIntervalElapsed() = 0; - /** - * Schedules choke round forcibly. - */ - virtual void scheduleForcedChokeRound() = 0; - virtual void executeChoke() = 0; }; |
