--- AnyEvent-MP/MP/Node.pm 2009/08/03 21:35:03 1.6 +++ AnyEvent-MP/MP/Node.pm 2009/08/04 14:10:51 1.7 @@ -118,6 +118,19 @@ } } +sub kill { + my ($self, $port, @reason) = @_; + + $self->send (["", kil => $port, @reason]); + +# delete $AnyEvent::MP::Base::PORT{$port}; + +# my $mon = delete $AnyEvent::MP::Base::LMON{$port} +# or return; + +# $_->(@reason) for values %$mon; +} + sub monitor { my ($self, $portid, $cb) = @_; @@ -254,6 +267,17 @@ AnyEvent::MP::Base::_inject (@{ $_[1] }); } +sub kill { + my ($self, $port, @reason) = @_; + + delete $AnyEvent::MP::Base::PORT{$port}; + + my $mon = delete $AnyEvent::MP::Base::LMON{$port} + or return; + + $_->(@reason) for values %$mon; +} + sub monitor { my ($self, $portid, $cb) = @_;