Open-Harbor/osrm-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

add some comments to reduce NCSS complexity

Browse Source
This commit is contained in:
Dennis Luxen 2014-06-03 10:49:25 +02:00
parent 8fda5a187b
commit a4689c7a27
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
Server/Connection.cpp
View File

@ -65,6 +65,7 @@ void Connection::handle_read(const boost::system::error_code &e, std::size_t byt
{ {
if (!e) if (!e)
{ {
// no error detected, let's parse the request
CompressionType compression_type(noCompression); CompressionType compression_type(noCompression);
boost::tribool result; boost::tribool result;
boost::tie(result, boost::tuples::ignore) = boost::tie(result, boost::tuples::ignore) =
@ -73,6 +74,7 @@ void Connection::handle_read(const boost::system::error_code &e, std::size_t byt
incoming_data_buffer.data() + bytes_transferred, incoming_data_buffer.data() + bytes_transferred,
&compression_type); &compression_type);
// the request has been parsed
if (result) if (result)
{ {
request.endpoint = TCP_socket.remote_endpoint().address(); request.endpoint = TCP_socket.remote_endpoint().address();
@ -82,6 +84,7 @@ void Connection::handle_read(const boost::system::error_code &e, std::size_t byt
std::vector<char> compressed_output; std::vector<char> compressed_output;
std::vector<boost::asio::const_buffer> output_buffer; std::vector<boost::asio::const_buffer> output_buffer;
// compress the result w/ gzip/deflate if requested
switch (compression_type) switch (compression_type)
{ {
case deflateRFC1951: case deflateRFC1951:
@ -127,7 +130,7 @@ void Connection::handle_read(const boost::system::error_code &e, std::size_t byt
} }
} }
else if (!result) else if (!result)
{ { // request is not parseable
reply = Reply::StockReply(Reply::badRequest); reply = Reply::StockReply(Reply::badRequest);
boost::asio::async_write(TCP_socket, boost::asio::async_write(TCP_socket,
@ -138,6 +141,7 @@ void Connection::handle_read(const boost::system::error_code &e, std::size_t byt
} }
else else
{ {
// we don't have a result yet, so continue reading
TCP_socket.async_read_some( TCP_socket.async_read_some(
boost::asio::buffer(incoming_data_buffer), boost::asio::buffer(incoming_data_buffer),
strand.wrap(boost::bind(&Connection::handle_read, strand.wrap(boost::bind(&Connection::handle_read,