| … | |
… | |
| 150 | }; |
150 | }; |
| 151 | } |
151 | } |
| 152 | |
152 | |
| 153 | $self->{hdl} = new AnyEvent::Handle |
153 | $self->{hdl} = new AnyEvent::Handle |
| 154 | +($self->{fh} ? (fh => $self->{fh}) : (connect => $self->{connect})), |
154 | +($self->{fh} ? (fh => $self->{fh}) : (connect => $self->{connect})), |
| 155 | autocork => 1, |
155 | autocork => $config->{autocork}, |
| 156 | no_delay => 1, |
156 | no_delay => exists $config->{nodelay} ? $config->{nodelay} : 1, |
| 157 | keepalive => 1, |
157 | keepalive => 1, |
| 158 | on_error => sub { |
158 | on_error => sub { |
| 159 | $self->error ($_[2]); |
159 | $self->error ($_[2]); |
| 160 | }, |
160 | }, |
| 161 | rtimeout => $timeout, |
161 | rtimeout => $timeout, |
| … | |
… | |
| 164 | my $greeting_kv = $self->{local_greeting} ||= {}; |
164 | my $greeting_kv = $self->{local_greeting} ||= {}; |
| 165 | |
165 | |
| 166 | $greeting_kv->{tls} = "1.0" if $self->{tls_ctx}; |
166 | $greeting_kv->{tls} = "1.0" if $self->{tls_ctx}; |
| 167 | $greeting_kv->{provider} = "AE-$AnyEvent::MP::VERSION"; # MP.pm might not be loaded, so best effort :( |
167 | $greeting_kv->{provider} = "AE-$AnyEvent::MP::VERSION"; # MP.pm might not be loaded, so best effort :( |
| 168 | $greeting_kv->{peeraddr} = AnyEvent::Socket::format_hostport $self->{peerhost}, $self->{peerport}; |
168 | $greeting_kv->{peeraddr} = AnyEvent::Socket::format_hostport $self->{peerhost}, $self->{peerport}; |
| 169 | $greeting_kv->{timeout} = $self->{timeout}; |
|
|
| 170 | |
169 | |
| 171 | my $protocol = $self->{protocol} || "aemp"; |
170 | my $protocol = $self->{protocol} || "aemp"; |
| 172 | |
171 | |
| 173 | # can modify greeting_kv |
172 | # can modify greeting_kv |
| 174 | $_->($self) for $protocol eq "aemp" ? @HOOK_CONNECT : (); |
173 | $_->($self) for $protocol eq "aemp" ? @HOOK_CONNECT : (); |
