| … | |
… | |
| 190 | $self->{remote_greeting} = { |
190 | $self->{remote_greeting} = { |
| 191 | map /^([^=]+)(?:=(.*))?/ ? ($1 => $2) : (), |
191 | map /^([^=]+)(?:=(.*))?/ ? ($1 => $2) : (), |
| 192 | @kv |
192 | @kv |
| 193 | }; |
193 | }; |
| 194 | |
194 | |
|
|
195 | $_->($self) for @HOOK_GREETING; |
|
|
196 | |
| 195 | if ($aemp ne "aemp") { |
197 | if ($aemp ne "aemp") { |
| 196 | return $self->error ("unparsable greeting"); |
198 | return $self->error ("unparsable greeting"); |
| 197 | } elsif ($version != $PROTOCOL_VERSION) { |
199 | } elsif ($version != $PROTOCOL_VERSION) { |
| 198 | return $self->error ("version mismatch (we: $PROTOCOL_VERSION, they: $version)"); |
200 | return $self->error ("version mismatch (we: $PROTOCOL_VERSION, they: $version)"); |
| 199 | } elsif ($rnode eq $AnyEvent::MP::Kernel::NODE) { |
201 | } elsif ($rnode eq $AnyEvent::MP::Kernel::NODE) { |
| … | |
… | |
| 312 | |
314 | |
| 313 | Scalar::Util::weaken $rmsg; |
315 | Scalar::Util::weaken $rmsg; |
| 314 | Scalar::Util::weaken $src_node; |
316 | Scalar::Util::weaken $src_node; |
| 315 | }); |
317 | }); |
| 316 | }); |
318 | }); |
| 317 | |
|
|
| 318 | $_->($self) for @HOOK_GREETING; |
|
|
| 319 | }); |
319 | }); |
| 320 | } |
320 | } |
| 321 | |
321 | |
| 322 | $self |
322 | $self |
| 323 | } |
323 | } |
