diff options
Diffstat (limited to 'src/InitiateConnectionCommandFactory.cc')
| -rw-r--r-- | src/InitiateConnectionCommandFactory.cc | 45 |
1 files changed, 22 insertions, 23 deletions
diff --git a/src/InitiateConnectionCommandFactory.cc b/src/InitiateConnectionCommandFactory.cc index b4615d7a..ecaafa5b 100644 --- a/src/InitiateConnectionCommandFactory.cc +++ b/src/InitiateConnectionCommandFactory.cc @@ -48,46 +48,45 @@ namespace aria2 { std::unique_ptr<Command> -InitiateConnectionCommandFactory::createInitiateConnectionCommand -(cuid_t cuid, - const std::shared_ptr<Request>& req, - const std::shared_ptr<FileEntry>& fileEntry, - RequestGroup* requestGroup, - DownloadEngine* e) +InitiateConnectionCommandFactory::createInitiateConnectionCommand( + cuid_t cuid, const std::shared_ptr<Request>& req, + const std::shared_ptr<FileEntry>& fileEntry, RequestGroup* requestGroup, + DownloadEngine* e) { - if(req->getProtocol() == "http" + if (req->getProtocol() == "http" #ifdef ENABLE_SSL - // for SSL - || req->getProtocol() == "https" + // for SSL + || + req->getProtocol() == "https" #endif // ENABLE_SSL - ) { + ) { - if(requestGroup->getOption()->getAsBool(PREF_ENABLE_HTTP_KEEP_ALIVE)) { + if (requestGroup->getOption()->getAsBool(PREF_ENABLE_HTTP_KEEP_ALIVE)) { req->setKeepAliveHint(true); } - if(requestGroup->getOption()->getAsBool(PREF_ENABLE_HTTP_PIPELINING)) { + if (requestGroup->getOption()->getAsBool(PREF_ENABLE_HTTP_PIPELINING)) { req->setPipeliningHint(true); } return make_unique<HttpInitiateConnectionCommand>(cuid, req, fileEntry, requestGroup, e); - } else if(req->getProtocol() == "ftp" + } + else if (req->getProtocol() == "ftp" #ifdef HAVE_LIBSSH2 - || req->getProtocol() == "sftp" + || req->getProtocol() == "sftp" #endif // HAVE_LIBSSH2 - ) { - if(req->getFile().empty()) { - throw DL_ABORT_EX - (fmt("FTP/SFTP URI %s doesn't contain file path.", - req->getUri().c_str())); + ) { + if (req->getFile().empty()) { + throw DL_ABORT_EX(fmt("FTP/SFTP URI %s doesn't contain file path.", + req->getUri().c_str())); } return make_unique<FtpInitiateConnectionCommand>(cuid, req, fileEntry, requestGroup, e); - } else { + } + else { // these protocols are not supported yet - throw DL_ABORT_EX - (fmt("%s is not supported yet.", - req->getProtocol().c_str())); + throw DL_ABORT_EX( + fmt("%s is not supported yet.", req->getProtocol().c_str())); } } |