From b1132d6b10cd3791b9529d7031d723fd0e2d8215 Mon Sep 17 00:00:00 2001 From: Tatsuhiro Tsujikawa Date: Sun, 27 Dec 2015 18:39:47 +0900 Subject: make clang-format using clang-format-3.6 --- src/BackupIPv4ConnectCommand.cc | 86 ++++++++++++++++++++++------------------- 1 file changed, 46 insertions(+), 40 deletions(-) (limited to 'src/BackupIPv4ConnectCommand.cc') diff --git a/src/BackupIPv4ConnectCommand.cc b/src/BackupIPv4ConnectCommand.cc index 66eaf6a9..61ef9e28 100644 --- a/src/BackupIPv4ConnectCommand.cc +++ b/src/BackupIPv4ConnectCommand.cc @@ -45,24 +45,22 @@ namespace aria2 { -BackupConnectInfo::BackupConnectInfo() - : cancel(false) -{} +BackupConnectInfo::BackupConnectInfo() : cancel(false) {} -BackupIPv4ConnectCommand::BackupIPv4ConnectCommand -(cuid_t cuid, const std::string& ipaddr, uint16_t port, - const std::shared_ptr& info, Command* mainCommand, - RequestGroup* requestGroup, DownloadEngine* e) -: Command(cuid), - ipaddr_(ipaddr), - port_(port), - info_(info), - mainCommand_(mainCommand), - requestGroup_(requestGroup), - e_(e), - startTime_(global::wallclock()), - timeoutCheck_(global::wallclock()), - timeout_(requestGroup_->getOption()->getAsInt(PREF_CONNECT_TIMEOUT)) +BackupIPv4ConnectCommand::BackupIPv4ConnectCommand( + cuid_t cuid, const std::string& ipaddr, uint16_t port, + const std::shared_ptr& info, Command* mainCommand, + RequestGroup* requestGroup, DownloadEngine* e) + : Command(cuid), + ipaddr_(ipaddr), + port_(port), + info_(info), + mainCommand_(mainCommand), + requestGroup_(requestGroup), + e_(e), + startTime_(global::wallclock()), + timeoutCheck_(global::wallclock()), + timeout_(requestGroup_->getOption()->getAsInt(PREF_CONNECT_TIMEOUT)) { requestGroup_->increaseStreamCommand(); requestGroup_->increaseNumCommand(); @@ -72,7 +70,7 @@ BackupIPv4ConnectCommand::~BackupIPv4ConnectCommand() { requestGroup_->decreaseNumCommand(); requestGroup_->decreaseStreamCommand(); - if(socket_) { + if (socket_) { e_->deleteSocketForWriteCheck(socket_, this); } } @@ -80,60 +78,68 @@ BackupIPv4ConnectCommand::~BackupIPv4ConnectCommand() bool BackupIPv4ConnectCommand::execute() { bool retval = false; - if(requestGroup_->downloadFinished() || requestGroup_->isHaltRequested()) { + if (requestGroup_->downloadFinished() || requestGroup_->isHaltRequested()) { retval = true; - } else if(info_->cancel) { - A2_LOG_INFO(fmt("CUID#%" PRId64 " - Backup connection canceled", - getCuid())); + } + else if (info_->cancel) { + A2_LOG_INFO( + fmt("CUID#%" PRId64 " - Backup connection canceled", getCuid())); retval = true; - } else if(socket_) { - if(writeEventEnabled()) { + } + else if (socket_) { + if (writeEventEnabled()) { try { std::string error = socket_->getSocketError(); - if(error.empty()) { + if (error.empty()) { A2_LOG_INFO(fmt("CUID#%" PRId64 " - Backup connection to %s " - "established", getCuid(), ipaddr_.c_str())); + "established", + getCuid(), ipaddr_.c_str())); info_->ipaddr = ipaddr_; e_->deleteSocketForWriteCheck(socket_, this); info_->socket.swap(socket_); mainCommand_->setStatus(STATUS_ONESHOT_REALTIME); e_->setNoWait(true); retval = true; - } else { + } + else { A2_LOG_INFO(fmt("CUID#%" PRId64 " - Backup connection failed: %s", getCuid(), error.c_str())); retval = true; } - } catch(RecoverableException& e) { - A2_LOG_INFO_EX(fmt("CUID#%" PRId64 " - Backup connection failed", - getCuid()), e); + } + catch (RecoverableException& e) { + A2_LOG_INFO_EX( + fmt("CUID#%" PRId64 " - Backup connection failed", getCuid()), e); retval = true; } } - } else if(!socket_) { + } + else if (!socket_) { // TODO Although we check 300ms initial timeout as described in // RFC 6555, the interval will be much longer and around 1 second // due to the refresh interval mechanism in DownloadEngine. - if(startTime_.difference(global::wallclock()) >= - std::chrono::milliseconds(300)) { + if (startTime_.difference(global::wallclock()) >= + std::chrono::milliseconds(300)) { socket_ = std::make_shared(); try { socket_->establishConnection(ipaddr_, port_); e_->addSocketForWriteCheck(socket_, this); timeoutCheck_ = global::wallclock(); - } catch(RecoverableException& e) { - A2_LOG_INFO_EX(fmt("CUID#%" PRId64 " - Backup connection failed", - getCuid()), e); + } + catch (RecoverableException& e) { + A2_LOG_INFO_EX( + fmt("CUID#%" PRId64 " - Backup connection failed", getCuid()), e); socket_.reset(); retval = true; } } - } else if(timeoutCheck_.difference(global::wallclock()) >= timeout_) { - A2_LOG_INFO(fmt("CUID#%" PRId64 " - Backup connection command timeout", - getCuid())); + } + else if (timeoutCheck_.difference(global::wallclock()) >= timeout_) { + A2_LOG_INFO( + fmt("CUID#%" PRId64 " - Backup connection command timeout", getCuid())); retval = true; } - if(!retval) { + if (!retval) { e_->addCommand(std::unique_ptr(this)); } return retval; -- cgit