1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037 |
- // Copyright 2008 Christophe Henry
- // henry UNDERSCORE christophe AT hotmail DOT com
- // This is an extended version of the state machine available in the boost::mpl library
- // Distributed under the same license as the original.
- // Copyright for the original version:
- // Copyright 2005 David Abrahams and Aleksey Gurtovoy. Distributed
- // under the Boost Software License, Version 1.0. (See accompanying
- // file LICENSE_1_0.txt or copy at
- // http://www.boost.org/LICENSE_1_0.txt)
- #ifndef BOOST_MSM_BACK_STATEMACHINE_H
- #define BOOST_MSM_BACK_STATEMACHINE_H
- #include <exception>
- #include <vector>
- #include <functional>
- #include <numeric>
- #include <utility>
- #include <algorithm>
- #include <boost/core/no_exceptions_support.hpp>
- #include <boost/core/ignore_unused.hpp>
- #include <boost/mpl/contains.hpp>
- #include <boost/mpl/deref.hpp>
- #include <boost/mpl/assert.hpp>
- #include <boost/fusion/container/vector/convert.hpp>
- #include <boost/fusion/include/as_vector.hpp>
- #include <boost/fusion/include/as_set.hpp>
- #include <boost/fusion/container/set.hpp>
- #include <boost/fusion/include/set.hpp>
- #include <boost/fusion/include/set_fwd.hpp>
- #include <boost/fusion/include/mpl.hpp>
- #include <boost/fusion/sequence/intrinsic/at_key.hpp>
- #include <boost/fusion/include/at_key.hpp>
- #include <boost/fusion/algorithm/iteration/for_each.hpp>
- #include <boost/fusion/include/for_each.hpp>
- #include <boost/assert.hpp>
- #include <boost/ref.hpp>
- #include <boost/type_traits.hpp>
- #include <boost/utility/enable_if.hpp>
- #include <boost/type_traits/is_convertible.hpp>
- #include <boost/bind/bind.hpp>
- #include <boost/function.hpp>
- #ifndef BOOST_NO_RTTI
- #include <boost/any.hpp>
- #endif
- #include <boost/serialization/base_object.hpp>
- #include <boost/parameter.hpp>
- #include <boost/msm/active_state_switching_policies.hpp>
- #include <boost/msm/row_tags.hpp>
- #include <boost/msm/msm_grammar.hpp>
- #include <boost/msm/back/fold_to_list.hpp>
- #include <boost/msm/back/metafunctions.hpp>
- #include <boost/msm/back/history_policies.hpp>
- #include <boost/msm/back/common_types.hpp>
- #include <boost/msm/back/args.hpp>
- #include <boost/msm/back/default_compile_policy.hpp>
- #include <boost/msm/back/dispatch_table.hpp>
- #include <boost/msm/back/no_fsm_check.hpp>
- #include <boost/msm/back/queue_container_deque.hpp>
- BOOST_MPL_HAS_XXX_TRAIT_DEF(accept_sig)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(no_automatic_create)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(non_forwarding_flag)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(direct_entry)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(initial_event)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(final_event)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(do_serialize)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(history_policy)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(fsm_check)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(compile_policy)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(queue_container_policy)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(using_declared_table)
- BOOST_MPL_HAS_XXX_TRAIT_DEF(event_queue_before_deferred_queue)
- #ifndef BOOST_MSM_CONSTRUCTOR_ARG_SIZE
- #define BOOST_MSM_CONSTRUCTOR_ARG_SIZE 5 // default max number of arguments for constructors
- #endif
- namespace boost { namespace msm { namespace back
- {
- // event used internally for wrapping a direct entry
- template <class StateType,class Event>
- struct direct_entry_event
- {
- typedef int direct_entry;
- typedef StateType active_state;
- typedef Event contained_event;
- direct_entry_event(Event const& evt):m_event(evt){}
- Event const& m_event;
- };
- BOOST_PARAMETER_TEMPLATE_KEYWORD(front_end)
- BOOST_PARAMETER_TEMPLATE_KEYWORD(history_policy)
- BOOST_PARAMETER_TEMPLATE_KEYWORD(compile_policy)
- BOOST_PARAMETER_TEMPLATE_KEYWORD(fsm_check_policy)
- BOOST_PARAMETER_TEMPLATE_KEYWORD(queue_container_policy)
- typedef ::boost::parameter::parameters<
- ::boost::parameter::required< ::boost::msm::back::tag::front_end >
- , ::boost::parameter::optional<
- ::boost::parameter::deduced< ::boost::msm::back::tag::history_policy>, has_history_policy< ::boost::mpl::_ >
- >
- , ::boost::parameter::optional<
- ::boost::parameter::deduced< ::boost::msm::back::tag::compile_policy>, has_compile_policy< ::boost::mpl::_ >
- >
- , ::boost::parameter::optional<
- ::boost::parameter::deduced< ::boost::msm::back::tag::fsm_check_policy>, has_fsm_check< ::boost::mpl::_ >
- >
- , ::boost::parameter::optional<
- ::boost::parameter::deduced< ::boost::msm::back::tag::queue_container_policy>,
- has_queue_container_policy< ::boost::mpl::_ >
- >
- > state_machine_signature;
- // just here to disable use of proto when not needed
- template <class T, class F,class Enable=void>
- struct make_euml_terminal;
- template <class T,class F>
- struct make_euml_terminal<T,F,typename ::boost::disable_if<has_using_declared_table<F> >::type>
- {};
- template <class T,class F>
- struct make_euml_terminal<T,F,typename ::boost::enable_if<has_using_declared_table<F> >::type>
- : public proto::extends<typename proto::terminal< boost::msm::state_tag>::type, T, boost::msm::state_domain>
- {};
- // library-containing class for state machines. Pass the actual FSM class as
- // the Concrete parameter.
- // A0=Derived,A1=NoHistory,A2=CompilePolicy,A3=FsmCheckPolicy >
- template <
- class A0
- , class A1 = parameter::void_
- , class A2 = parameter::void_
- , class A3 = parameter::void_
- , class A4 = parameter::void_
- >
- class state_machine : //public Derived
- public ::boost::parameter::binding<
- typename state_machine_signature::bind<A0,A1,A2,A3,A4>::type, ::boost::msm::back::tag::front_end
- >::type
- , public make_euml_terminal<state_machine<A0,A1,A2,A3,A4>,
- typename ::boost::parameter::binding<
- typename state_machine_signature::bind<A0,A1,A2,A3,A4>::type, ::boost::msm::back::tag::front_end
- >::type
- >
- {
- public:
- // Create ArgumentPack
- typedef typename
- state_machine_signature::bind<A0,A1,A2,A3,A4>::type
- state_machine_args;
- // Extract first logical parameter.
- typedef typename ::boost::parameter::binding<
- state_machine_args, ::boost::msm::back::tag::front_end>::type Derived;
- typedef typename ::boost::parameter::binding<
- state_machine_args, ::boost::msm::back::tag::history_policy, NoHistory >::type HistoryPolicy;
- typedef typename ::boost::parameter::binding<
- state_machine_args, ::boost::msm::back::tag::compile_policy, favor_runtime_speed >::type CompilePolicy;
- typedef typename ::boost::parameter::binding<
- state_machine_args, ::boost::msm::back::tag::fsm_check_policy, no_fsm_check >::type FsmCheckPolicy;
- typedef typename ::boost::parameter::binding<
- state_machine_args, ::boost::msm::back::tag::queue_container_policy,
- queue_container_deque >::type QueueContainerPolicy;
- private:
- typedef boost::msm::back::state_machine<
- A0,A1,A2,A3,A4> library_sm;
- typedef ::boost::function<
- execute_return ()> transition_fct;
- typedef ::boost::function<
- execute_return () > deferred_fct;
- typedef typename QueueContainerPolicy::
- template In<
- std::pair<deferred_fct,char> >::type deferred_events_queue_t;
- typedef typename QueueContainerPolicy::
- template In<transition_fct>::type events_queue_t;
- typedef typename boost::mpl::eval_if<
- typename is_active_state_switch_policy<Derived>::type,
- get_active_state_switch_policy<Derived>,
- // default
- ::boost::mpl::identity<active_state_switch_after_entry>
- >::type active_state_switching;
- typedef bool (*flag_handler)(library_sm const&);
- // all state machines are friend with each other to allow embedding any of them in another fsm
- template <class ,class , class, class, class
- > friend class boost::msm::back::state_machine;
- // helper to add, if needed, visitors to all states
- // version without visitors
- template <class StateType,class Enable=void>
- struct visitor_fct_helper
- {
- public:
- visitor_fct_helper(){}
- void fill_visitors(int)
- {
- }
- template <class FCT>
- void insert(int,FCT)
- {
- }
- template <class VISITOR>
- void execute(int,VISITOR)
- {
- }
- };
- // version with visitors
- template <class StateType>
- struct visitor_fct_helper<StateType,typename ::boost::enable_if<has_accept_sig<StateType> >::type>
- {
- public:
- visitor_fct_helper():m_state_visitors(){}
- void fill_visitors(int number_of_states)
- {
- m_state_visitors.resize(number_of_states);
- }
- template <class FCT>
- void insert(int index,FCT fct)
- {
- m_state_visitors[index]=fct;
- }
- void execute(int index)
- {
- m_state_visitors[index]();
- }
- #define MSM_VISITOR_HELPER_EXECUTE_SUB(z, n, unused) ARG ## n vis ## n
- #define MSM_VISITOR_HELPER_EXECUTE(z, n, unused) \
- template <BOOST_PP_ENUM_PARAMS(n, class ARG)> \
- void execute(int index BOOST_PP_COMMA_IF(n) \
- BOOST_PP_ENUM(n, MSM_VISITOR_HELPER_EXECUTE_SUB, ~ ) ) \
- { \
- m_state_visitors[index](BOOST_PP_ENUM_PARAMS(n,vis)); \
- }
- BOOST_PP_REPEAT_FROM_TO(1,BOOST_PP_ADD(BOOST_MSM_VISITOR_ARG_SIZE,1), MSM_VISITOR_HELPER_EXECUTE, ~)
- #undef MSM_VISITOR_HELPER_EXECUTE
- #undef MSM_VISITOR_HELPER_EXECUTE_SUB
- private:
- typedef typename StateType::accept_sig::type visitor_fct;
- typedef std::vector<visitor_fct> visitors;
- visitors m_state_visitors;
- };
- template <class StateType,class Enable=int>
- struct deferred_msg_queue_helper
- {
- void clear(){}
- };
- template <class StateType>
- struct deferred_msg_queue_helper<StateType,
- typename ::boost::enable_if<
- typename ::boost::msm::back::has_fsm_deferred_events<StateType>::type,int >::type>
- {
- public:
- deferred_msg_queue_helper():m_deferred_events_queue(),m_cur_seq(0){}
- void clear()
- {
- m_deferred_events_queue.clear();
- }
- deferred_events_queue_t m_deferred_events_queue;
- char m_cur_seq;
- };
- public:
- // tags
- typedef int composite_tag;
- // in case someone needs to know
- typedef HistoryPolicy history_policy;
- struct InitEvent { };
- struct ExitEvent { };
- // flag handling
- struct Flag_AND
- {
- typedef std::logical_and<bool> type;
- };
- struct Flag_OR
- {
- typedef std::logical_or<bool> type;
- };
- typedef typename Derived::BaseAllStates BaseState;
- typedef Derived ConcreteSM;
- // if the front-end fsm provides an initial_event typedef, replace InitEvent by this one
- typedef typename ::boost::mpl::eval_if<
- typename has_initial_event<Derived>::type,
- get_initial_event<Derived>,
- ::boost::mpl::identity<InitEvent>
- >::type fsm_initial_event;
- // if the front-end fsm provides an exit_event typedef, replace ExitEvent by this one
- typedef typename ::boost::mpl::eval_if<
- typename has_final_event<Derived>::type,
- get_final_event<Derived>,
- ::boost::mpl::identity<ExitEvent>
- >::type fsm_final_event;
- template <class ExitPoint>
- struct exit_pt : public ExitPoint
- {
- // tags
- typedef ExitPoint wrapped_exit;
- typedef int pseudo_exit;
- typedef library_sm owner;
- typedef int no_automatic_create;
- typedef typename
- ExitPoint::event Event;
- typedef ::boost::function<execute_return (Event const&)>
- forwarding_function;
- // forward event to the higher-level FSM
- template <class ForwardEvent>
- void forward_event(ForwardEvent const& incomingEvent)
- {
- // use helper to forward or not
- ForwardHelper< ::boost::is_convertible<ForwardEvent,Event>::value>::helper(incomingEvent,m_forward);
- }
- void set_forward_fct(::boost::function<execute_return (Event const&)> fct)
- {
- m_forward = fct;
- }
- exit_pt():m_forward(){}
- // by assignments, we keep our forwarding functor unchanged as our containing SM did not change
- template <class RHS>
- exit_pt(RHS&):m_forward(){}
- exit_pt<ExitPoint>& operator= (const exit_pt<ExitPoint>& )
- {
- return *this;
- }
- private:
- forwarding_function m_forward;
- // using partial specialization instead of enable_if because of VC8 bug
- template <bool OwnEvent, int Dummy=0>
- struct ForwardHelper
- {
- template <class ForwardEvent>
- static void helper(ForwardEvent const& ,forwarding_function& )
- {
- // Not our event, assert
- BOOST_ASSERT(false);
- }
- };
- template <int Dummy>
- struct ForwardHelper<true,Dummy>
- {
- template <class ForwardEvent>
- static void helper(ForwardEvent const& incomingEvent,forwarding_function& forward_fct)
- {
- // call if handler set, if not, this state is simply a terminate state
- if (forward_fct)
- forward_fct(incomingEvent);
- }
- };
- };
- template <class EntryPoint>
- struct entry_pt : public EntryPoint
- {
- // tags
- typedef EntryPoint wrapped_entry;
- typedef int pseudo_entry;
- typedef library_sm owner;
- typedef int no_automatic_create;
- };
- template <class EntryPoint>
- struct direct : public EntryPoint
- {
- // tags
- typedef EntryPoint wrapped_entry;
- typedef int explicit_entry_state;
- typedef library_sm owner;
- typedef int no_automatic_create;
- };
- typedef typename get_number_of_regions<typename Derived::initial_state>::type nr_regions;
- // Template used to form rows in the transition table
- template<
- typename ROW
- >
- struct row_
- {
- //typedef typename ROW::Source T1;
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- // if the source is an exit pseudo state, then
- // current_state_type becomes the result of get_owner
- // meaning the containing SM from which the exit occurs
- typedef typename ::boost::mpl::eval_if<
- typename has_pseudo_exit<T1>::type,
- get_owner<T1,library_sm>,
- ::boost::mpl::identity<typename ROW::Source> >::type current_state_type;
- // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry
- // else if Target is an explicit_entry, next_state_type becomes the result of get_owner
- // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself
- typedef typename ::boost::mpl::eval_if<
- typename ::boost::mpl::is_sequence<T2>::type,
- get_fork_owner<T2,library_sm>,
- ::boost::mpl::eval_if<
- typename has_no_automatic_create<T2>::type,
- get_owner<T2,library_sm>,
- ::boost::mpl::identity<T2> >
- >::type next_state_type;
- // if a guard condition is here, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list ) )
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event& evt)
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- BOOST_STATIC_CONSTANT(int, next_state = (get_state_id<stt,next_state_type>::type::value));
- boost::ignore_unused(state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active
- if (has_pseudo_exit<T1>::type::value &&
- !is_exit_state_active<T1,get_owner<T1,library_sm> >(fsm))
- {
- return HANDLED_FALSE;
- }
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state);
- // the guard condition has already been checked
- execute_exit<current_state_type>
- (::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state);
- // then call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list);
- fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state);
- // and finally the entry method of the new current state
- convert_event_and_execute_entry<next_state_type,T2>
- (::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state);
- return res;
- }
- };
- // row having only a guard condition
- template<
- typename ROW
- >
- struct g_row_
- {
- //typedef typename ROW::Source T1;
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- // if the source is an exit pseudo state, then
- // current_state_type becomes the result of get_owner
- // meaning the containing SM from which the exit occurs
- typedef typename ::boost::mpl::eval_if<
- typename has_pseudo_exit<T1>::type,
- get_owner<T1,library_sm>,
- ::boost::mpl::identity<typename ROW::Source> >::type current_state_type;
- // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry
- // else if Target is an explicit_entry, next_state_type becomes the result of get_owner
- // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself
- typedef typename ::boost::mpl::eval_if<
- typename ::boost::mpl::is_sequence<T2>::type,
- get_fork_owner<T2,library_sm>,
- ::boost::mpl::eval_if<
- typename has_no_automatic_create<T2>::type,
- get_owner<T2,library_sm>,
- ::boost::mpl::identity<T2> >
- >::type next_state_type;
- // if a guard condition is defined, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list ))
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event const& evt)
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- BOOST_STATIC_CONSTANT(int, next_state = (get_state_id<stt,next_state_type>::type::value));
- boost::ignore_unused(state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active
- if (has_pseudo_exit<T1>::type::value &&
- !is_exit_state_active<T1,get_owner<T1,library_sm> >(fsm))
- {
- return HANDLED_FALSE;
- }
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state);
- // the guard condition has already been checked
- execute_exit<current_state_type>
- (::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state);
- fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state);
- // and finally the entry method of the new current state
- convert_event_and_execute_entry<next_state_type,T2>
- (::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state);
- return HANDLED_TRUE;
- }
- };
- // row having only an action method
- template<
- typename ROW
- >
- struct a_row_
- {
- //typedef typename ROW::Source T1;
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- // if the source is an exit pseudo state, then
- // current_state_type becomes the result of get_owner
- // meaning the containing SM from which the exit occurs
- typedef typename ::boost::mpl::eval_if<
- typename has_pseudo_exit<T1>::type,
- get_owner<T1,library_sm>,
- ::boost::mpl::identity<typename ROW::Source> >::type current_state_type;
- // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry
- // else if Target is an explicit_entry, next_state_type becomes the result of get_owner
- // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself
- typedef typename ::boost::mpl::eval_if<
- typename ::boost::mpl::is_sequence<T2>::type,
- get_fork_owner<T2,library_sm>,
- ::boost::mpl::eval_if<
- typename has_no_automatic_create<T2>::type,
- get_owner<T2,library_sm>,
- ::boost::mpl::identity<T2> >
- >::type next_state_type;
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event& evt)
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- BOOST_STATIC_CONSTANT(int, next_state = (get_state_id<stt,next_state_type>::type::value));
- boost::ignore_unused(state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active
- if (has_pseudo_exit<T1>::type::value &&
- !is_exit_state_active<T1,get_owner<T1,library_sm> >(fsm))
- {
- return HANDLED_FALSE;
- }
- fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state);
- // no need to check the guard condition
- // first call the exit method of the current state
- execute_exit<current_state_type>
- (::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state);
- // then call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list);
- fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state);
- // and finally the entry method of the new current state
- convert_event_and_execute_entry<next_state_type,T2>
- (::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state);
- return res;
- }
- };
- // row having no guard condition or action, simply transitions
- template<
- typename ROW
- >
- struct _row_
- {
- //typedef typename ROW::Source T1;
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- // if the source is an exit pseudo state, then
- // current_state_type becomes the result of get_owner
- // meaning the containing SM from which the exit occurs
- typedef typename ::boost::mpl::eval_if<
- typename has_pseudo_exit<T1>::type,
- get_owner<T1,library_sm>,
- ::boost::mpl::identity<typename ROW::Source> >::type current_state_type;
- // if Target is a sequence, then we have a fork and expect a sequence of explicit_entry
- // else if Target is an explicit_entry, next_state_type becomes the result of get_owner
- // meaning the containing SM if the row is "outside" the containing SM or else the explicit_entry state itself
- typedef typename ::boost::mpl::eval_if<
- typename ::boost::mpl::is_sequence<T2>::type,
- get_fork_owner<T2,library_sm>,
- ::boost::mpl::eval_if<
- typename has_no_automatic_create<T2>::type,
- get_owner<T2,library_sm>,
- ::boost::mpl::identity<T2> >
- >::type next_state_type;
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int region_index, int state, transition_event const& evt)
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- BOOST_STATIC_CONSTANT(int, next_state = (get_state_id<stt,next_state_type>::type::value));
- boost::ignore_unused(state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- // if T1 is an exit pseudo state, then take the transition only if the pseudo exit state is active
- if (has_pseudo_exit<T1>::type::value &&
- !is_exit_state_active<T1,get_owner<T1,library_sm> >(fsm))
- {
- return HANDLED_FALSE;
- }
- fsm.m_states[region_index] = active_state_switching::after_guard(current_state,next_state);
- // first call the exit method of the current state
- execute_exit<current_state_type>
- (::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_exit(current_state,next_state);
- fsm.m_states[region_index] = active_state_switching::after_action(current_state,next_state);
- // and finally the entry method of the new current state
- convert_event_and_execute_entry<next_state_type,T2>
- (::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),evt,fsm);
- fsm.m_states[region_index] = active_state_switching::after_entry(current_state,next_state);
- return HANDLED_TRUE;
- }
- };
- // "i" rows are rows for internal transitions
- template<
- typename ROW
- >
- struct irow_
- {
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- typedef typename ROW::Source current_state_type;
- typedef T2 next_state_type;
- // if a guard condition is here, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list))
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int , int state, transition_event const& evt)
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- boost::ignore_unused(state, current_state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- // call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list);
- return res;
- }
- };
- // row having only a guard condition
- template<
- typename ROW
- >
- struct g_irow_
- {
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- typedef typename ROW::Source current_state_type;
- typedef T2 next_state_type;
- // if a guard condition is defined, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list) )
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int , int state, transition_event const& evt)
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- boost::ignore_unused(state, current_state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- return HANDLED_TRUE;
- }
- };
- // row having only an action method
- template<
- typename ROW
- >
- struct a_irow_
- {
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- typedef typename ROW::Source current_state_type;
- typedef T2 next_state_type;
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int , int state, transition_event const& evt)
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- boost::ignore_unused(state, current_state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- // call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- ::boost::fusion::at_key<current_state_type>(fsm.m_substate_list),
- ::boost::fusion::at_key<next_state_type>(fsm.m_substate_list),
- fsm.m_substate_list);
- return res;
- }
- };
- // row simply ignoring the event
- template<
- typename ROW
- >
- struct _irow_
- {
- typedef typename make_entry<typename ROW::Source,library_sm>::type T1;
- typedef typename make_exit<typename ROW::Target,library_sm>::type T2;
- typedef typename ROW::Evt transition_event;
- typedef typename ROW::Source current_state_type;
- typedef T2 next_state_type;
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& , int , int state, transition_event const& )
- {
- BOOST_STATIC_CONSTANT(int, current_state = (get_state_id<stt,current_state_type>::type::value));
- boost::ignore_unused(state, current_state); // Avoid warnings if BOOST_ASSERT expands to nothing.
- BOOST_ASSERT(state == (current_state));
- return HANDLED_TRUE;
- }
- };
- // transitions internal to this state machine (no substate involved)
- template<
- typename ROW,
- typename StateType
- >
- struct internal_
- {
- typedef StateType current_state_type;
- typedef StateType next_state_type;
- typedef typename ROW::Evt transition_event;
- // if a guard condition is here, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- fsm.m_substate_list) )
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int , int , transition_event const& evt)
- {
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- // then call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- fsm.m_substate_list);
- return res;
- }
- };
- template<
- typename ROW
- >
- struct internal_ <ROW,library_sm>
- {
- typedef library_sm current_state_type;
- typedef library_sm next_state_type;
- typedef typename ROW::Evt transition_event;
- // if a guard condition is here, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- fsm,
- fsm,
- fsm.m_substate_list) )
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int , int , transition_event const& evt)
- {
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- // then call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- fsm,
- fsm,
- fsm.m_substate_list);
- return res;
- }
- };
- template<
- typename ROW,
- typename StateType
- >
- struct a_internal_
- {
- typedef StateType current_state_type;
- typedef StateType next_state_type;
- typedef typename ROW::Evt transition_event;
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt)
- {
- // then call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- fsm.m_substate_list);
- return res;
- }
- };
- template<
- typename ROW
- >
- struct a_internal_ <ROW,library_sm>
- {
- typedef library_sm current_state_type;
- typedef library_sm next_state_type;
- typedef typename ROW::Evt transition_event;
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt)
- {
- // then call the action method
- HandledEnum res = ROW::action_call(fsm,evt,
- fsm,
- fsm,
- fsm.m_substate_list);
- return res;
- }
- };
- template<
- typename ROW,
- typename StateType
- >
- struct g_internal_
- {
- typedef StateType current_state_type;
- typedef StateType next_state_type;
- typedef typename ROW::Evt transition_event;
- // if a guard condition is here, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- ::boost::fusion::at_key<StateType>(fsm.m_substate_list),
- fsm.m_substate_list) )
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt)
- {
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- return HANDLED_TRUE;
- }
- };
- template<
- typename ROW
- >
- struct g_internal_ <ROW,library_sm>
- {
- typedef library_sm current_state_type;
- typedef library_sm next_state_type;
- typedef typename ROW::Evt transition_event;
- // if a guard condition is here, call it to check that the event is accepted
- static bool check_guard(library_sm& fsm,transition_event const& evt)
- {
- if ( ROW::guard_call(fsm,evt,
- fsm,
- fsm,
- fsm.m_substate_list) )
- return true;
- return false;
- }
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int, int, transition_event const& evt)
- {
- if (!check_guard(fsm,evt))
- {
- // guard rejected the event, we stay in the current one
- return HANDLED_GUARD_REJECT;
- }
- return HANDLED_TRUE;
- }
- };
- template<
- typename ROW,
- typename StateType
- >
- struct _internal_
- {
- typedef StateType current_state_type;
- typedef StateType next_state_type;
- typedef typename ROW::Evt transition_event;
- static HandledEnum execute(library_sm& , int , int , transition_event const& )
- {
- return HANDLED_TRUE;
- }
- };
- template<
- typename ROW
- >
- struct _internal_ <ROW,library_sm>
- {
- typedef library_sm current_state_type;
- typedef library_sm next_state_type;
- typedef typename ROW::Evt transition_event;
- static HandledEnum execute(library_sm& , int , int , transition_event const& )
- {
- return HANDLED_TRUE;
- }
- };
- // Template used to form forwarding rows in the transition table for every row of a composite SM
- template<
- typename T1
- , class Evt
- >
- struct frow
- {
- typedef T1 current_state_type;
- typedef T1 next_state_type;
- typedef Evt transition_event;
- // tag to find out if a row is a forwarding row
- typedef int is_frow;
- // Take the transition action and return the next state.
- static HandledEnum execute(library_sm& fsm, int region_index, int , transition_event const& evt)
- {
- // false as second parameter because this event is forwarded from outer fsm
- execute_return res =
- (::boost::fusion::at_key<current_state_type>(fsm.m_substate_list)).process_event_internal(evt);
- fsm.m_states[region_index]=get_state_id<stt,T1>::type::value;
- return res;
- }
- // helper metafunctions used by dispatch table and give the frow a new event
- // (used to avoid double entries in a table because of base events)
- template <class NewEvent>
- struct replace_event
- {
- typedef frow<T1,NewEvent> type;
- };
- };
- template <class Tag, class Transition,class StateType>
- struct create_backend_stt
- {
- };
- template <class Transition,class StateType>
- struct create_backend_stt<g_row_tag,Transition,StateType>
- {
- typedef g_row_<Transition> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<a_row_tag,Transition,StateType>
- {
- typedef a_row_<Transition> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<_row_tag,Transition,StateType>
- {
- typedef _row_<Transition> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<row_tag,Transition,StateType>
- {
- typedef row_<Transition> type;
- };
- // internal transitions
- template <class Transition,class StateType>
- struct create_backend_stt<g_irow_tag,Transition,StateType>
- {
- typedef g_irow_<Transition> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<a_irow_tag,Transition,StateType>
- {
- typedef a_irow_<Transition> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<irow_tag,Transition,StateType>
- {
- typedef irow_<Transition> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<_irow_tag,Transition,StateType>
- {
- typedef _irow_<Transition> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<sm_a_i_row_tag,Transition,StateType>
- {
- typedef a_internal_<Transition,StateType> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<sm_g_i_row_tag,Transition,StateType>
- {
- typedef g_internal_<Transition,StateType> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<sm_i_row_tag,Transition,StateType>
- {
- typedef internal_<Transition,StateType> type;
- };
- template <class Transition,class StateType>
- struct create_backend_stt<sm__i_row_tag,Transition,StateType>
- {
- typedef _internal_<Transition,StateType> type;
- };
- template <class Transition,class StateType=void>
- struct make_row_tag
- {
- typedef typename create_backend_stt<typename Transition::row_type_tag,Transition,StateType>::type type;
- };
- // add to the stt the initial states which could be missing (if not being involved in a transition)
- template <class BaseType, class stt_simulated = typename BaseType::transition_table>
- struct create_real_stt
- {
- //typedef typename BaseType::transition_table stt_simulated;
- typedef typename ::boost::mpl::fold<
- stt_simulated,mpl::vector0<>,
- ::boost::mpl::push_back< ::boost::mpl::placeholders::_1,
- make_row_tag< ::boost::mpl::placeholders::_2 , BaseType > >
- >::type type;
- };
- template <class Table,class Intermediate,class StateType>
- struct add_forwarding_row_helper
- {
- typedef typename generate_event_set<Table>::type all_events;
- typedef typename ::boost::mpl::fold<
- all_events, Intermediate,
- ::boost::mpl::push_back< ::boost::mpl::placeholders::_1,
- frow<StateType, ::boost::mpl::placeholders::_2> > >::type type;
- };
- // gets the transition table from a composite and make from it a forwarding row
- template <class StateType,class IsComposite>
- struct get_internal_transition_table
- {
- // first get the table of a composite
- typedef typename recursive_get_transition_table<StateType>::type original_table;
- // we now look for the events the composite has in its internal transitions
- // the internal ones are searched recursively in sub-sub... states
- // we go recursively because our states can also have internal tables or substates etc.
- typedef typename recursive_get_internal_transition_table<StateType, ::boost::mpl::true_>::type recursive_istt;
- typedef typename ::boost::mpl::fold<
- recursive_istt,::boost::mpl::vector0<>,
- ::boost::mpl::push_back< ::boost::mpl::placeholders::_1,
- make_row_tag< ::boost::mpl::placeholders::_2 , StateType> >
- >::type recursive_istt_with_tag;
- typedef typename ::boost::mpl::insert_range< original_table, typename ::boost::mpl::end<original_table>::type,
- recursive_istt_with_tag>::type table_with_all_events;
- // and add for every event a forwarding row
- typedef typename ::boost::mpl::eval_if<
- typename CompilePolicy::add_forwarding_rows,
- add_forwarding_row_helper<table_with_all_events,::boost::mpl::vector0<>,StateType>,
- ::boost::mpl::identity< ::boost::mpl::vector0<> >
- >::type type;
- };
- template <class StateType>
- struct get_internal_transition_table<StateType, ::boost::mpl::false_ >
- {
- typedef typename create_real_stt<StateType, typename StateType::internal_transition_table >::type type;
- };
- // typedefs used internally
- typedef typename create_real_stt<Derived>::type real_transition_table;
- typedef typename create_stt<library_sm>::type stt;
- typedef typename get_initial_states<typename Derived::initial_state>::type initial_states;
- typedef typename generate_state_set<stt>::type state_list;
- typedef typename HistoryPolicy::template apply<nr_regions::value>::type concrete_history;
- typedef typename ::boost::fusion::result_of::as_set<state_list>::type substate_list;
- typedef typename ::boost::msm::back::generate_event_set<
- typename create_real_stt<library_sm, typename library_sm::internal_transition_table >::type
- >::type processable_events_internal_table;
- // extends the transition table with rows from composite states
- template <class Composite>
- struct extend_table
- {
- // add the init states
- //typedef typename create_stt<Composite>::type stt;
- typedef typename Composite::stt Stt;
- // add the internal events defined in the internal_transition_table
- // Note: these are added first because they must have a lesser prio
- // than the deeper transitions in the sub regions
- // table made of a stt + internal transitions of composite
- typedef typename ::boost::mpl::fold<
- typename Composite::internal_transition_table,::boost::mpl::vector0<>,
- ::boost::mpl::push_back< ::boost::mpl::placeholders::_1,
- make_row_tag< ::boost::mpl::placeholders::_2 , Composite> >
- >::type internal_stt;
- typedef typename ::boost::mpl::insert_range<
- Stt,
- typename ::boost::mpl::end<Stt>::type,
- internal_stt
- //typename get_internal_transition_table<Composite, ::boost::mpl::true_ >::type
- >::type stt_plus_internal;
- // for every state, add its transition table (if any)
- // transformed as frow
- typedef typename ::boost::mpl::fold<state_list,stt_plus_internal,
- ::boost::mpl::insert_range<
- ::boost::mpl::placeholders::_1,
- ::boost::mpl::end< ::boost::mpl::placeholders::_1>,
- get_internal_transition_table<
- ::boost::mpl::placeholders::_2,
- is_composite_state< ::boost::mpl::placeholders::_2> > >
- >::type type;
- };
- // extend the table with tables from composite states
- typedef typename extend_table<library_sm>::type complete_table;
- // build a sequence of regions
- typedef typename get_regions_as_sequence<typename Derived::initial_state>::type seq_initial_states;
- // Member functions
- // start the state machine (calls entry of the initial state)
- void start()
- {
- // reinitialize our list of currently active states with the ones defined in Derived::initial_state
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> >
- (init_states(m_states));
- // call on_entry on this SM
- (static_cast<Derived*>(this))->on_entry(fsm_initial_event(),*this);
- ::boost::mpl::for_each<initial_states, boost::msm::wrap<mpl::placeholders::_1> >
- (call_init<fsm_initial_event>(fsm_initial_event(),this));
- // give a chance to handle an anonymous (eventless) transition
- handle_eventless_transitions_helper<library_sm> eventless_helper(this,true);
- eventless_helper.process_completion_event();
- }
- // start the state machine (calls entry of the initial state passing incomingEvent to on_entry's)
- template <class Event>
- void start(Event const& incomingEvent)
- {
- // reinitialize our list of currently active states with the ones defined in Derived::initial_state
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> >
- (init_states(m_states));
- // call on_entry on this SM
- (static_cast<Derived*>(this))->on_entry(incomingEvent,*this);
- ::boost::mpl::for_each<initial_states, boost::msm::wrap<mpl::placeholders::_1> >
- (call_init<Event>(incomingEvent,this));
- // give a chance to handle an anonymous (eventless) transition
- handle_eventless_transitions_helper<library_sm> eventless_helper(this,true);
- eventless_helper.process_completion_event();
- }
- // stop the state machine (calls exit of the current state)
- void stop()
- {
- do_exit(fsm_final_event(),*this);
- }
- // stop the state machine (calls exit of the current state passing finalEvent to on_exit's)
- template <class Event>
- void stop(Event const& finalEvent)
- {
- do_exit(finalEvent,*this);
- }
- // Main function used by clients of the derived FSM to make transitions.
- template<class Event>
- execute_return process_event(Event const& evt)
- {
- return process_event_internal(evt, EVENT_SOURCE_DIRECT);
- }
- template <class EventType>
- void enqueue_event_helper(EventType const& evt, ::boost::mpl::false_ const &)
- {
- execute_return (library_sm::*pf) (EventType const&, EventSource) =
- &library_sm::process_event_internal;
- m_events_queue.m_events_queue.push_back(
- ::boost::bind(
- pf, this, evt,
- static_cast<EventSource>(EVENT_SOURCE_MSG_QUEUE)));
- }
- template <class EventType>
- void enqueue_event_helper(EventType const& , ::boost::mpl::true_ const &)
- {
- // no queue
- }
- void execute_queued_events_helper(::boost::mpl::false_ const &)
- {
- while(!m_events_queue.m_events_queue.empty())
- {
- transition_fct to_call = m_events_queue.m_events_queue.front();
- m_events_queue.m_events_queue.pop_front();
- to_call();
- }
- }
- void execute_queued_events_helper(::boost::mpl::true_ const &)
- {
- // no queue required
- }
- void execute_single_queued_event_helper(::boost::mpl::false_ const &)
- {
- transition_fct to_call = m_events_queue.m_events_queue.front();
- m_events_queue.m_events_queue.pop_front();
- to_call();
- }
- void execute_single_queued_event_helper(::boost::mpl::true_ const &)
- {
- // no queue required
- }
- // enqueues an event in the message queue
- // call execute_queued_events to process all queued events.
- // Be careful if you do this during event processing, the event will be processed immediately
- // and not kept in the queue
- template <class EventType>
- void enqueue_event(EventType const& evt)
- {
- enqueue_event_helper<EventType>(evt, typename is_no_message_queue<library_sm>::type());
- }
- // empty the queue and process events
- void execute_queued_events()
- {
- execute_queued_events_helper(typename is_no_message_queue<library_sm>::type());
- }
- void execute_single_queued_event()
- {
- execute_single_queued_event_helper(typename is_no_message_queue<library_sm>::type());
- }
- typename events_queue_t::size_type get_message_queue_size() const
- {
- return m_events_queue.m_events_queue.size();
- }
- events_queue_t& get_message_queue()
- {
- return m_events_queue.m_events_queue;
- }
- const events_queue_t& get_message_queue() const
- {
- return m_events_queue.m_events_queue;
- }
- void clear_deferred_queue()
- {
- m_deferred_events_queue.clear();
- }
- deferred_events_queue_t& get_deferred_queue()
- {
- return m_deferred_events_queue.m_deferred_events_queue;
- }
- const deferred_events_queue_t& get_deferred_queue() const
- {
- return m_deferred_events_queue.m_deferred_events_queue;
- }
- // Getter that returns the current state of the FSM
- const int* current_state() const
- {
- return this->m_states;
- }
- template <class Archive>
- struct serialize_state
- {
- serialize_state(Archive& ar):ar_(ar){}
- template<typename T>
- typename ::boost::enable_if<
- typename ::boost::mpl::or_<
- typename has_do_serialize<T>::type,
- typename is_composite_state<T>::type
- >::type
- ,void
- >::type
- operator()(T& t) const
- {
- ar_ & t;
- }
- template<typename T>
- typename ::boost::disable_if<
- typename ::boost::mpl::or_<
- typename has_do_serialize<T>::type,
- typename is_composite_state<T>::type
- >::type
- ,void
- >::type
- operator()(T&) const
- {
- // no state to serialize
- }
- Archive& ar_;
- };
- template<class Archive>
- void serialize(Archive & ar, const unsigned int)
- {
- // invoke serialization of the base class
- (serialize_state<Archive>(ar))(boost::serialization::base_object<Derived>(*this));
- // now our attributes
- ar & m_states;
- // queues cannot be serialized => skip
- ar & m_history;
- ar & m_event_processing;
- ar & m_is_included;
- // visitors cannot be serialized => skip
- ::boost::fusion::for_each(m_substate_list, serialize_state<Archive>(ar));
- }
- // linearly search for the state with the given id
- struct get_state_id_helper
- {
- get_state_id_helper(int id,const BaseState** res,const library_sm* self_):
- result_state(res),searched_id(id),self(self_) {}
- template <class StateType>
- void operator()(boost::msm::wrap<StateType> const&)
- {
- // look for the state id until found
- BOOST_STATIC_CONSTANT(int, id = (get_state_id<stt,StateType>::value));
- if (!*result_state && (id == searched_id))
- {
- *result_state = &::boost::fusion::at_key<StateType>(self->m_substate_list);
- }
- }
- const BaseState** result_state;
- int searched_id;
- const library_sm* self;
- };
- // return the state whose id is passed or 0 if not found
- // caution if you need this, you probably need polymorphic states
- // complexity: O(number of states)
- BaseState* get_state_by_id(int id)
- {
- const BaseState* result_state=0;
- ::boost::mpl::for_each<state_list,
- ::boost::msm::wrap< ::boost::mpl::placeholders::_1> > (get_state_id_helper(id,&result_state,this));
- return const_cast<BaseState*>(result_state);
- }
- const BaseState* get_state_by_id(int id) const
- {
- const BaseState* result_state=0;
- ::boost::mpl::for_each<state_list,
- ::boost::msm::wrap< ::boost::mpl::placeholders::_1> > (get_state_id_helper(id,&result_state,this));
- return result_state;
- }
- // true if the sm is used in another sm
- bool is_contained() const
- {
- return m_is_included;
- }
- // get the history policy class
- concrete_history& get_history()
- {
- return m_history;
- }
- concrete_history const& get_history() const
- {
- return m_history;
- }
- // get a state (const version)
- // as a pointer
- template <class State>
- typename ::boost::enable_if<typename ::boost::is_pointer<State>::type,State >::type
- get_state(::boost::msm::back::dummy<0> = 0) const
- {
- return const_cast<State >
- (&
- (::boost::fusion::at_key<
- typename ::boost::remove_const<typename ::boost::remove_pointer<State>::type>::type>(m_substate_list)));
- }
- // as a reference
- template <class State>
- typename ::boost::enable_if<typename ::boost::is_reference<State>::type,State >::type
- get_state(::boost::msm::back::dummy<1> = 0) const
- {
- return const_cast<State >
- ( ::boost::fusion::at_key<
- typename ::boost::remove_const<typename ::boost::remove_reference<State>::type>::type>(m_substate_list) );
- }
- // get a state (non const version)
- // as a pointer
- template <class State>
- typename ::boost::enable_if<typename ::boost::is_pointer<State>::type,State >::type
- get_state(::boost::msm::back::dummy<0> = 0)
- {
- return &(static_cast<typename boost::add_reference<typename ::boost::remove_pointer<State>::type>::type >
- (::boost::fusion::at_key<typename ::boost::remove_pointer<State>::type>(m_substate_list)));
- }
- // as a reference
- template <class State>
- typename ::boost::enable_if<typename ::boost::is_reference<State>::type,State >::type
- get_state(::boost::msm::back::dummy<1> = 0)
- {
- return ::boost::fusion::at_key<typename ::boost::remove_reference<State>::type>(m_substate_list);
- }
- // checks if a flag is active using the BinaryOp as folding function
- template <class Flag,class BinaryOp>
- bool is_flag_active() const
- {
- flag_handler* flags_entries = get_entries_for_flag<Flag>();
- bool res = (*flags_entries[ m_states[0] ])(*this);
- for (int i = 1; i < nr_regions::value ; ++i)
- {
- res = typename BinaryOp::type() (res,(*flags_entries[ m_states[i] ])(*this));
- }
- return res;
- }
- // checks if a flag is active using no binary op if 1 region, or OR if > 1 regions
- template <class Flag>
- bool is_flag_active() const
- {
- return FlagHelper<Flag,(nr_regions::value>1)>::helper(*this,get_entries_for_flag<Flag>());
- }
- // visit the currently active states (if these are defined as visitable
- // by implementing accept)
- void visit_current_states()
- {
- for (int i=0; i<nr_regions::value;++i)
- {
- m_visitors.execute(m_states[i]);
- }
- }
- #define MSM_VISIT_STATE_SUB(z, n, unused) ARG ## n vis ## n
- #define MSM_VISIT_STATE_EXECUTE(z, n, unused) \
- template <BOOST_PP_ENUM_PARAMS(n, class ARG)> \
- void visit_current_states(BOOST_PP_ENUM(n, MSM_VISIT_STATE_SUB, ~ ) ) \
- { \
- for (int i=0; i<nr_regions::value;++i) \
- { \
- m_visitors.execute(m_states[i],BOOST_PP_ENUM_PARAMS(n,vis)); \
- } \
- }
- BOOST_PP_REPEAT_FROM_TO(1,BOOST_PP_ADD(BOOST_MSM_VISITOR_ARG_SIZE,1), MSM_VISIT_STATE_EXECUTE, ~)
- #undef MSM_VISIT_STATE_EXECUTE
- #undef MSM_VISIT_STATE_SUB
- // puts the given event into the deferred queue
- template <class Event>
- typename::boost::disable_if< typename ::boost::msm::is_kleene_event<Event>::type, void>::type
- defer_event(Event const& e)
- {
- // to call this function, you need either a state with a deferred_events typedef
- // or that the fsm provides the activate_deferred_events typedef
- BOOST_MPL_ASSERT(( has_fsm_deferred_events<library_sm> ));
- execute_return (library_sm::*pf) (Event const&, EventSource) =
- &library_sm::process_event_internal;
- // Deferred events are added with a correlation sequence that helps to
- // identify when an event was added - This is typically to distinguish
- // between events deferred in this processing versus previous.
- m_deferred_events_queue.m_deferred_events_queue.push_back(
- std::make_pair(
- ::boost::bind(
- pf, this, e, static_cast<EventSource>(EVENT_SOURCE_DIRECT|EVENT_SOURCE_DEFERRED)),
- static_cast<char>(m_deferred_events_queue.m_cur_seq+1)));
- }
- protected:
- template <class KleeneEvent, class Fsm>
- struct defer_event_kleene_helper
- {
- defer_event_kleene_helper(KleeneEvent const& e, Fsm* fsm, bool& found)
- : m_event(e), m_fsm(fsm), m_found(found) {}
- // History initializer function object, used with mpl::for_each
- template <class Event>
- void operator()(Event const& ev)
- {
- if (m_event.type() == boost::typeindex::type_id<decltype(ev)>().type_info())
- {
- m_found = true;
- // to call this function, you need either a state with a deferred_events typedef
- // or that the fsm provides the activate_deferred_events typedef
- BOOST_MPL_ASSERT((has_fsm_deferred_events<library_sm>));
- ::boost::msm::back::execute_return(library_sm:: * pf) (Event const&, ::boost::msm::back::EventSource) =
- &library_sm::process_event_internal;
- // Deferred events are added with a correlation sequence that helps to
- // identify when an event was added - This is typically to distinguish
- // between events deferred in this processing versus previous.
- m_fsm->m_deferred_events_queue.m_deferred_events_queue.push_back(
- std::make_pair(
- ::boost::bind(
- pf, m_fsm, boost::any_cast<Event>(m_event), static_cast<::boost::msm::back::EventSource>(::boost::msm::back::EVENT_SOURCE_DIRECT | ::boost::msm::back::EVENT_SOURCE_DEFERRED)),
- static_cast<char>(m_fsm->m_deferred_events_queue.m_cur_seq + 1)));
- }
- }
- KleeneEvent const& m_event;
- Fsm* m_fsm;
- bool& m_found;
- };
- public:
- template <class Event>
- typename::boost::enable_if< typename ::boost::msm::is_kleene_event<Event>::type, void>::type
- defer_event(Event const& e)
- {
- typedef typename generate_event_set<stt>::type event_list;
- bool found = false;
- boost::fusion::for_each(
- event_list(),
- defer_event_kleene_helper<Event,library_sm>(e,this,found));
- if (!found)
- {
- for (int i = 0; i < nr_regions::value; ++i)
- {
- this->no_transition(e, *this, this->m_states[i]);
- }
- }
- }
- protected: // interface for the derived class
- // helper used to fill the initial states
- struct init_states
- {
- init_states(int* const init):m_initial_states(init),m_index(-1){}
- // History initializer function object, used with mpl::for_each
- template <class State>
- void operator()(::boost::msm::wrap<State> const&)
- {
- m_initial_states[++m_index]=get_state_id<stt,State>::type::value;
- }
- int* const m_initial_states;
- int m_index;
- };
- public:
- struct update_state
- {
- update_state(substate_list& to_overwrite_):to_overwrite(&to_overwrite_){}
- template<typename StateType>
- void operator()(StateType const& astate) const
- {
- ::boost::fusion::at_key<StateType>(*to_overwrite)=astate;
- }
- substate_list* to_overwrite;
- };
- template <class Expr>
- void set_states(Expr const& expr)
- {
- ::boost::fusion::for_each(
- ::boost::fusion::as_vector(FoldToList()(expr, boost::fusion::nil_())),update_state(this->m_substate_list));
- }
- // Construct with the default initial states
- state_machine()
- :Derived()
- ,m_events_queue()
- ,m_deferred_events_queue()
- ,m_history()
- ,m_event_processing(false)
- ,m_is_included(false)
- ,m_visitors()
- ,m_substate_list()
- {
- // initialize our list of states with the ones defined in Derived::initial_state
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> >
- (init_states(m_states));
- m_history.set_initial_states(m_states);
- // create states
- fill_states(this);
- }
- // Construct with the default initial states and some default argument(s)
- #if defined (BOOST_NO_CXX11_RVALUE_REFERENCES) \
- || defined (BOOST_NO_CXX11_VARIADIC_TEMPLATES) \
- || defined (BOOST_NO_CXX11_FUNCTION_TEMPLATE_DEFAULT_ARGS)
- template <class Expr>
- state_machine
- (Expr const& expr, typename ::boost::enable_if<typename ::boost::proto::is_expr<Expr>::type >::type* = 0)
- :Derived()
- , m_events_queue()
- , m_deferred_events_queue()
- , m_history()
- , m_event_processing(false)
- , m_is_included(false)
- , m_visitors()
- , m_substate_list()
- {
- BOOST_MPL_ASSERT_MSG(
- (::boost::proto::matches<Expr, FoldToList>::value),
- THE_STATES_EXPRESSION_PASSED_DOES_NOT_MATCH_GRAMMAR,
- (FoldToList));
- // initialize our list of states with the ones defined in Derived::initial_state
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> >
- (init_states(m_states));
- m_history.set_initial_states(m_states);
- // create states
- set_states(expr);
- fill_states(this);
- }
- #define MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB(z, n, unused) ARG ## n t ## n
- #define MSM_CONSTRUCTOR_HELPER_EXECUTE(z, n, unused) \
- template <BOOST_PP_ENUM_PARAMS(n, class ARG)> \
- state_machine<A0,A1,A2,A3,A4 \
- >(BOOST_PP_ENUM(n, MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB, ~ ), \
- typename ::boost::disable_if<typename ::boost::proto::is_expr<ARG0>::type >::type* =0 ) \
- :Derived(BOOST_PP_ENUM_PARAMS(n,t)) \
- ,m_events_queue() \
- ,m_deferred_events_queue() \
- ,m_history() \
- ,m_event_processing(false) \
- ,m_is_included(false) \
- ,m_visitors() \
- ,m_substate_list() \
- { \
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> > \
- (init_states(m_states)); \
- m_history.set_initial_states(m_states); \
- fill_states(this); \
- } \
- template <class Expr,BOOST_PP_ENUM_PARAMS(n, class ARG)> \
- state_machine<A0,A1,A2,A3,A4 \
- >(Expr const& expr,BOOST_PP_ENUM(n, MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB, ~ ), \
- typename ::boost::enable_if<typename ::boost::proto::is_expr<Expr>::type >::type* =0 ) \
- :Derived(BOOST_PP_ENUM_PARAMS(n,t)) \
- ,m_events_queue() \
- ,m_deferred_events_queue() \
- ,m_history() \
- ,m_event_processing(false) \
- ,m_is_included(false) \
- ,m_visitors() \
- ,m_substate_list() \
- { \
- BOOST_MPL_ASSERT_MSG( \
- ( ::boost::proto::matches<Expr, FoldToList>::value), \
- THE_STATES_EXPRESSION_PASSED_DOES_NOT_MATCH_GRAMMAR, \
- (FoldToList)); \
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> > \
- (init_states(m_states)); \
- m_history.set_initial_states(m_states); \
- set_states(expr); \
- fill_states(this); \
- }
- BOOST_PP_REPEAT_FROM_TO(1,BOOST_PP_ADD(BOOST_MSM_CONSTRUCTOR_ARG_SIZE,1), MSM_CONSTRUCTOR_HELPER_EXECUTE, ~)
- #undef MSM_CONSTRUCTOR_HELPER_EXECUTE
- #undef MSM_CONSTRUCTOR_HELPER_EXECUTE_SUB
- #else
- template <class ARG0,class... ARG,class=typename ::boost::disable_if<typename ::boost::proto::is_expr<ARG0>::type >::type>
- state_machine(ARG0&& t0,ARG&&... t)
- :Derived(std::forward<ARG0>(t0), std::forward<ARG>(t)...)
- ,m_events_queue()
- ,m_deferred_events_queue()
- ,m_history()
- ,m_event_processing(false)
- ,m_is_included(false)
- ,m_visitors()
- ,m_substate_list()
- {
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> >
- (init_states(m_states));
- m_history.set_initial_states(m_states);
- fill_states(this);
- }
- template <class Expr,class... ARG,class=typename ::boost::enable_if<typename ::boost::proto::is_expr<Expr>::type >::type>
- state_machine(Expr const& expr,ARG&&... t)
- :Derived(std::forward<ARG>(t)...)
- ,m_events_queue()
- ,m_deferred_events_queue()
- ,m_history()
- ,m_event_processing(false)
- ,m_is_included(false)
- ,m_visitors()
- ,m_substate_list()
- {
- BOOST_MPL_ASSERT_MSG(
- ( ::boost::proto::matches<Expr, FoldToList>::value),
- THE_STATES_EXPRESSION_PASSED_DOES_NOT_MATCH_GRAMMAR,
- (FoldToList));
- ::boost::mpl::for_each< seq_initial_states, ::boost::msm::wrap<mpl::placeholders::_1> >
- (init_states(m_states));
- m_history.set_initial_states(m_states);
- set_states(expr);
- fill_states(this);
- }
- #endif
- // assignment operator using the copy policy to decide if non_copyable, shallow or deep copying is necessary
- library_sm& operator= (library_sm const& rhs)
- {
- if (this != &rhs)
- {
- Derived::operator=(rhs);
- do_copy(rhs);
- }
- return *this;
- }
- state_machine(library_sm const& rhs)
- : Derived(rhs)
- {
- if (this != &rhs)
- {
- // initialize our list of states with the ones defined in Derived::initial_state
- fill_states(this);
- do_copy(rhs);
- }
- }
- // the following 2 functions handle the terminate/interrupt states handling
- // if one of these states is found, the first one is used
- template <class Event>
- bool is_event_handling_blocked_helper( ::boost::mpl::true_ const &)
- {
- // if the state machine is terminated, do not handle any event
- if (is_flag_active< ::boost::msm::TerminateFlag>())
- return true;
- // if the state machine is interrupted, do not handle any event
- // unless the event is the end interrupt event
- if ( is_flag_active< ::boost::msm::InterruptedFlag>() &&
- !is_flag_active< ::boost::msm::EndInterruptFlag<Event> >())
- return true;
- return false;
- }
- // otherwise simple handling, no flag => continue
- template <class Event>
- bool is_event_handling_blocked_helper( ::boost::mpl::false_ const &)
- {
- // no terminate/interrupt states detected
- return false;
- }
- void do_handle_prio_msg_queue_deferred_queue(EventSource source, HandledEnum handled, ::boost::mpl::true_ const &)
- {
- // non-default. Handle msg queue with higher prio than deferred queue
- if (!(EVENT_SOURCE_MSG_QUEUE & source))
- {
- do_post_msg_queue_helper(
- ::boost::mpl::bool_<
- is_no_message_queue<library_sm>::type::value>());
- if (!(EVENT_SOURCE_DEFERRED & source))
- {
- handle_defer_helper<library_sm> defer_helper(m_deferred_events_queue);
- defer_helper.do_handle_deferred(HANDLED_TRUE & handled);
- }
- }
- }
- void do_handle_prio_msg_queue_deferred_queue(EventSource source, HandledEnum handled, ::boost::mpl::false_ const &)
- {
- // default. Handle deferred queue with higher prio than msg queue
- if (!(EVENT_SOURCE_DEFERRED & source))
- {
- handle_defer_helper<library_sm> defer_helper(m_deferred_events_queue);
- defer_helper.do_handle_deferred(HANDLED_TRUE & handled);
- // Handle any new events generated into the queue, but only if
- // we're not already processing from the message queue.
- if (!(EVENT_SOURCE_MSG_QUEUE & source))
- {
- do_post_msg_queue_helper(
- ::boost::mpl::bool_<
- is_no_message_queue<library_sm>::type::value>());
- }
- }
- }
- // the following functions handle pre/post-process handling of a message queue
- template <class StateType,class EventType>
- bool do_pre_msg_queue_helper(EventType const&, ::boost::mpl::true_ const &)
- {
- // no message queue needed
- return true;
- }
- template <class StateType,class EventType>
- bool do_pre_msg_queue_helper(EventType const& evt, ::boost::mpl::false_ const &)
- {
- execute_return (library_sm::*pf) (EventType const&, EventSource) =
- &library_sm::process_event_internal;
- // if we are already processing an event
- if (m_event_processing)
- {
- // event has to be put into the queue
- m_events_queue.m_events_queue.push_back(
- ::boost::bind(
- pf, this, evt,
- static_cast<EventSource>(EVENT_SOURCE_DIRECT | EVENT_SOURCE_MSG_QUEUE)));
- return false;
- }
- // event can be handled, processing
- m_event_processing = true;
- return true;
- }
- void do_post_msg_queue_helper( ::boost::mpl::true_ const &)
- {
- // no message queue needed
- }
- void do_post_msg_queue_helper( ::boost::mpl::false_ const &)
- {
- process_message_queue(this);
- }
- void do_allow_event_processing_after_transition( ::boost::mpl::true_ const &)
- {
- // no message queue needed
- }
- void do_allow_event_processing_after_transition( ::boost::mpl::false_ const &)
- {
- m_event_processing = false;
- }
- // the following 2 functions handle the processing either with a try/catch protection or without
- template <class StateType,class EventType>
- HandledEnum do_process_helper(EventType const& evt, ::boost::mpl::true_ const &, bool is_direct_call)
- {
- return this->do_process_event(evt,is_direct_call);
- }
- template <class StateType,class EventType>
- HandledEnum do_process_helper(EventType const& evt, ::boost::mpl::false_ const &, bool is_direct_call)
- {
- // when compiling without exception support there is no formal parameter "e" in the catch handler.
- // Declaring a local variable here does not hurt and will be "used" to make the code in the handler
- // compilable although the code will never be executed.
- std::exception e;
- BOOST_TRY
- {
- return this->do_process_event(evt,is_direct_call);
- }
- BOOST_CATCH (std::exception& e)
- {
- // give a chance to the concrete state machine to handle
- this->exception_caught(evt,*this,e);
- return ::boost::msm::back::HANDLED_FALSE;
- }
- BOOST_CATCH_END
- return HANDLED_TRUE;
- }
- // handling of deferred events
- // if none is found in the SM, take the following empty main version
- template <class StateType, class Enable = int>
- struct handle_defer_helper
- {
- handle_defer_helper(deferred_msg_queue_helper<library_sm>& ){}
- void do_handle_deferred(bool)
- {
- }
- };
- // otherwise the standard version handling the deferred events
- template <class StateType>
- struct handle_defer_helper
- <StateType, typename enable_if< typename ::boost::msm::back::has_fsm_deferred_events<StateType>::type,int >::type>
- {
- struct sort_greater
- {
- bool operator()(
- typename deferred_events_queue_t::value_type const& d1,
- typename deferred_events_queue_t::value_type const& d2)
- {
- return d1.second > d2.second;
- }
- };
- struct set_sequence
- {
- set_sequence(char s) :seq_(s) {}
- void operator()(typename deferred_events_queue_t::value_type& d)
- {
- d.second = seq_;
- }
- char seq_;
- };
- handle_defer_helper(deferred_msg_queue_helper<library_sm>& a_queue):
- m_events_queue(a_queue) {}
- void do_handle_deferred(bool new_seq=false)
- {
- // A new sequence is typically started upon initial entry to the
- // state, or upon a new transition. When this occurs we want to
- // process all previously deferred events by incrementing the
- // correlation sequence.
- if (new_seq)
- {
- ++m_events_queue.m_cur_seq;
- }
- char& cur_seq = m_events_queue.m_cur_seq;
- // Iteratively process all of the events within the deferred
- // queue upto (but not including) newly deferred events.
- // if we did not defer one in the queue, then we need to try again
- bool not_only_deferred = false;
- while (!m_events_queue.m_deferred_events_queue.empty())
- {
- typename deferred_events_queue_t::value_type& pair =
- m_events_queue.m_deferred_events_queue.front();
- if (cur_seq != pair.second)
- {
- break;
- }
- deferred_fct next = pair.first;
- m_events_queue.m_deferred_events_queue.pop_front();
- boost::msm::back::execute_return res = next();
- if (res != ::boost::msm::back::HANDLED_FALSE && res != ::boost::msm::back::HANDLED_DEFERRED)
- {
- not_only_deferred = true;
- }
- if (not_only_deferred)
- {
- // handled one, stop processing deferred until next block reorders
- break;
- }
- }
- if (not_only_deferred)
- {
- // attempt to go back to the situation prior to processing,
- // in case some deferred events would have been re-queued
- // in that case those would have a higher sequence number
- std::stable_sort(
- m_events_queue.m_deferred_events_queue.begin(),
- m_events_queue.m_deferred_events_queue.end(),
- sort_greater()
- );
- // reset sequence number for all
- std::for_each(
- m_events_queue.m_deferred_events_queue.begin(),
- m_events_queue.m_deferred_events_queue.end(),
- set_sequence(m_events_queue.m_cur_seq + 1)
- );
- // one deferred event was successfully processed, try again
- do_handle_deferred(true);
- }
- }
- private:
- deferred_msg_queue_helper<library_sm>& m_events_queue;
- };
- // handling of eventless transitions
- // if none is found in the SM, nothing to do
- template <class StateType, class Enable = void>
- struct handle_eventless_transitions_helper
- {
- handle_eventless_transitions_helper(library_sm* , bool ){}
- void process_completion_event(EventSource = EVENT_SOURCE_DEFAULT){}
- };
- // otherwise
- template <class StateType>
- struct handle_eventless_transitions_helper
- <StateType, typename enable_if< typename ::boost::msm::back::has_fsm_eventless_transition<StateType>::type >::type>
- {
- handle_eventless_transitions_helper(library_sm* self_, bool handled_):self(self_),handled(handled_){}
- void process_completion_event(EventSource source = EVENT_SOURCE_DEFAULT)
- {
- typedef typename ::boost::mpl::deref<
- typename ::boost::mpl::begin<
- typename find_completion_events<StateType>::type
- >::type
- >::type first_completion_event;
- if (handled)
- {
- self->process_event_internal(
- first_completion_event(),
- source | EVENT_SOURCE_DIRECT);
- }
- }
- private:
- library_sm* self;
- bool handled;
- };
- // helper class called in case the event to process has been found in the fsm's internal stt and is therefore processable
- template<class Event>
- struct process_fsm_internal_table
- {
- typedef typename ::boost::mpl::has_key<processable_events_internal_table,Event>::type is_event_processable;
- // forward to the correct do_process
- static void process(Event const& evt,library_sm* self_,HandledEnum& result)
- {
- do_process(evt,self_,result,is_event_processable());
- }
- private:
- // the event is processable, let's try!
- static void do_process(Event const& evt,library_sm* self_,HandledEnum& result, ::boost::mpl::true_)
- {
- if (result != HANDLED_TRUE)
- {
- typedef dispatch_table<library_sm,complete_table,Event,CompilePolicy> table;
- HandledEnum res_internal = table::instance().entries[0](*self_, 0, self_->m_states[0], evt);
- result = (HandledEnum)((int)result | (int)res_internal);
- }
- }
- // version doing nothing if the event is not in the internal stt and we can save ourselves the time trying to process
- static void do_process(Event const& ,library_sm* ,HandledEnum& , ::boost::mpl::false_)
- {
- // do nothing
- }
- };
- template <class StateType,class Enable=void>
- struct region_processing_helper
- {
- public:
- region_processing_helper(library_sm* self_,HandledEnum& result_)
- :self(self_),result(result_){}
- template<class Event>
- void process(Event const& evt)
- {
- // use this table as if it came directly from the user
- typedef dispatch_table<library_sm,complete_table,Event,CompilePolicy> table;
- // +1 because index 0 is reserved for this fsm
- HandledEnum res =
- table::instance().entries[self->m_states[0]+1](
- *self, 0, self->m_states[0], evt);
- result = (HandledEnum)((int)result | (int)res);
- // process the event in the internal table of this fsm if the event is processable (present in the table)
- process_fsm_internal_table<Event>::process(evt,self,result);
- }
- library_sm* self;
- HandledEnum& result;
- };
- // version with visitors
- template <class StateType>
- struct region_processing_helper<StateType,typename ::boost::enable_if<
- ::boost::mpl::is_sequence<typename StateType::initial_state> >::type>
- {
- private:
- // process event in one region
- template <class region_id,int Dummy=0>
- struct In
- {
- template<class Event>
- static void process(Event const& evt,library_sm* self_,HandledEnum& result_)
- {
- // use this table as if it came directly from the user
- typedef dispatch_table<library_sm,complete_table,Event,CompilePolicy> table;
- // +1 because index 0 is reserved for this fsm
- HandledEnum res =
- table::instance().entries[self_->m_states[region_id::value]+1](
- *self_, region_id::value , self_->m_states[region_id::value], evt);
- result_ = (HandledEnum)((int)result_ | (int)res);
- In< ::boost::mpl::int_<region_id::value+1> >::process(evt,self_,result_);
- }
- };
- template <int Dummy>
- struct In< ::boost::mpl::int_<nr_regions::value>,Dummy>
- {
- // end of processing
- template<class Event>
- static void process(Event const& evt,library_sm* self_,HandledEnum& result_)
- {
- // process the event in the internal table of this fsm if the event is processable (present in the table)
- process_fsm_internal_table<Event>::process(evt,self_,result_);
- }
- };
- public:
- region_processing_helper(library_sm* self_,HandledEnum& result_)
- :self(self_),result(result_){}
- template<class Event>
- void process(Event const& evt)
- {
- In< ::boost::mpl::int_<0> >::process(evt,self,result);
- }
- library_sm* self;
- HandledEnum& result;
- };
- // Main function used internally to make transitions
- // Can only be called for internally (for example in an action method) generated events.
- template<class Event>
- execute_return process_event_internal(Event const& evt,
- EventSource source = EVENT_SOURCE_DEFAULT)
- {
- // if the state machine has terminate or interrupt flags, check them, otherwise skip
- if (is_event_handling_blocked_helper<Event>
- ( ::boost::mpl::bool_<has_fsm_blocking_states<library_sm>::type::value>() ) )
- {
- return HANDLED_TRUE;
- }
- // if a message queue is needed and processing is on the way
- if (!do_pre_msg_queue_helper<Event>
- (evt,::boost::mpl::bool_<is_no_message_queue<library_sm>::type::value>()))
- {
- // wait for the end of current processing
- return HANDLED_TRUE;
- }
- else
- {
- // Process event
- HandledEnum handled = this->do_process_helper<Event>(
- evt,
- ::boost::mpl::bool_<is_no_exception_thrown<library_sm>::type::value>(),
- (EVENT_SOURCE_DIRECT & source));
- // at this point we allow the next transition be executed without enqueing
- // so that completion events and deferred events execute now (if any)
- do_allow_event_processing_after_transition(
- ::boost::mpl::bool_<is_no_message_queue<library_sm>::type::value>());
- // Process completion transitions BEFORE any other event in the
- // pool (UML Standard 2.3 15.3.14)
- handle_eventless_transitions_helper<library_sm>
- eventless_helper(this,(HANDLED_TRUE & handled));
- eventless_helper.process_completion_event(source);
- // After handling, take care of the deferred events, but only if
- // we're not already processing from the deferred queue.
- do_handle_prio_msg_queue_deferred_queue(
- source,handled,
- ::boost::mpl::bool_<has_event_queue_before_deferred_queue<library_sm>::type::value>());
- return handled;
- }
- }
- // minimum event processing without exceptions, queues, etc.
- template<class Event>
- HandledEnum do_process_event(Event const& evt, bool is_direct_call)
- {
- HandledEnum handled = HANDLED_FALSE;
- // dispatch the event to every region
- region_processing_helper<Derived> helper(this,handled);
- helper.process(evt);
- // if the event has not been handled and we have orthogonal zones, then
- // generate an error on every active state
- // for state machine states contained in other state machines, do not handle
- // but let the containing sm handle the error, unless the event was generated in this fsm
- // (by calling process_event on this fsm object, is_direct_call == true)
- // completion events do not produce an error
- if ( (!is_contained() || is_direct_call) && !handled && !is_completion_event<Event>::type::value)
- {
- for (int i=0; i<nr_regions::value;++i)
- {
- this->no_transition(evt,*this,this->m_states[i]);
- }
- }
- return handled;
- }
- // default row arguments for the compilers which accept this
- template <class Event>
- bool no_guard(Event const&){return true;}
- template <class Event>
- void no_action(Event const&){}
- #ifndef BOOST_NO_RTTI
- HandledEnum process_any_event( ::boost::any const& evt);
- #endif
- private:
- // composite accept implementation. First calls accept on the composite, then accept on all its active states.
- void composite_accept()
- {
- this->accept();
- this->visit_current_states();
- }
- #define MSM_COMPOSITE_ACCEPT_SUB(z, n, unused) ARG ## n vis ## n
- #define MSM_COMPOSITE_ACCEPT_SUB2(z, n, unused) boost::ref( vis ## n )
- #define MSM_COMPOSITE_ACCEPT_EXECUTE(z, n, unused) \
- template <BOOST_PP_ENUM_PARAMS(n, class ARG)> \
- void composite_accept(BOOST_PP_ENUM(n, MSM_COMPOSITE_ACCEPT_SUB, ~ ) ) \
- { \
- this->accept(BOOST_PP_ENUM_PARAMS(n,vis)); \
- this->visit_current_states(BOOST_PP_ENUM(n,MSM_COMPOSITE_ACCEPT_SUB2, ~)); \
- }
- BOOST_PP_REPEAT_FROM_TO(1,BOOST_PP_ADD(BOOST_MSM_VISITOR_ARG_SIZE,1), MSM_COMPOSITE_ACCEPT_EXECUTE, ~)
- #undef MSM_COMPOSITE_ACCEPT_EXECUTE
- #undef MSM_COMPOSITE_ACCEPT_SUB
- #undef MSM_COMPOSITE_ACCEPT_SUB2
- // helper used to call the init states at the start of the state machine
- template <class Event>
- struct call_init
- {
- call_init(Event const& an_event,library_sm* self_):
- evt(an_event),self(self_){}
- template <class State>
- void operator()(boost::msm::wrap<State> const&)
- {
- execute_entry(::boost::fusion::at_key<State>(self->m_substate_list),evt,*self);
- }
- private:
- Event const& evt;
- library_sm* self;
- };
- // helper for flag handling. Uses OR by default on orthogonal zones.
- template <class Flag,bool orthogonalStates>
- struct FlagHelper
- {
- static bool helper(library_sm const& sm,flag_handler* )
- {
- // by default we use OR to accumulate the flags
- return sm.is_flag_active<Flag,Flag_OR>();
- }
- };
- template <class Flag>
- struct FlagHelper<Flag,false>
- {
- static bool helper(library_sm const& sm,flag_handler* flags_entries)
- {
- // just one active state, so we can call operator[] with 0
- return flags_entries[sm.current_state()[0]](sm);
- }
- };
- // handling of flag
- // defines a true and false functions plus a forwarding one for composite states
- template <class StateType,class Flag>
- struct FlagHandler
- {
- static bool flag_true(library_sm const& )
- {
- return true;
- }
- static bool flag_false(library_sm const& )
- {
- return false;
- }
- static bool forward(library_sm const& fsm)
- {
- return ::boost::fusion::at_key<StateType>(fsm.m_substate_list).template is_flag_active<Flag>();
- }
- };
- template <class Flag>
- struct init_flags
- {
- private:
- // helper function, helps hiding the forward function for non-state machines states.
- template <class T>
- void helper (flag_handler* an_entry,int offset, ::boost::mpl::true_ const & )
- {
- // composite => forward
- an_entry[offset] = &FlagHandler<T,Flag>::forward;
- }
- template <class T>
- void helper (flag_handler* an_entry,int offset, ::boost::mpl::false_ const & )
- {
- // default no flag
- an_entry[offset] = &FlagHandler<T,Flag>::flag_false;
- }
- // attributes
- flag_handler* entries;
- public:
- init_flags(flag_handler* entries_)
- : entries(entries_)
- {}
- // Flags initializer function object, used with mpl::for_each
- template <class StateType>
- void operator()( ::boost::msm::wrap<StateType> const& )
- {
- typedef typename get_flag_list<StateType>::type flags;
- typedef typename ::boost::mpl::contains<flags,Flag >::type found;
- BOOST_STATIC_CONSTANT(int, state_id = (get_state_id<stt,StateType>::type::value));
- if (found::type::value)
- {
- // the type defined the flag => true
- entries[state_id] = &FlagHandler<StateType,Flag>::flag_true;
- }
- else
- {
- // false or forward
- typedef typename ::boost::mpl::and_<
- typename is_composite_state<StateType>::type,
- typename ::boost::mpl::not_<
- typename has_non_forwarding_flag<Flag>::type>::type >::type composite_no_forward;
- helper<StateType>(entries,state_id,::boost::mpl::bool_<composite_no_forward::type::value>());
- }
- }
- };
- // maintains for every flag a static array containing the flag value for every state
- template <class Flag>
- flag_handler* get_entries_for_flag() const
- {
- BOOST_STATIC_CONSTANT(int, max_state = (mpl::size<state_list>::value));
- static flag_handler flags_entries[max_state];
- // build a state list, but only once
- static flag_handler* flags_entries_ptr =
- (::boost::mpl::for_each<state_list, boost::msm::wrap< ::boost::mpl::placeholders::_1> >
- (init_flags<Flag>(flags_entries)),
- flags_entries);
- return flags_entries_ptr;
- }
- // helper used to create a state using the correct constructor
- template <class State, class Enable=void>
- struct create_state_helper
- {
- static void set_sm(library_sm* )
- {
- // state doesn't need its sm
- }
- };
- // create a state requiring a pointer to the state machine
- template <class State>
- struct create_state_helper<State,typename boost::enable_if<typename State::needs_sm >::type>
- {
- static void set_sm(library_sm* sm)
- {
- // create and set the fsm
- ::boost::fusion::at_key<State>(sm->m_substate_list).set_sm_ptr(sm);
- }
- };
- // main unspecialized helper class
- template <class StateType,int ARGS>
- struct visitor_args;
- #define MSM_VISITOR_ARGS_SUB(z, n, unused) BOOST_PP_CAT(::boost::placeholders::_,BOOST_PP_ADD(n,1))
- #define MSM_VISITOR_ARGS_TYPEDEF_SUB(z, n, unused) typename StateType::accept_sig::argument ## n
- #define MSM_VISITOR_ARGS_EXECUTE(z, n, unused) \
- template <class StateType> \
- struct visitor_args<StateType,n> \
- { \
- template <class State> \
- static typename enable_if_c<!is_composite_state<State>::value,void >::type \
- helper (library_sm* sm, \
- int id,StateType& astate) \
- { \
- sm->m_visitors.insert(id, boost::bind(&StateType::accept, \
- ::boost::ref(astate) BOOST_PP_COMMA_IF(n) BOOST_PP_ENUM(n, MSM_VISITOR_ARGS_SUB, ~) )); \
- } \
- template <class State> \
- static typename enable_if_c<is_composite_state<State>::value,void >::type \
- helper (library_sm* sm, \
- int id,StateType& astate) \
- { \
- void (StateType::*caccept)(BOOST_PP_ENUM(n, MSM_VISITOR_ARGS_TYPEDEF_SUB, ~ ) ) \
- = &StateType::composite_accept; \
- sm->m_visitors.insert(id, boost::bind(caccept, \
- ::boost::ref(astate) BOOST_PP_COMMA_IF(n) BOOST_PP_ENUM(n, MSM_VISITOR_ARGS_SUB, ~) )); \
- } \
- };
- BOOST_PP_REPEAT(BOOST_PP_ADD(BOOST_MSM_VISITOR_ARG_SIZE,1), MSM_VISITOR_ARGS_EXECUTE, ~)
- #undef MSM_VISITOR_ARGS_EXECUTE
- #undef MSM_VISITOR_ARGS_SUB
- // the IBM compiler seems to have problems with nested classes
- // the same seems to apply to the Apple version of gcc 4.0.1 (just in case we do for < 4.1)
- // and also to MS VC < 8
- #if defined (__IBMCPP__) || (__GNUC__ == 4 && __GNUC_MINOR__ < 1) || (defined(_MSC_VER) && (_MSC_VER < 1400))
- public:
- #endif
- template<class ContainingSM>
- void set_containing_sm(ContainingSM* sm)
- {
- m_is_included=true;
- ::boost::fusion::for_each(m_substate_list,add_state<ContainingSM>(this,sm));
- }
- #if defined (__IBMCPP__) || (__GNUC__ == 4 && __GNUC_MINOR__ < 1) || (defined(_MSC_VER) && (_MSC_VER < 1400))
- private:
- #endif
- // A function object for use with mpl::for_each that stuffs
- // states into the state list.
- template<class ContainingSM>
- struct add_state
- {
- add_state(library_sm* self_,ContainingSM* sm)
- : self(self_),containing_sm(sm){}
- // State is a sub fsm with exit pseudo states and gets a pointer to this fsm, so it can build a callback
- template <class StateType>
- typename ::boost::enable_if<
- typename is_composite_state<StateType>::type,void >::type
- new_state_helper(boost::msm::back::dummy<0> = 0) const
- {
- ::boost::fusion::at_key<StateType>(self->m_substate_list).set_containing_sm(containing_sm);
- }
- // State is a sub fsm without exit pseudo states and does not get a callback to this fsm
- // or state is a normal state and needs nothing except creation
- template <class StateType>
- typename ::boost::enable_if<
- typename boost::mpl::and_<typename boost::mpl::not_
- <typename is_composite_state<StateType>::type>::type,
- typename boost::mpl::not_
- <typename is_pseudo_exit<StateType>::type>::type
- >::type,void>::type
- new_state_helper( ::boost::msm::back::dummy<1> = 0) const
- {
- //nothing to do
- }
- // state is exit pseudo state and gets callback to target fsm
- template <class StateType>
- typename ::boost::enable_if<typename is_pseudo_exit<StateType>::type,void >::type
- new_state_helper( ::boost::msm::back::dummy<2> = 0) const
- {
- execute_return (ContainingSM::*pf) (typename StateType::event const& evt)=
- &ContainingSM::process_event;
- ::boost::function<execute_return (typename StateType::event const&)> fct =
- ::boost::bind(pf,containing_sm,::boost::placeholders::_1);
- ::boost::fusion::at_key<StateType>(self->m_substate_list).set_forward_fct(fct);
- }
- // for every defined state in the sm
- template <class State>
- void operator()( State const&) const
- {
- //create a new state with the defined id and type
- BOOST_STATIC_CONSTANT(int, state_id = (get_state_id<stt,State>::value));
- this->new_state_helper<State>(),
- create_state_helper<State>::set_sm(self);
- // create a visitor callback
- visitor_helper(state_id,::boost::fusion::at_key<State>(self->m_substate_list),
- ::boost::mpl::bool_<has_accept_sig<State>::type::value>());
- }
- private:
- // support possible use of a visitor if accept_sig is defined
- template <class StateType>
- void visitor_helper(int id,StateType& astate, ::boost::mpl::true_ const & ) const
- {
- visitor_args<StateType,StateType::accept_sig::args_number>::
- template helper<StateType>(self,id,astate);
- }
- template <class StateType>
- void visitor_helper(int ,StateType& , ::boost::mpl::false_ const &) const
- {
- // nothing to do
- }
- library_sm* self;
- ContainingSM* containing_sm;
- };
- // helper used to copy every state if needed
- struct copy_helper
- {
- copy_helper(library_sm* sm):
- m_sm(sm){}
- template <class StateType>
- void operator()( ::boost::msm::wrap<StateType> const& )
- {
- BOOST_STATIC_CONSTANT(int, state_id = (get_state_id<stt,StateType>::type::value));
- // possibly also set the visitor
- visitor_helper<StateType>(state_id);
- // and for states that keep a pointer to the fsm, reset the pointer
- create_state_helper<StateType>::set_sm(m_sm);
- }
- template <class StateType>
- typename ::boost::enable_if<typename has_accept_sig<StateType>::type,void >::type
- visitor_helper(int id) const
- {
- visitor_args<StateType,StateType::accept_sig::args_number>::template helper<StateType>
- (m_sm,id,::boost::fusion::at_key<StateType>(m_sm->m_substate_list));
- }
- template <class StateType>
- typename ::boost::disable_if<typename has_accept_sig<StateType>::type,void >::type
- visitor_helper(int) const
- {
- // nothing to do
- }
- library_sm* m_sm;
- };
- // helper to copy the active states attribute
- template <class region_id,int Dummy=0>
- struct region_copy_helper
- {
- static void do_copy(library_sm* self_,library_sm const& rhs)
- {
- self_->m_states[region_id::value] = rhs.m_states[region_id::value];
- region_copy_helper< ::boost::mpl::int_<region_id::value+1> >::do_copy(self_,rhs);
- }
- };
- template <int Dummy>
- struct region_copy_helper< ::boost::mpl::int_<nr_regions::value>,Dummy>
- {
- // end of processing
- static void do_copy(library_sm*,library_sm const& ){}
- };
- // copy functions for deep copy (no need of a 2nd version for NoCopy as noncopyable handles it)
- void do_copy (library_sm const& rhs,
- ::boost::msm::back::dummy<0> = 0)
- {
- // deep copy simply assigns the data
- region_copy_helper< ::boost::mpl::int_<0> >::do_copy(this,rhs);
- m_events_queue = rhs.m_events_queue;
- m_deferred_events_queue = rhs.m_deferred_events_queue;
- m_history = rhs.m_history;
- m_event_processing = rhs.m_event_processing;
- m_is_included = rhs.m_is_included;
- m_substate_list = rhs.m_substate_list;
- // except for the states themselves, which get duplicated
- ::boost::mpl::for_each<state_list, ::boost::msm::wrap< ::boost::mpl::placeholders::_1> >
- (copy_helper(this));
- }
- // helper used to call the correct entry/exit method
- // unfortunately in O(number of states in the sub-sm) but should be better than a virtual call
- template<class Event,bool is_entry>
- struct entry_exit_helper
- {
- entry_exit_helper(int id,Event const& e,library_sm* self_):
- state_id(id),evt(e),self(self_){}
- // helper for entry actions
- template <class IsEntry,class State>
- typename ::boost::enable_if<typename IsEntry::type,void >::type
- helper( ::boost::msm::back::dummy<0> = 0)
- {
- BOOST_STATIC_CONSTANT(int, id = (get_state_id<stt,State>::value));
- if (id == state_id)
- {
- execute_entry<State>(::boost::fusion::at_key<State>(self->m_substate_list),evt,*self);
- }
- }
- // helper for exit actions
- template <class IsEntry,class State>
- typename boost::disable_if<typename IsEntry::type,void >::type
- helper( ::boost::msm::back::dummy<1> = 0)
- {
- BOOST_STATIC_CONSTANT(int, id = (get_state_id<stt,State>::value));
- if (id == state_id)
- {
- execute_exit<State>(::boost::fusion::at_key<State>(self->m_substate_list),evt,*self);
- }
- }
- // iterates through all states to find the one to be activated
- template <class State>
- void operator()( ::boost::msm::wrap<State> const&)
- {
- entry_exit_helper<Event,is_entry>::template helper< ::boost::mpl::bool_<is_entry>,State >();
- }
- private:
- int state_id;
- Event const& evt;
- library_sm* self;
- };
- // helper to start the fsm
- template <class region_id,int Dummy=0>
- struct region_start_helper
- {
- template<class Event>
- static void do_start(library_sm* self_,Event const& incomingEvent)
- {
- //forward the event for handling by sub state machines
- ::boost::mpl::for_each<state_list, ::boost::msm::wrap< ::boost::mpl::placeholders::_1> >
- (entry_exit_helper<Event,true>(self_->m_states[region_id::value],incomingEvent,self_));
- region_start_helper
- < ::boost::mpl::int_<region_id::value+1> >::do_start(self_,incomingEvent);
- }
- };
- template <int Dummy>
- struct region_start_helper< ::boost::mpl::int_<nr_regions::value>,Dummy>
- {
- // end of processing
- template<class Event>
- static void do_start(library_sm*,Event const& ){}
- };
- // start for states machines which are themselves embedded in other state machines (composites)
- template <class Event>
- void internal_start(Event const& incomingEvent)
- {
- region_start_helper< ::boost::mpl::int_<0> >::do_start(this,incomingEvent);
- // give a chance to handle an anonymous (eventless) transition
- handle_eventless_transitions_helper<library_sm> eventless_helper(this,true);
- eventless_helper.process_completion_event();
- }
- template <class StateType>
- struct find_region_id
- {
- template <int region,int Dummy=0>
- struct In
- {
- enum {region_index=region};
- };
- // if the user provides no region, find it!
- template<int Dummy>
- struct In<-1,Dummy>
- {
- typedef typename build_orthogonal_regions<
- library_sm,
- initial_states
- >::type all_regions;
- enum {region_index= find_region_index<all_regions,StateType>::value };
- };
- enum {region_index = In<StateType::zone_index>::region_index };
- };
- // helper used to set the correct state as active state upon entry into a fsm
- struct direct_event_start_helper
- {
- direct_event_start_helper(library_sm* self_):self(self_){}
- // this variant is for the standard case, entry due to activation of the containing FSM
- template <class EventType,class FsmType>
- typename ::boost::disable_if<typename has_direct_entry<EventType>::type,void>::type
- operator()(EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<0> = 0)
- {
- (static_cast<Derived*>(self))->on_entry(evt,fsm);
- self->internal_start(evt);
- }
- // this variant is for the direct entry case (just one entry, not a sequence of entries)
- template <class EventType,class FsmType>
- typename ::boost::enable_if<
- typename ::boost::mpl::and_<
- typename ::boost::mpl::not_< typename is_pseudo_entry<
- typename EventType::active_state>::type >::type,
- typename ::boost::mpl::and_<typename has_direct_entry<EventType>::type,
- typename ::boost::mpl::not_<typename ::boost::mpl::is_sequence
- <typename EventType::active_state>::type >::type
- >::type>::type,void
- >::type
- operator()(EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<1> = 0)
- {
- (static_cast<Derived*>(self))->on_entry(evt,fsm);
- int state_id = get_state_id<stt,typename EventType::active_state::wrapped_entry>::value;
- BOOST_STATIC_ASSERT(find_region_id<typename EventType::active_state::wrapped_entry>::region_index >= 0);
- BOOST_STATIC_ASSERT(find_region_id<typename EventType::active_state::wrapped_entry>::region_index < nr_regions::value);
- // just set the correct zone, the others will be default/history initialized
- self->m_states[find_region_id<typename EventType::active_state::wrapped_entry>::region_index] = state_id;
- self->internal_start(evt.m_event);
- }
- // this variant is for the fork entry case (a sequence on entries)
- template <class EventType,class FsmType>
- typename ::boost::enable_if<
- typename ::boost::mpl::and_<
- typename ::boost::mpl::not_<
- typename is_pseudo_entry<typename EventType::active_state>::type >::type,
- typename ::boost::mpl::and_<typename has_direct_entry<EventType>::type,
- typename ::boost::mpl::is_sequence<
- typename EventType::active_state>::type
- >::type>::type,void
- >::type
- operator()(EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<2> = 0)
- {
- (static_cast<Derived*>(self))->on_entry(evt,fsm);
- ::boost::mpl::for_each<typename EventType::active_state,
- ::boost::msm::wrap< ::boost::mpl::placeholders::_1> >
- (fork_helper<EventType>(self,evt));
- // set the correct zones, the others (if any) will be default/history initialized
- self->internal_start(evt.m_event);
- }
- // this variant is for the pseudo state entry case
- template <class EventType,class FsmType>
- typename ::boost::enable_if<
- typename is_pseudo_entry<typename EventType::active_state >::type,void
- >::type
- operator()(EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<3> = 0)
- {
- // entry on the FSM
- (static_cast<Derived*>(self))->on_entry(evt,fsm);
- int state_id = get_state_id<stt,typename EventType::active_state::wrapped_entry>::value;
- BOOST_STATIC_ASSERT(find_region_id<typename EventType::active_state::wrapped_entry>::region_index >= 0);
- BOOST_STATIC_ASSERT(find_region_id<typename EventType::active_state::wrapped_entry>::region_index < nr_regions::value);
- // given region starts with the entry pseudo state as active state
- self->m_states[find_region_id<typename EventType::active_state::wrapped_entry>::region_index] = state_id;
- self->internal_start(evt.m_event);
- // and we process the transition in the zone of the newly active state
- // (entry pseudo states are, according to UML, a state connecting 1 transition outside to 1 inside
- self->process_event(evt.m_event);
- }
- private:
- // helper for the fork case, does almost like the direct entry
- library_sm* self;
- template <class EventType>
- struct fork_helper
- {
- fork_helper(library_sm* self_,EventType const& evt_):
- helper_self(self_),helper_evt(evt_){}
- template <class StateType>
- void operator()( ::boost::msm::wrap<StateType> const& )
- {
- int state_id = get_state_id<stt,typename StateType::wrapped_entry>::value;
- BOOST_STATIC_ASSERT(find_region_id<typename StateType::wrapped_entry>::region_index >= 0);
- BOOST_STATIC_ASSERT(find_region_id<typename StateType::wrapped_entry>::region_index < nr_regions::value);
- helper_self->m_states[find_region_id<typename StateType::wrapped_entry>::region_index] = state_id;
- }
- private:
- library_sm* helper_self;
- EventType const& helper_evt;
- };
- };
- // helper for entry
- template <class region_id,int Dummy=0>
- struct region_entry_exit_helper
- {
- template<class Event>
- static void do_entry(library_sm* self_,Event const& incomingEvent)
- {
- self_->m_states[region_id::value] =
- self_->m_history.history_entry(incomingEvent)[region_id::value];
- region_entry_exit_helper
- < ::boost::mpl::int_<region_id::value+1> >::do_entry(self_,incomingEvent);
- }
- template<class Event>
- static void do_exit(library_sm* self_,Event const& incomingEvent)
- {
- ::boost::mpl::for_each<state_list, ::boost::msm::wrap< ::boost::mpl::placeholders::_1> >
- (entry_exit_helper<Event,false>(self_->m_states[region_id::value],incomingEvent,self_));
- region_entry_exit_helper
- < ::boost::mpl::int_<region_id::value+1> >::do_exit(self_,incomingEvent);
- }
- };
- template <int Dummy>
- struct region_entry_exit_helper< ::boost::mpl::int_<nr_regions::value>,Dummy>
- {
- // end of processing
- template<class Event>
- static void do_entry(library_sm*,Event const& ){}
- template<class Event>
- static void do_exit(library_sm*,Event const& ){}
- };
- // entry/exit for states machines which are themselves embedded in other state machines (composites)
- template <class Event,class FsmType>
- void do_entry(Event const& incomingEvent,FsmType& fsm)
- {
- // by default we activate the history/init states, can be overwritten by direct_event_start_helper
- region_entry_exit_helper< ::boost::mpl::int_<0> >::do_entry(this,incomingEvent);
- // block immediate handling of events
- m_event_processing = true;
- // if the event is generating a direct entry/fork, set the current state(s) to the direct state(s)
- direct_event_start_helper(this)(incomingEvent,fsm);
- // handle messages which were generated and blocked in the init calls
- m_event_processing = false;
- // look for deferred events waiting
- handle_defer_helper<library_sm> defer_helper(m_deferred_events_queue);
- defer_helper.do_handle_deferred(true);
- process_message_queue(this);
- }
- template <class Event,class FsmType>
- void do_exit(Event const& incomingEvent,FsmType& fsm)
- {
- // first recursively exit the sub machines
- // forward the event for handling by sub state machines
- region_entry_exit_helper< ::boost::mpl::int_<0> >::do_exit(this,incomingEvent);
- // then call our own exit
- (static_cast<Derived*>(this))->on_exit(incomingEvent,fsm);
- // give the history a chance to handle this (or not).
- m_history.history_exit(this->m_states);
- // history decides what happens with deferred events
- if (!m_history.process_deferred_events(incomingEvent))
- {
- clear_deferred_queue();
- }
- }
- // the IBM and VC<8 compilers seem to have problems with the friend declaration of dispatch_table
- #if defined (__IBMCPP__) || (defined(_MSC_VER) && (_MSC_VER < 1400))
- public:
- #endif
- // no transition for event.
- template <class Event>
- static HandledEnum call_no_transition(library_sm& , int , int , Event const& )
- {
- return HANDLED_FALSE;
- }
- // no transition for event for internal transitions (not an error).
- template <class Event>
- static HandledEnum call_no_transition_internal(library_sm& , int , int , Event const& )
- {
- //// reject to give others a chance to handle
- //return HANDLED_GUARD_REJECT;
- return HANDLED_FALSE;
- }
- // called for deferred events. Address set in the dispatch_table at init
- template <class Event>
- static HandledEnum defer_transition(library_sm& fsm, int , int , Event const& e)
- {
- fsm.defer_event(e);
- return HANDLED_DEFERRED;
- }
- // called for completion events. Default address set in the dispatch_table at init
- // prevents no-transition detection for completion events
- template <class Event>
- static HandledEnum default_eventless_transition(library_sm&, int, int , Event const&)
- {
- return HANDLED_FALSE;
- }
- #if defined (__IBMCPP__) || (defined(_MSC_VER) && (_MSC_VER < 1400))
- private:
- #endif
- // removes one event from the message queue and processes it
- template <class StateType>
- void process_message_queue(StateType*,
- typename ::boost::disable_if<typename is_no_message_queue<StateType>::type,void >::type* = 0)
- {
- // Iteratively process all events from the message queue.
- while (!m_events_queue.m_events_queue.empty())
- {
- transition_fct next = m_events_queue.m_events_queue.front();
- m_events_queue.m_events_queue.pop_front();
- next();
- }
- }
- template <class StateType>
- void process_message_queue(StateType*,
- typename ::boost::enable_if<typename is_no_message_queue<StateType>::type,void >::type* = 0)
- {
- // nothing to process
- }
- // helper function. In cases where the event is wrapped (target is a direct entry states)
- // we want to send only the real event to on_entry, not the wrapper.
- template <class EventType>
- static
- typename boost::enable_if<typename has_direct_entry<EventType>::type,typename EventType::contained_event const& >::type
- remove_direct_entry_event_wrapper(EventType const& evt,boost::msm::back::dummy<0> = 0)
- {
- return evt.m_event;
- }
- template <class EventType>
- static typename boost::disable_if<typename has_direct_entry<EventType>::type,EventType const& >::type
- remove_direct_entry_event_wrapper(EventType const& evt,boost::msm::back::dummy<1> = 0)
- {
- // identity. No wrapper
- return evt;
- }
- // calls the entry/exit or on_entry/on_exit depending on the state type
- // (avoids calling virtually)
- // variant for FSMs
- template <class StateType,class EventType,class FsmType>
- static
- typename boost::enable_if<typename is_composite_state<StateType>::type,void >::type
- execute_entry(StateType& astate,EventType const& evt,FsmType& fsm,boost::msm::back::dummy<0> = 0)
- {
- // calls on_entry on the fsm then handles direct entries, fork, entry pseudo state
- astate.do_entry(evt,fsm);
- }
- // variant for states
- template <class StateType,class EventType,class FsmType>
- static
- typename ::boost::disable_if<
- typename ::boost::mpl::or_<typename is_composite_state<StateType>::type,
- typename is_pseudo_exit<StateType>::type >::type,void >::type
- execute_entry(StateType& astate,EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<1> = 0)
- {
- // simple call to on_entry
- astate.on_entry(remove_direct_entry_event_wrapper(evt),fsm);
- }
- // variant for exit pseudo states
- template <class StateType,class EventType,class FsmType>
- static
- typename ::boost::enable_if<typename is_pseudo_exit<StateType>::type,void >::type
- execute_entry(StateType& astate,EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<2> = 0)
- {
- // calls on_entry on the state then forward the event to the transition which should be defined inside the
- // contained fsm
- astate.on_entry(evt,fsm);
- astate.forward_event(evt);
- }
- template <class StateType,class EventType,class FsmType>
- static
- typename ::boost::enable_if<typename is_composite_state<StateType>::type,void >::type
- execute_exit(StateType& astate,EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<0> = 0)
- {
- astate.do_exit(evt,fsm);
- }
- template <class StateType,class EventType,class FsmType>
- static
- typename ::boost::disable_if<typename is_composite_state<StateType>::type,void >::type
- execute_exit(StateType& astate,EventType const& evt,FsmType& fsm, ::boost::msm::back::dummy<1> = 0)
- {
- // simple call to on_exit
- astate.on_exit(evt,fsm);
- }
- // helper allowing special handling of direct entries / fork
- template <class StateType,class TargetType,class EventType,class FsmType>
- static
- typename ::boost::disable_if<
- typename ::boost::mpl::or_<typename has_explicit_entry_state<TargetType>::type,
- ::boost::mpl::is_sequence<TargetType> >::type,void>::type
- convert_event_and_execute_entry(StateType& astate,EventType const& evt, FsmType& fsm, ::boost::msm::back::dummy<1> = 0)
- {
- // if the target is a normal state, do the standard entry handling
- execute_entry<StateType>(astate,evt,fsm);
- }
- template <class StateType,class TargetType,class EventType,class FsmType>
- static
- typename ::boost::enable_if<
- typename ::boost::mpl::or_<typename has_explicit_entry_state<TargetType>::type,
- ::boost::mpl::is_sequence<TargetType> >::type,void >::type
- convert_event_and_execute_entry(StateType& astate,EventType const& evt, FsmType& fsm, ::boost::msm::back::dummy<0> = 0)
- {
- // for the direct entry, pack the event in a wrapper so that we handle it differently during fsm entry
- execute_entry(astate,msm::back::direct_entry_event<TargetType,EventType>(evt),fsm);
- }
- // creates all the states
- template <class ContainingSM>
- void fill_states(ContainingSM* containing_sm=0)
- {
- // checks that regions are truly orthogonal
- FsmCheckPolicy::template check_orthogonality<library_sm>();
- // checks that all states are reachable
- FsmCheckPolicy::template check_unreachable_states<library_sm>();
- BOOST_STATIC_CONSTANT(int, max_state = (mpl::size<state_list>::value));
- // allocate the place without reallocation
- m_visitors.fill_visitors(max_state);
- ::boost::fusion::for_each(m_substate_list,add_state<ContainingSM>(this,containing_sm));
- }
- private:
- template <class StateType,class Enable=void>
- struct msg_queue_helper
- {
- public:
- msg_queue_helper():m_events_queue(){}
- events_queue_t m_events_queue;
- };
- template <class StateType>
- struct msg_queue_helper<StateType,
- typename ::boost::enable_if<typename is_no_message_queue<StateType>::type >::type>
- {
- };
- template <class Fsm,class Stt, class Event, class Compile>
- friend struct dispatch_table;
- // data members
- int m_states[nr_regions::value];
- msg_queue_helper<library_sm> m_events_queue;
- deferred_msg_queue_helper
- <library_sm> m_deferred_events_queue;
- concrete_history m_history;
- bool m_event_processing;
- bool m_is_included;
- visitor_fct_helper<BaseState> m_visitors;
- substate_list m_substate_list;
- };
- } } }// boost::msm::back
- #endif //BOOST_MSM_BACK_STATEMACHINE_H
|