[ViewVC] Diff of: cvs/AnyEvent-MP/MP.pm

Comparing AnyEvent-MP/MP.pm (file contents):
Revision 1.17 by root, Mon Aug 3 08:35:40 2009 UTC vs.
Revision 1.18 by root, Mon Aug 3 21:35:03 2009 UTC

 use base "Exporter";
 our $VERSION = '0.02';
 our @EXPORT = qw(
-   NODE $NODE $PORT snd rcv _any_
+   NODE $NODE $PORT snd rcv mon del _any_
    create_port create_port_on
    create_miniport
    become_slave become_public
 );
 The type of data you can transfer depends on the transport protocol: when
 JSON is used, then only strings, numbers and arrays and hashes consisting
 of those are allowed (no objects). When Storable is used, then anything
 that Storable can serialise and deserialise is allowed, and for the local
 node, anything can be passed.
+=item mon $portid, sub { }
+#TODO monitor the given port
+=cut
+sub mon {
+   my ($noderef, $port) = split /#/, shift, 2;
+   my $node = AnyEvent::MP::Base::add_node $noderef;
+   my $cb = shift;
+   $node->monitor ($port, $cb);
+   defined wantarray
+      and AnyEvent::Util::guard { $node->unmonitor ($port, $cb) }
+}
 =item $local_port = create_port
 Create a new local port object. See the next section for allowed methods.
 =cut
 use overload
    '""'     => sub { $_[0]{id} },
    fallback => 1;
+sub TO_JSON { $_[0]{id} }
 =item $port->rcv (type => $callback->($port, @msg))
 =item $port->rcv ($smartmatch => $callback->($port, @msg))
 =cut
 sub destroy {
    my ($self) = @_;
+   AnyEvent::MP::Base::del $self->{id};
    delete $AnyEvent::MP::Base::WKP{ $self->{wkname} };
    delete $AnyEvent::MP::Base::PORT{$_}
       for @{ $self->{names} };
 }

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines