summaryrefslogtreecommitdiff
path: root/src/DefaultBtMessageDispatcher.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/DefaultBtMessageDispatcher.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/DefaultBtMessageDispatcher.cc')
-rw-r--r--src/DefaultBtMessageDispatcher.cc48
1 files changed, 29 insertions, 19 deletions
diff --git a/src/DefaultBtMessageDispatcher.cc b/src/DefaultBtMessageDispatcher.cc
index 22e96d32..d3e96244 100644
--- a/src/DefaultBtMessageDispatcher.cc
+++ b/src/DefaultBtMessageDispatcher.cc
@@ -64,7 +64,9 @@ DefaultBtMessageDispatcher::DefaultBtMessageDispatcher():
DefaultBtMessageDispatcher::~DefaultBtMessageDispatcher()
{
- logger->debug("DefaultBtMessageDispatcher::deleted");
+ if(logger->debug()) {
+ logger->debug("DefaultBtMessageDispatcher::deleted");
+ }
}
void DefaultBtMessageDispatcher::addMessageToQueue(const BtMessageHandle& btMessage)
@@ -144,11 +146,13 @@ public:
void operator()(const RequestSlot& slot) const
{
- _logger->debug(MSG_DELETING_REQUEST_SLOT,
- _cuid,
- slot.getIndex(),
- slot.getBlockIndex());
- _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ if(_logger->debug()) {
+ _logger->debug(MSG_DELETING_REQUEST_SLOT,
+ _cuid,
+ slot.getIndex(),
+ slot.getBlockIndex());
+ _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ }
_piece->cancelBlock(slot.getBlockIndex());
}
};
@@ -191,11 +195,13 @@ public:
void operator()(const RequestSlot& slot) const
{
if(!_peer->isInPeerAllowedIndexSet(slot.getIndex())) {
- _logger->debug(MSG_DELETING_REQUEST_SLOT_CHOKED,
- _cuid,
- slot.getIndex(),
- slot.getBlockIndex());
- _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ if(_logger->debug()) {
+ _logger->debug(MSG_DELETING_REQUEST_SLOT_CHOKED,
+ _cuid,
+ slot.getIndex(),
+ slot.getBlockIndex());
+ _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ }
SharedHandle<Piece> piece = _pieceStorage->getPiece(slot.getIndex());
piece->cancelBlock(slot.getBlockIndex());
}
@@ -266,17 +272,21 @@ public:
void operator()(const RequestSlot& slot)
{
if(slot.isTimeout(_now, _requestTimeout)) {
- _logger->debug(MSG_DELETING_REQUEST_SLOT_TIMEOUT,
- _cuid,
- slot.getBlockIndex());
- _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ if(_logger->debug()) {
+ _logger->debug(MSG_DELETING_REQUEST_SLOT_TIMEOUT,
+ _cuid,
+ slot.getBlockIndex());
+ _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ }
slot.getPiece()->cancelBlock(slot.getBlockIndex());
_peer->snubbing(true);
} else if(slot.getPiece()->hasBlock(slot.getBlockIndex())) {
- _logger->debug(MSG_DELETING_REQUEST_SLOT_ACQUIRED,
- _cuid,
- slot.getBlockIndex());
- _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ if(_logger->debug()) {
+ _logger->debug(MSG_DELETING_REQUEST_SLOT_ACQUIRED,
+ _cuid,
+ slot.getBlockIndex());
+ _logger->debug("index=%d, begin=%d", slot.getIndex(), slot.getBegin());
+ }
_messageDispatcher->addMessageToQueue
(_messageFactory->createCancelMessage(slot.getIndex(),
slot.getBegin(),