diff options
Diffstat (limited to 'src/FtpTunnelResponseCommand.cc')
| -rw-r--r-- | src/FtpTunnelResponseCommand.cc | 49 |
1 files changed, 49 insertions, 0 deletions
diff --git a/src/FtpTunnelResponseCommand.cc b/src/FtpTunnelResponseCommand.cc new file mode 100644 index 00000000..7009310c --- /dev/null +++ b/src/FtpTunnelResponseCommand.cc @@ -0,0 +1,49 @@ +/* <!-- copyright */ +/* + * aria2 - a simple utility for downloading files faster + * + * Copyright (C) 2006 Tatsuhiro Tsujikawa + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ +/* copyright --> */ +#include "FtpTunnelResponseCommand.h" +#include "FtpNegotiationCommand.h" +#include "DlRetryEx.h" +#include "message.h" + +FtpTunnelResponseCommand::FtpTunnelResponseCommand(int cuid, Request* req, DownloadEngine* e, Socket* s):AbstractCommand(cuid, req, e, s) { + http = new HttpConnection(cuid, socket, req, e->option, e->logger); +} + +FtpTunnelResponseCommand::~FtpTunnelResponseCommand() { + delete http; +} + +bool FtpTunnelResponseCommand::executeInternal(Segment segment) { + HttpHeader headers; + int status = http->receiveResponse(headers); + if(status == 0) { + // we didn't receive all of headers yet. + e->commands.push(this); + return false; + } + if(status != 200) { + throw new DlRetryEx(EX_PROXY_CONNECTION_FAILED); + } + FtpNegotiationCommand* command = new FtpNegotiationCommand(cuid, req, e, socket); + e->commands.push(command); + return true; +} |
