104 {
105
106 auto& states =
m_slot->algsStates;
108 const int decision = [
state]() {
109 switch ( state ) {
110 case AState::EVTACCEPTED:
111 return 1;
112 case AState::EVTREJECTED:
113 return 0;
114 default:
115 return -1;
116 };
117 }();
118
119 if ( -1 == decision ) { return false; }
120
121 m_slot->controlFlowState[node.getNodeIndex()] = decision;
122
124 for ( const auto& output : node.getOutputDataNodes() )
125 for (
auto& consumer :
output->getConsumers() ) consumer->accept( promoter );
126
127
129 auto& parents = node.getParentDecisionHubs();
130 if ( parents.size() == 1 ) {
131 parents[0]->accept( vis );
132 }
else if (
m_slot->parentSlot ) {
133 auto scout = SubSlotScout(
m_slot, node );
134 for ( auto& p : parents ) {
135 p->accept( scout );
136 if ( scout.reply() ) p->accept( vis );
137 scout.reset();
138 }
139 } else {
140 auto scout = ActiveLineageScout(
m_slot, node );
141 for ( auto& p : parents ) {
142 p->accept( scout );
143 if ( scout.reply() ) p->accept( vis );
144 scout.reset();
145 }
146 }
147
148 return true;
149 }
AlgsExecutionStates::State AState
Public Member Functions inherited from concurrency::IGraphVisitor
1.13.1