Mercurial > hg > nginx-tests
view debug_connection_syslog.t @ 1127:6620cd57a96a
Tests: replaced all occurrences of vec/select API with IO::Select.
author | Sergey Kandaurov <pluknet@nginx.com> |
---|---|
date | Fri, 10 Feb 2017 12:41:43 +0300 |
parents | a04323ab0622 |
children | bef8be8a6224 |
line wrap: on
line source
#!/usr/bin/perl # (C) Nginx, Inc. # Tests for debug_connection with syslog. ############################################################################### use warnings; use strict; use Test::More; use IO::Select; BEGIN { use FindBin; chdir($FindBin::Bin); } use lib 'lib'; use Test::Nginx; ############################################################################### select STDERR; $| = 1; select STDOUT; $| = 1; my $t = Test::Nginx->new()->has(qw/http --with-debug ipv6 proxy/); $t->write_file_expand('nginx.conf', <<'EOF'); %%TEST_GLOBALS%% daemon off; events { debug_connection ::1; } http { %%TEST_GLOBALS_HTTP%% error_log syslog:server=127.0.0.1:%%PORT_8081_UDP%% alert; error_log syslog:server=127.0.0.1:%%PORT_8082_UDP%% alert; server { listen 127.0.0.1:8080; listen [::1]:%%PORT_8080%%; server_name localhost; location /debug { proxy_pass http://[::1]:%%PORT_8080%%/; } } } EOF $t->try_run('no inet6 support')->plan(5); ############################################################################### is(get_syslog('/', port(8081)), '', 'no debug_connection syslog 1'); is(get_syslog('/', port(8082)), '', 'no debug_connection syslog 2'); my @msgs = get_syslog('/debug', port(8081), port(8082)); like($msgs[0], qr/\[debug\]/, 'debug_connection syslog 1'); like($msgs[1], qr/\[debug\]/, 'debug_connection syslog 2'); is($msgs[0], $msgs[1], 'debug_connection syslog1 syslog2 match'); ############################################################################### sub get_syslog { my ($uri, @port) = @_; my (@s); my @data; eval { local $SIG{ALRM} = sub { die "timeout\n" }; local $SIG{PIPE} = sub { die "sigpipe\n" }; alarm(1); map { push @s, IO::Socket::INET->new( Proto => 'udp', LocalAddr => "127.0.0.1:$_" ); } (@port); alarm(0); }; alarm(0); if ($@) { log_in("died: $@"); return undef; } http_get($uri); map { my $data = ''; IO::Select->new($_)->can_read(1); while (IO::Select->new($_)->can_read(0.1)) { my ($buffer); sysread($_, $buffer, 4096); $data .= $buffer; } push @data, $data; $_->close(); } (@s); return $data[0] if scalar @data == 1; return @data; } ###############################################################################