From 9f0a602ce3d2ffb4426fc6f0da0db257fbc90333 Mon Sep 17 00:00:00 2001 From: Tatsuhiro Tsujikawa Date: Sat, 9 May 2009 14:01:35 +0000 Subject: 2009-05-09 Tatsuhiro Tsujikawa Removed --enable-http-server and --http-server-listen-port options. Added --enable-xml-rpc and --xml-rpc-listen-port instead. The original feature for --enable-http-server that reports download progress in HTML was officially removed. Persist XML-RPC connection if client supports keep-alive. * src/DownloadEngineFactory.cc * src/HttpServerCommand.cc * src/HttpServerResponseCommand.cc * src/Makefile.am * src/Makefile.in * src/OptionHandlerFactory.cc * src/RequestGroupMan.cc * src/main.cc * src/option_processing.cc * src/prefs.cc * src/prefs.h * src/usage_text.h --- src/HttpServerCommand.cc | 158 ----------------------------------------------- 1 file changed, 158 deletions(-) (limited to 'src/HttpServerCommand.cc') diff --git a/src/HttpServerCommand.cc b/src/HttpServerCommand.cc index a06e53f9..7d889945 100644 --- a/src/HttpServerCommand.cc +++ b/src/HttpServerCommand.cc @@ -33,12 +33,6 @@ */ /* copyright --> */ #include "HttpServerCommand.h" - -#include -#include -#include -#include - #include "SocketCore.h" #include "DownloadEngine.h" #include "HttpServer.h" @@ -46,12 +40,7 @@ #include "Logger.h" #include "RequestGroup.h" #include "RequestGroupMan.h" -#include "BtContext.h" -#include "Util.h" -#include "HttpServerResponseCommand.h" #include "HttpServerBodyCommand.h" -#include "CheckIntegrityEntry.h" -#include "FileAllocationEntry.h" #include "RecoverableException.h" namespace aria2 { @@ -83,153 +72,6 @@ HttpServerCommand::~HttpServerCommand() _e->deleteSocketForReadCheck(_socket, this); } -class PrintSummaryHtml -{ -private: - std::ostream& _o; - -public: - PrintSummaryHtml(std::ostream& o):_o(o) {} - - void operator()(const SharedHandle& rg) - { - _o << "
getGID() << "\">" - << "[#" << rg->getGID() << "]" - << " FILE:" << "" - << Util::htmlEscape(rg->getFilePath()) << ""; -#ifdef ENABLE_BITTORRENT - SharedHandle btContext = - dynamic_pointer_cast(rg->getDownloadContext()); - if(!btContext.isNull()) { - _o << "
" << " Info Hash:" << btContext->getInfoHashAsString(); - } -#endif // ENABLE_BITTORRENT - _o << "
"; - - TransferStat stat = rg->calculateStat(); - unsigned int eta = 0; - if(rg->getTotalLength() > 0 && stat.getDownloadSpeed() > 0) { - eta = - (rg->getTotalLength()-rg->getCompletedLength())/stat.getDownloadSpeed(); - } -#ifdef ENABLE_BITTORRENT - if(!btContext.isNull() && rg->downloadFinished()) { - _o << "SEEDING" << "(" << "ratio:" - << std::fixed << std::setprecision(1) - << ((stat.getAllTimeUploadLength()*10)/rg->getCompletedLength())/10.0 - << ") "; - } -#endif // ENABLE_BITTORRENT - _o << Util::abbrevSize(rg->getCompletedLength()) - << "B" - << "/" - << Util::abbrevSize(rg->getTotalLength()) - << "B"; - if(rg->getTotalLength() > 0) { - _o << "(" - << 100*rg->getCompletedLength()/rg->getTotalLength() - << "%)"; - } - _o << " " - << "CN:" - << rg->getNumConnection(); - if(!rg->downloadFinished()) { - _o << " " - << "SPD:" - << std::fixed << std::setprecision(2) - << stat.getDownloadSpeed()/1024.0 << "KiB/s"; - } - if(stat.getSessionUploadLength() > 0) { - _o << " " - << "UP:" - << std::fixed << std::setprecision(2) - << stat.getUploadSpeed()/1024.0 << "KiB/s" - << "(" << Util::abbrevSize(stat.getAllTimeUploadLength()) << "B)"; - } - if(eta > 0) { - _o << " " - << "ETA:" - << Util::htmlEscape(Util::secfmt(eta)); - } - _o << "
" - << "
"; - } -}; - -static std::string createResponse(DownloadEngine* e) -{ - std::ostringstream strm; - const std::deque > groups = - e->_requestGroupMan->getRequestGroups(); - std::for_each(groups.begin(), groups.end(), PrintSummaryHtml(strm)); - - { - SharedHandle entry = - e->_fileAllocationMan->getPickedEntry(); - if(!entry.isNull()) { - strm << "
" - << "[FileAlloc:" - << "#" << entry->getRequestGroup()->getGID() << " " - << Util::abbrevSize(entry->getCurrentLength()) - << "B" - << "/" - << Util::abbrevSize(entry->getTotalLength()) - << "B" - << "("; - if(entry->getTotalLength() > 0) { - strm << 100*entry->getCurrentLength()/entry->getTotalLength(); - } else { - strm << "--"; - } - strm << "%)" - << "]"; - if(e->_fileAllocationMan->hasNext()) { - strm << "(" - << e->_fileAllocationMan->countEntryInQueue() - << "waiting...)"; - } - strm << "

"; - } - } -#ifdef ENABLE_MESSAGE_DIGEST - { - SharedHandle entry = - e->_checkIntegrityMan->getPickedEntry(); - if(!entry.isNull()) { - strm << "
" - << "[HashCheck:" - << "#" << entry->getRequestGroup()->getGID() << " " - << Util::abbrevSize(entry->getCurrentLength()) - << "B" - << "/" - << Util::abbrevSize(entry->getTotalLength()) - << "B" - << "(" - << 100*entry->getCurrentLength()/entry->getTotalLength() - << "%)" - << "]"; - if(e->_checkIntegrityMan->hasNext()) { - strm << "(" - << e->_checkIntegrityMan->countEntryInQueue() - << "waiting...)"; - } - strm << "

"; - } - } -#endif // ENABLE_MESSAGE_DIGEST - std::string body = - "" - "" - "" - "" - "aria2" - "" - "

aria2 - Download Progress

"+strm.str()+"" - ""; - return body; -} - bool HttpServerCommand::execute() { if(_e->_requestGroupMan->downloadFinished() || _e->isHaltRequested()) { -- cgit