summaryrefslogtreecommitdiff
path: root/src/DHTRoutingTable.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-11-20 08:21:36 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-11-20 08:21:36 +0000
commit580098eb4929a3bdbf424af18da361259ef2efe5 (patch)
treec6ff77fa55fcbdcdd0ca21ec2105db14a8c050d3 /src/DHTRoutingTable.cc
parent3940da75624b194cdd5036f9fe330fcecc725964 (diff)
2010-11-20 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Rewritten Logger interface. Logger now writes source file name and line number in log file.
Diffstat (limited to 'src/DHTRoutingTable.cc')
-rw-r--r--src/DHTRoutingTable.cc27
1 files changed, 8 insertions, 19 deletions
diff --git a/src/DHTRoutingTable.cc b/src/DHTRoutingTable.cc
index bffcad3f..a9fbd157 100644
--- a/src/DHTRoutingTable.cc
+++ b/src/DHTRoutingTable.cc
@@ -45,6 +45,7 @@
#include "util.h"
#include "LogFactory.h"
#include "Logger.h"
+#include "fmt.h"
namespace aria2 {
@@ -52,8 +53,7 @@ DHTRoutingTable::DHTRoutingTable(const SharedHandle<DHTNode>& localNode)
: localNode_(localNode),
root_(new DHTBucketTreeNode
(SharedHandle<DHTBucket>(new DHTBucket(localNode_)))),
- numBucket_(1),
- logger_(LogFactory::getInstance())
+ numBucket_(1)
{}
DHTRoutingTable::~DHTRoutingTable()
@@ -73,30 +73,21 @@ bool DHTRoutingTable::addGoodNode(const SharedHandle<DHTNode>& node)
bool DHTRoutingTable::addNode(const SharedHandle<DHTNode>& node, bool good)
{
- if(logger_->debug()) {
- logger_->debug("Trying to add node:%s", node->toString().c_str());
- }
+ A2_LOG_DEBUG(fmt("Trying to add node:%s", node->toString().c_str()));
if(*localNode_ == *node) {
- if(logger_->debug()) {
- logger_->debug("Adding node with the same ID with localnode is not"
- " allowed.");
- }
+ A2_LOG_DEBUG("Adding node with the same ID with localnode is not allowed.");
return false;
}
DHTBucketTreeNode* treeNode = dht::findTreeNodeFor(root_, node->getID());
while(1) {
const SharedHandle<DHTBucket>& bucket = treeNode->getBucket();
if(bucket->addNode(node)) {
- if(logger_->debug()) {
- logger_->debug("Added DHTNode.");
- }
+ A2_LOG_DEBUG("Added DHTNode.");
return true;
} else if(bucket->splitAllowed()) {
- if(logger_->debug()) {
- logger_->debug("Splitting bucket. Range:%s-%s",
+ A2_LOG_DEBUG(fmt("Splitting bucket. Range:%s-%s",
util::toHex(bucket->getMinID(), DHT_ID_LENGTH).c_str(),
- util::toHex(bucket->getMaxID(), DHT_ID_LENGTH).c_str());
- }
+ util::toHex(bucket->getMaxID(), DHT_ID_LENGTH).c_str()));
treeNode->split();
++numBucket_;
if(treeNode->getLeft()->isInRange(node->getID())) {
@@ -107,9 +98,7 @@ bool DHTRoutingTable::addNode(const SharedHandle<DHTNode>& node, bool good)
} else {
if(good) {
bucket->cacheNode(node);
- if(logger_->debug()) {
- logger_->debug("Cached node=%s", node->toString().c_str());
- }
+ A2_LOG_DEBUG(fmt("Cached node=%s", node->toString().c_str()));
}
return false;
}