Method ReceiveBodyWithChunks

net/http/client.cpp:289–340

For content data in chunks

    // For content data in chunks
    void ReceiveBodyWithChunks(char *begin, char *end, char* current)
    {
        std::string body;
        body.reserve(m_max_response_length);

        int buffer_length = end - current;
        while (begin < end) {
            size_t received = 0;

            *current = 0; // For the following strstr.
            char *p = strstr(begin, "\r\n");
            if (p != NULL) {
                int chunk_size = 0;
                if (sscanf(begin, "%x", &chunk_size) != 1) { // NOLINT(runtime/printf)
                    m_error_code = HttpClient::ERROR_FAIL_TO_READ_CHUNKSIZE;
                    return;
                }
                begin = p + 2;
                if (chunk_size == 0) {
                    // finish
                    m_response.MutableBody()->swap(body);
                    return;
                }

                chunk_size += 2; // "\r\n" is appended to the end of chunk
                int downloaded = current - begin;
                chunk_size = std::min(chunk_size, buffer_length);
                // if the downloaded content is not enough, download more.
                if (downloaded < chunk_size) {
                    size_t length = chunk_size - downloaded;
                    if (!m_connector.ReceiveAll(current, length, &received)) {
                        m_error_code = HttpClient::ERROR_FAIL_TO_GET_RESPONSE;
                        return;
                    }
                    current += received;
                    buffer_length -= received;
                }
                // remove this "\r\n"
                body.append(begin, chunk_size - 2);
                begin += chunk_size;
            } else {
                // there is not enough content to get a whole CHUNK header
                // download more data.
                if (!m_connector.Receive(current, buffer_length, &received)) {
                    m_error_code = HttpClient::ERROR_FAIL_TO_GET_RESPONSE;
                    return;
                }
                current += received;
                buffer_length -= received;
            }
        }
    }

    // Old HTTP servers will close connection after send response package
    void ReceiveBodyWithConnectionReset(char *begin, char *end, char* current)