Commit3b28e1e

committed

Fixed http::async_connection::write_first_line()

Use persistent buffer for boost::asio::async_write

1 parent5253bac commit3b28e1eCopy full SHA for 3b28e1e

File tree

-7

lines changed

-7

lines changed

Lines changed: 6 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -289,7 +289,7 @@ namespace boost { namespace network { namespace http {`
`289`	`289`	`Handler & handler;`
`290`	`290`	`utils::thread_pool & thread_pool_;`
`291`	`291`	`volatilebool headers_already_sent, first_line_already_sent, headers_in_progress, first_line_in_progress;`
`292`		`- asio::streambuf headers_buffer;`
	`292`	`+ asio::streambuf headers_buffer, first_line_buffer;`
`293`	`293`
`294`	`294`	`boost::recursive_mutex headers_mutex;`
`295`	`295`	`buffer_type read_buffer_;`
`@@ -525,19 +525,18 @@ namespace boost { namespace network { namespace http {`
`525`	`525`	`if (first_line_in_progress)return;`
`526`	`526`	`first_line_in_progress =true;`
`527`	`527`
`528`		`- std::vector<asio::const_buffer> buffers;`
`529`	`528`	`typedef constants<Tag> consts;`
`530`		`-typename ostringstream<Tag>::type first_line_stream;`
`531`		`- first_line_stream`
	`529`	`+ first_line_buffer.consume(first_line_buffer.size());`
	`530`	`+ std::ostreamfirst_line_stream(&first_line_buffer);`
	`531`	`+ first_line_stream`
`532`	`532`	`<<consts::http_slash() <<1<<consts::dot() <<1 <<consts::space()`
`533`	`533`	`<< status <<consts::space() <<status_message(status)`
`534`	`534`	`<<consts::crlf()`
	`535`	`+ << std::flush`
`535`	`536`	`;`
`536`		`- std::string first_line = first_line_stream.str();`
`537`		`- buffers.push_back(asio::buffer(first_line));`
`538`	`537`	`asio::async_write(`
`539`	`538`	`socket()`
`540`		`- ,buffers`
	`539`	`+ ,first_line_buffer`
`541`	`540`	`, callback);`
`542`	`541`	`}`
`543`	`542`

Comments

(0)