1 2 /* 3 * Copyright (C) NGINX, Inc. 4 * Copyright (C) Valentin V. Bartenev 5 */ 6 7 #include <nxt_main.h> 8 #include "nxt_tests.h" 9 10 11 typedef struct { 12 nxt_str_t method; 13 nxt_str_t target; 14 nxt_str_t exten; 15 nxt_str_t args; 16 u_char version[8]; 17 18 /* target with "/." */ 19 unsigned complex_target:1; 20 /* target with "%" */ 21 unsigned quoted_target:1; 22 /* target with " " */ 23 unsigned space_in_target:1; 24 /* target with "+" */ 25 unsigned plus_in_target:1; 26 } nxt_http_parse_test_request_line_t; 27 28 29 typedef union { 30 void *pointer; 31 nxt_int_t result; 32 nxt_http_parse_test_request_line_t request_line; 33 } nxt_http_parse_test_data_t; 34 35 36 typedef struct { 37 nxt_str_t request; 38 nxt_int_t result; 39 nxt_int_t (*handler)(nxt_http_request_parse_t *rp, 40 nxt_http_parse_test_data_t *data, 41 nxt_str_t *request, nxt_log_t *log); 42 43 nxt_http_parse_test_data_t data; 44 } nxt_http_parse_test_case_t; 45 46 47 static nxt_int_t nxt_http_parse_test_run(nxt_http_request_parse_t *rp, 48 nxt_str_t *request); 49 static nxt_int_t nxt_http_parse_test_bench(nxt_thread_t *thr, 50 nxt_str_t *request, nxt_lvlhsh_t *hash, const char *name, nxt_uint_t n); 51 static nxt_int_t nxt_http_parse_test_request_line(nxt_http_request_parse_t *rp, 52 nxt_http_parse_test_data_t *data, 53 nxt_str_t *request, nxt_log_t *log); 54 static nxt_int_t nxt_http_parse_test_fields(nxt_http_request_parse_t *rp, 55 nxt_http_parse_test_data_t *data, nxt_str_t *request, nxt_log_t *log); 56 57 58 static nxt_int_t nxt_http_test_header_return(void *ctx, nxt_http_field_t *field, 59 uintptr_t data); 60 61 62 static nxt_http_parse_test_case_t nxt_http_test_cases[] = { 63 { 64 nxt_string("GET / HTTP/1.0\r\n\r\n"), 65 NXT_DONE, 66 &nxt_http_parse_test_request_line, 67 { .request_line = { 68 nxt_string("GET"), 69 nxt_string("/"), 70 nxt_null_string, 71 nxt_null_string, 72 "HTTP/1.0", 73 0, 0, 0, 0 74 }} 75 }, 76 { 77 nxt_string("XXX-METHOD /d.ir/fi+le.ext?key=val HTTP/1.2\n\n"), 78 NXT_DONE, 79 &nxt_http_parse_test_request_line, 80 { .request_line = { 81 nxt_string("XXX-METHOD"), 82 nxt_string("/d.ir/fi+le.ext?key=val"), 83 nxt_string("ext?key=val"), 84 nxt_string("key=val"), 85 "HTTP/1.2", 86 0, 0, 0, 1 87 }} 88 }, 89 { 90 nxt_string("GET /di.r/? HTTP/1.0\r\n\r\n"), 91 NXT_DONE, 92 &nxt_http_parse_test_request_line, 93 { .request_line = { 94 nxt_string("GET"), 95 nxt_string("/di.r/?"), 96 nxt_null_string, 97 nxt_string(""), 98 "HTTP/1.0", 99 0, 0, 0, 0 100 }} 101 }, 102 { 103 nxt_string("GEt / HTTP/1.0\r\n\r\n"), 104 NXT_HTTP_PARSE_INVALID, 105 NULL, { NULL } 106 }, 107 { 108 nxt_string("GET /\0 HTTP/1.0\r\n\r\n"), 109 NXT_HTTP_PARSE_INVALID, 110 NULL, { NULL } 111 }, 112 { 113 nxt_string("GET /\r HTTP/1.0\r\n\r\n"), 114 NXT_HTTP_PARSE_INVALID, 115 NULL, { NULL } 116 }, 117 { 118 nxt_string("GET /\n HTTP/1.0\r\n\r\n"), 119 NXT_HTTP_PARSE_INVALID, 120 NULL, { NULL } 121 }, 122 { 123 nxt_string("GET / HTTP/1.0\r\r\n"), 124 NXT_HTTP_PARSE_INVALID, 125 NULL, { NULL } 126 }, 127 { 128 nxt_string("GET / HTTP/2.0\r\n"), 129 NXT_HTTP_PARSE_UNSUPPORTED_VERSION, 130 NULL, { NULL } 131 }, 132 { 133 nxt_string("GET /. HTTP/1.0\r\n\r\n"), 134 NXT_DONE, 135 &nxt_http_parse_test_request_line, 136 { .request_line = { 137 nxt_string("GET"), 138 nxt_string("/."), 139 nxt_null_string, 140 nxt_null_string, 141 "HTTP/1.0", 142 1, 0, 0, 0 143 }} 144 }, 145 { 146 nxt_string("GET /# HTTP/1.0\r\n\r\n"), 147 NXT_DONE, 148 &nxt_http_parse_test_request_line, 149 { .request_line = { 150 nxt_string("GET"), 151 nxt_string("/#"), 152 nxt_null_string, 153 nxt_null_string, 154 "HTTP/1.0", 155 1, 0, 0, 0 156 }} 157 }, 158 { 159 nxt_string("GET /?# HTTP/1.0\r\n\r\n"), 160 NXT_DONE, 161 &nxt_http_parse_test_request_line, 162 { .request_line = { 163 nxt_string("GET"), 164 nxt_string("/?#"), 165 nxt_null_string, 166 nxt_string("#"), 167 "HTTP/1.0", 168 1, 0, 0, 0 169 }} 170 }, 171 { 172 nxt_string("GET // HTTP/1.0\r\n\r\n"), 173 NXT_DONE, 174 &nxt_http_parse_test_request_line, 175 { .request_line = { 176 nxt_string("GET"), 177 nxt_string("//"), 178 nxt_null_string, 179 nxt_null_string, 180 "HTTP/1.0", 181 1, 0, 0, 0 182 }} 183 }, 184 { 185 nxt_string("GET /%20 HTTP/1.0\r\n\r\n"), 186 NXT_DONE, 187 &nxt_http_parse_test_request_line, 188 { .request_line = { 189 nxt_string("GET"), 190 nxt_string("/%20"), 191 nxt_null_string, 192 nxt_null_string, 193 "HTTP/1.0", 194 0, 1, 0, 0 195 }} 196 }, 197 { 198 nxt_string("GET / a HTTP/1.0\r\n\r\n"), 199 NXT_DONE, 200 &nxt_http_parse_test_request_line, 201 { .request_line = { 202 nxt_string("GET"), 203 nxt_string("/ a"), 204 nxt_null_string, 205 nxt_null_string, 206 "HTTP/1.0", 207 0, 0, 1, 0 208 }} 209 }, 210 { 211 nxt_string("GET / HTTP/1.0 HTTP/1.1\r\n\r\n"), 212 NXT_DONE, 213 &nxt_http_parse_test_request_line, 214 { .request_line = { 215 nxt_string("GET"), 216 nxt_string("/ HTTP/1.0"), 217 nxt_null_string, 218 nxt_null_string, 219 "HTTP/1.1", 220 0, 0, 1, 0 221 }} 222 }, 223 { 224 nxt_string("GET / HTTP/1.1\r\n" 225 "Host: example.com\r\n\r\n"), 226 NXT_DONE, 227 NULL, { NULL } 228 }, 229 { 230 nxt_string("GET / HTTP/1.1\r\n" 231 "Host:\r\n\r\n"), 232 NXT_DONE, 233 NULL, { NULL } 234 }, 235 { 236 nxt_string("GET / HTTP/1.1\r\n" 237 "Host example.com\r\n\r\n"), 238 NXT_HTTP_PARSE_INVALID, 239 NULL, { NULL } 240 }, 241 { 242 nxt_string("GET / HTTP/1.1\r\n" 243 ":Host: example.com\r\n\r\n"), 244 NXT_HTTP_PARSE_INVALID, 245 NULL, { NULL } 246 }, 247 { 248 nxt_string("GET / HTTP/1.1\r\n" 249 "Ho_st: example.com\r\n\r\n"), 250 NXT_DONE, 251 NULL, { NULL } 252 }, 253 { 254 nxt_string("GET / HTTP/1.1\r\n" 255 "Ho\0st: example.com\r\n\r\n"), 256 NXT_HTTP_PARSE_INVALID, 257 NULL, { NULL } 258 }, 259 { 260 nxt_string("GET / HTTP/1.1\r\n" 261 "Ho\rst: example.com\r\n\r\n"), 262 NXT_HTTP_PARSE_INVALID, 263 NULL, { NULL } 264 }, 265 { 266 nxt_string("GET / HTTP/1.1\r\n" 267 "Host: exa\0mple.com\r\n\r\n"), 268 NXT_HTTP_PARSE_INVALID, 269 NULL, { NULL } 270 }, 271 { 272 nxt_string("GET / HTTP/1.1\r\n" 273 "Host: exa\rmple.com\r\n\r\n"), 274 NXT_HTTP_PARSE_INVALID, 275 NULL, { NULL } 276 }, 277 { 278 nxt_string("GET / HTTP/1.1\r\n" 279 "X-Unknown-Header: value\r\n" 280 "X-Good-Header: value\r\n\r\n"), 281 NXT_DONE, 282 &nxt_http_parse_test_fields, 283 { .result = NXT_OK } 284 }, 285 { 286 nxt_string("GET / HTTP/1.1\r\n" 287 "X-Good-Header: value\r\n" 288 "X-Unknown-Header: value\r\n" 289 "X-Bad-Header: value\r\n\r\n"), 290 NXT_DONE, 291 &nxt_http_parse_test_fields, 292 { .result = NXT_ERROR } 293 }, 294 }; 295 296 297 static nxt_http_field_proc_t nxt_http_test_fields[] = { 298 { nxt_string("X-Bad-Header"), 299 &nxt_http_test_header_return, 300 NXT_ERROR }, 301 302 { nxt_string("X-Good-Header"), 303 &nxt_http_test_header_return, 304 NXT_OK }, 305 }; 306 307 308 static nxt_lvlhsh_t nxt_http_test_fields_hash; 309 310 311 static nxt_http_field_proc_t nxt_http_test_bench_fields[] = { 312 { nxt_string("Host"), 313 &nxt_http_test_header_return, NXT_OK }, 314 { nxt_string("User-Agent"), 315 &nxt_http_test_header_return, NXT_OK }, 316 { nxt_string("Accept"), 317 &nxt_http_test_header_return, NXT_OK }, 318 { nxt_string("Accept-Encoding"), 319 &nxt_http_test_header_return, NXT_OK }, 320 { nxt_string("Accept-Language"), 321 &nxt_http_test_header_return, NXT_OK }, 322 { nxt_string("Connection"), 323 &nxt_http_test_header_return, NXT_OK }, 324 { nxt_string("Content-Length"), 325 &nxt_http_test_header_return, NXT_OK }, 326 { nxt_string("Content-Range"), 327 &nxt_http_test_header_return, NXT_OK }, 328 { nxt_string("Content-Type"), 329 &nxt_http_test_header_return, NXT_OK }, 330 { nxt_string("Cookie"), 331 &nxt_http_test_header_return, NXT_OK }, 332 { nxt_string("Range"), 333 &nxt_http_test_header_return, NXT_OK }, 334 { nxt_string("If-Range"), 335 &nxt_http_test_header_return, NXT_OK }, 336 { nxt_string("Transfer-Encoding"), 337 &nxt_http_test_header_return, NXT_OK }, 338 { nxt_string("Expect"), 339 &nxt_http_test_header_return, NXT_OK }, 340 { nxt_string("Via"), 341 &nxt_http_test_header_return, NXT_OK }, 342 { nxt_string("If-Modified-Since"), 343 &nxt_http_test_header_return, NXT_OK }, 344 { nxt_string("If-Unmodified-Since"), 345 &nxt_http_test_header_return, NXT_OK }, 346 { nxt_string("If-Match"), 347 &nxt_http_test_header_return, NXT_OK }, 348 { nxt_string("If-None-Match"), 349 &nxt_http_test_header_return, NXT_OK }, 350 { nxt_string("Referer"), 351 &nxt_http_test_header_return, NXT_OK }, 352 { nxt_string("Date"), 353 &nxt_http_test_header_return, NXT_OK }, 354 { nxt_string("Upgrade"), 355 &nxt_http_test_header_return, NXT_OK }, 356 { nxt_string("Authorization"), 357 &nxt_http_test_header_return, NXT_OK }, 358 { nxt_string("Keep-Alive"), 359 &nxt_http_test_header_return, NXT_OK }, 360 { nxt_string("X-Forwarded-For"), 361 &nxt_http_test_header_return, NXT_OK }, 362 { nxt_string("X-Forwarded-Host"), 363 &nxt_http_test_header_return, NXT_OK }, 364 { nxt_string("X-Forwarded-Proto"), 365 &nxt_http_test_header_return, NXT_OK }, 366 { nxt_string("X-Http-Method-Override"), 367 &nxt_http_test_header_return, NXT_OK }, 368 { nxt_string("X-Real-IP"), 369 &nxt_http_test_header_return, NXT_OK }, 370 { nxt_string("X-Request-ID"), 371 &nxt_http_test_header_return, NXT_OK }, 372 { nxt_string("TE"), 373 &nxt_http_test_header_return, NXT_OK }, 374 { nxt_string("Pragma"), 375 &nxt_http_test_header_return, NXT_OK }, 376 { nxt_string("Cache-Control"), 377 &nxt_http_test_header_return, NXT_OK }, 378 { nxt_string("Origin"), 379 &nxt_http_test_header_return, NXT_OK }, 380 { nxt_string("Upgrade-Insecure-Requests"), 381 &nxt_http_test_header_return, NXT_OK }, 382 }; 383 384 385 static nxt_str_t nxt_http_test_simple_request = nxt_string( 386 "GET /page HTTP/1.1\r\n" 387 "Host: example.com\r\n\r\n" 388 ); 389 390 391 static nxt_str_t nxt_http_test_big_request = nxt_string( 392 "POST /path/to/very/interesting/article/on.this.site?arg1=value&arg2=value" 393 "2&very_big_arg=even_bigger_value HTTP/1.1\r\n" 394 "Host: www.example.com\r\n" 395 "User-Agent: Mozilla/5.0 (X11; Gentoo Linux x86_64; rv:42.0) Firefox/42.0" 396 "\r\n" 397 "Accept: text/html,application/json,application/xml;q=0.9,*/*;q=0.8\r\n" 398 "Accept-Language: ru-RU,ru;q=0.8,en-US;q=0.6,en;q=0.4\r\n" 399 "Accept-Encoding: gzip, deflate, br\r\n" 400 "If-Modified-Since: Wed, 31 Dec 1986 16:00:00 GMT\r\n" 401 "Referer: https://example.org/path/to/not-interesting/article.html\r\n" 402 "Cookie: name=value; name2=value2; some_big_cookie=iVBORw0KGgoAAAANSUhEUgA" 403 "AAEAAAABACAMAAACdt4HsAAAABGdBTUEAALGPC/xhBQAAAAFzUkdCAK7OHOkAAABmelRY" 404 "dFJhdyBwcm9maWxlIHR5cGUgZXhpZgAAeNptitsJgEAMBP9ThSWsZy6PcvKhcB1YvjEni" 405 "ODAwjAs7ec4aCmkEXc1cREk7OwtUgyTFRA3BU+vFPjS7gUI/p46Q0u2fP/1B7oA1Scbwk" 406 "nkf9gAAAAJcEhZcwAADsMAAA7DAcdvqGQAAACfUExURQwMDDw8PFBQUAICAhQUFAcHBxs" 407 "bGxEREQkJCTk5OTU1NSAgIFRUVB8fH0xMTCUlJVtbW0pKSikpKS8vL0BAQEZGRjMzM2Bg" 408 "YL6+vsDAwLS0tF1dXXJycrGxsWVlZWhoaKenp29vb6urq8TExHp6epSUlLu7u66urqOjo" 409 "5ycnH9/f4CAgJOTk5qamo6OjoWFhYiIiHd3d8nJyc/Pz9LS0ojXP1QAAAihSURBVFjDZV" 410 "eHdqM6EBUYEEh0EM3gCu41+/7/294dCSfZsxOHeM8yV3f6iGVGYohNEtJPGEjPiSLpMTz" 411 "zokg8DmGOCOm/P0I6MTPaBGDPCGEYV3kEzchjzPOSPIkk8BzuM8fSCOFfALER+6MdpnaV" 412 "55FMoOP7UliioK8QzpiT0Qv0Fl4lDJvFPwChETuHFjhw7vhRVcGAXDqcfhhnRaZUWeJTW" 413 "pYVCBEYAJihtCsUpIhyq6win3ueDCoRBIknJRwACtz3AJhDYBhESsmyEjhaKv0MRJIIFR" 414 "d4XyYqC1RWwQFeBF2CcApCmEFI2KwHTRIrsMq8UnYcRUkehKtlaGeq8BjowKHEQf7oEgH" 415 "JcKRWpSeZpTIrs5dKlGX9fF7GfrtdWqDAuce1IyOtLbWyRKRYIIIPBo63gswO07q20/p6" 416 "2txvj+flvUZUZeQ4IODBGDoYivoReREzugaAJKuX637dP0/DbnMGwuWyTTNlBYX0ItL3E" 417 "q2ptUmYZi9+ANLt9r2+nrqmORKD1/W9Xi3hirisEumQOz+qRv5hUL/H1bg7tG0znKbHCy" 418 "Zs16u6TgmiQH5rLW2Ltslhf6kjO1bjOJ4PTfu1PwDgeR0BsF6BBCBQIThee+P78QvAQNS" 419 "X17mD/tfXYaMBejAAhWWahqoiB5q8dmYQ9rc+AF7Trmn2BLC7vy4XQ0ADpHZmJRQPznVO" 420 "0YcABJRnBwBg+Tofm3a//2q7zYREIAAyAQRQQKqAJ/ksH4CPC4wJy9uma2eA2+syjtsVn" 421 "LicKzDTRYaqMgi/AQyHQNSPY0uyb7vdHVEcezDQBhAHJXLPqLOZxN8+CLJVehmapoUX2u" 422 "54okzsIXACucAOYyunov62AUDiN0IQd69+dyAf7PfdsLlRGAGwXekowIgySRzoMzZzcAj" 423 "gpxIs9Ti+TsTghLMvV1Lfbvt+vbTR9ZAJtlWoXxSIwaxuohCUt8Pp3LTd+XHt01KF9XZL" 424 "iRhXkSwKCzYg7X2NwGYYJsRvCHU6nndNO3SH4TauV9v3OK7rUKHnUJaiTxRl4XODwD8mC" 425 "Gptn0Q8j1e4oOmmfi0iZY/naRuWaIyiNI1bxDljs/7M4Hcxlta9fzTd/qubrrdYpNZ2GL" 426 "ZxgJboFkmFVhGLLPE/6ubPp5nNTphOAGj/QHavtZ292t3KLouiQocqbXhRKOlr+/9hoA0" 427 "og/d+dzi0/+2b7nTr60vXbtZhJkQZx2GaLsNMxZ8ozk5gphN/M4i79nBo/uwHdJPn1Db7" 428 "c40aUgoDRVdTmhn3awbsXxOs4PZfc2i+vrrTNCEe+/0JnTmkoZOiJcT2co4i5z9hnHu6Z" 429 "bxoT7sWAM3mfp9O7Vd7rnUV6E8ap2lk/MdmJzD2eyRohKrf4+DmON2ej6HZ31epnnqpLg" 430 "ZV8dmFMw6fB0vww0Gs903ToJaviOifdnrXS6SxhgjjxNEF9BH6VlUVMKqf+STqPTLpeHr" 431 "0l2HYHaYeHohVZiOIYUYjhjHfx0cLAHI96Qrzi4BXeYxiRi94PjeH4/k8xshgO8u0HYoI" 432 "EIDvQgzEPOJIaGAlSSQQye54nzbH3Wb3wFSJ9SJAi0XAZ33NwXUXC5dJFIRHvZo7n0Z3J" 433 "oDNaYef0zVd2bFZJjDzEmhByWfQ8bi/gDDpuz7NCa4RidhivT90w7B51tfXpV+F2CVEqd" 434 "eamC+gj5cYznSYawCYwSPvEIbP3ArqXXdeXze3MUUNBJbSAGHgGuOZ7maazAfAoXnnaP8" 435 "yN9kdj8fhjPY8TNt6FWchDTbsVB4s196jANI3XwNQPPXM9LSLmZ/Ae0f8nuGC2lhPK5md" 436 "++zbh76B8V0Wmaz0aOB7epHy5XA4b3ZIgt1puvYYrCkaQZyhCrjZ1ehw+B//An2skMYLh" 437 "GDCXB3b43Q6dhSL+7NHQ0YZYW3yyVfgyUwoOI1WABje3IkkBRMHRPmmPWxupyM4nF/jek" 438 "mrp8pSSSqap++aSADA1ZuTtsLTewPgKmfadx2q8YwNZVwhDzJVZnbGfEcDOB8A/Y1wDAV" 439 "iRxtHVLF321EiTJf3u0b+osLgglyTximcUQr6NJ2ZvwDAxwa9ejg8l7wcDsOAZLptwzgr" 440 "LUXLdOC5nF5yPi6giFAYsbTwbwQHcRCejFCHA/lwwoZFZRBjvZlbGJ4mGylj8E27giJDo" 441 "SQCsvJyR702xwGz8X5dp7qSMuy7lGcmhBrB13XxC8Asw7zIueBJ/brvEINHvzRLeSmS3C" 442 "SfTgHDwaXKIOd5c4/RoYzrRHiOtbpOm8391dNuhXW3rECBzwC+qWQS+IAZABSBE+VoJzV" 443 "6P+e5Wl9u9wlZRJtNjEXTLq1INwHdhvxZH9GkcFI8HFqAsWDLhYw5k0W8Hl8Y0fUSFxBs" 444 "9CquLGFKQBfcDODPrQGPnPpRlADAiZEMCVb1/r0lAkjD0kq9xSJnmj/7NoEiYUxAElOOA" 445 "SMoFgwAUhbKpnmANhTTFSXD+x6jEjJm+CaUXIdfJhFuN3RLy3GbcBcqYjJPKH8QwGWdod" 446 "nbEgqOMQD6xpXQJ/fjelXlgKU9vghk4S0KwZIC15YSvXjZ15awslAHzP00008iUEE7oC4" 447 "r7nKHerJAl18gGRGPAMwzez2GVpmFFhEAAKOe5CN6ZL6v0znPpVcluBMyj2ZDHhWLhciT" 448 "Ctq4UKb9uIIfV3ChqzvJpxvpWBIeAOheSXQ8ZEEig2DhyjyqSqVoJ9j2W0y2knLW16dCd" 449 "6EjyQ0a/E23IDDwowJ5IFJsMzJaRAEoxOFy1S+tXDAAcMdlxoP4w7UtnABQe0nhUa1HES" 450 "5kVennooC/WWEpANRLK4mYjplkcy/ViU+n627I8gjXIJ9L5APiCDYiqFD7IIYLWKoKySj" 451 "lUXleNM9TzcSfdxRGqlKijGALtTVJA7bgi0RVRaByyhjqP1S73BxPyjoeM47LPRqvVInU" 452 "cvGoCit3GRpZ5VC0XZ1zpg6pb1AqLAhDD8L/AcHH1p8sEFAHAAAAAElFTkSuQmCC\r\n" 453 "Connection: keep-alive\r\n" 454 "Content-Length: 0\r\n" 455 "Upgrade-Insecure-Requests: 1\r\n" 456 "Pragma: no-cache\r\n" 457 "Cache-Control: no-cache\r\n" 458 "X-Forwarded-For: 192.0.2.0, 198.51.100.0, 203.0.113.0\r\n" 459 "\r\n" 460 ); 461 462 463 nxt_int_t 464 nxt_http_parse_test(nxt_thread_t *thr) 465 { 466 nxt_mp_t *mp, *mp_temp; 467 nxt_int_t rc; 468 nxt_uint_t i, colls, lvl_colls; 469 nxt_lvlhsh_t hash; 470 nxt_http_request_parse_t rp; 471 nxt_http_parse_test_case_t *test; 472 473 nxt_thread_time_update(thr); 474 475 mp = nxt_mp_create(1024, 128, 256, 32); 476 if (mp == NULL) { 477 return NXT_ERROR; 478 } 479 480 rc = nxt_http_fields_hash(&nxt_http_test_fields_hash, mp, 481 nxt_http_test_fields, 482 nxt_nitems(nxt_http_test_fields)); 483 if (rc != NXT_OK) { 484 return NXT_ERROR; 485 } 486 487 for (i = 0; i < nxt_nitems(nxt_http_test_cases); i++) { 488 test = &nxt_http_test_cases[i]; 489 490 nxt_memzero(&rp, sizeof(nxt_http_request_parse_t)); 491 492 mp_temp = nxt_mp_create(1024, 128, 256, 32); 493 if (mp_temp == NULL) { 494 return NXT_ERROR; 495 } 496 497 if (nxt_http_parse_request_init(&rp, mp_temp) != NXT_OK) { 498 return NXT_ERROR; 499 } 500 501 rc = nxt_http_parse_test_run(&rp, &test->request); 502 503 if (rc != test->result) { 504 nxt_log_alert(thr->log, "http parse test case failed:\n" 505 " - request:\n\"%V\"\n" 506 " - result: %i (expected: %i)", 507 &test->request, rc, test->result); 508 return NXT_ERROR; 509 } 510 511 if (test->handler != NULL 512 && test->handler(&rp, &test->data, &test->request, thr->log) 513 != NXT_OK) 514 { 515 return NXT_ERROR; 516 } 517 518 nxt_mp_destroy(mp_temp); 519 } 520 521 nxt_log_error(NXT_LOG_NOTICE, thr->log, "http parse test passed"); 522 523 nxt_memzero(&hash, sizeof(nxt_lvlhsh_t)); 524 525 colls = nxt_http_fields_hash_collisions(&hash, mp, 526 nxt_http_test_bench_fields, 527 nxt_nitems(nxt_http_test_bench_fields), 528 0); 529 530 nxt_memzero(&hash, sizeof(nxt_lvlhsh_t)); 531 532 lvl_colls = nxt_http_fields_hash_collisions(&hash, mp, 533 nxt_http_test_bench_fields, 534 nxt_nitems(nxt_http_test_bench_fields), 535 1); 536 537 nxt_log_error(NXT_LOG_NOTICE, thr->log, 538 "http parse test hash collisions %ui out of %ui, level: %ui", 539 colls, nxt_nitems(nxt_http_test_bench_fields), lvl_colls); 540 541 nxt_memzero(&hash, sizeof(nxt_lvlhsh_t)); 542 543 rc = nxt_http_fields_hash(&hash, mp, nxt_http_test_bench_fields, 544 nxt_nitems(nxt_http_test_bench_fields)); 545 if (rc != NXT_OK) { 546 return NXT_ERROR; 547 } 548 549 if (nxt_http_parse_test_bench(thr, &nxt_http_test_simple_request, 550 &hash, "simple", 1000000) 551 != NXT_OK) 552 { 553 return NXT_ERROR; 554 } 555 556 if (nxt_http_parse_test_bench(thr, &nxt_http_test_big_request, 557 &hash, "big", 100000) 558 != NXT_OK) 559 { 560 return NXT_ERROR; 561 } 562 563 nxt_mp_destroy(mp); 564 565 return NXT_OK; 566 } 567 568 569 static nxt_int_t 570 nxt_http_parse_test_run(nxt_http_request_parse_t *rp, nxt_str_t *request) 571 { 572 nxt_int_t rc; 573 nxt_buf_mem_t buf; 574 575 buf.start = request->start; 576 buf.end = request->start + request->length; 577 578 buf.pos = buf.start; 579 buf.free = buf.pos + 1; 580 581 do { 582 buf.free++; 583 rc = nxt_http_parse_request(rp, &buf); 584 } while (buf.free < buf.end && rc == NXT_AGAIN); 585 586 return rc; 587 } 588 589 590 static nxt_int_t 591 nxt_http_parse_test_bench(nxt_thread_t *thr, nxt_str_t *request, 592 nxt_lvlhsh_t *hash, const char *name, nxt_uint_t n) 593 { 594 nxt_mp_t *mp; 595 nxt_nsec_t start, end; 596 nxt_uint_t i; 597 nxt_buf_mem_t buf; 598 nxt_http_request_parse_t rp; 599 600 nxt_log_error(NXT_LOG_NOTICE, thr->log, 601 "http parse %s request bench started: %uz bytes, %ui runs", 602 name, request->length, n); 603 604 buf.start = request->start; 605 buf.end = request->start + request->length; 606 607 nxt_thread_time_update(thr); 608 start = nxt_thread_monotonic_time(thr); 609 610 for (i = 0; nxt_fast_path(i < n); i++) { 611 nxt_memzero(&rp, sizeof(nxt_http_request_parse_t)); 612 613 mp = nxt_mp_create(1024, 128, 256, 32); 614 if (nxt_slow_path(mp == NULL)) { 615 return NXT_ERROR; 616 } 617 618 if (nxt_slow_path(nxt_http_parse_request_init(&rp, mp) != NXT_OK)) { 619 return NXT_ERROR; 620 } 621 622 buf.pos = buf.start; 623 buf.free = buf.end; 624 625 if (nxt_slow_path(nxt_http_parse_request(&rp, &buf) != NXT_DONE)) { 626 nxt_log_alert(thr->log, "http parse %s request bench failed " 627 "while parsing", name); 628 return NXT_ERROR; 629 } 630 631 if (nxt_slow_path(nxt_http_fields_process(rp.fields, hash, NULL) 632 != NXT_OK)) 633 { 634 nxt_log_alert(thr->log, "http parse %s request bench failed " 635 "while fields processing", name); 636 return NXT_ERROR; 637 } 638 639 nxt_mp_destroy(mp); 640 } 641 642 nxt_thread_time_update(thr); 643 end = nxt_thread_monotonic_time(thr); 644 645 nxt_log_error(NXT_LOG_NOTICE, thr->log, 646 "http parse %s request bench: %0.3fs", 647 name, (end - start) / 1000000000.0); 648 649 return NXT_OK; 650 } 651 652 653 static nxt_int_t 654 nxt_http_parse_test_request_line(nxt_http_request_parse_t *rp, 655 nxt_http_parse_test_data_t *data, nxt_str_t *request, nxt_log_t *log) 656 { 657 nxt_str_t str; 658 659 nxt_http_parse_test_request_line_t *test = &data->request_line; 660 661 if (rp->method.start != test->method.start 662 && !nxt_strstr_eq(&rp->method, &test->method)) 663 { 664 nxt_log_alert(log, "http parse test case failed:\n" 665 " - request:\n\"%V\"\n" 666 " - method: \"%V\" (expected: \"%V\")", 667 request, &rp->method, &test->method); 668 return NXT_ERROR; 669 } 670 671 str.length = rp->target_end - rp->target_start; 672 str.start = rp->target_start; 673 674 if (str.start != test->target.start 675 && !nxt_strstr_eq(&str, &test->target)) 676 { 677 nxt_log_alert(log, "http parse test case failed:\n" 678 " - request:\n\"%V\"\n" 679 " - target: \"%V\" (expected: \"%V\")", 680 request, &str, &test->target); 681 return NXT_ERROR; 682 } 683 684 str.length = (rp->exten_start != NULL) ? rp->target_end - rp->exten_start 685 : 0; 686 str.start = rp->exten_start; 687 688 if (str.start != test->exten.start 689 && !nxt_strstr_eq(&str, &test->exten)) 690 { 691 nxt_log_alert(log, "http parse test case failed:\n" 692 " - request:\n\"%V\"\n" 693 " - exten: \"%V\" (expected: \"%V\")", 694 request, &str, &test->exten); 695 return NXT_ERROR; 696 } 697 698 str.length = (rp->args_start != NULL) ? rp->target_end - rp->args_start 699 : 0; 700 str.start = rp->args_start; 701 702 if (str.start != test->args.start 703 && !nxt_strstr_eq(&str, &test->args)) 704 { 705 nxt_log_alert(log, "http parse test case failed:\n" 706 " - request:\n\"%V\"\n" 707 " - args: \"%V\" (expected: \"%V\")", 708 request, &str, &test->args); 709 return NXT_ERROR; 710 } 711 712 if (nxt_memcmp(rp->version.str, test->version, 8) != 0) { 713 nxt_log_alert(log, "http parse test case failed:\n" 714 " - request:\n\"%V\"\n" 715 " - version: \"%*s\" (expected: \"%*s\")", request, 716 (size_t) 8, rp->version.str, 717 (size_t) 8, test->version); 718 return NXT_ERROR; 719 } 720 721 if (rp->complex_target != test->complex_target) { 722 nxt_log_alert(log, "http parse test case failed:\n" 723 " - request:\n\"%V\"\n" 724 " - complex_target: %d (expected: %d)", 725 request, rp->complex_target, test->complex_target); 726 return NXT_ERROR; 727 } 728 729 if (rp->quoted_target != test->quoted_target) { 730 nxt_log_alert(log, "http parse test case failed:\n" 731 " - request:\n\"%V\"\n" 732 " - quoted_target: %d (expected: %d)", 733 request, rp->quoted_target, test->quoted_target); 734 return NXT_ERROR; 735 } 736 737 if (rp->space_in_target != test->space_in_target) { 738 nxt_log_alert(log, "http parse test case failed:\n" 739 " - request:\n\"%V\"\n" 740 " - space_in_target: %d (expected: %d)", 741 request, rp->space_in_target, test->space_in_target); 742 return NXT_ERROR; 743 } 744 745 if (rp->plus_in_target != test->plus_in_target) { 746 nxt_log_alert(log, "http parse test case failed:\n" 747 " - request:\n\"%V\"\n" 748 " - plus_in_target: %d (expected: %d)", 749 request, rp->plus_in_target, test->plus_in_target); 750 return NXT_ERROR; 751 } 752 753 return NXT_OK; 754 } 755 756 757 static nxt_int_t 758 nxt_http_parse_test_fields(nxt_http_request_parse_t *rp, 759 nxt_http_parse_test_data_t *data, nxt_str_t *request, nxt_log_t *log) 760 { 761 nxt_int_t rc; 762 763 rc = nxt_http_fields_process(rp->fields, &nxt_http_test_fields_hash, NULL); 764 765 if (rc != data->result) { 766 nxt_log_alert(log, "http parse test hash failed:\n" 767 " - request:\n\"%V\"\n" 768 " - result: %i (expected: %i)", 769 request, rc, data->result); 770 return NXT_ERROR; 771 } 772 773 return NXT_OK; 774 } 775 776 777 static nxt_int_t 778 nxt_http_test_header_return(void *ctx, nxt_http_field_t *field, uintptr_t data) 779 { 780 return data; 781 } 782