ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/cvsroot/AnyEvent-MP/MP.pm
(Generate patch)

Comparing cvsroot/AnyEvent-MP/MP.pm (file contents):
Revision 1.139 by root, Thu Mar 22 20:07:31 2012 UTC vs.
Revision 1.144 by root, Fri Mar 23 21:16:25 2012 UTC

… …
47 # execute callbacks in $SELF port context 47 # execute callbacks in $SELF port context
48 my $timer = AE::timer 1, 0, psub { 48 my $timer = AE::timer 1, 0, psub {
49 die "kill the port, delayed"; 49 die "kill the port, delayed";
50 }; 50 };
51 51
52=head1 CURRENT STATUS 52 # distributed database - modification
53 db_set $family => $subkey [=> $value] # add a subkey
54 db_del $family => $subkey... # delete one or more subkeys
55 db_reg $family => $port [=> $value] # register a port
53 56
54 bin/aemp - stable. 57 # distributed database - queries
55 AnyEvent::MP - stable API, should work. 58 db_family $family => $cb->(\%familyhash)
56 AnyEvent::MP::Intro - explains most concepts. 59 db_keys $family => $cb->(\@keys)
57 AnyEvent::MP::Kernel - mostly stable API. 60 db_values $family => $cb->(\@values)
58 AnyEvent::MP::Global - stable API. 61
62 # distributed database - monitoring a family
63 db_mon $family => $cb->(\%familyhash, \@added, \@changed, \@deleted)
59 64
60=head1 DESCRIPTION 65=head1 DESCRIPTION
61 66
62This module (-family) implements a simple message passing framework. 67This module (-family) implements a simple message passing framework.
63 68
… …
178 183
179package AnyEvent::MP; 184package AnyEvent::MP;
180 185
181use AnyEvent::MP::Config (); 186use AnyEvent::MP::Config ();
182use AnyEvent::MP::Kernel; 187use AnyEvent::MP::Kernel;
183use AnyEvent::MP::Kernel qw(%NODE %PORT %PORT_DATA $UNIQ $RUNIQ $ID); 188use AnyEvent::MP::Kernel qw(
189 %NODE %PORT %PORT_DATA $UNIQ $RUNIQ $ID
190 add_node load_func
191
192 NODE $NODE
193 configure
194 node_of port_is_local
195 snd kil
196 db_set db_del
197 db_mon db_family db_keys db_values
198);
184 199
185use common::sense; 200use common::sense;
186 201
187use Carp (); 202use Carp ();
188 203
189use AE (); 204use AnyEvent ();
190use Guard (); 205use Guard ();
191 206
192use base "Exporter"; 207use base "Exporter";
193 208
194our $VERSION = $AnyEvent::MP::Config::VERSION; 209our $VERSION = $AnyEvent::MP::Config::VERSION;
195 210
196our @EXPORT = qw( 211our @EXPORT = qw(
197 NODE $NODE *SELF node_of after 212 NODE $NODE
198 configure 213 configure
214 node_of port_is_local
215 snd kil
216 db_set db_del
217 db_mon db_family db_keys db_values
218
219 *SELF
220
199 snd rcv mon mon_guard kil psub peval spawn cal 221 port rcv mon mon_guard psub peval spawn cal
200 port
201 db_set db_del db_reg 222 db_set db_del db_reg
202 db_mon db_family db_keys db_values 223 db_mon db_family db_keys db_values
224
225 after
203); 226);
204 227
205our $SELF; 228our $SELF;
206 229
207sub _self_die() { 230sub _self_die() {
… …
218 241
219=item $nodeid = node_of $port 242=item $nodeid = node_of $port
220 243
221Extracts and returns the node ID from a port ID or a node ID. 244Extracts and returns the node ID from a port ID or a node ID.
222 245
246=item $is_local = port_is_local $port
247
248Returns true iff the port is a local port.
249
223=item configure $profile, key => value... 250=item configure $profile, key => value...
224 251
225=item configure key => value... 252=item configure key => value...
226 253
227Before a node can talk to other nodes on the network (i.e. enter 254Before a node can talk to other nodes on the network (i.e. enter
… …
246=item force => $boolean (default false) 273=item force => $boolean (default false)
247 274
248IF true, then the values specified in the C<configure> will take 275IF true, then the values specified in the C<configure> will take
249precedence over any values configured via the rc file. The default is for 276precedence over any values configured via the rc file. The default is for
250the rc file to override any options specified in the program. 277the rc file to override any options specified in the program.
251
252=item secure => $pass->(@msg)
253
254In addition to specifying a boolean, you can specify a code reference that
255is called for every code execution attempt - the execution request is
256granted iff the callback returns a true value.
257
258Most of the time the callback should look only at
259C<$AnyEvent::MP::Kernel::SRCNODE> to make a decision, and not at the
260actual message (which can be about anything, and is mostly provided for
261diagnostic purposes).
262
263See F<semp setsecure> for more info.
264 278
265=back 279=back
266 280
267=over 4 281=over 4
268 282
… …
472 486
473sub rcv($@) { 487sub rcv($@) {
474 my $port = shift; 488 my $port = shift;
475 my ($nodeid, $portid) = split /#/, $port, 2; 489 my ($nodeid, $portid) = split /#/, $port, 2;
476 490
477 $NODE{$nodeid} == $NODE{""} 491 $nodeid eq $NODE
478 or Carp::croak "$port: rcv can only be called on local ports, caught"; 492 or Carp::croak "$port: rcv can only be called on local ports, caught";
479 493
480 while (@_) { 494 while (@_) {
481 if (ref $_[0]) { 495 if (ref $_[0]) {
482 if (my $self = $PORT_DATA{$portid}) { 496 if (my $self = $PORT_DATA{$portid}) {
… …
1041=item db_values $family => $cb->(\@values) 1055=item db_values $family => $cb->(\@values)
1042 1056
1043Same as C<db_family>, except it only queries the family I<values> and passes them 1057Same as C<db_family>, except it only queries the family I<values> and passes them
1044as array reference to the callback. 1058as array reference to the callback.
1045 1059
1046=item $guard = db_mon $family => $cb->($familyhash, \@added, \@changed, \@deleted) 1060=item $guard = db_mon $family => $cb->(\%familyhash, \@added, \@changed, \@deleted)
1047 1061
1048Creates a monitor on the given database family. Each time a key is set 1062Creates a monitor on the given database family. Each time a key is set
1049or or is deleted the callback is called with a hash containing the 1063or or is deleted the callback is called with a hash containing the
1050database family and three lists of added, changed and deleted subkeys, 1064database family and three lists of added, changed and deleted subkeys,
1051respectively. If no keys have changed then the array reference might be 1065respectively. If no keys have changed then the array reference might be
… …
1267 1281
1268=over 4 1282=over 4
1269 1283
1270=item AnyEvent::MP::Global no longer has group management functions. 1284=item AnyEvent::MP::Global no longer has group management functions.
1271 1285
1286At least not officially - the grp_* functions are still exported and might
1287work, but they will be removed in some later release.
1288
1272AnyEvent::MP now comes with a distributed database that is more 1289AnyEvent::MP now comes with a distributed database that is more
1273powerful. Its database families map closely to port groups, but the API 1290powerful. Its database families map closely to port groups, but the API
1274has changed (the functions are also now exported by AnyEvent::MP). Here is 1291has changed (the functions are also now exported by AnyEvent::MP). Here is
1275a rough porting guide: 1292a rough porting guide:
1276 1293

Diff Legend

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