--- AnyEvent-MP/MP.pm	2009/08/14 16:15:37	1.54
+++ AnyEvent-MP/MP.pm	2009/08/24 08:06:49	1.61
@@ -128,9 +128,9 @@
 our $VERSION = $AnyEvent::MP::Kernel::VERSION;
 
 our @EXPORT = qw(
-   NODE $NODE *SELF node_of _any_
+   NODE $NODE *SELF node_of after
    resolve_node initialise_node
-   snd rcv mon kil reg psub spawn
+   snd rcv mon mon_guard kil reg psub spawn
    port
 );
 
@@ -199,12 +199,20 @@
 will try to connect to all of them and will become a slave attached to the
 first node it can successfully connect to.
 
+Note that slave nodes cannot change their name, and consequently, their
+master, so if the master goes down, the slave node will not function well
+anymore until it can re-establish conenciton to its master. This makes
+slave nodes unsuitable for long-term nodes or fault-tolerant networks.
+
 =back
 
 This function will block until all nodes have been resolved and, for slave
 nodes, until it has successfully established a connection to a master
 server.
 
+All the seednodes will also be specially marked to automatically retry
+connecting to them infinitely.
+
 Example: become a public node listening on the guessed noderef, or the one
 specified via C<aemp> for the current node. This should be the most common
 form of invocation for "daemon"-type nodes.
@@ -390,7 +398,7 @@
    my $port = shift;
    my ($noderef, $portid) = split /#/, $port, 2;
 
-   ($NODE{$noderef} || add_node $noderef) == $NODE{""}
+   $NODE{$noderef} == $NODE{""}
       or Carp::croak "$port: rcv can only be called on local ports, caught";
 
    while (@_) {
@@ -499,6 +507,9 @@
 port). After the monitoring action was invoked, further messages might get
 delivered again.
 
+Note that monitoring-actions are one-shot: once released, they are removed
+and will not trigger again.
+
 In the first form (callback), the callback is simply called with any
 number of C<@reason> elements (no @reason means that the port was deleted
 "normally"). Note also that I<< the callback B<must> never die >>, so use
@@ -668,57 +679,32 @@
    $_[0] =~ /::/
       or Carp::croak "spawn init function must be a fully-qualified name, caught";
 
-   ($NODE{$noderef} || add_node $noderef)
-      ->send (["", "AnyEvent::MP::_spawn" => $id, @_]);
+   snd_to_func $noderef, "AnyEvent::MP::_spawn" => $id, @_;
 
    "$noderef#$id"
 }
 
-=back
-
-=head1 NODE MESSAGES
+=item after $timeout, @msg
 
-Nodes understand the following messages sent to them. Many of them take
-arguments called C<@reply>, which will simply be used to compose a reply
-message - C<$reply[0]> is the port to reply to, C<$reply[1]> the type and
-the remaining arguments are simply the message data.
+=item after $timeout, $callback
 
-While other messages exist, they are not public and subject to change.
+Either sends the given message, or call the given callback, after the
+specified number of seconds.
 
-=over 4
+This is simply a utility function that come sin handy at times.
 
 =cut
 
-=item lookup => $name, @reply
-
-Replies with the port ID of the specified well-known port, or C<undef>.
-
-=item devnull => ...
-
-Generic data sink/CPU heat conversion.
-
-=item relay => $port, @msg
+sub after($@) {
+   my ($timeout, @action) = @_;
 
-Simply forwards the message to the given port.
-
-=item eval => $string[ @reply]
-
-Evaluates the given string. If C<@reply> is given, then a message of the
-form C<@reply, $@, @evalres> is sent.
-
-Example: crash another node.
-
-   snd $othernode, eval => "exit";
-
-=item time => @reply
-
-Replies the the current node time to C<@reply>.
-
-Example: tell the current node to send the current time to C<$myport> in a
-C<timereply> message.
-
-   snd $NODE, time => $myport, timereply => 1, 2;
-   # => snd $myport, timereply => 1, 2, <time>
+   my $t; $t = AE::timer $timeout, 0, sub {
+      undef $t;
+      ref $action[0]
+         ? $action[0]()
+         : snd @action;
+   };
+}
 
 =back