diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-03-26 17:12:52 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-03-26 17:20:27 +0900 |
| commit | d64089632e82a2548752c7a6baaa68365a795a74 (patch) | |
| tree | 57fc7b85a8c1290975d58fa4761b04a7695bf7e3 /src/DHTMessageTrackerEntry.cc | |
| parent | c81b1321122e8509b55c94c0cbca0d8d6d319f0c (diff) | |
| parent | a7cd943a06b1a5ff4515b57060b84037f8d01f9f (diff) | |
Merge branch 'master' into random-webseeding
Diffstat (limited to 'src/DHTMessageTrackerEntry.cc')
| -rw-r--r-- | src/DHTMessageTrackerEntry.cc | 45 |
1 files changed, 23 insertions, 22 deletions
diff --git a/src/DHTMessageTrackerEntry.cc b/src/DHTMessageTrackerEntry.cc index 042725f8..9a4f4ad8 100644 --- a/src/DHTMessageTrackerEntry.cc +++ b/src/DHTMessageTrackerEntry.cc @@ -42,40 +42,41 @@ namespace aria2 { -DHTMessageTrackerEntry::DHTMessageTrackerEntry -(std::shared_ptr<DHTNode> targetNode, - std::string transactionID, - std::string messageType, - std::chrono::seconds timeout, - std::unique_ptr<DHTMessageCallback> callback) - : targetNode_{std::move(targetNode)}, - transactionID_{std::move(transactionID)}, - messageType_{std::move(messageType)}, - callback_{std::move(callback)}, - dispatchedTime_{global::wallclock()}, - timeout_{std::move(timeout)} -{} +DHTMessageTrackerEntry::DHTMessageTrackerEntry( + std::shared_ptr<DHTNode> targetNode, std::string transactionID, + std::string messageType, std::chrono::seconds timeout, + std::unique_ptr<DHTMessageCallback> callback) + : targetNode_{std::move(targetNode)}, + transactionID_{std::move(transactionID)}, + messageType_{std::move(messageType)}, + callback_{std::move(callback)}, + dispatchedTime_{global::wallclock()}, + timeout_{std::move(timeout)} +{ +} bool DHTMessageTrackerEntry::isTimeout() const { return dispatchedTime_.difference(global::wallclock()) >= timeout_; } -void DHTMessageTrackerEntry::extendTimeout() -{} +void DHTMessageTrackerEntry::extendTimeout() {} -bool DHTMessageTrackerEntry::match(const std::string& transactionID, const std::string& ipaddr, uint16_t port) const +bool DHTMessageTrackerEntry::match(const std::string& transactionID, + const std::string& ipaddr, + uint16_t port) const { - if(transactionID_ != transactionID || targetNode_->getPort() != port) { + if (transactionID_ != transactionID || targetNode_->getPort() != port) { return false; } - if(targetNode_->getIPAddress() == ipaddr) { + if (targetNode_->getIPAddress() == ipaddr) { return true; } - if(util::endsWith(targetNode_->getIPAddress(), ipaddr)) { - return targetNode_->getIPAddress() == "::ffff:"+ipaddr; - } else if(util::endsWith(ipaddr, targetNode_->getIPAddress())) { - return ipaddr == "::ffff:"+targetNode_->getIPAddress(); + if (util::endsWith(targetNode_->getIPAddress(), ipaddr)) { + return targetNode_->getIPAddress() == "::ffff:" + ipaddr; + } + else if (util::endsWith(ipaddr, targetNode_->getIPAddress())) { + return ipaddr == "::ffff:" + targetNode_->getIPAddress(); } return false; } |
