diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-02-09 12:20:20 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-02-09 12:20:20 +0000 |
| commit | e227e53d7b7afb63255ae9df4cdc0ef56ff577d9 (patch) | |
| tree | 883aecdcf7348a4115cb9eb897e5d1133bae6a53 /src/DHTMessageTracker.cc | |
| parent | 65c094664c52ff1dc8330166858e5280f0bfdf88 (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.cc | 30 |
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(); |
