/*
 * Copyright (C) NGINX, Inc.
 * Copyright (C) Valentin V. Bartenev
 */

#include <nxt_main.h>


typedef struct {
    nxt_str_t  method;
    nxt_str_t  target;
    nxt_str_t  exten;
    nxt_str_t  args;
    u_char     version[8];

    /* target with "/." */
    unsigned   complex_target:1;
    /* target with "%" */
    unsigned   quoted_target:1;
    /* target with " " */
    unsigned   space_in_target:1;
    /* target with "+" */
    unsigned   plus_in_target:1;
} nxt_http_parse_unit_test_request_line_t;


typedef union {
    void                                     *pointer;
    nxt_int_t                                result;
    nxt_http_parse_unit_test_request_line_t  request_line;
} nxt_http_parse_unit_test_data_t;


typedef struct {
    nxt_str_t  request;
    nxt_int_t  result;
    nxt_int_t  (*handler)(nxt_http_request_parse_t *rp,
                          nxt_http_parse_unit_test_data_t *data,
                          nxt_str_t *request, nxt_log_t *log);

    nxt_http_parse_unit_test_data_t  data;
} nxt_http_parse_unit_test_case_t;


static nxt_int_t nxt_http_parse_unit_test_run(nxt_http_request_parse_t *rp,
    nxt_str_t *request);
static nxt_int_t nxt_http_parse_unit_test_bench(nxt_thread_t *thr,
    nxt_str_t *request, nxt_http_fields_hash_t *hash, const char *name,
    nxt_uint_t n);
static nxt_int_t nxt_http_parse_unit_test_request_line(
    nxt_http_request_parse_t *rp, nxt_http_parse_unit_test_data_t *data,
    nxt_str_t *request, nxt_log_t *log);
static nxt_int_t nxt_http_parse_unit_test_fields(
    nxt_http_request_parse_t *rp, nxt_http_parse_unit_test_data_t *data,
    nxt_str_t *request, nxt_log_t *log);


static nxt_int_t nxt_http_unit_test_header_return(void *ctx,
    nxt_http_field_t *field, nxt_log_t *log);


static nxt_http_parse_unit_test_case_t  nxt_http_unit_test_cases[] = {
    {
        nxt_string("GET / HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/"),
            nxt_null_string,
            nxt_null_string,
            "HTTP/1.0",
            0, 0, 0, 0
        }}
    },
    {
        nxt_string("XXX-METHOD    /d.ir/fi+le.ext?key=val    HTTP/1.2\n\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("XXX-METHOD"),
            nxt_string("/d.ir/fi+le.ext?key=val"),
            nxt_string("ext?key=val"),
            nxt_string("key=val"),
            "HTTP/1.2",
            0, 0, 0, 1
        }}
    },
    {
        nxt_string("GET /di.r/? HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/di.r/?"),
            nxt_null_string,
            nxt_string(""),
            "HTTP/1.0",
            0, 0, 0, 0
        }}
    },
    {
        nxt_string("GEt / HTTP/1.0\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET /\0 HTTP/1.0\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET /\r HTTP/1.0\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET /\n HTTP/1.0\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.0\r\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET /. HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/."),
            nxt_null_string,
            nxt_null_string,
            "HTTP/1.0",
            1, 0, 0, 0
        }}
    },
    {
        nxt_string("GET /# HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/#"),
            nxt_null_string,
            nxt_null_string,
            "HTTP/1.0",
            1, 0, 0, 0
        }}
    },
    {
        nxt_string("GET /?# HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/?#"),
            nxt_null_string,
            nxt_string("#"),
            "HTTP/1.0",
            1, 0, 0, 0
        }}
    },
    {
        nxt_string("GET // HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("//"),
            nxt_null_string,
            nxt_null_string,
            "HTTP/1.0",
            1, 0, 0, 0
        }}
    },
    {
        nxt_string("GET /%20 HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/%20"),
            nxt_null_string,
            nxt_null_string,
            "HTTP/1.0",
            0, 1, 0, 0
        }}
    },
    {
        nxt_string("GET / a HTTP/1.0\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/ a"),
            nxt_null_string,
            nxt_null_string,
            "HTTP/1.0",
            0, 0, 1, 0
        }}
    },
    {
        nxt_string("GET / HTTP/1.0 HTTP/1.1\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_request_line,
        { .request_line = {
            nxt_string("GET"),
            nxt_string("/ HTTP/1.0"),
            nxt_null_string,
            nxt_null_string,
            "HTTP/1.1",
            0, 0, 1, 0
        }}
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Host: example.com\r\n\r\n"),
        NXT_DONE,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Host:\r\n\r\n"),
        NXT_DONE,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Host example.com\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   ":Host: example.com\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Ho_st: example.com\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Ho\0st: example.com\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Ho\rst: example.com\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Host: exa\0mple.com\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "Host: exa\rmple.com\r\n\r\n"),
        NXT_ERROR,
        NULL, { NULL }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "X-Unknown-Header: value\r\n"
                   "X-Good-Header: value\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_fields,
        { .result = NXT_OK }
    },
    {
        nxt_string("GET / HTTP/1.1\r\n"
                   "X-Good-Header: value\r\n"
                   "X-Unknown-Header: value\r\n"
                   "X-Bad-Header: value\r\n\r\n"),
        NXT_DONE,
        &nxt_http_parse_unit_test_fields,
        { .result = NXT_ERROR }
    },
};


