summaryrefslogtreecommitdiff
path: root/src/DHTMessageTracker.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-02-09 12:20:20 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-02-09 12:20:20 +0000
commite227e53d7b7afb63255ae9df4cdc0ef56ff577d9 (patch)
tree883aecdcf7348a4115cb9eb897e5d1133bae6a53 /src/DHTMessageTracker.cc
parent65c094664c52ff1dc8330166858e5280f0bfdf88 (diff)
2010-02-09 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Wrapped logger->debug(...) with if(logger->debug()) { ... } * src/AbstractCommand.cc * src/AdaptiveURISelector.cc * src/BtPieceMessage.cc * src/BtPortMessage.cc * src/CreateRequestCommand.cc * src/DHTAbstractNodeLookupTask.cc * src/DHTBucket.cc * src/DHTGetPeersCommand.cc * src/DHTMessageDispatcherImpl.cc * src/DHTMessageFactoryImpl.cc * src/DHTMessageTracker.cc * src/DHTPeerAnnounceStorage.cc * src/DHTRoutingTable.cc * src/DHTSetup.cc * src/DefaultBtAnnounce.cc * src/DefaultBtInteractive.cc * src/DefaultBtMessageDispatcher.cc * src/DefaultBtMessageReceiver.cc * src/DefaultBtProgressInfoFile.cc * src/DefaultBtRequestFactory.cc * src/DefaultPeerStorage.cc * src/DefaultPieceStorage.cc * src/DownloadCommand.cc * src/DownloadEngine.cc * src/EpollEventPoll.cc * src/FileAllocationCommand.cc * src/FileEntry.cc * src/FtpNegotiationCommand.cc * src/HandshakeExtensionMessage.cc * src/HttpListenCommand.cc * src/HttpServer.cc * src/HttpSkipResponseCommand.cc * src/IteratableChunkChecksumValidator.cc * src/Logger.h * src/MSEHandshake.cc * src/MetalinkPostDownloadHandler.cc * src/MultiDiskAdaptor.cc * src/PeerAbstractCommand.cc * src/PeerConnection.cc * src/PeerListenCommand.cc * src/PeerReceiveHandshakeCommand.cc * src/RequestGroup.cc * src/RequestGroupMan.cc * src/SegmentMan.cc * src/SelectEventPoll.cc * src/ServerStat.cc * src/SimpleBtMessage.cc * src/SocketCore.cc * src/TrackerWatcherCommand.cc * src/UTMetadataDataExtensionMessage.cc * src/UTMetadataRequestFactory.cc * src/UTMetadataRequestTracker.cc * src/XmlRpcMethod.cc
Diffstat (limited to 'src/DHTMessageTracker.cc')
-rw-r--r--src/DHTMessageTracker.cc30
1 files changed, 21 insertions, 9 deletions
diff --git a/src/DHTMessageTracker.cc b/src/DHTMessageTracker.cc
index 4b112ce7..e8d7b67e 100644
--- a/src/DHTMessageTracker.cc
+++ b/src/DHTMessageTracker.cc
@@ -77,14 +77,18 @@ DHTMessageTracker::messageArrived(const BDE& dict,
throw DL_ABORT_EX(StringFormat("Malformed DHT message. From:%s:%u",
ipaddr.c_str(), port).str());
}
- _logger->debug("Searching tracker entry for TransactionID=%s, Remote=%s:%u",
- util::toHex(tid.s()).c_str(), ipaddr.c_str(), port);
+ if(_logger->debug()) {
+ _logger->debug("Searching tracker entry for TransactionID=%s, Remote=%s:%u",
+ util::toHex(tid.s()).c_str(), ipaddr.c_str(), port);
+ }
for(std::deque<SharedHandle<DHTMessageTrackerEntry> >::iterator i =
_entries.begin(); i != _entries.end(); ++i) {
if((*i)->match(tid.s(), ipaddr, port)) {
SharedHandle<DHTMessageTrackerEntry> entry = *i;
_entries.erase(i);
- _logger->debug("Tracker entry found.");
+ if(_logger->debug()) {
+ _logger->debug("Tracker entry found.");
+ }
SharedHandle<DHTNode> targetNode = entry->getTargetNode();
SharedHandle<DHTMessage> message =
@@ -93,13 +97,17 @@ DHTMessageTracker::messageArrived(const BDE& dict,
targetNode->getPort());
int64_t rtt = entry->getElapsedMillis();
- _logger->debug("RTT is %s", util::itos(rtt).c_str());
+ if(_logger->debug()) {
+ _logger->debug("RTT is %s", util::itos(rtt).c_str());
+ }
message->getRemoteNode()->updateRTT(rtt);
SharedHandle<DHTMessageCallback> callback = entry->getCallback();
return std::pair<SharedHandle<DHTMessage>, SharedHandle<DHTMessageCallback> >(message, callback);
}
}
- _logger->debug("Tracker entry not found.");
+ if(_logger->debug()) {
+ _logger->debug("Tracker entry not found.");
+ }
return std::pair<SharedHandle<DHTMessage>, SharedHandle<DHTMessageCallback> >();
}
@@ -112,13 +120,17 @@ void DHTMessageTracker::handleTimeout()
SharedHandle<DHTMessageTrackerEntry> entry = *i;
i = _entries.erase(i);
SharedHandle<DHTNode> node = entry->getTargetNode();
- _logger->debug("Message timeout: To:%s:%u",
- node->getIPAddress().c_str(), node->getPort());
+ if(_logger->debug()) {
+ _logger->debug("Message timeout: To:%s:%u",
+ node->getIPAddress().c_str(), node->getPort());
+ }
node->updateRTT(entry->getElapsedMillis());
node->timeout();
if(node->isBad()) {
- _logger->debug("Marked bad: %s:%u",
- node->getIPAddress().c_str(), node->getPort());
+ if(_logger->debug()) {
+ _logger->debug("Marked bad: %s:%u",
+ node->getIPAddress().c_str(), node->getPort());
+ }
_routingTable->dropNode(node);
}
SharedHandle<DHTMessageCallback> callback = entry->getCallback();