summaryrefslogtreecommitdiff
path: root/src/AbstractCommand.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/AbstractCommand.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/AbstractCommand.cc')
-rw-r--r--src/AbstractCommand.cc41
1 files changed, 28 insertions, 13 deletions
diff --git a/src/AbstractCommand.cc b/src/AbstractCommand.cc
index f8055177..3294e50d 100644
--- a/src/AbstractCommand.cc
+++ b/src/AbstractCommand.cc
@@ -97,8 +97,10 @@ AbstractCommand::~AbstractCommand() {
}
bool AbstractCommand::execute() {
- logger->debug("CUID#%d - socket: read:%d, write:%d, hup:%d, err:%d",
- cuid, _readEvent, _writeEvent, _hupEvent, _errorEvent);
+ if(logger->debug()) {
+ logger->debug("CUID#%d - socket: read:%d, write:%d, hup:%d, err:%d",
+ cuid, _readEvent, _writeEvent, _hupEvent, _errorEvent);
+ }
try {
if(_requestGroup->downloadFinished() || _requestGroup->isHaltRequested()) {
//logger->debug("CUID#%d - finished.", cuid);
@@ -188,7 +190,9 @@ bool AbstractCommand::execute() {
}
} catch(DlAbortEx& err) {
if(req.isNull()) {
- logger->debug(EX_EXCEPTION_CAUGHT, err);
+ if(logger->debug()) {
+ logger->debug(EX_EXCEPTION_CAUGHT, err);
+ }
} else {
logger->error(MSG_DOWNLOAD_ABORTED,
DL_ABORT_EX2(StringFormat
@@ -240,13 +244,17 @@ void AbstractCommand::tryReserved() {
// and there are no URI left. Because file length is unknown, we
// can assume that there are no in-flight request object.
if(entry->getLength() == 0 && entry->getRemainingUris().empty()) {
- logger->debug("CUID#%d - Not trying next request."
- " No reserved/pooled request is remaining and"
- " total length is still unknown.", cuid);
+ if(logger->debug()) {
+ logger->debug("CUID#%d - Not trying next request."
+ " No reserved/pooled request is remaining and"
+ " total length is still unknown.", cuid);
+ }
return;
}
}
- logger->debug("CUID#%d - Trying reserved/pooled request.", cuid);
+ if(logger->debug()) {
+ logger->debug("CUID#%d - Trying reserved/pooled request.", cuid);
+ }
Commands commands;
_requestGroup->createNextCommand(commands, e, 1);
e->setNoWait(true);
@@ -259,8 +267,10 @@ bool AbstractCommand::prepareForRetry(time_t wait) {
}
if(!req.isNull()) {
_fileEntry->poolRequest(req);
- logger->debug("CUID#%d - Pooling request URI=%s",
- cuid, req->getUrl().c_str());
+ if(logger->debug()) {
+ logger->debug("CUID#%d - Pooling request URI=%s",
+ cuid, req->getUrl().c_str());
+ }
if(!_requestGroup->getSegmentMan().isNull()) {
_requestGroup->getSegmentMan()->recognizeSegmentFor(_fileEntry);
}
@@ -286,8 +296,9 @@ void AbstractCommand::onAbort() {
_fileEntry->removeIdenticalURI(req->getUrl());
_fileEntry->removeRequest(req);
}
-
- logger->debug("CUID#%d - Aborting download", cuid);
+ if(logger->debug()) {
+ logger->debug("CUID#%d - Aborting download", cuid);
+ }
if(!_requestGroup->getPieceStorage().isNull()) {
_requestGroup->getSegmentMan()->cancelSegment(cuid);
}
@@ -446,9 +457,13 @@ SharedHandle<Request> AbstractCommand::createProxyRequest() const
if(!proxy.empty()) {
proxyRequest.reset(new Request());
if(proxyRequest->setUrl(proxy)) {
- logger->debug("CUID#%d - Using proxy", cuid);
+ if(logger->debug()) {
+ logger->debug("CUID#%d - Using proxy", cuid);
+ }
} else {
- logger->debug("CUID#%d - Failed to parse proxy string", cuid);
+ if(logger->debug()) {
+ logger->debug("CUID#%d - Failed to parse proxy string", cuid);
+ }
proxyRequest.reset();
}
}