summaryrefslogtreecommitdiff
path: root/src/InitiateConnectionCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:39:47 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:40:08 +0900
commitb1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch)
tree9ce465b42bf09372118335c7c619bb2b41869eaf /src/InitiateConnectionCommand.cc
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/InitiateConnectionCommand.cc')
-rw-r--r--src/InitiateConnectionCommand.cc81
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);
}
}