diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2006-04-17 16:17:20 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2006-04-17 16:17:20 +0000 |
| commit | 39276dcb00b33372e1ac5fbd0de2d60c733aeb60 (patch) | |
| tree | dd69b00525b60066b9e79b9924ad5c5028b65b4e /src/PeerAbstractCommand.cc | |
| parent | dcc225a145aa784c85472e9618cd5fdf96a271b6 (diff) | |
To add LogFactory which creates singleton logger:
* src/LogFactory.h: New class.
* src/LogFactory.cc: New class.
* src/Command.h (logger): New variable.
(Constructor): Use LogFactory.
* src/AbstractCommand.cc: Use Command::logger
* src/PeerConnection.cc (Constructor): Deleted the argument
logger.
Use LogFactory.
* src/SegmentSplitter.h : Made logger protected.
* src/SegmentSplitter.cc (Constructor): Use LogFactory.
* src/SegmentMan.cc (Constructor): Use LogFactory.
* src/DownloadEngine.h : Made logger protected.
* src/DownloadEngine.cc (Constructor): Use LogFactory.
* src/PeerInteractionCommand.cc : Use Command::logger.
* src/HttpResponseCommand.cc : Use Command::logger.
* src/SegmentMan.h : Made logger private.
* src/TorrentMan.h : Made logger private.
* src/TorrentMan.cc : Use LogFactory.
* src/FtpNegotiateCommand.cc : Use Command::logger.
* src/HttpConnection.h (Constructor): Deleted the argument
logger.
* src/HttpConnection.cc (Constructor): Deleted the argument
logger.
Use LogFactory.
* src/FtpConnection.h (Constructor): Deleted the argument
logger.
* src/FtpConnection.cc (Constructor): Deleted the argument
logger.
Use LogFactory.
* src/DownloadCommand.cc : Use Command::logger.
* src/PeerAbstractCommand.cc : Use Command::logger.
* src/PeerListenCommand.cc : Use Command::logger.
* src/PeerInitiateConnectionCommand.cc : Use Command::logger.
* src/HttpInitiateConnectionCommand.cc : Use Command::logger.
* src/FtpInitiateConnectionCommand.cc : Use Command::logger.
* src/TrackerWatcherCommand.cc : Use Command::logger.
* src/TrackerUpdateCommand.cc : Use Command::logger.
* src/TrackerDownloadCommand.cc : Use Command::logger.
* src/RequestSlotMan.cc (Constructor): Deleted the argument
logger.
Use LogFactory.
* src/SendMessageQueue.h (Constructor): Deleted the argument
logger.
* src/SendMessageQueue.cc (Constructor): Deleted the argument
logger.
Use LogFactory.
* src/main.cc (main): Use LogFactory.
* src/DiskAdaptor.h (logger): New variable.
* src/DiskAdaptor.cc (Constructor): Use LogFactory.
* src/CopyDiskAdaptor.cc (fixFilename): Added a log message.
Diffstat (limited to 'src/PeerAbstractCommand.cc')
| -rw-r--r-- | src/PeerAbstractCommand.cc | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/PeerAbstractCommand.cc b/src/PeerAbstractCommand.cc index fe164ffa..93a2670e 100644 --- a/src/PeerAbstractCommand.cc +++ b/src/PeerAbstractCommand.cc @@ -22,10 +22,10 @@ #include "PeerAbstractCommand.h" #include "DlAbortEx.h" #include "DlRetryEx.h" -#include <sys/time.h> #include "Util.h" #include "message.h" #include "prefs.h" +#include <sys/time.h> PeerAbstractCommand::PeerAbstractCommand(int cuid, Peer* peer, TorrentDownloadEngine* e, const Socket* s): Command(cuid), e(e), peer(peer), checkSocketIsReadable(false), checkSocketIsWritable(false) { @@ -90,13 +90,13 @@ bool PeerAbstractCommand::execute() { //e->torrentMan->updatePeer(peer); return returnValue; } catch(Exception* err) { - e->logger->error(MSG_DOWNLOAD_ABORTED, err, cuid); + logger->error(MSG_DOWNLOAD_ABORTED, err, cuid); onAbort(err); delete(err); return prepareForNextPeer(0); } /*catch(DlRetryEx* err) { - e->logger->error(MSG_RESTARTING_DOWNLOAD, err, cuid); + logger->error(MSG_RESTARTING_DOWNLOAD, err, cuid); peer->tryCount++; bool isAbort = e->option->getAsInt(PREF_MAX_TRIES) != 0 && peer->tryCount >= e->option->getAsInt(PREF_MAX_TRIES); @@ -106,7 +106,7 @@ bool PeerAbstractCommand::execute() { } delete(err); if(isAbort) { - e->logger->error(MSG_MAX_TRY, cuid, tryCount); + logger->error(MSG_MAX_TRY, cuid, tryCount); return true; } else { return prepareForRetry(e->option->getAsInt(PREF_RETRY_WAIT)); @@ -136,7 +136,7 @@ void PeerAbstractCommand::onAbort(Exception* ex) { peer->amInterested = false; peer->peerChoking = true; peer->peerInterested = false; - e->logger->debug("CUID#%d - peer %s:%d banned.", cuid, peer->ipaddr.c_str(), peer->port); + logger->debug("CUID#%d - peer %s:%d banned.", cuid, peer->ipaddr.c_str(), peer->port); } void PeerAbstractCommand::setReadCheckSocket(Socket* socket) { |
