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/InitiateConnectionCommand.cc | |
| parent | 4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff) | |
make clang-format using clang-format-3.6
Diffstat (limited to 'src/InitiateConnectionCommand.cc')
| -rw-r--r-- | src/InitiateConnectionCommand.cc | 81 |
1 files changed, 41 insertions, 40 deletions
diff --git a/src/InitiateConnectionCommand.cc b/src/InitiateConnectionCommand.cc index 612d8b12..92c32ace 100644 --- a/src/InitiateConnectionCommand.cc +++ b/src/InitiateConnectionCommand.cc @@ -56,13 +56,11 @@ namespace aria2 { -InitiateConnectionCommand::InitiateConnectionCommand -(cuid_t cuid, - const std::shared_ptr<Request>& req, - const std::shared_ptr<FileEntry>& fileEntry, - RequestGroup* requestGroup, - DownloadEngine* e) - : AbstractCommand(cuid, req, fileEntry, requestGroup, e) +InitiateConnectionCommand::InitiateConnectionCommand( + cuid_t cuid, const std::shared_ptr<Request>& req, + const std::shared_ptr<FileEntry>& fileEntry, RequestGroup* requestGroup, + DownloadEngine* e) + : AbstractCommand(cuid, req, fileEntry, requestGroup, e) { setTimeout(std::chrono::seconds(getOption()->getAsInt(PREF_DNS_TIMEOUT))); // give a chance to be executed in the next loop in DownloadEngine @@ -73,20 +71,22 @@ InitiateConnectionCommand::InitiateConnectionCommand InitiateConnectionCommand::~InitiateConnectionCommand() {} -bool InitiateConnectionCommand::executeInternal() { +bool InitiateConnectionCommand::executeInternal() +{ std::string hostname; uint16_t port; std::shared_ptr<Request> proxyRequest = createProxyRequest(); - if(!proxyRequest) { + if (!proxyRequest) { hostname = getRequest()->getHost(); port = getRequest()->getPort(); - } else { + } + else { hostname = proxyRequest->getHost(); port = proxyRequest->getPort(); } std::vector<std::string> addrs; std::string ipaddr = resolveHostname(addrs, hostname, port); - if(ipaddr.empty()) { + if (ipaddr.empty()) { addCommandSelf(); return false; } @@ -96,21 +96,21 @@ bool InitiateConnectionCommand::executeInternal() { getDownloadEngine()->setNoWait(true); getDownloadEngine()->addCommand(std::move(c)); return true; - } catch(RecoverableException& ex) { + } + catch (RecoverableException& ex) { // Catch exception and retry another address. // See also AbstractCommand::checkIfConnectionEstablished // TODO ipaddr might not be used if pooled socket was found. getDownloadEngine()->markBadIPAddress(hostname, ipaddr, port); - if(!getDownloadEngine()->findCachedIPAddress(hostname, port).empty()) { + if (!getDownloadEngine()->findCachedIPAddress(hostname, port).empty()) { A2_LOG_INFO_EX(EX_EXCEPTION_CAUGHT, ex); - A2_LOG_INFO(fmt(MSG_CONNECT_FAILED_AND_RETRY, - getCuid(), - ipaddr.c_str(), port)); + A2_LOG_INFO( + fmt(MSG_CONNECT_FAILED_AND_RETRY, getCuid(), ipaddr.c_str(), port)); auto command = - InitiateConnectionCommandFactory::createInitiateConnectionCommand - (getCuid(), getRequest(), getFileEntry(), getRequestGroup(), - getDownloadEngine()); + InitiateConnectionCommandFactory::createInitiateConnectionCommand( + getCuid(), getRequest(), getFileEntry(), getRequestGroup(), + getDownloadEngine()); getDownloadEngine()->setNoWait(true); getDownloadEngine()->addCommand(std::move(command)); return true; @@ -120,10 +120,9 @@ bool InitiateConnectionCommand::executeInternal() { } } -void InitiateConnectionCommand::setConnectedAddrInfo -(const std::shared_ptr<Request>& req, - const std::string& hostname, - const std::shared_ptr<SocketCore>& socket) +void InitiateConnectionCommand::setConnectedAddrInfo( + const std::shared_ptr<Request>& req, const std::string& hostname, + const std::shared_ptr<SocketCore>& socket) { std::pair<std::string, uint16_t> peerAddr; socket->getPeerInfo(peerAddr); @@ -131,30 +130,32 @@ void InitiateConnectionCommand::setConnectedAddrInfo } std::shared_ptr<BackupConnectInfo> -InitiateConnectionCommand::createBackupIPv4ConnectCommand -(const std::string& hostname, const std::string& ipaddr, uint16_t port, - Command* mainCommand) +InitiateConnectionCommand::createBackupIPv4ConnectCommand( + const std::string& hostname, const std::string& ipaddr, uint16_t port, + Command* mainCommand) { // Prepare IPv4 backup connection attempt in "Happy Eyeballs" // fashion. std::shared_ptr<BackupConnectInfo> info; char buf[sizeof(in6_addr)]; - if(inetPton(AF_INET6, ipaddr.c_str(), &buf) == -1) { + if (inetPton(AF_INET6, ipaddr.c_str(), &buf) == -1) { return info; } A2_LOG_INFO("Searching IPv4 address for backup connection attempt"); std::vector<std::string> addrs; getDownloadEngine()->findAllCachedIPAddresses(std::back_inserter(addrs), hostname, port); - for(std::vector<std::string>::const_iterator i = addrs.begin(), - eoi = addrs.end(); i != eoi; ++i) { - if(inetPton(AF_INET, (*i).c_str(), &buf) == 0) { + for (std::vector<std::string>::const_iterator i = addrs.begin(), + eoi = addrs.end(); + i != eoi; ++i) { + if (inetPton(AF_INET, (*i).c_str(), &buf) == 0) { info = std::make_shared<BackupConnectInfo>(); - auto command = make_unique<BackupIPv4ConnectCommand> - (getDownloadEngine()->newCUID(), *i, port, info, mainCommand, - getRequestGroup(), getDownloadEngine()); + auto command = make_unique<BackupIPv4ConnectCommand>( + getDownloadEngine()->newCUID(), *i, port, info, mainCommand, + getRequestGroup(), getDownloadEngine()); A2_LOG_INFO(fmt("Issue backup connection command CUID#%" PRId64 - ", addr=%s", command->getCuid(), (*i).c_str())); + ", addr=%s", + command->getCuid(), (*i).c_str())); getDownloadEngine()->addCommand(std::move(command)); return info; } @@ -162,13 +163,13 @@ InitiateConnectionCommand::createBackupIPv4ConnectCommand return info; } -void InitiateConnectionCommand::setupBackupConnection -(const std::string& hostname, const std::string& addr, uint16_t port, - ConnectCommand* c) +void InitiateConnectionCommand::setupBackupConnection( + const std::string& hostname, const std::string& addr, uint16_t port, + ConnectCommand* c) { - std::shared_ptr<BackupConnectInfo> backupConnectInfo - = createBackupIPv4ConnectCommand(hostname, addr, port, c); - if(backupConnectInfo) { + std::shared_ptr<BackupConnectInfo> backupConnectInfo = + createBackupIPv4ConnectCommand(hostname, addr, port, c); + if (backupConnectInfo) { c->setBackupConnectInfo(backupConnectInfo); } } |
