Commitf9ab8b3

authored and

committed

Fixed an issue with chunked content - client was expecting too many bytes and could block forever.

1 parent2ee4843 commitf9ab8b3Copy full SHA for f9ab8b3

File tree

-1

lines changed

-1

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -132,6 +132,7 @@ namespace boost { namespace network { namespace http { namespace impl {`
`132`	`132`	`bool stopping =false;`
`133`	`133`	`do {`
`134`	`134`	`std::size_t chunk_size_line =read_until(socket_, response_buffer,"\r\n", error);`
	`135`	`+ std::size_t tooMuchRead = response_buffer.size() - chunk_size_line;`
`135`	`136`	`if ((chunk_size_line ==0) && (error != boost::asio::error::eof))throwboost::system::system_error(error);`
`136`	`137`	`std::size_t chunk_size =0;`
`137`	`138`	`string_type data;`
`@@ -148,7 +149,8 @@ namespace boost { namespace network { namespace http { namespace impl {`
`148`	`149`	`}else {`
`149`	`150`	`bool stopping_inner =false;`
`150`	`151`	`do {`
`151`		`- std::size_t chunk_bytes_read =read(socket_, response_buffer,boost::asio::transfer_at_least(chunk_size +2), error);`
	`152`	`+assert( tooMuchRead <= chunk_size +2 );`
	`153`	`+ std::size_t chunk_bytes_read =read(socket_, response_buffer,boost::asio::transfer_at_least(chunk_size +2 - tooMuchRead), error);`
`152`	`154`	`if (chunk_bytes_read ==0) {`
`153`	`155`	`if (error != boost::asio::error::eof)throwboost::system::system_error(error);`
`154`	`156`	`stopping_inner =true;`

Comments

(0)