Mercurial > hg > nginx-tests
view fastcgi_body2.t @ 1940:aec72dcee93b
Tests: unconditional QUIC datagram expansion with Initial packets.
Used to get rid of "quic UDP datagram is too small for initial packet" messages.
In future, we may need this to reconsider to allow mocking with custom padding,
but for now suppressing such messages is sufficiently good enough.
author | Sergey Kandaurov <pluknet@nginx.com> |
---|---|
date | Mon, 11 Dec 2023 14:01:49 +0400 |
parents | 42d9fd20eeb6 |
children |
line wrap: on
line source
#!/usr/bin/perl # (C) Maxim Dounin # (C) Sergey Kandaurov # (C) Nginx, Inc. # Test for fastcgi backend with large request body, # with fastcgi_next_upstream directive. ############################################################################### use warnings; use strict; use Test::More; BEGIN { use FindBin; chdir($FindBin::Bin); } use lib 'lib'; use Test::Nginx; ############################################################################### select STDERR; $| = 1; select STDOUT; $| = 1; eval { require FCGI; }; plan(skip_all => 'FCGI not installed') if $@; plan(skip_all => 'win32') if $^O eq 'MSWin32'; my $t = Test::Nginx->new()->has(qw/http fastcgi/)->plan(2) ->write_file_expand('nginx.conf', <<'EOF'); %%TEST_GLOBALS%% daemon off; events { } http { %%TEST_GLOBALS_HTTP%% upstream u { server 127.0.0.1:8081; server 127.0.0.1:8082 backup; } upstream u2 { server 127.0.0.1:8081; server 127.0.0.1:8082 backup; } server { listen 127.0.0.1:8080; server_name localhost; location / { fastcgi_pass u; fastcgi_param REQUEST_URI $request_uri; fastcgi_param CONTENT_LENGTH $content_length; # fastcgi_next_upstream error timeout; fastcgi_read_timeout 1s; } location /in_memory { fastcgi_pass u2; fastcgi_param REQUEST_URI $request_uri; fastcgi_param CONTENT_LENGTH $content_length; # fastcgi_next_upstream error timeout; fastcgi_read_timeout 1s; client_body_buffer_size 128k; } } } EOF $t->run_daemon(\&fastcgi_daemon, port(8081)); $t->run_daemon(\&fastcgi_daemon, port(8082)); $t->run(); $t->waitforsocket('127.0.0.1:' . port(8081)); $t->waitforsocket('127.0.0.1:' . port(8082)); ############################################################################### like(http_get_length('/', 'x' x 102400), qr/X-Length: 102400/, 'body length - in file'); like(http_get_length('/in_memory', 'x' x 102400), qr/X-Length: 102400/, 'body length - in memory'); ############################################################################### sub http_get_length { my ($url, $body) = @_; my $length = length $body; return http(<<EOF); GET $url HTTP/1.0 Host: localhost Content-Length: $length $body EOF } ############################################################################### sub fastcgi_daemon { my ($port) = @_; my $socket = FCGI::OpenSocket("127.0.0.1:$port", 5); my $request = FCGI::Request(\*STDIN, \*STDOUT, \*STDERR, \%ENV, $socket); while( $request->Accept() >= 0 ) { read(STDIN, my $body, $ENV{'CONTENT_LENGTH'} || 0); my $len = length $body; sleep 3 if $port == port(8081); print <<EOF; Location: http://localhost/redirect Content-Type: text/html X-Length: $len EOF } FCGI::CloseSocket($socket); } ###############################################################################