Mercurial > hg > nginx-tests

annotate lib/Test/Nginx/Stream.pm @ 1978:79753dd514e6 default tip

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Tests: added test for mail proxy timeout.
author Rob Mueller <robm@fastmailteam.com>
date Wed, 15 May 2024 23:51:31 +0300
parents 6d3a8f4eb9b2
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
1 package Test::Nginx::Stream;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
2
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
3 # (C) Andrey Zelenkov
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
4 # (C) Nginx, Inc.
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
5
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
6 # Module for nginx stream tests.
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
7
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
8 ###############################################################################
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
9
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
10 use warnings;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
11 use strict;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
12
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
13 use base qw/ Exporter /;
868
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
14 our @EXPORT_OK = qw/ stream dgram /;
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
15
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
16 use Test::More qw//;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
17 use IO::Select;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
18 use IO::Socket;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
19
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
20 use Test::Nginx;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
21
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
22 sub stream {
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
23 return Test::Nginx::Stream->new(@_);
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
24 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
25
868
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
26 sub dgram {
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
27 unshift(@_, "PeerAddr") if @_ == 1;
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
28
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
29 return Test::Nginx::Stream->new(
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
30 Proto => "udp",
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
31 @_
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
32 );
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
33 }
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
34
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
35 sub new {
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
36 my $self = {};
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
37 bless $self, shift @_;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
38
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
39 unshift(@_, "PeerAddr") if @_ == 1;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
40
1863
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
41 eval {
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
42 local $SIG{ALRM} = sub { die "timeout\n" };
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
43 local $SIG{PIPE} = sub { die "sigpipe\n" };
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
44 alarm(8);
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
45
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
46 $self->{_socket} = IO::Socket::INET->new(
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
47 Proto => "tcp",
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
48 PeerAddr => '127.0.0.1',
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
49 @_
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
50 )
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
51 or die "Can't connect to nginx: $!\n";
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
52
1863
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
53 if ({@_}->{'SSL'}) {
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
54 require IO::Socket::SSL;
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
55 IO::Socket::SSL->start_SSL(
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
56 $self->{_socket},
1970
6d3a8f4eb9b2 Tests: relaxed SSL version used in testing.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1863
diff changeset
57 SSL_version => 'SSLv23',
1863
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
58 SSL_verify_mode =>
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
59 IO::Socket::SSL::SSL_VERIFY_NONE(),
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
60 @_
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
61 )
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
62 or die $IO::Socket::SSL::SSL_ERROR . "\n";
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
63
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
64 my $s = $self->{_socket};
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
65 log_in("ssl cipher: " . $s->get_cipher());
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
66 log_in("ssl cert: " . $s->peer_certificate('issuer'));
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
67 }
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
68
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
69 alarm(0);
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
70 };
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
71 alarm(0);
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
72 if ($@) {
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
73 log_in("died: $@");
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
74 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
75
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
76 $self->{_socket}->autoflush(1);
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
77
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
78 return $self;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
79 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
80
1863
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
81 sub DESTROY {
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
82 my $self = shift;
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
83 $self->{_socket}->close();
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
84 }
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
85
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
86 sub write {
935
25a4b2fdd3fb Tests: I/O timeout options introduced in Stream.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 875
diff changeset
87 my ($self, $message, %extra) = @_;
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
88 my $s = $self->{_socket};
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
89
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
90 local $SIG{PIPE} = 'IGNORE';
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
91
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
92 $s->blocking(0);
935
25a4b2fdd3fb Tests: I/O timeout options introduced in Stream.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 875
diff changeset
93 while (IO::Select->new($s)->can_write($extra{write_timeout} || 1.5)) {
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
94 my $n = $s->syswrite($message);
1852
1197c152215b Tests: fixed warning in case of a closed stream.
Eugene Grebenschikov <e.grebenshchikov@nginx.com>
parents: 1825
diff changeset
95 last unless $n;
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
96 log_out(substr($message, 0, $n));
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
97
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
98 $message = substr($message, $n);
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
99 last unless length $message;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
100 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
101
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
102 if (length $message) {
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
103 $s->close();
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
104 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
105 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
106
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
107 sub read {
935
25a4b2fdd3fb Tests: I/O timeout options introduced in Stream.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 875
diff changeset
108 my ($self, %extra) = @_;
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
109 my ($s, $buf);
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
110
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
111 $s = $self->{_socket};
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
112
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
113 $s->blocking(0);
1825
3629eda94c1b Tests: handling of EWOULDBLOCK from sysread() with IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1824
diff changeset
114 while (IO::Select->new($s)->can_read($extra{read_timeout} || 8)) {
3629eda94c1b Tests: handling of EWOULDBLOCK from sysread() with IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1824
diff changeset
115 my $n = $s->sysread($buf, 1024);
3629eda94c1b Tests: handling of EWOULDBLOCK from sysread() with IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1824
diff changeset
116 next if !defined $n && $!{EWOULDBLOCK};
3629eda94c1b Tests: handling of EWOULDBLOCK from sysread() with IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1824
diff changeset
117 last;
1824
5d3aee48ed8e Tests: style.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1423
diff changeset
118 }
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
119
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
120 log_in($buf);
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
121 return $buf;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
122 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
123
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
124 sub io {
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
125 my $self = shift;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
126
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
127 my ($data, %extra) = @_;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
128 my $length = $extra{length};
868
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
129 my $read = $extra{read};
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
130
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
131 $read = 1 if !defined $read
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
132 && $self->{_socket}->socktype() == &SOCK_DGRAM;
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
133
935
25a4b2fdd3fb Tests: I/O timeout options introduced in Stream.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 875
diff changeset
134 $self->write($data, %extra);
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
135
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
136 $data = '';
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
137 while (1) {
868
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
138 last if defined $read && --$read < 0;
d2cb9ed7412e Tests: stream udp tests.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 816
diff changeset
139
935
25a4b2fdd3fb Tests: I/O timeout options introduced in Stream.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 875
diff changeset
140 my $buf = $self->read(%extra);
875
c380b4b7e2e4 Tests: compatibility with perl < 5.12 in Stream.pm.
Andrey Zelenkov <zelenkov@nginx.com>
parents: 868
diff changeset
141 last unless defined $buf and length($buf);
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
142
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
143 $data .= $buf;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
144 last if defined $length && length($data) >= $length;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
145 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
146
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
147 return $data;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
148 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
149
1024
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
150 sub sockaddr {
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
151 my $self = shift;
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
152 return $self->{_socket}->sockaddr();
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
153 }
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
154
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
155 sub sockhost {
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
156 my $self = shift;
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
157 return $self->{_socket}->sockhost();
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
158 }
91e64c1ceec9 Tests: stream access_log tests.
Sergey Kandaurov <pluknet@nginx.com>
parents: 969
diff changeset
159
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
160 sub sockport {
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
161 my $self = shift;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
162 return $self->{_socket}->sockport();
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
163 }
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
164
1863
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
165 sub socket {
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
166 my ($self) = @_;
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
167 $self->{_socket};
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
168 }
dbb7561a9441 Tests: reworked stream SSL tests to use IO::Socket::SSL.
Maxim Dounin <mdounin@mdounin.ru>
parents: 1852
diff changeset
169
816
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
170 ###############################################################################
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
171
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
172 1;
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
173
77359b849cd5 Tests: stream package.
Andrey Zelenkov <zelenkov@nginx.com>
parents:
diff changeset
174 ###############################################################################