/* */ #include "PeerAbstractCommand.h" #include "Peer.h" #include "DownloadEngine.h" #include "Option.h" #include "DlAbortEx.h" #include "Socket.h" #include "Logger.h" #include "LogFactory.h" #include "message.h" #include "prefs.h" #include "DownloadFailureException.h" #include "fmt.h" #include "wallclock.h" #include "util.h" namespace aria2 { PeerAbstractCommand::PeerAbstractCommand (cuid_t cuid, const SharedHandle& peer, DownloadEngine* e, const SocketHandle& s) : Command(cuid), checkPoint_(global::wallclock()), // TODO referring global option timeout_(e->getOption()->getAsInt(PREF_BT_TIMEOUT)), e_(e), socket_(s), peer_(peer), checkSocketIsReadable_(false), checkSocketIsWritable_(false), noCheck_(false) { if(socket_ && socket_->isOpen()) { setReadCheckSocket(socket_); } } PeerAbstractCommand::~PeerAbstractCommand() { disableReadCheckSocket(); disableWriteCheckSocket(); } bool PeerAbstractCommand::execute() { A2_LOG_DEBUG(fmt("CUID#%lld -" " socket: read:%d, write:%d, hup:%d, err:%d, noCheck:%d", getCuid(), readEventEnabled(), writeEventEnabled(), hupEventEnabled(), errorEventEnabled(), noCheck_)); if(exitBeforeExecute()) { onAbort(); return true; } try { if(noCheck_ || (checkSocketIsReadable_ && readEventEnabled()) || (checkSocketIsWritable_ && writeEventEnabled()) || hupEventEnabled()) { checkPoint_ = global::wallclock(); } else if(errorEventEnabled()) { throw DL_ABORT_EX (fmt(MSG_NETWORK_PROBLEM, socket_->getSocketError().c_str())); } if(checkPoint_.difference(global::wallclock()) >= timeout_) { throw DL_ABORT_EX(EX_TIME_OUT); } return executeInternal(); } catch(DownloadFailureException& err) { A2_LOG_ERROR_EX(EX_DOWNLOAD_ABORTED, err); onAbort(); onFailure(err); return true; } catch(RecoverableException& err) { A2_LOG_DEBUG_EX(fmt(MSG_TORRENT_DOWNLOAD_ABORTED, getCuid()), err); A2_LOG_DEBUG(fmt(MSG_PEER_BANNED, getCuid(), peer_->getIPAddress().c_str(), peer_->getPort())); onAbort(); return prepareForNextPeer(0); } } // TODO this method removed when PeerBalancerCommand is implemented bool PeerAbstractCommand::prepareForNextPeer(time_t wait) { return true; } void PeerAbstractCommand::disableReadCheckSocket() { if(checkSocketIsReadable_) { e_->deleteSocketForReadCheck(readCheckTarget_, this); checkSocketIsReadable_ = false; readCheckTarget_.reset(); } } void PeerAbstractCommand::setReadCheckSocket(const SocketHandle& socket) { if(!socket->isOpen()) { disableReadCheckSocket(); } else { if(checkSocketIsReadable_) { if(*readCheckTarget_ != *socket) { e_->deleteSocketForReadCheck(readCheckTarget_, this); e_->addSocketForReadCheck(socket, this); readCheckTarget_ = socket; } } else { e_->addSocketForReadCheck(socket, this); checkSocketIsReadable_ = true; readCheckTarget_ = socket; } } } void PeerAbstractCommand::disableWriteCheckSocket() { if(checkSocketIsWritable_) { e_->deleteSocketForWriteCheck(writeCheckTarget_, this); checkSocketIsWritable_ = false; writeCheckTarget_.reset(); } } void PeerAbstractCommand::setWriteCheckSocket(const SocketHandle& socket) { if(!socket->isOpen()) { disableWriteCheckSocket(); } else { if(checkSocketIsWritable_) { if(*writeCheckTarget_ != *socket) { e_->deleteSocketForWriteCheck(writeCheckTarget_, this); e_->addSocketForWriteCheck(socket, this); writeCheckTarget_ = socket; } } else { e_->addSocketForWriteCheck(socket, this); checkSocketIsWritable_ = true; writeCheckTarget_ = socket; } } } void PeerAbstractCommand::setNoCheck(bool check) { noCheck_ = check; } void PeerAbstractCommand::updateKeepAlive() { checkPoint_ = global::wallclock(); } void PeerAbstractCommand::createSocket() { socket_.reset(new SocketCore()); } } // namespace aria2