1 | #!/usr/bin/perl |
1 | #!/usr/bin/perl |
2 | |
2 | |
3 | BEGIN { eval "use Net::SSLeay 1.33 (); 1" or ((print "1..0 # SKIP no usable Net::SSLeay\n"), exit 0) } |
3 | BEGIN { eval "use Net::SSLeay 1.33 (); 1" or ((print "1..0 # SKIP no usable Net::SSLeay\n"), exit 0) } |
4 | |
4 | |
5 | use Test::More tests => 410; |
5 | use Test::More tests => 415; |
6 | |
6 | |
|
|
7 | no warnings; |
7 | use strict qw(vars subs); |
8 | use strict qw(vars subs); |
8 | |
9 | |
9 | use AnyEvent::Socket; |
10 | use AnyEvent::Socket; |
10 | use AnyEvent::Handle; |
11 | use AnyEvent::Handle; |
11 | use AnyEvent::TLS; |
12 | use AnyEvent::TLS; |
12 | |
13 | |
13 | my $ctx = new AnyEvent::TLS cert_file => $0; |
14 | my $ctx = new AnyEvent::TLS cert_file => $0; |
14 | |
15 | |
15 | for my $mode (1..5) { |
16 | for my $mode (1..5) { |
|
|
17 | ok (1, "mode $mode"); |
|
|
18 | |
16 | my $server_done = AnyEvent->condvar; |
19 | my $server_done = AnyEvent->condvar; |
17 | my $client_done = AnyEvent->condvar; |
20 | my $client_done = AnyEvent->condvar; |
18 | |
21 | |
19 | my $server_port = AnyEvent->condvar; |
22 | my $server_port = AnyEvent->condvar; |
20 | |
23 | |
… | |
… | |
29 | tls => "accept", |
32 | tls => "accept", |
30 | tls_ctx => $ctx, |
33 | tls_ctx => $ctx, |
31 | fh => $fh, |
34 | fh => $fh, |
32 | timeout => 8, |
35 | timeout => 8, |
33 | on_error => sub { |
36 | on_error => sub { |
34 | ok (0, "server_error <$!>"); |
37 | ok (0, "server_error <$_[2]>"); |
35 | $server_done->send; undef $hd; |
38 | $server_done->send; undef $hd; |
36 | }, |
39 | }, |
37 | on_eof => sub { |
40 | on_eof => sub { |
38 | ok (1, "server_eof"); |
41 | ok (1, "server_eof"); |
39 | $server_done->send; undef $hd; |
42 | $server_done->send; undef $hd; |
… | |
… | |
81 | }, sub { |
84 | }, sub { |
82 | $server_port->send ($_[2]); |
85 | $server_port->send ($_[2]); |
83 | }; |
86 | }; |
84 | |
87 | |
85 | my $hd; $hd = new AnyEvent::Handle |
88 | my $hd; $hd = new AnyEvent::Handle |
86 | connect => ["localhost", $server_port->recv], |
89 | connect => ["127.0.0.1", $server_port->recv], |
87 | tls => "connect", |
90 | tls => "connect", |
88 | tls_ctx => $ctx, |
91 | tls_ctx => $ctx, |
89 | timeout => 8, |
92 | timeout => 8, |
90 | on_connect => sub { |
93 | on_connect => sub { |
91 | ok (1, "client_connect $mode"); |
94 | ok (1, "client_connect $mode"); |
92 | }, |
95 | }, |
93 | on_error => sub { |
96 | on_error => sub { |
94 | ok (0, "client_error <$!>"); |
97 | ok (0, "client_error <$_[2]>"); |
95 | $client_done->send; undef $hd; |
98 | $client_done->send; undef $hd; |
96 | }, |
99 | }, |
97 | on_eof => sub { |
100 | on_eof => sub { |
98 | ok (1, "client_eof"); |
101 | ok (1, "client_eof"); |
99 | $client_done->send; undef $hd; |
102 | $client_done->send; undef $hd; |
… | |
… | |
134 | $hd->push_write (packstring => "N", "\x00" x $len); |
137 | $hd->push_write (packstring => "N", "\x00" x $len); |
135 | }; |
138 | }; |
136 | |
139 | |
137 | for my $i (1..$cnt) { |
140 | for my $i (1..$cnt) { |
138 | $hd->push_read (line => sub { |
141 | $hd->push_read (line => sub { |
|
|
142 | my ($i, $cnt, $block) = ($i, $cnt, $block); # 5.8.9. bug workaround |
139 | my $len = $_[1]; |
143 | my $len = $_[1]; |
140 | ok (1, "client block $len/1"); |
144 | ok (1, "client block $len/1"); |
141 | $hd->unshift_read (packstring => "N", sub { |
145 | $hd->unshift_read (packstring => "N", sub { |
142 | ok ($len == length $_[1], "client block $len/2"); |
146 | ok ($len == length $_[1], "client block $len/2"); |
143 | |
147 | |
144 | if ($i != $cnt) { |
148 | if ($i != $cnt) { |
145 | $block->(); |
149 | $block->(); |
146 | } else { |
150 | } else { |
147 | ok (1, "client_drain"); |
151 | ok (1, "client_drain 5"); |
148 | $client_done->send; undef $hd; |
152 | $client_done->send; undef $hd; |
149 | } |
153 | } |
150 | }); |
154 | }); |
151 | }); |
155 | }); |
152 | } |
156 | } |
… | |
… | |
158 | $client_done->recv; |
162 | $client_done->recv; |
159 | } |
163 | } |
160 | |
164 | |
161 | __END__ |
165 | __END__ |
162 | -----BEGIN RSA PRIVATE KEY----- |
166 | -----BEGIN RSA PRIVATE KEY----- |
163 | MIIBOwIBAAJBAL3Qbshr1ENmAzHxIRIvUaIG8+PCjc7xdXLBm+asBPMu0APQVQXJ |
167 | MIIEpAIBAAKCAQEA02VwAqlQzCrPenkxUjawHcXzJreJ9LDhX7Bkg3E/RB6Ilm4D |
164 | RTL3DueRUB51hAgSPgzSnj+ryZVzdcDER+UCAwEAAQJAGRftDWHz9dUOpxORo63N |
168 | LBeilCmzkY7avp57+WCiVw2qkg+kH4Ef2sd+r10UCGPh/1diLehRAzp3Ho1bixyg |
165 | xPXWWE3oIWuac0lVKvGi1eMoI4UCW/Y7qM4rXsUXqasUo3mxV24+QqJHDQid1qi6 |
169 | w+zkDm79OnN3uHxuKigkAxx3GGz9HhQA83U+RUns+39/OnFh0RY6/f5rV2ziA9jD |
166 | AQIhAN5BtiqfjFjb97uUbdE6aiqE+nSG0eXlkeHKNpBNtiUxAiEA2qHNZ5fcQTqT |
170 | 6HK3Mnsuxocd46YbVdiqlQK430CgiGj8dV44JG6+R6x3r5qXDbbRtGubC29kQOUq |
167 | 4qlnYhbI+g6bTwuR7QnzzGTlHUGxsPUCIQDLfvTw37Zb4cNYb1WBPW/ZUHoU2SAz |
171 | kYslbpTo7ml8ShyqAP6qa8BpeSIaNG1CQQ/7JkAdxSWyFHqMQ0HR3BUiaEfUElZt |
168 | 01cXmdMNmumL8QIhAJMGTENl9FBJPDopAcUM3YqLWBYICdIF51WEZC8QhpYhAiBe |
172 | DFgXcCkKB5F8jx+wYoLzlPHHZaUvfP2nueYjcwIDAQABAoIBAQCtRDMuu0ByV5R/ |
169 | KcoNT51hv3pKK8oZtPJGsKFjmGVVnZeNNzyQmt/YWw== |
173 | Od5nGFP500mcrkrwuBnBqH56DdRhLPWe9sS62xRyhEuePoykOJo8qCvnVlg8J33K |
|
|
174 | JLfLRkBb09qbleKiuyjJn+Tm1IDWFd62gtxyOjQicG41/nZeS/6vpv79XdNvvcUp |
|
|
175 | ZhPxeGN1v0XyTWomqNAX5DSuAl5Q5HxkaRYNeuLZaPYkqmEVTgYqNSes/wRLKUb6 |
|
|
176 | MaVrZ9AA/oHJMmmV4evf06s7l7ICjxAWeas7CI6UGkEz8ZFoVRJsLk5xtTsnZLgf |
|
|
177 | f24/pqHz1vApPs7CsJhK2HsLZcxMPD+hmTNI/Njl51WoH8zGhkv+p88vDzybpNSF |
|
|
178 | Hpkl+ZlBAoGBAOyfjVLD0OznJKSFksoCZKS4dlPHgXUb47Qb/XchIySQ/DNO6ff9 |
|
|
179 | AA6r6doDFp51A8N1GRtGQN4LKujFPOdZ5ah7zbc2PfuOJGHku0Oby+ydgHJ19eW4 |
|
|
180 | s3CIM20TuzLndFPrEGFgOrt+i5qKisti2OOZhjsDwfd48vsBm9U20lUpAoGBAOS1 |
|
|
181 | Chm+vA7JevPzl+acbDSiyELaNRAXZ73CX4NIxJURjsgDeOurnBtLQEQyagZbNHcx |
|
|
182 | W4pc59Ql5KDLzu/Sne8oC3pxhaWeIPhc2d3cd/8UyGtQLtN2QnilwkjHgi3x1JGb |
|
|
183 | RPRsgAV6nwn10qUrze1XLkHsTCRI4QYD/k0uXcs7AoGBAMStJaFag2i2Ax4ArG7e |
|
|
184 | KFtFu4yNckwtv0kwTrBbScOWAxp+iDiJASgwunJsSLuylUs8JH8oGLi23ZaWgrXl |
|
|
185 | Yd918BpNqp1Rm2oG3aQndguZKm95Hscvi26Itv39/YYlHeq2omndu1OmrlDowM6m |
|
|
186 | vZIIRKr+x5Vz4brCro09QPxpAoGARJAdghBTEl/Gc2HgdOsJ6VGvlZMS+0r498NQ |
|
|
187 | nOvwuvuzgTTBSG1+9BPAJXGzpUosVVs/pSArA8eEXcwbsnvCixLHNiLYPQlFuw8i |
|
|
188 | 5UcV1iul1b4I+63lSYPv1Z+x4BIydqBEsL3iN0JGcVb3mjqilndfT7YGMY6DnykN |
|
|
189 | UJgI2EcCgYAMfZHnD06XFM8ny+NsFILItpGqjCmAhkEPGwl1Zhy5Hx16CFDPDwGt |
|
|
190 | CmIbxNSLsDyiiK+i5tuSUFhV2Bw/iT539979INTIdNL1ughfhATR8MVNiOKCvZBa |
|
|
191 | uoEeE19szmG7Mj2eV2IDH0e8iaikjRFcfN89s39tNn1AjBNmEccUJA== |
170 | -----END RSA PRIVATE KEY----- |
192 | -----END RSA PRIVATE KEY----- |
|
|
193 | ----- |
171 | -----BEGIN CERTIFICATE----- |
194 | -----BEGIN CERTIFICATE----- |
172 | MIIDJjCCAtCgAwIBAgIJAJ3NPnD6z5+2MA0GCSqGSIb3DQEBBQUAMIGWMQswCQYD |
195 | MIIDHTCCAgWgAwIBAgIJAPASTbY2HCx0MA0GCSqGSIb3DQEBBQUAMBMxETAPBgNV |
173 | VQQGEwJYTjETMBEGA1UECBMKU29tZS1TdGF0ZTESMBAGA1UEBxMJU29tZS1DaXR5 |
196 | BAMTCEFueUV2ZW50MB4XDTEyMDQwNTA1NTk1MFoXDTM3MDQwNTA1NTk1MFowEzER |
174 | MRUwEwYDVQQKEwxTb21lLUNvbXBhbnkxEjAQBgNVBAsTCVNvbWUtVW5pdDEQMA4G |
197 | MA8GA1UEAxMIQW55RXZlbnQwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIB |
175 | A1UEAxMHU29tZS1DTjEhMB8GCSqGSIb3DQEJARYSc29tZUBlbWFpbC5pbnZhbGlk |
198 | AQDTZXACqVDMKs96eTFSNrAdxfMmt4n0sOFfsGSDcT9EHoiWbgMsF6KUKbORjtq+ |
176 | MB4XDTA4MTAwMTA3NDk1OFoXDTM5MDMwODA3NDk1OFowgZYxCzAJBgNVBAYTAlhO |
199 | nnv5YKJXDaqSD6QfgR/ax36vXRQIY+H/V2It6FEDOncejVuLHKDD7OQObv06c3e4 |
177 | MRMwEQYDVQQIEwpTb21lLVN0YXRlMRIwEAYDVQQHEwlTb21lLUNpdHkxFTATBgNV |
200 | fG4qKCQDHHcYbP0eFADzdT5FSez7f386cWHRFjr9/mtXbOID2MPocrcyey7Ghx3j |
178 | BAoTDFNvbWUtQ29tcGFueTESMBAGA1UECxMJU29tZS1Vbml0MRAwDgYDVQQDEwdT |
201 | phtV2KqVArjfQKCIaPx1Xjgkbr5HrHevmpcNttG0a5sLb2RA5SqRiyVulOjuaXxK |
179 | b21lLUNOMSEwHwYJKoZIhvcNAQkBFhJzb21lQGVtYWlsLmludmFsaWQwXDANBgkq |
202 | HKoA/qprwGl5Iho0bUJBD/smQB3FJbIUeoxDQdHcFSJoR9QSVm0MWBdwKQoHkXyP |
180 | hkiG9w0BAQEFAANLADBIAkEAvdBuyGvUQ2YDMfEhEi9Rogbz48KNzvF1csGb5qwE |
203 | H7BigvOU8cdlpS98/ae55iNzAgMBAAGjdDByMB0GA1UdDgQWBBTHphJ9Il0PtIWD |
181 | 8y7QA9BVBclFMvcO55FQHnWECBI+DNKeP6vJlXN1wMRH5QIDAQABo4H+MIH7MB0G |
204 | DI9aueToXo9DYzBDBgNVHSMEPDA6gBTHphJ9Il0PtIWDDI9aueToXo9DY6EXpBUw |
182 | A1UdDgQWBBScspJuXxPCTlFAyiMeXa6j/zW8ATCBywYDVR0jBIHDMIHAgBScspJu |
205 | EzERMA8GA1UEAxMIQW55RXZlbnSCCQDwEk22NhwsdDAMBgNVHRMEBTADAQH/MA0G |
183 | XxPCTlFAyiMeXa6j/zW8AaGBnKSBmTCBljELMAkGA1UEBhMCWE4xEzARBgNVBAgT |
206 | CSqGSIb3DQEBBQUAA4IBAQA/vY+qg2xjNeOuDySW/VOsStEwcaiAm/t24z3TYoZG |
184 | ClNvbWUtU3RhdGUxEjAQBgNVBAcTCVNvbWUtQ2l0eTEVMBMGA1UEChMMU29tZS1D |
207 | 2ZzyKuvFXolhXsalCahNPcyUxZqDAekODPRaq+geFaZrOn41cq/LABTKv5Theukv |
185 | b21wYW55MRIwEAYDVQQLEwlTb21lLVVuaXQxEDAOBgNVBAMTB1NvbWUtQ04xITAf |
208 | H7IruIFARBo1pTPFCKMnDqESBdHvV1xTOcKGxGH5I9iMgiUrd/NnlAaloT/cCNFI |
186 | BgkqhkiG9w0BCQEWEnNvbWVAZW1haWwuaW52YWxpZIIJAJ3NPnD6z5+2MAwGA1Ud |
209 | OwhEPsF9kBsZwJBGWrjjVttU2lzMzizS7vaSIWLBuEDObWbSXiU+IdG+nODOe2Dv |
187 | EwQFMAMBAf8wDQYJKoZIhvcNAQEFBQADQQA48HjY23liyBMmh3cNo9TC+/bu/G3E |
210 | W7PL43yd4fz4HQvN4IaZrtwkd7XiKodRR1gWjLjW/3y5kuXL+DA/jkTjrRgiH8K7 |
188 | oT5npm3+Lh6VA/4kKMyMu2mP31BToTZfl7vUcBJCQBhPFYOiPd/HnwzW |
211 | lVjm7gvkULRV2POQqtc2DUVXLubQmmGSjmQmxSwFX65t |
189 | -----END CERTIFICATE----- |
212 | -----END CERTIFICATE----- |
190 | |
|
|
191 | |
|
|
192 | |
|
|