summaryrefslogtreecommitdiff
path: root/src/DHTMessageTrackerEntry.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2016-03-26 17:12:52 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2016-03-26 17:20:27 +0900
commitd64089632e82a2548752c7a6baaa68365a795a74 (patch)
tree57fc7b85a8c1290975d58fa4761b04a7695bf7e3 /src/DHTMessageTrackerEntry.cc
parentc81b1321122e8509b55c94c0cbca0d8d6d319f0c (diff)
parenta7cd943a06b1a5ff4515b57060b84037f8d01f9f (diff)
Merge branch 'master' into random-webseeding
Diffstat (limited to 'src/DHTMessageTrackerEntry.cc')
-rw-r--r--src/DHTMessageTrackerEntry.cc45
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;
}