| … | |
… | |
| 332 | my ($self) = @_; |
332 | my ($self) = @_; |
| 333 | |
333 | |
| 334 | (delete $self->{release})->() |
334 | (delete $self->{release})->() |
| 335 | if exists $self->{release}; |
335 | if exists $self->{release}; |
| 336 | |
336 | |
| 337 | # first connect with a master node |
|
|
| 338 | $AnyEvent::MP::Kernel::SLAVE->($self->{remote_node}) |
|
|
| 339 | if ref $AnyEvent::MP::Kernel::SLAVE; |
|
|
| 340 | |
|
|
| 341 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
337 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
| 342 | Scalar::Util::weaken ($self->{node} = $node); |
338 | Scalar::Util::weaken ($self->{node} = $node); |
| 343 | $node->transport_connect ($self); |
339 | $node->transport_connect ($self); |
| 344 | } |
340 | } |
| 345 | |
341 | |
