diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-01-26 18:50:48 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-01-26 18:50:48 +0900 |
| commit | 3a19b65dd77ff7a71c8ad277ec9ba3e17de7ee2d (patch) | |
| tree | 82aaceccab603d214ea89599bf9207e623a220d8 /src | |
| parent | 91b26ab2a8c252c36d3cd7bfd48fe7d622e443f3 (diff) | |
Rename /BadCondition/ in Peer to /Drop/
Diffstat (limited to 'src')
| -rw-r--r-- | src/DefaultPeerStorage.cc | 2 | ||||
| -rw-r--r-- | src/Peer.cc | 6 | ||||
| -rw-r--r-- | src/Peer.h | 8 | ||||
| -rw-r--r-- | src/UTPexExtensionMessage.cc | 3 |
4 files changed, 9 insertions, 10 deletions
diff --git a/src/DefaultPeerStorage.cc b/src/DefaultPeerStorage.cc index b8a0ce5a..a6bb908d 100644 --- a/src/DefaultPeerStorage.cc +++ b/src/DefaultPeerStorage.cc @@ -238,7 +238,7 @@ void DefaultPeerStorage::onReturningPeer(const SharedHandle<Peer>& peer) { if(peer->isActive()) { if(peer->isDisconnectedGracefully() && !peer->isIncomingPeer()) { - peer->startBadCondition(); + peer->startDrop(); addDroppedPeer(peer); } // Execute choking algorithm if unchoked and interested peer is diff --git a/src/Peer.cc b/src/Peer.cc index 1ca02d91..4edcebb9 100644 --- a/src/Peer.cc +++ b/src/Peer.cc @@ -51,7 +51,7 @@ Peer::Peer(std::string ipaddr, uint16_t port, bool incoming): origPort_(port), cuid_(0), firstContactTime_(global::wallclock()), - badConditionStartTime_(0), + dropStartTime_(0), seeder_(false), res_(0), incoming_(incoming), @@ -317,9 +317,9 @@ void Peer::setAllBitfield() { updateSeeder(); } -void Peer::startBadCondition() +void Peer::startDrop() { - badConditionStartTime_ = global::wallclock(); + dropStartTime_ = global::wallclock(); } uint8_t Peer::getExtensionMessageID(int key) const @@ -71,7 +71,7 @@ private: Timer firstContactTime_; - Timer badConditionStartTime_; + Timer dropStartTime_; bool seeder_; @@ -145,7 +145,7 @@ public: return seeder_; } - void startBadCondition(); + void startDrop(); void allocateSessionResource(int32_t pieceLength, int64_t totalLength); @@ -160,9 +160,9 @@ public: void setFirstContactTime(const Timer& time); - const Timer& getBadConditionStartTime() const + const Timer& getDropStartTime() const { - return badConditionStartTime_; + return dropStartTime_; } // Before calling following member functions, make sure that diff --git a/src/UTPexExtensionMessage.cc b/src/UTPexExtensionMessage.cc index 3de9e8fc..a5245772 100644 --- a/src/UTPexExtensionMessage.cc +++ b/src/UTPexExtensionMessage.cc @@ -151,8 +151,7 @@ bool UTPexExtensionMessage::freshPeersAreFull() const bool UTPexExtensionMessage::addDroppedPeer(const SharedHandle<Peer>& peer) { if(!peer->isIncomingPeer() && - peer->getBadConditionStartTime(). - difference(global::wallclock()) < interval_) { + peer->getDropStartTime().difference(global::wallclock()) < interval_) { droppedPeers_.push_back(peer); return true; } else { |
