/* */ #include "PeerAbstractCommand.h" #include "Peer.h" #include "DownloadEngine.h" #include "Option.h" #include "DlAbortEx.h" #include "SocketCore.h" #include "uTPCore.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 std::shared_ptr& peer, DownloadEngine* e, const std::shared_ptr& s) : Command(cuid), checkPoint_(global::wallclock()), // TODO referring global option timeout_(std::chrono::seconds(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#%" PRId64 " -" " 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) { if (retryDifferentProtocol() == true) { return true; } 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); } } bool PeerAbstractCommand::retryDifferentProtocol() { return false; } // TODO this method removed when PeerBalancerCommand is implemented bool PeerAbstractCommand::prepareForNextPeer(time_t wait) { return true; } void PeerAbstractCommand::disableReadCheckSocket() { if (checkSocketIsReadable_) { setRWCheck(e_, readCheckTarget_, false, true); checkSocketIsReadable_ = false; readCheckTarget_.reset(); } } void PeerAbstractCommand::setReadCheckSocket( const std::shared_ptr& socket) { if (!socket->isOpen()) { disableReadCheckSocket(); } else { if (checkSocketIsReadable_) { if (*readCheckTarget_ != *socket) { setRWCheck(e_, readCheckTarget_, false, true); setRWCheck(e_, socket, true, true); readCheckTarget_ = socket; } } else { setRWCheck(e_, socket, true, true); checkSocketIsReadable_ = true; readCheckTarget_ = socket; } } } void PeerAbstractCommand::disableWriteCheckSocket() { if (checkSocketIsWritable_) { setRWCheck(e_, writeCheckTarget_, false, false); checkSocketIsWritable_ = false; writeCheckTarget_.reset(); } } void PeerAbstractCommand::setWriteCheckSocket( const std::shared_ptr& socket) { if (!socket->isOpen()) { disableWriteCheckSocket(); } else { if (checkSocketIsWritable_) { if (*writeCheckTarget_ != *socket) { setRWCheck(e_, writeCheckTarget_, false, false); setRWCheck(e_, socket, true, false); writeCheckTarget_ = socket; } } else { setRWCheck(e_, socket, true, false); checkSocketIsWritable_ = true; writeCheckTarget_ = socket; } } } void PeerAbstractCommand::setRWCheck(DownloadEngine* e, const std::shared_ptr& socket, int is_add, int is_read) { auto utp = std::dynamic_pointer_cast(socket); if (utp == nullptr) { if (is_add) { is_read ? e_->addSocketForReadCheck(socket, this) : e_->addSocketForWriteCheck(socket, this); } else { is_read ? e_->deleteSocketForReadCheck(socket, this) : e_->deleteSocketForWriteCheck(socket, this); } } else { utp->setRWCheck(this, is_add, is_read); } } void PeerAbstractCommand::setNoCheck(bool check) { noCheck_ = check; } void PeerAbstractCommand::updateKeepAlive() { checkPoint_ = global::wallclock(); } void PeerAbstractCommand::addCommandSelf() { e_->addCommand(std::unique_ptr(this)); } } // namespace aria2