diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:39:47 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:40:08 +0900 |
| commit | b1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch) | |
| tree | 9ce465b42bf09372118335c7c619bb2b41869eaf /src/FtpFinishDownloadCommand.cc | |
| parent | 4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff) | |
make clang-format using clang-format-3.6
Diffstat (limited to 'src/FtpFinishDownloadCommand.cc')
| -rw-r--r-- | src/FtpFinishDownloadCommand.cc | 59 |
1 files changed, 32 insertions, 27 deletions
diff --git a/src/FtpFinishDownloadCommand.cc b/src/FtpFinishDownloadCommand.cc index c4599348..4f1de617 100644 --- a/src/FtpFinishDownloadCommand.cc +++ b/src/FtpFinishDownloadCommand.cc @@ -54,17 +54,15 @@ namespace aria2 { -FtpFinishDownloadCommand::FtpFinishDownloadCommand -(cuid_t cuid, - const std::shared_ptr<Request>& req, - const std::shared_ptr<FileEntry>& fileEntry, - RequestGroup* requestGroup, - const std::shared_ptr<FtpConnection>& ftpConnection, - DownloadEngine* e, - const std::shared_ptr<SocketCore>& socket) - :AbstractCommand(cuid, req, fileEntry, requestGroup, e, socket), - ftpConnection_(ftpConnection) -{} +FtpFinishDownloadCommand::FtpFinishDownloadCommand( + cuid_t cuid, const std::shared_ptr<Request>& req, + const std::shared_ptr<FileEntry>& fileEntry, RequestGroup* requestGroup, + const std::shared_ptr<FtpConnection>& ftpConnection, DownloadEngine* e, + const std::shared_ptr<SocketCore>& socket) + : AbstractCommand(cuid, req, fileEntry, requestGroup, e, socket), + ftpConnection_(ftpConnection) +{ +} FtpFinishDownloadCommand::~FtpFinishDownloadCommand() {} @@ -72,43 +70,50 @@ FtpFinishDownloadCommand::~FtpFinishDownloadCommand() {} // AbstractCommand::_segments is empty. bool FtpFinishDownloadCommand::execute() { - if(getRequestGroup()->isHaltRequested()) { + if (getRequestGroup()->isHaltRequested()) { return true; } try { - if(readEventEnabled() || hupEventEnabled()) { + if (readEventEnabled() || hupEventEnabled()) { getCheckPoint() = global::wallclock(); int status = ftpConnection_->receiveResponse(); - if(status == 0) { + if (status == 0) { addCommandSelf(); return false; } - if(status == 226) { - if(getOption()->getAsBool(PREF_FTP_REUSE_CONNECTION)) { - getDownloadEngine()->poolSocket - (getRequest(), ftpConnection_->getUser(), createProxyRequest(), - getSocket(), ftpConnection_->getBaseWorkingDir()); + if (status == 226) { + if (getOption()->getAsBool(PREF_FTP_REUSE_CONNECTION)) { + getDownloadEngine()->poolSocket( + getRequest(), ftpConnection_->getUser(), createProxyRequest(), + getSocket(), ftpConnection_->getBaseWorkingDir()); } - } else { + } + else { A2_LOG_INFO(fmt("CUID#%" PRId64 " - Bad status for transfer complete.", getCuid())); } - } else if(getCheckPoint().difference(global::wallclock()) >= getTimeout()) { - A2_LOG_INFO(fmt("CUID#%" PRId64 " - Timeout before receiving transfer complete.", + } + else if (getCheckPoint().difference(global::wallclock()) >= getTimeout()) { + A2_LOG_INFO(fmt("CUID#%" PRId64 + " - Timeout before receiving transfer complete.", getCuid())); - } else { + } + else { addCommandSelf(); return false; } - } catch(RecoverableException& e) { - A2_LOG_INFO_EX(fmt("CUID#%" PRId64 " - Exception was thrown, but download was" + } + catch (RecoverableException& e) { + A2_LOG_INFO_EX(fmt("CUID#%" PRId64 + " - Exception was thrown, but download was" " finished, so we can ignore the exception.", getCuid()), e); } - if(getRequestGroup()->downloadFinished()) { + if (getRequestGroup()->downloadFinished()) { return true; - } else { + } + else { return prepareForRetry(0); } } |
