github
/
aria2
mirror of https://github.com/aria2/aria2
1
0
Fork 0
Code Issues Releases Wiki Activity

2010-01-06 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net> 

Pool connection if _contentEncodingDecoder is used and server
	supports persistent connection.
	* src/HttpDownloadCommand.cc
pull/1/head
Tatsuhiro Tsujikawa 2010-01-06 13:02:10 +00:00
parent f6a3ca0b1e
commit e237a6ebda
2 changed files with 22 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ChangeLog
View File

@ -1,3 +1,9 @@
2010-01-06 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Pool connection if _contentEncodingDecoder is used and server
supports persistent connection.
* src/HttpDownloadCommand.cc
2010-01-06 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net> 2010-01-06 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Updated doc. Updated doc.

17
src/HttpDownloadCommand.cc
View File

@ -47,6 +47,7 @@
#include "HttpHeader.h" #include "HttpHeader.h"
#include "Range.h" #include "Range.h"
#include "DownloadContext.h" #include "DownloadContext.h"
#include "Decoder.h"
namespace aria2 { namespace aria2 {
@ -82,9 +83,21 @@ bool HttpDownloadCommand::prepareForNextSegment() {
} else { } else {
if(req->isPipeliningEnabled() || if(req->isPipeliningEnabled() ||
(req->isKeepAliveEnabled() && (req->isKeepAliveEnabled() &&
(
((!_transferEncodingDecoder.isNull() && ((!_transferEncodingDecoder.isNull() &&
_requestGroup->downloadFinished()) || _transferEncodingDecoder->finished()) ||
_fileEntry->getLastOffset() == _segments.front()->getPositionToWrite()))) { (!_contentEncodingDecoder.isNull() &&
_contentEncodingDecoder->finished())) ||
_fileEntry->getLastOffset() ==
_segments.front()->getPositionToWrite()
)
)
) {
// TODO What if server sends EOF when _contentEncodingDecoder is
// used and server didn't send Connection: close? We end up to
// pool terminated socket. In HTTP/1.1, keep-alive is default,
// so closing connection without Connection: close header means
// that server is broken or not configured properly.
e->poolSocket(req, isProxyDefined(), socket); e->poolSocket(req, isProxyDefined(), socket);
} }
// The request was sent assuming that server supported pipelining, but // The request was sent assuming that server supported pipelining, but