| … | |
… | |
| 177 | peername => delete $arg{peername}, |
177 | peername => delete $arg{peername}, |
| 178 | ; |
178 | ; |
| 179 | |
179 | |
| 180 | my $greeting_kv = $self->{greeting} ||= {}; |
180 | my $greeting_kv = $self->{greeting} ||= {}; |
| 181 | |
181 | |
| 182 | $self->{local_node} = $AnyEvent::MP::Kernel::NODE; |
182 | $self->{local_node} ||= $AnyEvent::MP::Kernel::NODE; |
| 183 | |
183 | |
| 184 | $greeting_kv->{"tls"} = "1.0" if $arg{tls_ctx}; |
184 | $greeting_kv->{"tls"} = "1.0" if $arg{tls_ctx}; |
| 185 | $greeting_kv->{provider} = "AE-$AnyEvent::MP::Kernel::VERSION"; |
185 | $greeting_kv->{provider} = "AE-$AnyEvent::MP::Kernel::VERSION"; |
| 186 | $greeting_kv->{peeraddr} = AnyEvent::Socket::format_hostport $self->{peerhost}, $self->{peerport}; |
186 | $greeting_kv->{peeraddr} = AnyEvent::Socket::format_hostport $self->{peerhost}, $self->{peerport}; |
| 187 | $greeting_kv->{timeout} = $arg{timeout}; |
187 | $greeting_kv->{timeout} = $arg{timeout}; |
| … | |
… | |
| 333 | |
333 | |
| 334 | (delete $self->{release})->() |
334 | (delete $self->{release})->() |
| 335 | if exists $self->{release}; |
335 | if exists $self->{release}; |
| 336 | |
336 | |
| 337 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
337 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
|
|
338 | |
| 338 | Scalar::Util::weaken ($self->{node} = $node); |
339 | Scalar::Util::weaken ($self->{node} = $node); |
| 339 | $node->transport_connect ($self); |
340 | $node->transport_connect ($self); |
| 340 | } |
341 | } |
| 341 | |
342 | |
| 342 | sub send { |
343 | sub send { |
