Chris@16: // Copyright 2008 Christophe Henry Chris@16: // henry UNDERSCORE christophe AT hotmail DOT com Chris@16: // This is an extended version of the state machine available in the boost::mpl library Chris@16: // Distributed under the same license as the original. Chris@16: // Copyright for the original version: Chris@16: // Copyright 2005 David Abrahams and Aleksey Gurtovoy. Distributed Chris@16: // under the Boost Software License, Version 1.0. (See accompanying Chris@16: // file LICENSE_1_0.txt or copy at Chris@16: // http://www.boost.org/LICENSE_1_0.txt) Chris@16: Chris@16: #ifndef BOOST_MSM_BACK_STATEMACHINE_H Chris@16: #define BOOST_MSM_BACK_STATEMACHINE_H Chris@16: Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: Chris@16: #include Chris@16: Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #ifndef BOOST_NO_RTTI Chris@16: #include Chris@16: #endif Chris@16: Chris@16: #include Chris@16: Chris@16: #include Chris@16: Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(accept_sig) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(no_automatic_create) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(non_forwarding_flag) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(direct_entry) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(initial_event) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(final_event) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(do_serialize) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(history_policy) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(fsm_check) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(compile_policy) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(queue_container_policy) Chris@16: BOOST_MPL_HAS_XXX_TRAIT_DEF(using_declared_table) Chris@16: Chris@16: #ifndef BOOST_MSM_CONSTRUCTOR_ARG_SIZE Chris@16: #define BOOST_MSM_CONSTRUCTOR_ARG_SIZE 5 // default max number of arguments for constructors Chris@16: #endif Chris@16: Chris@16: namespace boost { namespace msm { namespace back Chris@16: { Chris@16: // event used internally for wrapping a direct entry Chris@16: template Chris@16: struct direct_entry_event Chris@16: { Chris@16: typedef int direct_entry; Chris@16: typedef StateType active_state; Chris@16: typedef Event contained_event; Chris@16: Chris@16: direct_entry_event(Event const& evt):m_event(evt){} Chris@16: Event const& m_event; Chris@16: }; Chris@16: Chris@16: // This declares the statically-initialized dispatch_table instance. Chris@16: template Chris@16: const boost::msm::back::dispatch_table Chris@16: dispatch_table::instance; Chris@16: Chris@16: BOOST_PARAMETER_TEMPLATE_KEYWORD(front_end) Chris@16: BOOST_PARAMETER_TEMPLATE_KEYWORD(history_policy) Chris@16: BOOST_PARAMETER_TEMPLATE_KEYWORD(compile_policy) Chris@16: BOOST_PARAMETER_TEMPLATE_KEYWORD(fsm_check_policy) Chris@16: BOOST_PARAMETER_TEMPLATE_KEYWORD(queue_container_policy) Chris@16: Chris@16: typedef ::boost::parameter::parameters< Chris@16: ::boost::parameter::required< ::boost::msm::back::tag::front_end > Chris@16: , ::boost::parameter::optional< Chris@16: ::boost::parameter::deduced< ::boost::msm::back::tag::history_policy>, has_history_policy< ::boost::mpl::_ > Chris@16: > Chris@16: , ::boost::parameter::optional< Chris@16: ::boost::parameter::deduced< ::boost::msm::back::tag::compile_policy>, has_compile_policy< ::boost::mpl::_ > Chris@16: > Chris@16: , ::boost::parameter::optional< Chris@16: ::boost::parameter::deduced< ::boost::msm::back::tag::fsm_check_policy>, has_fsm_check< ::boost::mpl::_ > Chris@16: > Chris@16: , ::boost::parameter::optional< Chris@16: ::boost::parameter::deduced< ::boost::msm::back::tag::queue_container_policy>, Chris@16: has_queue_container_policy< ::boost::mpl::_ > Chris@16: > Chris@16: > state_machine_signature; Chris@16: Chris@16: // just here to disable use of proto when not needed Chris@16: template Chris@16: struct make_euml_terminal; Chris@16: template Chris@16: struct make_euml_terminal >::type> Chris@16: {}; Chris@16: template Chris@16: struct make_euml_terminal >::type> Chris@16: : public proto::extends::type, T, boost::msm::state_domain> Chris@16: {}; Chris@16: Chris@16: // library-containing class for state machines. Pass the actual FSM class as Chris@16: // the Concrete parameter. Chris@16: // A0=Derived,A1=NoHistory,A2=CompilePolicy,A3=FsmCheckPolicy > Chris@16: template < Chris@16: class A0 Chris@16: , class A1 = parameter::void_ Chris@16: , class A2 = parameter::void_ Chris@16: , class A3 = parameter::void_ Chris@16: , class A4 = parameter::void_ Chris@16: > Chris@16: class state_machine : //public Derived Chris@16: public ::boost::parameter::binding< Chris@16: typename state_machine_signature::bind::type, ::boost::msm::back::tag::front_end Chris@16: >::type Chris@16: , public make_euml_terminal, Chris@16: typename ::boost::parameter::binding< Chris@16: typename state_machine_signature::bind::type, ::boost::msm::back::tag::front_end Chris@16: >::type Chris@16: > Chris@16: { Chris@16: public: Chris@16: // Create ArgumentPack Chris@16: typedef typename Chris@16: state_machine_signature::bind::type Chris@16: state_machine_args; Chris@16: Chris@16: // Extract first logical parameter. Chris@16: typedef typename ::boost::parameter::binding< Chris@16: state_machine_args, ::boost::msm::back::tag::front_end>::type Derived; Chris@16: Chris@16: typedef typename ::boost::parameter::binding< Chris@16: state_machine_args, ::boost::msm::back::tag::history_policy, NoHistory >::type HistoryPolicy; Chris@16: Chris@16: typedef typename ::boost::parameter::binding< Chris@16: state_machine_args, ::boost::msm::back::tag::compile_policy, favor_runtime_speed >::type CompilePolicy; Chris@16: Chris@16: typedef typename ::boost::parameter::binding< Chris@16: state_machine_args, ::boost::msm::back::tag::fsm_check_policy, no_fsm_check >::type FsmCheckPolicy; Chris@16: Chris@16: typedef typename ::boost::parameter::binding< Chris@16: state_machine_args, ::boost::msm::back::tag::queue_container_policy, Chris@16: queue_container_deque >::type QueueContainerPolicy; Chris@16: Chris@16: private: Chris@16: Chris@16: typedef boost::msm::back::state_machine< Chris@16: A0,A1,A2,A3,A4> library_sm; Chris@16: Chris@16: typedef ::boost::function< Chris@16: execute_return ()> transition_fct; Chris@16: typedef ::boost::function< Chris@16: execute_return () > deferred_fct; Chris@16: typedef typename QueueContainerPolicy:: Chris@16: template In< Chris@16: std::pair >::type deferred_events_queue_t; Chris@16: typedef typename QueueContainerPolicy:: Chris@16: template In::type events_queue_t; Chris@16: Chris@16: typedef typename boost::mpl::eval_if< Chris@16: typename is_active_state_switch_policy::type, Chris@16: get_active_state_switch_policy, Chris@16: // default Chris@16: ::boost::mpl::identity Chris@16: >::type active_state_switching; Chris@16: Chris@16: typedef bool (*flag_handler)(library_sm const&); Chris@16: Chris@16: // all state machines are friend with each other to allow embedding any of them in another fsm Chris@16: template friend class boost::msm::back::state_machine; Chris@16: Chris@16: // helper to add, if needed, visitors to all states Chris@16: // version without visitors Chris@16: template Chris@16: struct visitor_fct_helper Chris@16: { Chris@16: public: Chris@16: visitor_fct_helper(){} Chris@16: void fill_visitors(int) Chris@16: { Chris@16: } Chris@16: template Chris@16: void insert(int,FCT) Chris@16: { Chris@16: } Chris@16: template Chris@16: void execute(int,VISITOR) Chris@16: { Chris@16: } Chris@16: }; Chris@16: // version with visitors Chris@16: template Chris@16: struct visitor_fct_helper >::type> Chris@16: { Chris@16: public: Chris@16: visitor_fct_helper():m_state_visitors(){} Chris@16: void fill_visitors(int number_of_states) Chris@16: { Chris@16: m_state_visitors.resize(number_of_states); Chris@16: } Chris@16: template Chris@16: void insert(int index,FCT fct) Chris@16: { Chris@16: m_state_visitors[index]=fct; Chris@16: } Chris@16: void execute(int index) Chris@16: { Chris@16: m_state_visitors[index](); Chris@16: } Chris@16: Chris@16: #define MSM_VISITOR_HELPER_EXECUTE_SUB(z, n, unused) ARG ## n vis ## n Chris@16: #define MSM_VISITOR_HELPER_EXECUTE(z, n, unused) \ Chris@16: template \ Chris@16: void execute(int index BOOST_PP_COMMA_IF(n) \ Chris@16: BOOST_PP_ENUM(n, MSM_VISITOR_HELPER_EXECUTE_SUB, ~ ) ) \ Chris@16: { \ Chris@16: m_state_visitors[index](BOOST_PP_ENUM_PARAMS(n,vis)); \ Chris@16: } Chris@16: BOOST_PP_REPEAT_FROM_TO(1,BOOST_PP_ADD(BOOST_MSM_VISITOR_ARG_SIZE,1), MSM_VISITOR_HELPER_EXECUTE, ~) Chris@16: #undef MSM_VISITOR_HELPER_EXECUTE Chris@16: #undef MSM_VISITOR_HELPER_EXECUTE_SUB Chris@16: private: Chris@16: typedef typename StateType::accept_sig::type visitor_fct; Chris@16: typedef std::vector visitors; Chris@16: Chris@16: visitors m_state_visitors; Chris@16: }; Chris@16: Chris@16: template Chris@16: struct deferred_msg_queue_helper Chris@16: { Chris@101: void clear(){} Chris@16: }; Chris@16: template Chris@16: struct deferred_msg_queue_helper::type,int >::type> Chris@16: { Chris@16: public: Chris@16: deferred_msg_queue_helper():m_deferred_events_queue(){} Chris@101: void clear() Chris@101: { Chris@101: m_deferred_events_queue.clear(); Chris@101: } Chris@16: deferred_events_queue_t m_deferred_events_queue; Chris@16: }; Chris@16: Chris@16: public: Chris@16: // tags Chris@16: typedef int composite_tag; Chris@16: Chris@16: // in case someone needs to know Chris@16: typedef HistoryPolicy history_policy; Chris@16: Chris@16: struct InitEvent { }; Chris@16: struct ExitEvent { }; Chris@16: // flag handling Chris@16: struct Flag_AND Chris@16: { Chris@16: typedef std::logical_and type; Chris@16: }; Chris@16: struct Flag_OR Chris@16: { Chris@16: typedef std::logical_or type; Chris@16: }; Chris@16: typedef typename Derived::BaseAllStates BaseState; Chris@16: typedef Derived ConcreteSM; Chris@16: Chris@16: // if the front-end fsm provides an initial_event typedef, replace InitEvent by this one Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename has_initial_event::type, Chris@16: get_initial_event, Chris@16: ::boost::mpl::identity Chris@16: >::type fsm_initial_event; Chris@16: Chris@16: // if the front-end fsm provides an exit_event typedef, replace ExitEvent by this one Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename has_final_event::type, Chris@16: get_final_event, Chris@16: ::boost::mpl::identity Chris@16: >::type fsm_final_event; Chris@16: Chris@16: template Chris@16: struct exit_pt : public ExitPoint Chris@16: { Chris@16: // tags Chris@16: typedef ExitPoint wrapped_exit; Chris@16: typedef int pseudo_exit; Chris@16: typedef library_sm owner; Chris@16: typedef int no_automatic_create; Chris@16: typedef typename Chris@16: ExitPoint::event Event; Chris@16: typedef ::boost::function Chris@16: forwarding_function; Chris@16: Chris@16: // forward event to the higher-level FSM Chris@16: template Chris@16: void forward_event(ForwardEvent const& incomingEvent) Chris@16: { Chris@16: // use helper to forward or not Chris@16: ForwardHelper< ::boost::is_convertible::value>::helper(incomingEvent,m_forward); Chris@16: } Chris@16: void set_forward_fct(::boost::function fct) Chris@16: { Chris@16: m_forward = fct; Chris@16: } Chris@16: exit_pt():m_forward(){} Chris@16: // by assignments, we keep our forwarding functor unchanged as our containing SM did not change Chris@16: template Chris@101: exit_pt(RHS&):m_forward(){} Chris@16: exit_pt& operator= (const exit_pt& ) Chris@16: { Chris@16: return *this; Chris@16: } Chris@16: private: Chris@16: forwarding_function m_forward; Chris@16: Chris@16: // using partial specialization instead of enable_if because of VC8 bug Chris@16: template Chris@16: struct ForwardHelper Chris@16: { Chris@16: template Chris@16: static void helper(ForwardEvent const& ,forwarding_function& ) Chris@16: { Chris@16: // Not our event, assert Chris@16: BOOST_ASSERT(false); Chris@16: } Chris@16: }; Chris@16: template Chris@16: struct ForwardHelper Chris@16: { Chris@16: template Chris@16: static void helper(ForwardEvent const& incomingEvent,forwarding_function& forward_fct) Chris@16: { Chris@16: // call if handler set, if not, this state is simply a terminate state Chris@16: if (forward_fct) Chris@16: forward_fct(incomingEvent); Chris@16: } Chris@16: }; Chris@16: Chris@16: }; Chris@16: template Chris@16: struct entry_pt : public EntryPoint Chris@16: { Chris@16: // tags Chris@16: typedef EntryPoint wrapped_entry; Chris@16: typedef int pseudo_entry; Chris@16: typedef library_sm owner; Chris@16: typedef int no_automatic_create; Chris@16: }; Chris@16: template Chris@16: struct direct : public EntryPoint Chris@16: { Chris@16: // tags Chris@16: typedef EntryPoint wrapped_entry; Chris@16: typedef int explicit_entry_state; Chris@16: typedef library_sm owner; Chris@16: typedef int no_automatic_create; Chris@16: }; Chris@16: typedef typename get_number_of_regions::type nr_regions; Chris@16: // Template used to form rows in the transition table Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct row_ Chris@16: { Chris@16: //typedef typename ROW::Source T1; Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: // if the source is an exit pseudo state, then Chris@16: // current_state_type becomes the result of get_owner Chris@16: // meaning the containing SM from which the exit occurs Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename has_pseudo_exit::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity >::type current_state_type; Chris@16: Chris@16: // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry Chris@16: // else if Target is an explicit_entry, next_state_type becomes the result of get_owner Chris@16: // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename ::boost::mpl::is_sequence::type, Chris@16: get_fork_owner, Chris@16: ::boost::mpl::eval_if< Chris@16: typename has_no_automatic_create::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity > Chris@16: >::type next_state_type; Chris@16: Chris@16: // if a guard condition is here, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list ) ) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event const& evt) Chris@16: { Chris@16: Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_STATIC_CONSTANT(int, next_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active Chris@16: if (has_pseudo_exit::type::value && Chris@16: !is_exit_state_active >(fsm)) Chris@16: { Chris@16: return HANDLED_FALSE; Chris@16: } Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state); Chris@16: Chris@16: // the guard condition has already been checked Chris@16: execute_exit Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state); Chris@16: Chris@16: // then call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list); Chris@16: fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state); Chris@16: Chris@16: // and finally the entry method of the new current state Chris@16: convert_event_and_execute_entry Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state); Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: Chris@16: // row having only a guard condition Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct g_row_ Chris@16: { Chris@16: //typedef typename ROW::Source T1; Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: // if the source is an exit pseudo state, then Chris@16: // current_state_type becomes the result of get_owner Chris@16: // meaning the containing SM from which the exit occurs Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename has_pseudo_exit::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity >::type current_state_type; Chris@16: Chris@16: // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry Chris@16: // else if Target is an explicit_entry, next_state_type becomes the result of get_owner Chris@16: // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename ::boost::mpl::is_sequence::type, Chris@16: get_fork_owner, Chris@16: ::boost::mpl::eval_if< Chris@16: typename has_no_automatic_create::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity > Chris@16: >::type next_state_type; Chris@16: Chris@16: // if a guard condition is defined, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list )) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event const& evt) Chris@16: { Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_STATIC_CONSTANT(int, next_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active Chris@16: if (has_pseudo_exit::type::value && Chris@16: !is_exit_state_active >(fsm)) Chris@16: { Chris@16: return HANDLED_FALSE; Chris@16: } Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state); Chris@16: Chris@16: // the guard condition has already been checked Chris@16: execute_exit Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state); Chris@16: fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state); Chris@16: Chris@16: // and finally the entry method of the new current state Chris@16: convert_event_and_execute_entry Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state); Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: Chris@16: // row having only an action method Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct a_row_ Chris@16: { Chris@16: //typedef typename ROW::Source T1; Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: // if the source is an exit pseudo state, then Chris@16: // current_state_type becomes the result of get_owner Chris@16: // meaning the containing SM from which the exit occurs Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename has_pseudo_exit::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity >::type current_state_type; Chris@16: Chris@16: // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry Chris@16: // else if Target is an explicit_entry, next_state_type becomes the result of get_owner Chris@16: // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename ::boost::mpl::is_sequence::type, Chris@16: get_fork_owner, Chris@16: ::boost::mpl::eval_if< Chris@16: typename has_no_automatic_create::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity > Chris@16: >::type next_state_type; Chris@16: Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event const& evt) Chris@16: { Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_STATIC_CONSTANT(int, next_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: Chris@16: // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active Chris@16: if (has_pseudo_exit::type::value && Chris@16: !is_exit_state_active >(fsm)) Chris@16: { Chris@16: return HANDLED_FALSE; Chris@16: } Chris@16: fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state); Chris@16: Chris@16: // no need to check the guard condition Chris@16: // first call the exit method of the current state Chris@16: execute_exit Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state); Chris@16: Chris@16: // then call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list); Chris@16: fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state); Chris@16: Chris@16: // and finally the entry method of the new current state Chris@16: convert_event_and_execute_entry Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state); Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: Chris@16: // row having no guard condition or action, simply transitions Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct _row_ Chris@16: { Chris@16: //typedef typename ROW::Source T1; Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: // if the source is an exit pseudo state, then Chris@16: // current_state_type becomes the result of get_owner Chris@16: // meaning the containing SM from which the exit occurs Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename has_pseudo_exit::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity >::type current_state_type; Chris@16: Chris@16: // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry Chris@16: // else if Target is an explicit_entry, next_state_type becomes the result of get_owner Chris@16: // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename ::boost::mpl::is_sequence::type, Chris@16: get_fork_owner, Chris@16: ::boost::mpl::eval_if< Chris@16: typename has_no_automatic_create::type, Chris@16: get_owner, Chris@16: ::boost::mpl::identity > Chris@16: >::type next_state_type; Chris@16: Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event const& evt) Chris@16: { Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_STATIC_CONSTANT(int, next_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: Chris@16: // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active Chris@16: if (has_pseudo_exit::type::value && Chris@16: !is_exit_state_active >(fsm)) Chris@16: { Chris@16: return HANDLED_FALSE; Chris@16: } Chris@16: fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state); Chris@16: Chris@16: // first call the exit method of the current state Chris@16: execute_exit Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state); Chris@16: fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state); Chris@16: Chris@16: Chris@16: // and finally the entry method of the new current state Chris@16: convert_event_and_execute_entry Chris@16: (::boost::fusion::at_key(fsm.m_substate_list),evt,fsm); Chris@16: fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state); Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: // "i" rows are rows for internal transitions Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct irow_ Chris@16: { Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: typedef typename ROW::Source current_state_type; Chris@16: typedef T2 next_state_type; Chris@16: Chris@16: // if a guard condition is here, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list)) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int , int state, transition_event const& evt) Chris@16: { Chris@16: Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: Chris@16: // call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list); Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: Chris@16: // row having only a guard condition Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct g_irow_ Chris@16: { Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: typedef typename ROW::Source current_state_type; Chris@16: typedef T2 next_state_type; Chris@16: Chris@16: // if a guard condition is defined, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list) ) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int , int state, transition_event const& evt) Chris@16: { Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: Chris@16: // row having only an action method Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct a_irow_ Chris@16: { Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: Chris@16: typedef typename ROW::Evt transition_event; Chris@16: typedef typename ROW::Source current_state_type; Chris@16: typedef T2 next_state_type; Chris@16: Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int , int state, transition_event const& evt) Chris@16: { Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: Chris@16: // call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list); Chris@16: Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: // row simply ignoring the event Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct _irow_ Chris@16: { Chris@16: typedef typename make_entry::type T1; Chris@16: typedef typename make_exit::type T2; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: typedef typename ROW::Source current_state_type; Chris@16: typedef T2 next_state_type; Chris@16: Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& , int , int state, transition_event const& ) Chris@16: { Chris@16: BOOST_STATIC_CONSTANT(int, current_state = (get_state_id::type::value)); Chris@16: BOOST_ASSERT(state == (current_state)); Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: // transitions internal to this state machine (no substate involved) Chris@16: template< Chris@16: typename ROW, Chris@16: typename StateType Chris@16: > Chris@16: struct internal_ Chris@16: { Chris@16: typedef StateType current_state_type; Chris@16: typedef StateType next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: Chris@16: // if a guard condition is here, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list) ) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int , int , transition_event const& evt) Chris@16: { Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: Chris@16: // then call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list); Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct internal_ Chris@16: { Chris@16: typedef library_sm current_state_type; Chris@16: typedef library_sm next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: Chris@16: // if a guard condition is here, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: fsm, Chris@16: fsm, Chris@16: fsm.m_substate_list) ) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int , int , transition_event const& evt) Chris@16: { Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: Chris@16: // then call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: fsm, Chris@16: fsm, Chris@16: fsm.m_substate_list); Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: Chris@16: template< Chris@16: typename ROW, Chris@16: typename StateType Chris@16: > Chris@16: struct a_internal_ Chris@16: { Chris@16: typedef StateType current_state_type; Chris@16: typedef StateType next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt) Chris@16: { Chris@16: // then call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list); Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct a_internal_ Chris@16: { Chris@16: typedef library_sm current_state_type; Chris@16: typedef library_sm next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt) Chris@16: { Chris@16: // then call the action method Chris@16: HandledEnum res = ROW::action_call(fsm,evt, Chris@16: fsm, Chris@16: fsm, Chris@16: fsm.m_substate_list); Chris@16: return res; Chris@16: } Chris@16: }; Chris@16: template< Chris@16: typename ROW, Chris@16: typename StateType Chris@16: > Chris@16: struct g_internal_ Chris@16: { Chris@16: typedef StateType current_state_type; Chris@16: typedef StateType next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: Chris@16: // if a guard condition is here, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: ::boost::fusion::at_key(fsm.m_substate_list), Chris@16: fsm.m_substate_list) ) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt) Chris@16: { Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct g_internal_ Chris@16: { Chris@16: typedef library_sm current_state_type; Chris@16: typedef library_sm next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: Chris@16: // if a guard condition is here, call it to check that the event is accepted Chris@16: static bool check_guard(library_sm& fsm,transition_event const& evt) Chris@16: { Chris@16: if ( ROW::guard_call(fsm,evt, Chris@16: fsm, Chris@16: fsm, Chris@16: fsm.m_substate_list) ) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt) Chris@16: { Chris@16: if (!check_guard(fsm,evt)) Chris@16: { Chris@16: // guard rejected the event, we stay in the current one Chris@16: return HANDLED_GUARD_REJECT; Chris@16: } Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: template< Chris@16: typename ROW, Chris@16: typename StateType Chris@16: > Chris@16: struct _internal_ Chris@16: { Chris@16: typedef StateType current_state_type; Chris@16: typedef StateType next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: static HandledEnum execute(library_sm& , int , int , transition_event const& ) Chris@16: { Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: template< Chris@16: typename ROW Chris@16: > Chris@16: struct _internal_ Chris@16: { Chris@16: typedef library_sm current_state_type; Chris@16: typedef library_sm next_state_type; Chris@16: typedef typename ROW::Evt transition_event; Chris@16: static HandledEnum execute(library_sm& , int , int , transition_event const& ) Chris@16: { Chris@16: return HANDLED_TRUE; Chris@16: } Chris@16: }; Chris@16: // Template used to form forwarding rows in the transition table for every row of a composite SM Chris@16: template< Chris@16: typename T1 Chris@16: , class Evt Chris@16: > Chris@16: struct frow Chris@16: { Chris@16: typedef T1 current_state_type; Chris@16: typedef T1 next_state_type; Chris@16: typedef Evt transition_event; Chris@16: // tag to find out if a row is a forwarding row Chris@16: typedef int is_frow; Chris@16: Chris@16: // Take the transition action and return the next state. Chris@16: static HandledEnum execute(library_sm& fsm, int region_index, int , transition_event const& evt) Chris@16: { Chris@16: // false as second parameter because this event is forwarded from outer fsm Chris@16: execute_return res = Chris@16: (::boost::fusion::at_key(fsm.m_substate_list)).process_event_internal(evt,false); Chris@16: fsm.m_states[region_index]=get_state_id::type::value; Chris@16: return res; Chris@16: } Chris@16: // helper metafunctions used by dispatch table and give the frow a new event Chris@16: // (used to avoid double entries in a table because of base events) Chris@16: template Chris@16: struct replace_event Chris@16: { Chris@16: typedef frow type; Chris@16: }; Chris@16: }; Chris@16: Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef g_row_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef a_row_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt<_row_tag,Transition,StateType> Chris@16: { Chris@16: typedef _row_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef row_ type; Chris@16: }; Chris@16: // internal transitions Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef g_irow_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef a_irow_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef irow_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt<_irow_tag,Transition,StateType> Chris@16: { Chris@16: typedef _irow_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef a_internal_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef g_internal_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef internal_ type; Chris@16: }; Chris@16: template Chris@16: struct create_backend_stt Chris@16: { Chris@16: typedef _internal_ type; Chris@16: }; Chris@16: template Chris@16: struct make_row_tag Chris@16: { Chris@16: typedef typename create_backend_stt::type type; Chris@16: }; Chris@16: Chris@16: // add to the stt the initial states which could be missing (if not being involved in a transition) Chris@16: template Chris@16: struct create_real_stt Chris@16: { Chris@16: //typedef typename BaseType::transition_table stt_simulated; Chris@16: typedef typename ::boost::mpl::fold< Chris@16: stt_simulated,mpl::vector0<>, Chris@16: ::boost::mpl::push_back< ::boost::mpl::placeholders::_1, Chris@16: make_row_tag< ::boost::mpl::placeholders::_2 , BaseType > > Chris@16: >::type type; Chris@16: }; Chris@16: Chris@16: template Chris@16: struct add_forwarding_row_helper Chris@16: { Chris@16: typedef typename generate_event_set::type all_events; Chris@16: typedef typename ::boost::mpl::fold< Chris@16: all_events, Intermediate, Chris@16: ::boost::mpl::push_back< ::boost::mpl::placeholders::_1, Chris@16: frow > >::type type; Chris@16: }; Chris@16: // gets the transition table from a composite and make from it a forwarding row Chris@16: template Chris@16: struct get_internal_transition_table Chris@16: { Chris@16: // first get the table of a composite Chris@16: typedef typename recursive_get_transition_table::type original_table; Chris@16: Chris@16: // we now look for the events the composite has in its internal transitions Chris@16: // the internal ones are searched recursively in sub-sub... states Chris@16: // we go recursively because our states can also have internal tables or substates etc. Chris@16: typedef typename recursive_get_internal_transition_table::type recursive_istt; Chris@16: typedef typename ::boost::mpl::fold< Chris@16: recursive_istt,::boost::mpl::vector0<>, Chris@16: ::boost::mpl::push_back< ::boost::mpl::placeholders::_1, Chris@16: make_row_tag< ::boost::mpl::placeholders::_2 , StateType> > Chris@16: >::type recursive_istt_with_tag; Chris@16: Chris@16: typedef typename ::boost::mpl::insert_range< original_table, typename ::boost::mpl::end::type, Chris@16: recursive_istt_with_tag>::type table_with_all_events; Chris@16: Chris@16: // and add for every event a forwarding row Chris@16: typedef typename ::boost::mpl::eval_if< Chris@16: typename CompilePolicy::add_forwarding_rows, Chris@16: add_forwarding_row_helper,StateType>, Chris@16: ::boost::mpl::identity< ::boost::mpl::vector0<> > Chris@16: >::type type; Chris@16: }; Chris@16: template Chris@16: struct get_internal_transition_table Chris@16: { Chris@16: typedef typename create_real_stt::type type; Chris@16: }; Chris@16: // typedefs used internally Chris@16: typedef typename create_real_stt::type real_transition_table; Chris@16: typedef typename create_stt::type stt; Chris@16: typedef typename get_initial_states::type initial_states; Chris@16: typedef typename generate_state_set::type state_list; Chris@16: typedef typename HistoryPolicy::template apply::type concrete_history; Chris@16: Chris@16: typedef typename ::boost::fusion::result_of::as_set::type substate_list; Chris@16: typedef typename ::boost::msm::back::generate_event_set< Chris@16: typename create_real_stt::type Chris@16: >::type processable_events_internal_table; Chris@16: Chris@16: // extends the transition table with rows from composite states Chris@16: template Chris@16: struct extend_table Chris@16: { Chris@16: // add the init states Chris@16: //typedef typename create_stt::type stt; Chris@16: typedef typename Composite::stt Stt; Chris@16: Chris@16: // add the internal events defined in the internal_transition_table Chris@16: // Note: these are added first because they must have a lesser prio Chris@16: // than the deeper transitions in the sub regions Chris@16: // table made of a stt + internal transitions of composite Chris@16: typedef typename ::boost::mpl::fold< Chris@16: typename Composite::internal_transition_table,::boost::mpl::vector0<>, Chris@16: ::boost::mpl::push_back< ::boost::mpl::placeholders::_1, Chris@16: make_row_tag< ::boost::mpl::placeholders::_2 , Composite> > Chris@16: >::type internal_stt; Chris@16: Chris@16: typedef typename ::boost::mpl::insert_range< Chris@16: Stt, Chris@16: typename ::boost::mpl::end::type, Chris@16: internal_stt Chris@16: //typename get_internal_transition_table::type Chris@16: >::type stt_plus_internal; Chris@16: Chris@16: // for every state, add its transition table (if any) Chris@16: // transformed as frow Chris@16: typedef typename ::boost::mpl::fold, Chris@16: get_internal_transition_table< Chris@16: ::boost::mpl::placeholders::_2, Chris@16: is_composite_state< ::boost::mpl::placeholders::_2> > > Chris@16: >::type type; Chris@16: }; Chris@16: // extend the table with tables from composite states Chris@16: typedef typename extend_table::type complete_table; Chris@16: // build a sequence of regions Chris@16: typedef typename get_regions_as_sequence::type seq_initial_states; Chris@16: // Member functions Chris@16: Chris@16: // start the state machine (calls entry of the initial state) Chris@16: void start() Chris@16: { Chris@16: // reinitialize our list of currently active states with the ones defined in Derived::initial_state Chris@16: ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap > Chris@16: (init_states(m_states)); Chris@16: // call on_entry on this SM Chris@16: (static_cast(this))->on_entry(fsm_initial_event(),*this); Chris@16: ::boost::mpl::for_each > Chris@16: (call_init(fsm_initial_event(),this)); Chris@16: // give a chance to handle an anonymous (eventless) transition Chris@16: handle_eventless_transitions_helper eventless_helper(this,true); Chris@16: eventless_helper.process_completion_event(); Chris@16: } Chris@16: Chris@16: // start the state machine (calls entry of the initial state passing incomingEvent to on_entry's) Chris@16: template Chris@16: void start(Event const& incomingEvent) Chris@16: { Chris@16: // reinitialize our list of currently active states with the ones defined in Derived::initial_state Chris@16: ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap > Chris@16: (init_states(m_states)); Chris@16: // call on_entry on this SM Chris@16: (static_cast(this))->on_entry(incomingEvent,*this); Chris@16: ::boost::mpl::for_each > Chris@16: (call_init(incomingEvent,this)); Chris@16: // give a chance to handle an anonymous (eventless) transition Chris@16: handle_eventless_transitions_helper eventless_helper(this,true); Chris@16: eventless_helper.process_completion_event(); Chris@16: } Chris@16: Chris@16: // stop the state machine (calls exit of the current state) Chris@16: void stop() Chris@16: { Chris@16: do_exit(fsm_final_event(),*this); Chris@16: } Chris@16: Chris@16: // stop the state machine (calls exit of the current state passing finalEvent to on_exit's) Chris@16: template Chris@16: void stop(Event const& finalEvent) Chris@16: { Chris@16: do_exit(finalEvent,*this); Chris@16: } Chris@16: Chris@16: // Main function used by clients of the derived FSM to make transitions. Chris@16: template Chris@16: execute_return process_event(Event const& evt) Chris@16: { Chris@16: return process_event_internal(evt,true); Chris@16: } Chris@16: Chris@16: template Chris@16: void enqueue_event_helper(EventType const& evt, ::boost::mpl::false_ const &) Chris@16: { Chris@16: execute_return (library_sm::*pf) (EventType const& evt) = Chris@16: &library_sm::process_event; Chris@16: Chris@16: transition_fct f = ::boost::bind(pf,this,evt); Chris@16: m_events_queue.m_events_queue.push_back(f); Chris@16: } Chris@16: template Chris@101: void enqueue_event_helper(EventType const& , ::boost::mpl::true_ const &) Chris@16: { Chris@16: // no queue Chris@16: } Chris@16: Chris@16: void execute_queued_events_helper(::boost::mpl::false_ const &) Chris@16: { Chris@101: while(!m_events_queue.m_events_queue.empty()) Chris@101: { Chris@101: transition_fct to_call = m_events_queue.m_events_queue.front(); Chris@101: m_events_queue.m_events_queue.pop_front(); Chris@101: to_call(); Chris@101: } Chris@16: } Chris@16: void execute_queued_events_helper(::boost::mpl::true_ const &) Chris@16: { Chris@16: // no queue required Chris@16: } Chris@101: void execute_single_queued_event_helper(::boost::mpl::false_ const &) Chris@101: { Chris@101: transition_fct to_call = m_events_queue.m_events_queue.front(); Chris@101: m_events_queue.m_events_queue.pop_front(); Chris@101: to_call(); Chris@101: } Chris@101: void execute_single_queued_event_helper(::boost::mpl::true_ const &) Chris@101: { Chris@101: // no queue required Chris@101: } Chris@16: // enqueues an event in the message queue Chris@16: // call execute_queued_events to process all queued events. Chris@16: // Be careful if you do this during event processing, the event will be processed immediately Chris@16: // and not kept in the queue Chris@16: template Chris@16: void enqueue_event(EventType const& evt) Chris@16: { Chris@16: enqueue_event_helper(evt, typename is_no_message_queue::type()); Chris@16: } Chris@16: Chris@16: // empty the queue and process events Chris@16: void execute_queued_events() Chris@16: { Chris@16: execute_queued_events_helper(typename is_no_message_queue::type()); Chris@16: } Chris@101: void execute_single_queued_event() Chris@101: { Chris@101: execute_single_queued_event_helper(typename is_no_message_queue::type()); Chris@101: } Chris@16: typename events_queue_t::size_type get_message_queue_size() const Chris@16: { Chris@16: return m_events_queue.m_events_queue.size(); Chris@16: } Chris@16: Chris@16: events_queue_t& get_message_queue() Chris@16: { Chris@16: return m_events_queue.m_events_queue; Chris@16: } Chris@16: Chris@16: const events_queue_t& get_message_queue() const Chris@16: { Chris@16: return m_events_queue.m_events_queue; Chris@16: } Chris@16: Chris@101: void clear_deferred_queue() Chris@101: { Chris@101: m_deferred_events_queue.clear(); Chris@101: } Chris@101: Chris@16: deferred_events_queue_t& get_deferred_queue() Chris@16: { Chris@16: return m_deferred_events_queue.m_deferred_events_queue; Chris@16: } Chris@16: Chris@16: const deferred_events_queue_t& get_deferred_queue() const Chris@16: { Chris@16: return m_deferred_events_queue.m_deferred_events_queue; Chris@16: } Chris@16: Chris@16: // Getter that returns the current state of the FSM Chris@16: const int* current_state() const Chris@16: { Chris@16: return this->m_states; Chris@16: } Chris@16: Chris@16: template Chris@16: struct serialize_state Chris@16: { Chris@16: serialize_state(Archive& ar):ar_(ar){} Chris@16: Chris@16: template Chris@16: typename ::boost::enable_if< Chris@16: typename ::boost::mpl::or_< Chris@16: typename has_do_serialize::type, Chris@16: typename is_composite_state::type Chris@16: >::type Chris@16: ,void Chris@16: >::type Chris@16: operator()(T& t) const Chris@16: { Chris@16: ar_ & t; Chris@16: } Chris@16: template Chris@16: typename ::boost::disable_if< Chris@16: typename ::boost::mpl::or_< Chris@16: typename has_do_serialize::type, Chris@16: typename is_composite_state::type Chris@16: >::type Chris@16: ,void Chris@16: >::type Chris@101: operator()(T&) const Chris@16: { Chris@16: // no state to serialize Chris@16: } Chris@16: Archive& ar_; Chris@16: }; Chris@16: Chris@16: template Chris@16: void serialize(Archive & ar, const unsigned int) Chris@16: { Chris@16: // invoke serialization of the base class Chris@16: (serialize_state(ar))(boost::serialization::base_object(*this)); Chris@16: // now our attributes Chris@16: ar & m_states; Chris@16: // queues cannot be serialized => skip Chris@16: ar & m_history; Chris@16: ar & m_event_processing; Chris@16: ar & m_is_included; Chris@16: // visitors cannot be serialized => skip Chris@16: ::boost::fusion::for_each(m_substate_list, serialize_state(ar)); Chris@16: } Chris@16: Chris@16: // linearly search for the state with the given id Chris@16: struct get_state_id_helper Chris@16: { Chris@16: get_state_id_helper(int id,const BaseState** res,const library_sm* self_): Chris@16: result_state(res),searched_id(id),self(self_) {} Chris@16: Chris@16: template Chris@16: void operator()(boost::msm::wrap const&) Chris@16: { Chris@16: // look for the state id until found Chris@16: BOOST_STATIC_CONSTANT(int, id = (get_state_id::value)); Chris@16: if (!*result_state && (id == searched_id)) Chris@16: { Chris@16: *result_state = &::boost::fusion::at_key(self->m_substate_list); Chris@16: } Chris@16: } Chris@16: const BaseState** result_state; Chris@16: int searched_id; Chris@16: const library_sm* self; Chris@16: }; Chris@16: // return the state whose id is passed or 0 if not found Chris@16: // caution if you need this, you probably need polymorphic states Chris@16: // complexity: O(number of states) Chris@16: BaseState* get_state_by_id(int id) Chris@16: { Chris@16: const BaseState* result_state=0; Chris@16: ::boost::mpl::for_each > (get_state_id_helper(id,&result_state,this)); Chris@16: return const_cast(result_state); Chris@16: } Chris@16: const BaseState* get_state_by_id(int id) const Chris@16: { Chris@16: const BaseState* result_state=0; Chris@16: ::boost::mpl::for_each > (get_state_id_helper(id,&result_state,this)); Chris@16: return result_state; Chris@16: } Chris@16: // true if the sm is used in another sm Chris@16: bool is_contained() const Chris@16: { Chris@16: return m_is_included; Chris@16: } Chris@16: // get the history policy class Chris@16: concrete_history& get_history() Chris@16: { Chris@16: return m_history; Chris@16: } Chris@16: concrete_history const& get_history() const Chris@16: { Chris@16: return m_history; Chris@16: } Chris@16: // get a state (const version) Chris@16: // as a pointer Chris@16: template Chris@16: typename ::boost::enable_if::type,State >::type Chris@16: get_state(::boost::msm::back::dummy<0> = 0) const Chris@16: { Chris@16: return const_cast Chris@16: (& Chris@16: (::boost::fusion::at_key< Chris@16: typename ::boost::remove_const::type>::type>(m_substate_list))); Chris@16: } Chris@16: // as a reference Chris@16: template Chris@16: typename ::boost::enable_if::type,State >::type Chris@16: get_state(::boost::msm::back::dummy<1> = 0) const Chris@16: { Chris@16: return const_cast Chris@16: ( ::boost::fusion::at_key< Chris@16: typename ::boost::remove_const::type>::type>(m_substate_list) ); Chris@16: } Chris@16: // get a state (non const version) Chris@16: // as a pointer Chris@16: template Chris@16: typename ::boost::enable_if::type,State >::type Chris@16: get_state(::boost::msm::back::dummy<0> = 0) Chris@16: { Chris@16: return &(static_cast::type>::type > Chris@16: (::boost::fusion::at_key::type>(m_substate_list))); Chris@16: } Chris@16: // as a reference Chris@16: template Chris@16: typename ::boost::enable_if::type,State >::type Chris@16: get_state(::boost::msm::back::dummy<1> = 0) Chris@16: { Chris@16: return ::boost::fusion::at_key::type>(m_substate_list); Chris@16: } Chris@16: // checks if a flag is active using the BinaryOp as folding function Chris@16: template Chris@16: bool is_flag_active() const Chris@16: { Chris@16: flag_handler* flags_entries = get_entries_for_flag(); Chris@16: bool res = (*flags_entries[ m_states[0] ])(*this); Chris@16: for (int i = 1; i < nr_regions::value ; ++i) Chris@16: { Chris@16: res = typename BinaryOp::type() (res,(*flags_entries[ m_states[i] ])(*this)); Chris@16: } Chris@16: return res; Chris@16: } Chris@16: // checks if a flag is active using no binary op if 1 region, or OR if > 1 regions Chris@16: template Chris@16: bool is_flag_active() const Chris@16: { Chris@16: return FlagHelper1)>::helper(*this,get_entries_for_flag()); Chris@16: } Chris@16: // visit the currently active states (if these are defined as visitable Chris@16: // by implementing accept) Chris@16: void visit_current_states() Chris@16: { Chris@16: for (int i=0; i \ Chris@16: void visit_current_states(BOOST_PP_ENUM(n, MSM_VISIT_STATE_SUB, ~ ) ) \ Chris@16: { \ Chris@16: for (int i=0; i Chris@16: void defer_event(Event const& e) Chris@16: { Chris@16: // to call this function, you need either a state with a deferred_events typedef Chris@16: // or that the fsm provides the activate_deferred_events typedef Chris@16: BOOST_MPL_ASSERT(( has_fsm_deferred_events )); Chris@16: execute_return (library_sm::*pf) (Event const& evt)= &library_sm::process_event; Chris@16: Event temp (e); Chris@16: ::boost::function f= ::boost::bind(pf, this,temp); Chris@16: post_deferred_event(f); Chris@16: } Chris@16: Chris@16: protected: // interface for the derived class Chris@16: Chris@16: // helper used to fill the initial states Chris@16: struct init_states Chris@16: { Chris@16: init_states(int* const init):m_initial_states(init),m_index(-1){} Chris@16: Chris@16: // History initializer function object, used with mpl::for_each Chris@16: template Chris@16: void operator()(::boost::msm::wrap const&) Chris@16: { Chris@16: m_initial_states[++m_index]=get_state_id::type::value; Chris@16: } Chris@16: int* const m_initial_states; Chris@16: int m_index; Chris@16: }; Chris@16: public: Chris@16: struct update_state Chris@16: { Chris@16: update_state(substate_list& to_overwrite_):to_overwrite(&to_overwrite_){} Chris@16: template Chris@16: void operator()(StateType const& astate) const Chris@16: { Chris@16: ::boost::fusion::at_key(*to_overwrite)=astate; Chris@16: } Chris@16: substate_list* to_overwrite; Chris@16: }; Chris@16: template Chris@16: void set_states(Expr const& expr) Chris@16: { Chris@16: ::boost::fusion::for_each( Chris@16: ::boost::fusion::as_vector(FoldToList()(expr, boost::fusion::nil())),update_state(this->m_substate_list)); Chris@16: } Chris@16: Chris@16: // Construct with the default initial states Chris@16: state_machine() Chris@16: :Derived() Chris@16: ,m_events_queue() Chris@16: ,m_deferred_events_queue() Chris@16: ,m_history() Chris@16: ,m_event_processing(false) Chris@16: ,m_is_included(false) Chris@16: ,m_visitors() Chris@16: ,m_substate_list() Chris@16: { Chris@16: // initialize our list of states with the ones defined in Derived::initial_state Chris@16: ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap > Chris@16: (init_states(m_states)); Chris@16: m_history.set_initial_states(m_states); Chris@16: // create states Chris@16: fill_states(this); Chris@16: } Chris@16: template Chris@16: state_machine Chris@16: (Expr const& expr,typename ::boost::enable_if::type >::type* =0) Chris@16: :Derived() Chris@16: ,m_events_queue() Chris@16: ,m_deferred_events_queue() Chris@16: ,m_history() Chris@16: ,m_event_processing(false) Chris@16: ,m_is_included(false) Chris@16: ,m_visitors() Chris@16: ,m_substate_list() Chris@16: { Chris@16: BOOST_MPL_ASSERT_MSG( Chris@16: ( ::boost::proto::matches::value), Chris@16: THE_STATES_EXPRESSION_PASSED_DOES_NOT_MATCH_GRAMMAR, Chris@16: (FoldToList)); Chris@16: Chris@16: // initialize our list of states with the ones defined in Derived::initial_state Chris@16: ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap > Chris@16: (init_states(m_states)); Chris@16: m_history.set_initial_states(m_states); Chris@16: // create states Chris@16: set_states(expr); Chris@16: fill_states(this); Chris@16: } Chris@16: // Construct with the default initial states and some default argument(s) Chris@16: #define MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB(z, n, unused) ARG ## n t ## n Chris@16: #define MSM_CONSTRUCTOR_HELPER_EXECUTE(z, n, unused) \ Chris@16: template \ Chris@16: state_machine(BOOST_PP_ENUM(n, MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB, ~ ), \ Chris@16: typename ::boost::disable_if::type >::type* =0 ) \ Chris@16: :Derived(BOOST_PP_ENUM_PARAMS(n,t)) \ Chris@16: ,m_events_queue() \ Chris@16: ,m_deferred_events_queue() \ Chris@16: ,m_history() \ Chris@16: ,m_event_processing(false) \ Chris@16: ,m_is_included(false) \ Chris@16: ,m_visitors() \ Chris@16: ,m_substate_list() \ Chris@16: { \ Chris@16: ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap > \ Chris@16: (init_states(m_states)); \ Chris@16: m_history.set_initial_states(m_states); \ Chris@16: fill_states(this); \ Chris@16: } \ Chris@16: template \ Chris@16: state_machine(Expr const& expr,BOOST_PP_ENUM(n, MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB, ~ ), \ Chris@16: typename ::boost::enable_if::type >::type* =0 ) \ Chris@16: :Derived(BOOST_PP_ENUM_PARAMS(n,t)) \ Chris@16: ,m_events_queue() \ Chris@16: ,m_deferred_events_queue() \ Chris@16: ,m_history() \ Chris@16: ,m_event_processing(false) \ Chris@16: ,m_is_included(false) \ Chris@16: ,m_visitors() \ Chris@16: ,m_substate_list() \ Chris@16: { \ Chris@16: BOOST_MPL_ASSERT_MSG( \ Chris@16: ( ::boost::proto::matches::value), \ Chris@16: THE_STATES_EXPRESSION_PASSED_DOES_NOT_MATCH_GRAMMAR, \ Chris@16: (FoldToList)); \ Chris@16: ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap > \ Chris@16: (init_states(m_states)); \ Chris@16: m_history.set_initial_states(m_states); \ Chris@16: set_states(expr); \ Chris@16: fill_states(this); \ Chris@16: } Chris@16: Chris@16: BOOST_PP_REPEAT_FROM_TO(1,BOOST_PP_ADD(BOOST_MSM_CONSTRUCTOR_ARG_SIZE,1), MSM_CONSTRUCTOR_HELPER_EXECUTE, ~) Chris@16: #undef MSM_CONSTRUCTOR_HELPER_EXECUTE Chris@16: #undef MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB Chris@16: Chris@16: Chris@16: Chris@16: // assignment operator using the copy policy to decide if non_copyable, shallow or deep copying is necessary Chris@16: library_sm& operator= (library_sm const& rhs) Chris@16: { Chris@16: if (this != &rhs) Chris@16: { Chris@16: Derived::operator=(rhs); Chris@16: do_copy(rhs); Chris@16: } Chris@16: return *this; Chris@16: } Chris@16: state_machine Chris@16: (library_sm const& rhs) Chris@16: : Derived(rhs) Chris@16: { Chris@16: if (this != &rhs) Chris@16: { Chris@16: // initialize our list of states with the ones defined in Derived::initial_state Chris@16: fill_states(this); Chris@16: do_copy(rhs); Chris@16: } Chris@16: } Chris@16: Chris@16: // the following 2 functions handle the terminate/interrupt states handling Chris@16: // if one of these states is found, the first one is used Chris@16: template Chris@16: bool is_event_handling_blocked_helper( ::boost::mpl::true_ const &) Chris@16: { Chris@16: // if the state machine is terminated, do not handle any event Chris@16: if (is_flag_active< ::boost::msm::TerminateFlag>()) Chris@16: return true; Chris@16: // if the state machine is interrupted, do not handle any event Chris@16: // unless the event is the end interrupt event Chris@16: if ( is_flag_active< ::boost::msm::InterruptedFlag>() && Chris@16: !is_flag_active< ::boost::msm::EndInterruptFlag >()) Chris@16: return true; Chris@16: return false; Chris@16: } Chris@16: // otherwise simple handling, no flag => continue Chris@16: template Chris@16: bool is_event_handling_blocked_helper( ::boost::mpl::false_ const &) Chris@16: { Chris@16: // no terminate/interrupt states detected Chris@16: return false; Chris@16: } Chris@16: // the following functions handle pre/post-process handling of a message queue Chris@16: template Chris@101: bool do_pre_msg_queue_helper(EventType const&, ::boost::mpl::true_ const &) Chris@16: { Chris@16: // no message queue needed Chris@16: return true; Chris@16: } Chris@16: template Chris@16: bool do_pre_msg_queue_helper(EventType const& evt, ::boost::mpl::false_ const &) Chris@16: { Chris@16: execute_return (library_sm::*pf) (EventType const& evt) = Chris@16: &library_sm::process_event; Chris@16: // if we are already processing an event Chris@16: if (m_event_processing) Chris@16: { Chris@16: // event has to be put into the queue Chris@16: transition_fct f = ::boost::bind(pf,this,evt); Chris@16: m_events_queue.m_events_queue.push_back(f); Chris@16: return false; Chris@16: } Chris@16: // event can be handled, processing Chris@16: m_event_processing = true; Chris@16: return true; Chris@16: } Chris@16: void do_post_msg_queue_helper( ::boost::mpl::true_ const &) Chris@16: { Chris@16: // no message queue needed Chris@16: } Chris@16: void do_post_msg_queue_helper( ::boost::mpl::false_ const &) Chris@16: { Chris@16: m_event_processing = false; Chris@16: process_message_queue(this); Chris@16: } Chris@16: // the following 2 functions handle the processing either with a try/catch protection or without Chris@16: template Chris@16: HandledEnum do_process_helper(EventType const& evt, ::boost::mpl::true_ const &, bool is_direct_call) Chris@16: { Chris@16: return this->do_process_event(evt,is_direct_call); Chris@16: } Chris@16: template Chris@16: HandledEnum do_process_helper(EventType const& evt, ::boost::mpl::false_ const &, bool is_direct_call) Chris@16: { Chris@16: // when compiling without exception support there is no formal parameter "e" in the catch handler. Chris@16: // Declaring a local variable here does not hurt and will be "used" to make the code in the handler Chris@16: // compilable although the code will never be executed. Chris@16: std::exception e; Chris@16: BOOST_TRY Chris@16: { Chris@16: return this->do_process_event(evt,is_direct_call); Chris@16: } Chris@16: BOOST_CATCH (std::exception& e) Chris@16: { Chris@16: // give a chance to the concrete state machine to handle Chris@16: this->exception_caught(evt,*this,e); Chris@16: } Chris@16: BOOST_CATCH_END Chris@101: return HANDLED_TRUE; Chris@16: } Chris@16: // handling of deferred events Chris@16: // if none is found in the SM, take the following empty main version Chris@16: template Chris@16: struct handle_defer_helper Chris@16: { Chris@16: handle_defer_helper(deferred_msg_queue_helper& ){} Chris@16: void do_pre_handle_deferred() Chris@16: { Chris@16: } Chris@16: Chris@16: void do_post_handle_deferred(HandledEnum) Chris@16: { Chris@16: } Chris@16: }; Chris@16: // otherwise the standard version handling the deferred events Chris@16: template Chris@16: struct handle_defer_helper Chris@16: ::type,int >::type> Chris@16: { Chris@16: handle_defer_helper(deferred_msg_queue_helper& a_queue): Chris@16: events_queue(a_queue),next_deferred_event(){} Chris@16: void do_pre_handle_deferred() Chris@16: { Chris@16: } Chris@16: Chris@16: void do_post_handle_deferred(HandledEnum handled) Chris@16: { Chris@16: if (handled == HANDLED_TRUE) Chris@16: { Chris@16: // a transition has been taken, it makes sense again to try processing waiting deferred events Chris@16: // reset all events to not tested Chris@16: for (std::size_t i = 0; i < events_queue.m_deferred_events_queue.size(); ++i) Chris@16: { Chris@16: events_queue.m_deferred_events_queue[i].second=false; Chris@16: } Chris@16: // test first event Chris@16: if (!events_queue.m_deferred_events_queue.empty()) Chris@16: { Chris@16: deferred_fct next = events_queue.m_deferred_events_queue.front().first; Chris@16: events_queue.m_deferred_events_queue.pop_front(); Chris@16: next(); Chris@16: } Chris@16: } Chris@16: else Chris@16: { Chris@16: // look for next deferred event, if any Chris@16: typename deferred_events_queue_t::iterator it = Chris@16: std::find_if(events_queue.m_deferred_events_queue.begin(), Chris@16: events_queue.m_deferred_events_queue.end(), Chris@16: boost::bind(&std::pair::second, _1) == false); Chris@16: if (it != events_queue.m_deferred_events_queue.end()) Chris@16: { Chris@16: (*it).second = true; Chris@16: deferred_fct next = (*it).first; Chris@16: events_queue.m_deferred_events_queue.erase(it); Chris@16: next(); Chris@16: } Chris@16: } Chris@16: } Chris@16: Chris@16: private: Chris@16: deferred_msg_queue_helper& events_queue; Chris@16: deferred_fct next_deferred_event; Chris@16: }; Chris@16: Chris@16: // handling of eventless transitions Chris@16: // if none is found in the SM, nothing to do Chris@16: template Chris@16: struct handle_eventless_transitions_helper Chris@16: { Chris@16: handle_eventless_transitions_helper(library_sm* , bool ){} Chris@16: void process_completion_event(){} Chris@16: }; Chris@16: // otherwise Chris@16: template Chris@16: struct handle_eventless_transitions_helper Chris@16: ::type >::type> Chris@16: { Chris@16: handle_eventless_transitions_helper(library_sm* self_, bool handled_):self(self_),handled(handled_){} Chris@16: void process_completion_event() Chris@16: { Chris@16: typedef typename ::boost::mpl::deref< Chris@16: typename ::boost::mpl::begin< Chris@16: typename find_completion_events::type Chris@16: >::type Chris@16: >::type first_completion_event; Chris@16: if (handled) Chris@16: { Chris@16: self->process_event(first_completion_event() ); Chris@16: } Chris@16: } Chris@16: Chris@16: private: Chris@16: library_sm* self; Chris@16: bool handled; Chris@16: }; Chris@16: Chris@16: // helper class called in case the event to process has been found in the fsm's internal stt and is therefore processable Chris@16: template Chris@16: struct process_fsm_internal_table Chris@16: { Chris@16: typedef typename ::boost::mpl::has_key::type is_event_processable; Chris@16: Chris@16: // forward to the correct do_process Chris@16: static void process(Event const& evt,library_sm* self_,HandledEnum& result) Chris@16: { Chris@16: do_process(evt,self_,result,is_event_processable()); Chris@16: } Chris@16: private: Chris@16: // the event is processable, let's try! Chris@16: static void do_process(Event const& evt,library_sm* self_,HandledEnum& result, ::boost::mpl::true_) Chris@16: { Chris@16: if (result != HANDLED_TRUE) Chris@16: { Chris@16: typedef dispatch_table table; Chris@16: HandledEnum res_internal = table::instance.entries[0](*self_, 0, self_->m_states[0], evt); Chris@16: result = (HandledEnum)((int)result | (int)res_internal); Chris@16: } Chris@16: } Chris@16: // version doing nothing if the event is not in the internal stt and we can save ourselves the time trying to process Chris@16: static void do_process(Event const& ,library_sm* ,HandledEnum& , ::boost::mpl::false_) Chris@16: { Chris@16: // do nothing Chris@16: } Chris@16: }; Chris@16: Chris@16: template Chris@16: struct region_processing_helper Chris@16: { Chris@16: public: Chris@16: region_processing_helper(library_sm* self_,HandledEnum& result_) Chris@16: :self(self_),result(result_){} Chris@16: template Chris@16: void process(Event const& evt) Chris@16: { Chris@16: // use this table as if it came directly from the user Chris@16: typedef dispatch_table table; Chris@16: // +1 because index 0 is reserved for this fsm Chris@16: HandledEnum res = Chris@16: table::instance.entries[self->m_states[0]+1]( Chris@16: *self, 0, self->m_states[0], evt); Chris@16: result = (HandledEnum)((int)result | (int)res); Chris@16: // process the event in the internal table of this fsm if the event is processable (present in the table) Chris@16: process_fsm_internal_table::process(evt,self,result); Chris@16: } Chris@16: library_sm* self; Chris@16: HandledEnum& result; Chris@16: }; Chris@16: // version with visitors Chris@16: template Chris@16: struct region_processing_helper >::type> Chris@16: { Chris@16: private: Chris@16: // process event in one region Chris@16: template Chris@16: struct In Chris@16: { Chris@16: template Chris@16: static void process(Event const& evt,library_sm* self_,HandledEnum& result_) Chris@16: { Chris@16: // use this table as if it came directly from the user Chris@16: typedef dispatch_table table; Chris@16: // +1 because index 0 is reserved for this fsm Chris@16: HandledEnum res = Chris@16: table::instance.entries[self_->m_states[region_id::value]+1]( Chris@16: *self_, region_id::value , self_->m_states[region_id::value], evt); Chris@16: result_ = (HandledEnum)((int)result_ | (int)res); Chris@16: In< ::boost::mpl::int_ >::process(evt,self_,result_); Chris@16: } Chris@16: }; Chris@16: template Chris@16: struct In< ::boost::mpl::int_,Dummy> Chris@16: { Chris@16: // end of processing Chris@16: template Chris@16: static void process(Event const& evt,library_sm* self_,HandledEnum& result_) Chris@16: { Chris@16: // process the event in the internal table of this fsm if the event is processable (present in the table) Chris@16: process_fsm_internal_table::process(evt,self_,result_); Chris@16: } Chris@16: }; Chris@16: public: Chris@16: region_processing_helper(library_sm* self_,HandledEnum& result_) Chris@16: :self(self_),result(result_){} Chris@16: template Chris@16: void process(Event const& evt) Chris@16: { Chris@16: In< ::boost::mpl::int_<0> >::process(evt,self,result); Chris@16: } Chris@16: Chris@16: library_sm* self; Chris@16: HandledEnum& result; Chris@16: }; Chris@16: Chris@16: // Main function used internally to make transitions Chris@16: // Can only be called for internally (for example in an action method) generated events. Chris@16: template Chris@16: execute_return process_event_internal(Event const& evt, bool is_direct_call) Chris@16: { Chris@16: HandledEnum ret_handled=HANDLED_FALSE; Chris@16: // if the state machine has terminate or interrupt flags, check them, otherwise skip Chris@16: if (is_event_handling_blocked_helper Chris@16: ( ::boost::mpl::bool_::type::value>() ) ) Chris@16: return HANDLED_TRUE; Chris@16: // if a message queue is needed and processing is on the way Chris@16: if (!do_pre_msg_queue_helper