/* */ #include "InitiateConnectionCommandFactory.h" #include "HttpInitiateConnectionCommand.h" #include "FtpInitiateConnectionCommand.h" #include "Request.h" #include "RequestGroup.h" #include "DownloadEngine.h" #include "DlAbortEx.h" #include "fmt.h" #include "Option.h" #include "prefs.h" #include "SocketCore.h" #include "SocketRecvBuffer.h" namespace aria2 { Command* InitiateConnectionCommandFactory::createInitiateConnectionCommand (cuid_t cuid, const SharedHandle& req, const SharedHandle& fileEntry, RequestGroup* requestGroup, DownloadEngine* e) { if(req->getProtocol() == Request::PROTO_HTTP #ifdef ENABLE_SSL // for SSL || req->getProtocol() == Request::PROTO_HTTPS #endif // ENABLE_SSL ) { if(requestGroup->getOption()->getAsBool(PREF_ENABLE_HTTP_KEEP_ALIVE)) { req->setKeepAliveHint(true); } if(requestGroup->getOption()->getAsBool(PREF_ENABLE_HTTP_PIPELINING)) { req->setPipeliningHint(true); } return new HttpInitiateConnectionCommand(cuid, req, fileEntry, requestGroup, e); } else if(req->getProtocol() == Request::PROTO_FTP) { if(req->getFile().empty()) { throw DL_ABORT_EX (fmt("FTP URI %s doesn't contain file path.", req->getUri().c_str())); } return new FtpInitiateConnectionCommand(cuid, req, fileEntry, requestGroup, e); } else { // these protocols are not supported yet throw DL_ABORT_EX (fmt("%s is not supported yet.", req->getProtocol().c_str())); } } } // namespace aria2