… | |
… | |
312 | $self->{remote_greeting}{untrusted} = 1 |
312 | $self->{remote_greeting}{untrusted} = 1 |
313 | if $auth_method eq "tls_anon"; |
313 | if $auth_method eq "tls_anon"; |
314 | |
314 | |
315 | if ($protocol eq "aemp" and $self->{hdl}) { |
315 | if ($protocol eq "aemp" and $self->{hdl}) { |
316 | # listener-less nodes need to continuously probe |
316 | # listener-less nodes need to continuously probe |
317 | unless (@$AnyEvent::MP::Kernel::BINDS) { |
317 | # unless (@$AnyEvent::MP::Kernel::BINDS) { |
318 | $self->{hdl}->wtimeout ($timeout); |
318 | # $self->{hdl}->wtimeout ($timeout); |
319 | $self->{hdl}->on_wtimeout (sub { $self->{send}->([]) }); |
319 | # $self->{hdl}->on_wtimeout (sub { $self->{send}->([]) }); |
320 | } |
320 | # } |
321 | |
321 | |
322 | # receive handling |
322 | # receive handling |
323 | |
323 | |
324 | my $push_write = $hdl->can ("push_write"); |
324 | my $push_write = $hdl->can ("push_write"); |
325 | my $push_read = $hdl->can ("push_read"); |
325 | my $push_read = $hdl->can ("push_read"); |