1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910
|
# $Id: NFA.pm,v 1.14 2002/02/17 19:03:44 rcaputo Exp $
package POE::NFA;
use strict;
use vars qw($VERSION);
$VERSION = (qw($Revision: 1.14 $ ))[1];
use Carp qw(carp croak confess);
use POE::Preprocessor;
sub SPAWN_INLINES () { 'inline_states' }
sub SPAWN_OPTIONS () { 'options' }
sub OPT_TRACE () { 'trace' }
sub OPT_DEBUG () { 'debug' }
sub OPT_DEFAULT () { 'default' }
sub EN_DEFAULT () { '_default' }
sub EN_START () { '_start' }
sub EN_STOP () { '_stop' }
sub NFA_EN_GOTO_STATE () { 'poe_nfa_goto_state' }
sub NFA_EN_POP_STATE () { 'poe_nfa_pop_state' }
sub NFA_EN_PUSH_STATE () { 'poe_nfa_push_state' }
sub NFA_EN_STOP () { 'poe_nfa_stop' }
sub SELF_RUNSTATE () { 0 }
sub SELF_OPTIONS () { 1 }
sub SELF_STATES () { 2 }
sub SELF_CURRENT () { 3 }
sub SELF_STATE_STACK () { 4 }
sub SELF_INTERNALS () { 5 }
sub SELF_CURRENT_NAME () { 6 }
sub SELF_IS_IN_INTERNAL () { 7 }
sub STACK_STATE () { 0 }
sub STACK_EVENT () { 1 }
#------------------------------------------------------------------------------
macro fetch_id (<whence>) {
$POE::Kernel::poe_kernel->ID_session_to_id(<whence>)
}
macro define_trace (<const>) {
defined &TRACE_<const> or eval 'sub TRACE_<const> () { TRACE_DEFAULT }';
}
# MACROS END <-- search tag for editing
#------------------------------------------------------------------------------
BEGIN {
# ASSERT_DEFAULT changes the default value for other ASSERT_*
# constants. It inherits POE::Kernel's ASSERT_DEFAULT value, if
# it's present.
unless (defined &ASSERT_DEFAULT) {
if (defined &POE::Kernel::ASSERT_DEFAULT) {
eval( "sub ASSERT_DEFAULT () { " . &POE::Kernel::ASSERT_DEFAULT . " }" );
}
else {
eval 'sub ASSERT_DEFAULT () { 0 }';
}
};
# TRACE_DEFAULT changes the default value for other TRACE_*
# constants. It inherits POE::Kernel's TRACE_DEFAULT value, if
# it's present.
unless (defined &TRACE_DEFAULT) {
if (defined &POE::Kernel::TRACE_DEFAULT) {
eval( "sub TRACE_DEFAULT () { " . &POE::Kernel::TRACE_DEFAULT . " }" );
}
else {
eval 'sub TRACE_DEFAULT () { 0 }';
}
};
{% define_trace DESTROY %}
}
#------------------------------------------------------------------------------
# Export constants into calling packages. This is evil; perhaps
# EXPORT_OK instead? The parameters NFA has in common with SESSION
# (and other sessions) must be kept at the same offsets as each-other.
sub OBJECT () { 0 }
sub MACHINE () { 1 }
sub KERNEL () { 2 }
sub RUNSTATE () { 3 }
sub EVENT () { 4 }
sub SENDER () { 5 }
sub STATE () { 6 }
sub CALLER_FILE () { 7 }
sub CALLER_LINE () { 8 }
sub ARG0 () { 9 }
sub ARG1 () { 10 }
sub ARG2 () { 11 }
sub ARG3 () { 12 }
sub ARG4 () { 13 }
sub ARG5 () { 14 }
sub ARG6 () { 15 }
sub ARG7 () { 16 }
sub ARG8 () { 17 }
sub ARG9 () { 18 }
sub import {
my $package = caller();
no strict 'refs';
*{ $package . '::OBJECT' } = \&OBJECT;
*{ $package . '::MACHINE' } = \&MACHINE;
*{ $package . '::KERNEL' } = \&KERNEL;
*{ $package . '::RUNSTATE' } = \&RUNSTATE;
*{ $package . '::EVENT' } = \&EVENT;
*{ $package . '::SENDER' } = \&SENDER;
*{ $package . '::STATE' } = \&STATE;
*{ $package . '::ARG0' } = \&ARG0;
*{ $package . '::ARG1' } = \&ARG1;
*{ $package . '::ARG2' } = \&ARG2;
*{ $package . '::ARG3' } = \&ARG3;
*{ $package . '::ARG4' } = \&ARG4;
*{ $package . '::ARG5' } = \&ARG5;
*{ $package . '::ARG6' } = \&ARG6;
*{ $package . '::ARG7' } = \&ARG7;
*{ $package . '::ARG8' } = \&ARG8;
*{ $package . '::ARG9' } = \&ARG9;
}
#------------------------------------------------------------------------------
# Spawn a new state machine.
sub spawn {
my ($type, @params) = @_;
my @args;
# We treat the parameter list strictly as a hash. Rather than dying
# here with a Perl error, we'll catch it and blame it on the user.
croak "odd number of states/handlers (missing one or the other?)"
if @params & 1;
my %params = @params;
croak "$type requires a working Kernel"
unless defined $POE::Kernel::poe_kernel;
# Options are optional.
my $options = delete $params{+SPAWN_OPTIONS};
$options = { } unless defined $options;
# States are required.
croak "$type constructor requires a SPAWN_INLINES parameter"
unless exists $params{+SPAWN_INLINES};
my $states = delete $params{+SPAWN_INLINES};
# These are unknown.
croak( "$type constructor does not recognize these parameter names: ",
join(', ', sort(keys(%params)))
) if keys %params;
# Build me.
my $self =
bless [ { }, # SELF_RUNSTATE
$options, # SELF_OPTIONS
$states, # SELF_STATES
undef, # SELF_CURRENT
[ ], # SELF_STATE_STACK
{ }, # SELF_INTERNALS
'(undef)', # SELF_CURRENT_NAME
0, # SELF_IS_IN_INTERNAL
], $type;
# Register the machine with the POE kernel.
$POE::Kernel::poe_kernel->session_alloc($self);
# Return it for immediate reuse.
return $self;
}
#------------------------------------------------------------------------------
# Another good inheritance candidate.
sub DESTROY {
my $self = shift;
# NFA's data structures are destroyed through Perl's usual garbage
# collection. TRACE_DESTROY here just shows what's in the session
# before the destruction finishes.
TRACE_DESTROY and do {
print "----- NFA $self Leak Check -----\n";
print "-- Namespace (HEAP):\n";
foreach (sort keys (%{$self->[SELF_RUNSTATE]})) {
print " $_ = ", $self->[SELF_RUNSTATE]->{$_}, "\n";
}
print "-- Options:\n";
foreach (sort keys (%{$self->[SELF_OPTIONS]})) {
print " $_ = ", $self->[SELF_OPTIONS]->{$_}, "\n";
}
print "-- States:\n";
foreach (sort keys (%{$self->[SELF_STATES]})) {
print " $_ = ", $self->[SELF_STATES]->{$_}, "\n";
}
};
}
#------------------------------------------------------------------------------
sub _invoke_state {
my ($self, $sender, $event, $args, $file, $line) = @_;
# Trace the state invocation if tracing is enabled.
if ($self->[SELF_OPTIONS]->{+OPT_TRACE}) {
warn {% fetch_id $self %}, " -> $event\n";
}
# Discard troublesome things.
return if $event eq EN_START;
return if $event eq EN_STOP;
# Stop request has come through the queue. Shut us down.
if ($event eq NFA_EN_STOP) {
$POE::Kernel::poe_kernel->session_free( $self );
return;
}
# Make a state transition.
if ($event eq NFA_EN_GOTO_STATE) {
my ($new_state, $enter_event, @enter_args) = @$args;
# Make sure the new state exists.
die( {% fetch_id $self %},
" tried to enter nonexistent state '$new_state'\n"
)
unless exists $self->[SELF_STATES]->{$new_state};
# If an enter event was specified, make sure that exists too.
die( {% fetch_id $self %},
" tried to invoke nonexistent enter event '$enter_event' ",
"in state '$new_state'\n"
)
unless ( not defined $enter_event or
( length $enter_event and
exists $self->[SELF_STATES]->{$new_state}->{$enter_event}
)
);
# Invoke the current state's leave event, if one exists.
$self->_invoke_state( $self, 'leave', [], undef, undef )
if exists $self->[SELF_CURRENT]->{leave};
# Enter the new state.
$self->[SELF_CURRENT] = $self->[SELF_STATES]->{$new_state};
$self->[SELF_CURRENT_NAME] = $new_state;
# Invoke the new state's enter event, if requested.
$self->_invoke_state( $self, $enter_event, \@enter_args, undef, undef )
if defined $enter_event;
return undef;
}
# Push a state transition.
if ($event eq NFA_EN_PUSH_STATE) {
my @args = @$args;
push( @{$self->[SELF_STATE_STACK]},
[ $self->[SELF_CURRENT_NAME], # STACK_STATE
shift(@args), # STACK_EVENT
]
);
$self->_invoke_state( $self, NFA_EN_GOTO_STATE, \@args, undef, undef );
return undef;
}
# Pop a state transition.
if ($event eq NFA_EN_POP_STATE) {
die( {% fetch_id $self %},
" tried to pop a state from an empty stack\n"
)
unless @{ $self->[SELF_STATE_STACK] };
my ($previous_state, $previous_event) =
@{ pop @{ $self->[SELF_STATE_STACK] } };
$self->_invoke_state( $self, NFA_EN_GOTO_STATE,
[ $previous_state, $previous_event, @$args ],
undef, undef
);
return undef;
}
# Stop.
# Try to find the event handler in the current state or the internal
# event handlers used by wheels and the like.
my ( $handler, $is_in_internal );
if (exists $self->[SELF_CURRENT]->{$event}) {
$handler = $self->[SELF_CURRENT]->{$event};
}
elsif (exists $self->[SELF_INTERNALS]->{$event}) {
$handler = $self->[SELF_INTERNALS]->{$event};
$is_in_internal = ++$self->[SELF_IS_IN_INTERNAL];
}
# If it wasn't found in either of those, then check for _default in
# the current state.
elsif (exists $self->[SELF_CURRENT]->{+EN_DEFAULT}) {
# If we get this far, then there's a _default event to redirect
# the event to. Trace the redirection.
if ($self->[SELF_OPTIONS]->{+OPT_TRACE}) {
warn( {% fetch_id $self %},
" -> $event redirected to EN_DEFAULT in state ",
"'$self->[SELF_CURRENT_NAME]'\n"
);
}
$handler = $self->[SELF_CURRENT]->{+EN_DEFAULT};
# Fix up ARG0.. for _default.
$args = [ $event, $args ];
$event = EN_DEFAULT;
}
# No external event handler, no internal event handler, and no
# external _default handler. This is a grievous error, and now we
# must die.
else {
die( "a '$event' event was sent from $file at $line to session ",
{% fetch_id $self %}, ", but session ", {% fetch_id $self %},
" has neither that event nor a _default event to handle it ",
"in its current state, '$self->[SELF_CURRENT_NAME]'\n"
);
}
# Inline event handlers are invoked this way.
my $return;
if (ref($handler) eq 'CODE') {
$return = $handler->
( undef, # OBJECT
$self, # MACHINE
$POE::Kernel::poe_kernel, # KERNEL
$self->[SELF_RUNSTATE], # RUNSTATE
$event, # EVENT
$sender, # SENDER
$self->[SELF_CURRENT_NAME], # STATE
$file, # CALLER_FILE_NAME
$line, # CALLER_FILE_LINE
@$args # ARG0..
);
}
# Package and object handlers are invoked this way.
else {
my ($object, $method) = @$handler;
$return = $object->$method # OBJECT (package, implied)
( $self, # MACHINE
$POE::Kernel::poe_kernel, # KERNEL
$self->[SELF_RUNSTATE], # RUNSTATE
$event, # EVENT
$sender, # SENDER
$self->[SELF_CURRENT_NAME], # STATE
$file, # CALLER_FILE_NAME
$line, # CALLER_FILE_LINE
@$args # ARG0..
);
}
$self->[SELF_IS_IN_INTERNAL]-- if $is_in_internal;
return $return;
}
#------------------------------------------------------------------------------
# Add, remove or replace event handlers in the session. This is going
# to be tricky since wheels need this but the event handlers can't be
# limited to a single state. I think they'll go in a hidden internal
# state, or something.
macro validate_state {
carp "redefining state($name) for session(", {% fetch_id $self %}, ")"
if ( $self->[SELF_OPTIONS]->{+OPT_DEBUG} &&
(exists $self->[SELF_INTERNALS]->{$name})
);
}
sub register_state {
my ($self, $name, $handler, $method) = @_;
$method = $name unless defined $method;
# There is a handler, so try to define the state. This replaces an
# existing state.
if ($handler) {
# Coderef handlers are inline states.
if (ref($handler) eq 'CODE') {
{% validate_state %}
$self->[SELF_INTERNALS]->{$name} = $handler;
}
# Non-coderef handlers may be package or object states. See if
# the method belongs to the handler.
elsif ($handler->can($method)) {
{% validate_state %}
$self->[SELF_INTERNALS]->{$name} = [ $handler, $method ];
}
# Something's wrong. This code also seems wrong, since
# ref($handler) can't be 'CODE'.
else {
if ( (ref($handler) eq 'CODE') and
$self->[SELF_OPTIONS]->{+OPT_TRACE}
) {
carp( {% fetch_id $self %},
" : state($name) is not a proper ref - not registered"
)
}
else {
croak "object $handler does not have a '$method' method"
unless ($handler->can($method));
}
}
}
# No handler. Delete the state!
else {
delete $self->[SELF_INTERNALS]->{$name};
}
}
#------------------------------------------------------------------------------
# Return the session's ID. This is a thunk into POE::Kernel, where
# the session ID really lies. This is a good inheritance candidate.
sub ID {
{% fetch_id shift %}
}
#------------------------------------------------------------------------------
# Return the session's current state's name.
sub get_current_state {
my $self = shift;
return $self->[SELF_CURRENT_NAME];
}
#------------------------------------------------------------------------------
# Fetch the session's run state. In rare cases, libraries may need to
# break encapsulation this way, probably also using
# $kernel->get_current_session as an accessory to the crime.
sub get_runstate {
my $self = shift;
return $self->[SELF_RUNSTATE];
}
#------------------------------------------------------------------------------
# Set or fetch session options. This is virtually identical to
# POE::Session and a good inheritance candidate.
sub option {
my $self = shift;
my %return_values;
# Options are set in pairs.
while (@_ >= 2) {
my ($flag, $value) = splice(@_, 0, 2);
$flag = lc($flag);
# If the value is defined, then set the option.
if (defined $value) {
# Change some handy values into boolean representations. This
# clobbers the user's original values for the sake of DWIM-ism.
($value = 1) if ($value =~ /^(on|yes|true)$/i);
($value = 0) if ($value =~ /^(no|off|false)$/i);
$return_values{$flag} = $self->[SELF_OPTIONS]->{$flag};
$self->[SELF_OPTIONS]->{$flag} = $value;
}
# Remove the option if the value is undefined.
else {
$return_values{$flag} = delete $self->[SELF_OPTIONS]->{$flag};
}
}
# If only one option is left, then there's no value to set, so we
# fetch its value.
if (@_) {
my $flag = lc(shift);
$return_values{$flag} =
( exists($self->[SELF_OPTIONS]->{$flag})
? $self->[SELF_OPTIONS]->{$flag}
: undef
);
}
# If only one option was set or fetched, then return it as a scalar.
# Otherwise return it as a hash of option names and values.
my @return_keys = keys(%return_values);
if (@return_keys == 1) {
return $return_values{$return_keys[0]};
}
else {
return \%return_values;
}
}
#------------------------------------------------------------------------------
# This stuff is identical to the stuff in POE::Session. Good
# inheritance candidate.
# Create an anonymous sub that, when called, posts an event back to a
# session. This is highly experimental code to support Tk widgets and
# maybe Event callbacks. There's no guarantee that this code works
# yet, nor is there one that it'll be here in the next version.
# This maps postback references (stringified; blessing, and thus
# refcount, removed) to parent session IDs. Members are set when
# postbacks are created, and postbacks' DESTROY methods use it to
# perform the necessary cleanup when they go away. Thanks to njt for
# steering me right on this one.
my %postback_parent_id;
# I assume that when the postback owner loses all reference to it,
# they are done posting things back to us. That's when the postback's
# DESTROY is triggered, and referential integrity is maintained.
sub POE::NFA::Postback::DESTROY {
my $self = shift;
my $parent_id = delete $postback_parent_id{$self};
$POE::Kernel::poe_kernel->refcount_decrement( $parent_id, 'postback' );
}
# Create a postback closure, maintaining referential integrity in the
# process. The next step is to give it to something that expects to
# be handed a callback.
sub postback {
my ($self, $event, @etc) = @_;
my $id = {% fetch_id $self %};
my $postback = bless
sub {
$POE::Kernel::poe_kernel->post( $id, $event, [ @etc ], [ @_ ] );
0;
}, 'POE::NFA::Postback';
$postback_parent_id{$postback} = $id;
$POE::Kernel::poe_kernel->refcount_increment( $id, 'postback' );
$postback;
}
#==============================================================================
# New methods.
sub goto_state {
my ($self, $new_state, $entry_event, @entry_args) = @_;
if (defined $self->[SELF_CURRENT]) {
$POE::Kernel::poe_kernel->post( $self, NFA_EN_GOTO_STATE,
$new_state, $entry_event, @entry_args
);
}
else {
$POE::Kernel::poe_kernel->call( $self, NFA_EN_GOTO_STATE,
$new_state, $entry_event, @entry_args
);
}
}
sub stop {
my $self = shift;
$POE::Kernel::poe_kernel->post( $self, NFA_EN_STOP );
}
sub call_state {
my ($self, $return_event, $new_state, $entry_event, @entry_args) = @_;
$POE::Kernel::poe_kernel->post( $self, NFA_EN_PUSH_STATE,
$return_event,
$new_state, $entry_event, @entry_args
);
}
sub return_state {
my ($self, @entry_args) = @_;
$POE::Kernel::poe_kernel->post( $self, NFA_EN_POP_STATE, @entry_args );
}
###############################################################################
1;
__END__
=head1 NAME
POE::NFA - event driven nondeterministic finite automaton
=head1 SYNOPSIS
# Import POE::NFA constants.
use POE::NFA;
# Define a machine's states, each state's events, and the coderefs
# that handle each event.
my %states =
( start =>
{ event_one => \&handler_one,
event_two => \&handler_two,
...,
},
other_state =>
{ event_n => \&handler_n,
event_n_plus_one => \&handler_n_plus_one,
...,
},
...,
);
# Spawn an NFA and enter its initial state.
POE::NFA->spawn( inline_states => \%states
)->goto_state( $start_state, $start_event );
# Move to a new state.
$machine->goto_state( $new_state, $new_event, @args );
# Put the current state on a stack, and move to a new one.
$machine->call_state( $return_event, $new_state, $new_event, @args );
# Move to the previous state on the call stack.
$machine->return_state( @returns );
# Forcibly stop a machine.
$machine->stop();
=head1 DESCRIPTION
POE::NFA combines a runtime context with an event driven
nondeterministic finite state machine. Its main difference from
POE::Session is that it can embody many different states, and each
state has a separate group of event handlers. Events are delivered to
the appropriate handlers in the current state only, and moving to a
new state is an inexpensive way to change what happens when an event
arrives.
This manpage only discusses POE::NFA's differences from POE::Session.
It assumes a familiarity with Session's manpage, and it will refer
there whenever possible.
=head1 PUBLIC METHODS
See POE::Session's documentation.
=over 2
=item ID
See POE::Session.
=item create
POE::NFA does not have a create() constructor.
=item get_current_state
C<get_current_state()> returns the name of the machine's current
state. This method is mainly used for getting the state of some other
machine. In the machine's own event handlers, it's easier to just
access C<$_[STATE]>.
=item get_runstate
C<get_runstate()> returns the machine's current runstate. This is
equivalent to C<get_heap()> in POE::Session. In the machine's own
handlers, it's easier to just access C<$_[RUNSTATE]>.
=item new
POE::NFA does not have a new() constructor.
=item spawn STATE_NAME => HANDLERS_HASHREF, ...
C<spawn()> is POE::NFA's session constructor. It reflects the idea
that new state machines are spawned like threads or processes. The
machine itself is defined as a list of state names and hashrefs
mapping events to handlers within each state.
my %machine =
( state_1 =>
{ event_1 => \&handler_1,
event_2 => \&handler_2,
},
state_2 =>
{ event_1 => \&handler_3,
event_2 => \&handler_4,
},
);
Each state may define the same events. The proper handler will be
called depending on the machine's current state. For example, if
C<event_1> is dispatched while the previous machine is in C<state_2>,
then C<&handler_3> is called to handle the event. It happens because
the state -> event -> handler map looks like this:
$machine{state_2}->{event_1} = \&handler_3;
The spawn() method currently only accepts C<inline_states> and
C<options>. Others will be added as necessary.
=item option
See POE::Session.
=item postback
See POE::Session.
=item goto_state NEW_STATE
=item goto_state NEW_STATE, ENTRY_EVENT
=item goto_state NEW_STATE, ENTRY_EVENT, EVENT_ARGS
C<goto_state> puts the machine into a new state. If an ENTRY_EVENT is
specified, then that event will be dispatched when the machine enters
the new state. EVENT_ARGS, if included, will be passed to the entry
event's handler via C<ARG0..$#_>.
my $machine = $_[MACHINE];
$machine->goto_state( 'next_state' );
$machine->goto_state( 'next_state', 'call_this_event' );
$machine->goto_state( 'next_state', 'call_this_event', @with_these_args );
=item stop
C<stop()> forces a machine to stop. It's similar to posting C<_stop>
to the machine, but it performs some extra NFA cleanup. The machine
will also stop gracefully if it runs out of things to do, just like
POE::Session.
C<stop()> is heavy-handed. It will force resource cleanup. Circular
references in the machine's C<RUNSTATE> are not POE's responsibility
and may cause memory leaks.
$_[MACHINE]->stop();
=item call_state RETURN_EVENT, NEW_STATE
=item call_state RETURN_EVENT, NEW_STATE, ENTRY_EVENT
=item call_state RETURN_EVENT, NEW_STATE, ENTRY_EVENT, EVENT_ARGS
C<call_state()> is similar to C<goto_state()>, but it pushes the
current state on a stack. At some point a C<return_state()> call will
pop the saved state and cause the machine to return there.
C<call_state()> accepts one parameter different from C<goto_state()>,
and that is C<RETURN_EVENT>. C<RETURN_EVENT> specifies the event to
emit when the machine returns to the calling state. That is, the
called state returns to the caller's C<RETURN_EVENT> handler. The
C<RETURN_EVENT> handler receives C<return_states()>'s C<RETURN_ARGS>
via C<ARG0..$#_>.
$machine->call_state( 'return_here', 'new_state', 'entry_event' );
As with C<goto_state()>, C<ENTRY_EVENT> is the event that will be
emitted once the machine enters its new state. C<ENTRY_ARGS> are
parameters passed to the C<ENTRY_EVENT> handler via C<ARG0..$#_>.
=item return_state
=item return_state RETURN_ARGS
C<return_state()> returns to the most recent state which called
C<call_state()>, optionally invoking the calling state's
C<RETURN_EVENT>, possibly with C<RETURN_ARGS> passed to it via
C<ARG0..$#_>.
$_[MACHINE]->return_state( );
$_[MACHINE]->return_state( 'success', $success_value );
=back
=head1 PREDEFINED EVENT FIELDS
POE::NFA's predefined event fields are the same as POE::Session's with
the following three exceptions.
=over 2
=item MACHINE
C<MACHINE> is equivalent to Session's C<SESSION> field. It hold a
reference to the current state machine, and it's useful for calling
methods on it. See POE::Session's C<SESSION> field for more
information.
$_[MACHINE]->goto_state( $next_state, $next_state_entry_event );
=item RUNSTATE
C<RUNSTATE> is equivalent to Session's C<HEAP> field. It holds an
anoymous hash reference which POE is guaranteed not to touch. See
POE::Session's C<HEAP> field for more information.
=item STATE
C<STATE> contains the name of the machine's current state. It is not
equivalent to anything from POE::Session.
=item EVENT
C<EVENT> is equivalent to Session's C<STATE> field. It holds the name
of the event which invoked the current handler. See POE::Session's
C<STATE> field for more information.
=back
=head1 PREDEFINED EVENT NAMES
POE::NFA defines four events of its own. See POE::Session's
"PREDEFINED EVENT NAMES" section for more information about other
predefined events.
=over 2
=item poe_nfa_goto_state
=item poe_nfa_pop_state
=item poe_nfa_push_state
=item poe_nfa_stop
POE::NFA uses these states internally to manage state transitions and
stopping the machine in an orderly fashion. There may be others in
the future, and they will all follow the /^poe_nfa_/ naming
convention. To avoid conflicts, please don't define events beginning
with "poe_nfa_".
=back
=head1 MISCELLANEOUS CONCEPTS
=head2 States' Return Values
See POE::Session.
=head2 Resource Tracking
See POE::Session.
=head2 Synchronous and Asynchronous Events
See POE::Session.
=head2 Postbacks
See POE::Session.
=head2 Job Control and Family Values
See POE::Session.
=head1 SEE ALSO
Many of POE::NFA's features are taken directly from POE::Session.
Please see L<POE::Session> for more information.
The SEE ALSO section in L<POE> contains a table of contents covering
the entire POE distribution.
=head1 BUGS
See POE::Session's documentation.
Object and package states aren't implemented. Some other stuff is
just lashed together with twine. POE::NFA needs some more work.
=head1 AUTHORS & COPYRIGHTS
Please see L<POE> for more information about authors and contributors.
=cut
|