static nxt_http_fields_hash_entry_t  nxt_http_unit_test_fields[] = {
    { nxt_string("X-Bad-Header"),
      &nxt_http_unit_test_header_return,
      (uintptr_t) NXT_ERROR },

    { nxt_string("X-Good-Header"),
      &nxt_http_unit_test_header_return,
      (uintptr_t) NXT_OK },

    { nxt_null_string, NULL, 0 }
};


static nxt_http_fields_hash_entry_t  nxt_http_unit_test_bench_fields[] = {
    { nxt_string("Host"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("User-Agent"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("Accept-Encoding"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("Accept-Language"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("Connection"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("Content-Length"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("Content-Type"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("If-Modified-Since"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("If-Match"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("Date"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("Upgrade"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("X-Forwarded-For"),
      &nxt_http_unit_test_header_return, NXT_OK },
    { nxt_string("X-Request-ID"),
      &nxt_http_unit_test_header_return, NXT_OK },

    { nxt_null_string, NULL, 0 }
};


static nxt_str_t nxt_http_unit_test_simple_request = nxt_string(
    "GET /page HTTP/1.1\r\n"
    "Host: example.com\r\n\r\n"
);


static nxt_str_t nxt_http_unit_test_big_request = nxt_string(
    "POST /path/to/very/interesting/article/on.this.site?arg1=value&arg2=value"
        "2&very_big_arg=even_bigger_value HTTP/1.1\r\n"
    "Host: www.example.com\r\n"
    "User-Agent: Mozilla/5.0 (X11; Gentoo Linux x86_64; rv:42.0) Firefox/42.0"
        "\r\n"
    "Accept: text/html,application/json,application/xml;q=0.9,*/*;q=0.8\r\n"
    "Accept-Language: ru-RU,ru;q=0.8,en-US;q=0.6,en;q=0.4\r\n"
    "Accept-Encoding: gzip, deflate, br\r\n"
    "If-Modified-Since: Wed, 31 Dec 1986 16:00:00 GMT\r\n"
    "Referer: https://example.org/path/to/not-interesting/article.html\r\n"
    "Cookie: name=value; name2=value2; some_big_cookie=iVBORw0KGgoAAAANSUhEUgA"
        "AAEAAAABACAMAAACdt4HsAAAABGdBTUEAALGPC/xhBQAAAAFzUkdCAK7OHOkAAABmelRY"
        "dFJhdyBwcm9maWxlIHR5cGUgZXhpZgAAeNptitsJgEAMBP9ThSWsZy6PcvKhcB1YvjEni"
        "ODAwjAs7ec4aCmkEXc1cREk7OwtUgyTFRA3BU+vFPjS7gUI/p46Q0u2fP/1B7oA1Scbwk"
        "nkf9gAAAAJcEhZcwAADsMAAA7DAcdvqGQAAACfUExURQwMDDw8PFBQUAICAhQUFAcHBxs"
        "bGxEREQkJCTk5OTU1NSAgIFRUVB8fH0xMTCUlJVtbW0pKSikpKS8vL0BAQEZGRjMzM2Bg"
        "YL6+vsDAwLS0tF1dXXJycrGxsWVlZWhoaKenp29vb6urq8TExHp6epSUlLu7u66urqOjo"
        "5ycnH9/f4CAgJOTk5qamo6OjoWFhYiIiHd3d8nJyc/Pz9LS0ojXP1QAAAihSURBVFjDZV"
        "eHdqM6EBUYEEh0EM3gCu41+/7/294dCSfZsxOHeM8yV3f6iGVGYohNEtJPGEjPiSLpMTz"
        "zokg8DmGOCOm/P0I6MTPaBGDPCGEYV3kEzchjzPOSPIkk8BzuM8fSCOFfALER+6MdpnaV"
        "55FMoOP7UliioK8QzpiT0Qv0Fl4lDJvFPwChETuHFjhw7vhRVcGAXDqcfhhnRaZUWeJTW"
        "pYVCBEYAJihtCsUpIhyq6win3ueDCoRBIknJRwACtz3AJhDYBhESsmyEjhaKv0MRJIIFR"
        "d4XyYqC1RWwQFeBF2CcApCmEFI2KwHTRIrsMq8UnYcRUkehKtlaGeq8BjowKHEQf7oEgH"
        "JcKRWpSeZpTIrs5dKlGX9fF7GfrtdWqDAuce1IyOtLbWyRKRYIIIPBo63gswO07q20/p6"
        "2txvj+flvUZUZeQ4IODBGDoYivoReREzugaAJKuX637dP0/DbnMGwuWyTTNlBYX0ItL3E"
        "q2ptUmYZi9+ANLt9r2+nrqmORKD1/W9Xi3hirisEumQOz+qRv5hUL/H1bg7tG0znKbHCy"
        "Zs16u6TgmiQH5rLW2Ltslhf6kjO1bjOJ4PTfu1PwDgeR0BsF6BBCBQIThee+P78QvAQNS"
        "X17mD/tfXYaMBejAAhWWahqoiB5q8dmYQ9rc+AF7Trmn2BLC7vy4XQ0ADpHZmJRQPznVO"
        "0YcABJRnBwBg+Tofm3a//2q7zYREIAAyAQRQQKqAJ/ksH4CPC4wJy9uma2eA2+syjtsVn"
        "LicKzDTRYaqMgi/AQyHQNSPY0uyb7vdHVEcezDQBhAHJXLPqLOZxN8+CLJVehmapoUX2u"
        "54okzsIXACucAOYyunov62AUDiN0IQd69+dyAf7PfdsLlRGAGwXekowIgySRzoMzZzcAj"
        "gpxIs9Ti+TsTghLMvV1Lfbvt+vbTR9ZAJtlWoXxSIwaxuohCUt8Pp3LTd+XHt01KF9XZL"
        "iRhXkSwKCzYg7X2NwGYYJsRvCHU6nndNO3SH4TauV9v3OK7rUKHnUJaiTxRl4XODwD8mC"
        "Gptn0Q8j1e4oOmmfi0iZY/naRuWaIyiNI1bxDljs/7M4Hcxlta9fzTd/qubrrdYpNZ2GL"
        "ZxgJboFkmFVhGLLPE/6ubPp5nNTphOAGj/QHavtZ292t3KLouiQocqbXhRKOlr+/9hoA0"
        "og/d+dzi0/+2b7nTr60vXbtZhJkQZx2GaLsNMxZ8ozk5gphN/M4i79nBo/uwHdJPn1Db7"
        "c40aUgoDRVdTmhn3awbsXxOs4PZfc2i+vrrTNCEe+/0JnTmkoZOiJcT2co4i5z9hnHu6Z"
        "bxoT7sWAM3mfp9O7Vd7rnUV6E8ap2lk/MdmJzD2eyRohKrf4+DmON2ej6HZ31epnnqpLg"
        "ZV8dmFMw6fB0vww0Gs903ToJaviOifdnrXS6SxhgjjxNEF9BH6VlUVMKqf+STqPTLpeHr"
        "0l2HYHaYeHohVZiOIYUYjhjHfx0cLAHI96Qrzi4BXeYxiRi94PjeH4/k8xshgO8u0HYoI"
        "EIDvQgzEPOJIaGAlSSQQye54nzbH3Wb3wFSJ9SJAi0XAZ33NwXUXC5dJFIRHvZo7n0Z3J"
        "oDNaYef0zVd2bFZJjDzEmhByWfQ8bi/gDDpuz7NCa4RidhivT90w7B51tfXpV+F2CVEqd"
        "eamC+gj5cYznSYawCYwSPvEIbP3ArqXXdeXze3MUUNBJbSAGHgGuOZ7maazAfAoXnnaP8"
        "yN9kdj8fhjPY8TNt6FWchDTbsVB4s196jANI3XwNQPPXM9LSLmZ/Ae0f8nuGC2lhPK5md"
        "++zbh76B8V0Wmaz0aOB7epHy5XA4b3ZIgt1puvYYrCkaQZyhCrjZ1ehw+B//An2skMYLh"
        "GDCXB3b43Q6dhSL+7NHQ0YZYW3yyVfgyUwoOI1WABje3IkkBRMHRPmmPWxupyM4nF/jek"
        "mrp8pSSSqap++aSADA1ZuTtsLTewPgKmfadx2q8YwNZVwhDzJVZnbGfEcDOB8A/Y1wDAV"
        "iRxtHVLF321EiTJf3u0b+osLgglyTximcUQr6NJ2ZvwDAxwa9ejg8l7wcDsOAZLptwzgr"
        "LUXLdOC5nF5yPi6giFAYsbTwbwQHcRCejFCHA/lwwoZFZRBjvZlbGJ4mGylj8E27giJDo"
        "SQCsvJyR702xwGz8X5dp7qSMuy7lGcmhBrB13XxC8Asw7zIueBJ/brvEINHvzRLeSmS3C"
        "SfTgHDwaXKIOd5c4/RoYzrRHiOtbpOm8391dNuhXW3rECBzwC+qWQS+IAZABSBE+VoJzV"
        "6P+e5Wl9u9wlZRJtNjEXTLq1INwHdhvxZH9GkcFI8HFqAsWDLhYw5k0W8Hl8Y0fUSFxBs"
        "9CquLGFKQBfcDODPrQGPnPpRlADAiZEMCVb1/r0lAkjD0kq9xSJnmj/7NoEiYUxAElOOA"
        "SMoFgwAUhbKpnmANhTTFSXD+x6jEjJm+CaUXIdfJhFuN3RLy3GbcBcqYjJPKH8QwGWdod"
        "nbEgqOMQD6xpXQJ/fjelXlgKU9vghk4S0KwZIC15YSvXjZ15awslAHzP00008iUEE7oC4"
        "r7nKHerJAl18gGRGPAMwzez2GVpmFFhEAAKOe5CN6ZL6v0znPpVcluBMyj2ZDHhWLhciT"
        "Ctq4UKb9uIIfV3ChqzvJpxvpWBIeAOheSXQ8ZEEig2DhyjyqSqVoJ9j2W0y2knLW16dCd"
        "6EjyQ0a/E23IDDwowJ5IFJsMzJaRAEoxOFy1S+tXDAAcMdlxoP4w7UtnABQe0nhUa1HES"
        "5kVennooC/WWEpANRLK4mYjplkcy/ViU+n627I8gjXIJ9L5APiCDYiqFD7IIYLWKoKySj"
        "lUXleNM9TzcSfdxRGqlKijGALtTVJA7bgi0RVRaByyhjqP1S73BxPyjoeM47LPRqvVInU"
        "cvGoCit3GRpZ5VC0XZ1zpg6pb1AqLAhDD8L/AcHH1p8sEFAHAAAAAElFTkSuQmCC\r\n"
    "Connection: keep-alive\r\n"
    "Content-Length: 0\r\n"
    "Upgrade-Insecure-Requests: 1\r\n"
    "Pragma: no-cache\r\n"
    "Cache-Control: no-cache\r\n"
    "X-Forwarded-For: 192.0.2.0, 198.51.100.0, 203.0.113.0\r\n"
    "\r\n"
);


nxt_int_t
nxt_http_parse_unit_test(nxt_thread_t *thr)
{
    nxt_mp_t                         *mp, *mp_temp;
    nxt_int_t                        rc;
    nxt_uint_t                       i;
    nxt_http_fields_hash_t           *hash;
    nxt_http_request_parse_t         rp;
    nxt_http_parse_unit_test_case_t  *test;

    nxt_thread_time_update(thr);

    mp = nxt_mp_create(1024, 128, 256, 32);
    if (mp == NULL) {
        return NXT_ERROR;
    }

    hash = nxt_http_fields_hash_create(nxt_http_unit_test_fields, mp);
    if (hash == NULL) {
        return NXT_ERROR;
    }

    for (i = 0; i < nxt_nitems(nxt_http_unit_test_cases); i++) {
        test = &nxt_http_unit_test_cases[i];

        nxt_memzero(&rp, sizeof(nxt_http_request_parse_t));

        mp_temp = nxt_mp_create(1024, 128, 256, 32);
        if (mp_temp == NULL) {
            return NXT_ERROR;
        }

        if (nxt_http_parse_request_init(&rp, mp_temp) != NXT_OK) {
            return NXT_ERROR;
        }

        rp.fields_hash = hash;

        rc = nxt_http_parse_unit_test_run(&rp, &test->request);

        if (rc != test->result) {
            nxt_log_alert(thr->log, "http parse unit test case failed:\n"
                                    " - request:\n\"%V\"\n"
                                    " - result: %i (expected: %i)",
                                    &test->request, rc, test->result);
            return NXT_ERROR;
        }

        if (test->handler != NULL
            && test->handler(&rp, &test->data, &test->request, thr->log)
               != NXT_OK)
        {
            return NXT_ERROR;
        }

        nxt_mp_destroy(mp_temp);
    }

    nxt_log_error(NXT_LOG_NOTICE, thr->log, "http parse unit test passed");

    hash = nxt_http_fields_hash_create(nxt_http_unit_test_bench_fields, mp);
    if (hash == NULL) {
        return NXT_ERROR;
    }

    if (nxt_http_parse_unit_test_bench(thr, &nxt_http_unit_test_simple_request,
                                       hash, "simple", 10000000)
        != NXT_OK)
    {
        return NXT_ERROR;
    }

    if (nxt_http_parse_unit_test_bench(thr, &nxt_http_unit_test_big_request,
                                       hash, "big", 100000)
        != NXT_OK)
    {
        return NXT_ERROR;
    }

    nxt_mp_destroy(mp);

    return NXT_OK;
}


static nxt_int_t
nxt_http_parse_unit_test_run(nxt_http_request_parse_t *rp, nxt_str_t *request)
{
    nxt_int_t      rc;
    nxt_buf_mem_t  buf;

    buf.start = request->start;
    buf.end = request->start + request->length;

    buf.pos = buf.start;
    buf.free = buf.pos + 1;

    do {
        buf.free++;
        rc = nxt_http_parse_request(rp, &buf);
    } while (buf.free < buf.end && rc == NXT_AGAIN);

    return rc;
}


static nxt_int_t
nxt_http_parse_unit_test_bench(nxt_thread_t *thr, nxt_str_t *request,
    nxt_http_fields_hash_t *hash, const char *name, nxt_uint_t n)
{
    nxt_mp_t                  *mp;
    nxt_nsec_t                start, end;
    nxt_uint_t                i;
    nxt_buf_mem_t             buf;
    nxt_http_request_parse_t  rp;

    nxt_log_error(NXT_LOG_NOTICE, thr->log,
                  "http parse unit %s request bench started: "
                  "%uz bytes, %ui runs",
                  name, request->length, n);

    buf.start = request->start;
    buf.end = request->start + request->length;

    nxt_thread_time_update(thr);
    start = nxt_thread_monotonic_time(thr);

    for (i = 0; nxt_fast_path(i < n); i++) {
        nxt_memzero(&rp, sizeof(nxt_http_request_parse_t));

        mp = nxt_mp_create(1024, 128, 256, 32);
        if (nxt_slow_path(mp == NULL)) {
            return NXT_ERROR;
        }

        if (nxt_slow_path(nxt_http_parse_request_init(&rp, mp) != NXT_OK)) {
            return NXT_ERROR;
        }

        rp.fields_hash = hash;

        buf.pos = buf.start;
        buf.free = buf.end;

        if (nxt_slow_path(nxt_http_parse_request(&rp, &buf) != NXT_DONE)) {
            nxt_log_alert(thr->log, "http parse unit %s request bench failed "
                                    "while parsing", name);
            return NXT_ERROR;
        }

        if (nxt_slow_path(nxt_http_fields_process(rp.fields, NULL, thr->log)
                          != NXT_OK))
        {
            nxt_log_alert(thr->log, "http parse unit %s request bench failed "
                                    "while fields processing", name);
            return NXT_ERROR;
        }

        nxt_mp_destroy(mp);
    }

    nxt_thread_time_update(thr);
    end = nxt_thread_monotonic_time(thr);

    nxt_log_error(NXT_LOG_NOTICE, thr->log,
                  "http parse unit %s request bench: %0.3fs",
                  name, (end - start) / 1000000000.0);

    return NXT_OK;
}


static nxt_int_t
nxt_http_parse_unit_test_request_line(nxt_http_request_parse_t *rp,
    nxt_http_parse_unit_test_data_t *data, nxt_str_t *request, nxt_log_t *log)
{
    nxt_str_t  str;

    nxt_http_parse_unit_test_request_line_t  *test = &data->request_line;

    if (rp->method.start != test->method.start
        && !nxt_strstr_eq(&rp->method, &test->method))
    {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - method: \"%V\" (expected: \"%V\")",
                           request, &rp->method, &test->method);
        return NXT_ERROR;
    }

    str.length = rp->target_end - rp->target_start;
    str.start = rp->target_start;

    if (str.start != test->target.start
        && !nxt_strstr_eq(&str, &test->target))
    {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                            " - request:\n\"%V\"\n"
                            " - target: \"%V\" (expected: \"%V\")",
                            request, &str, &test->target);
        return NXT_ERROR;
    }

    str.length = (rp->exten_start != NULL) ? rp->target_end - rp->exten_start
                                           : 0;
    str.start = rp->exten_start;

    if (str.start != test->exten.start
        && !nxt_strstr_eq(&str, &test->exten))
    {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - exten: \"%V\" (expected: \"%V\")",
                           request, &str, &test->exten);
        return NXT_ERROR;
    }

    str.length = (rp->args_start != NULL) ? rp->target_end - rp->args_start
                                          : 0;
    str.start = rp->args_start;

    if (str.start != test->args.start
        && !nxt_strstr_eq(&str, &test->args))
    {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - args: \"%V\" (expected: \"%V\")",
                           request, &str, &test->args);
        return NXT_ERROR;
    }

    if (nxt_memcmp(rp->version.str, test->version, 8) != 0) {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - version: \"%*s\" (expected: \"%*s\")",
                           request, 8, rp->version.str, 8, test->version);
        return NXT_ERROR;
    }

    if (rp->complex_target != test->complex_target) {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - complex_target: %d (expected: %d)",
                           request, rp->complex_target, test->complex_target);
        return NXT_ERROR;
    }

    if (rp->quoted_target != test->quoted_target) {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - quoted_target: %d (expected: %d)",
                           request, rp->quoted_target, test->quoted_target);
        return NXT_ERROR;
    }

    if (rp->space_in_target != test->space_in_target) {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - space_in_target: %d (expected: %d)",
                           request, rp->space_in_target, test->space_in_target);
        return NXT_ERROR;
    }

    if (rp->plus_in_target != test->plus_in_target) {
        nxt_log_alert(log, "http parse unit test case failed:\n"
                           " - request:\n\"%V\"\n"
                           " - plus_in_target: %d (expected: %d)",
                           request, rp->plus_in_target, test->plus_in_target);
        return NXT_ERROR;
    }

    return NXT_OK;
}


static nxt_int_t
nxt_http_parse_unit_test_fields(nxt_http_request_parse_t *rp,
    nxt_http_parse_unit_test_data_t *data, nxt_str_t *request, nxt_log_t *log)
{
    nxt_int_t  rc;

    rc = nxt_http_fields_process(rp->fields, NULL, log);

    if (rc != data->result) {
        nxt_log_alert(log, "http parse unit test hash failed:\n"
                           " - request:\n\"%V\"\n"
                           " - result: %i (expected: %i)",
                           request, rc, data->result);
        return NXT_ERROR;
    }

    return NXT_OK;
}


static nxt_int_t
nxt_http_unit_test_header_return(void *ctx, nxt_http_field_t *field,
    nxt_log_t *log)
{
    return (nxt_int_t) field->data;
}