1 // SUPERV GraphExecutor : contains classes that permit execution of graphs and particularly the execution automaton
3 // Copyright (C) 2003 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
6 // This library is free software; you can redistribute it and/or
7 // modify it under the terms of the GNU Lesser General Public
8 // License as published by the Free Software Foundation; either
9 // version 2.1 of the License.
11 // This library is distributed in the hope that it will be useful,
12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 // Lesser General Public License for more details.
16 // You should have received a copy of the GNU Lesser General Public
17 // License along with this library; if not, write to the Free Software
18 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20 // See http://www.opencascade.org/SALOME/ or email : webmaster.salome@opencascade.org
24 // File : DataFlowBase_FiniteStateMachine.cxx
25 // Author : Jean Rahuel, CEA
35 #include "DataFlowExecutor_FiniteStateMachine.hxx"
37 void * start_function( void *p ) ;
40 #define VoidState SUPERV::VoidState
41 #define ToSuspendStartState SUPERV::ToSuspendStartState
42 #define ToSuspendState SUPERV::ToSuspendState
43 #define ToSuspendDoneState SUPERV::ToSuspendDoneState
44 #define ToKillState SUPERV::ToKillState
45 #define ToKillDoneState SUPERV::ToKillDoneState
46 #define ToStopState SUPERV::ToStopState
50 #define UnKnownState GraphExecutor::UnKnownState
51 #define DataUndefState GraphExecutor::DataUndefState
52 #define DataWaitingState GraphExecutor::DataWaitingState
53 #define DataReadyState GraphExecutor::DataReadyState
54 #define SuspendedReadyState GraphExecutor::SuspendedReadyState
55 #define SuspendedReadyToResumeState GraphExecutor::SuspendedReadyToResumeState
56 #define ResumedReadyState GraphExecutor::ResumedReadyState
57 #define KilledReadyState GraphExecutor::KilledReadyState
58 #define StoppedReadyState GraphExecutor::StoppedReadyState
59 #define ExecutingState GraphExecutor::ExecutingState
60 #define SuspendedExecutingState GraphExecutor::SuspendedExecutingState
61 #define ResumedExecutingState GraphExecutor::ResumedExecutingState
62 #define KilledExecutingState GraphExecutor::KilledExecutingState
63 #define StoppedExecutingState GraphExecutor::StoppedExecutingState
64 #define SuccessedExecutingState GraphExecutor::SuccessedExecutingState
65 #define ErroredExecutingState GraphExecutor::ErroredExecutingState
66 #define SuspendedSuccessedState GraphExecutor::SuspendedSuccessedState
67 #define SuspendedErroredState GraphExecutor::SuspendedErroredState
68 #define SuspendedSuccessedToReStartState GraphExecutor::SuspendedSuccessedToReStartState
69 #define SuspendedErroredToReStartState GraphExecutor::SuspendedErroredToReStartState
70 #define ResumedSuccessedState GraphExecutor::ResumedSuccessedState
71 #define ResumedErroredState GraphExecutor::ResumedErroredState
72 #define KilledSuccessedState GraphExecutor::KilledSuccessedState
73 #define KilledErroredState GraphExecutor::KilledErroredState
74 #define StoppedSuccessedState GraphExecutor::StoppedSuccessedState
75 #define StoppedErroredState GraphExecutor::StoppedErroredState
76 #define SuccessedState GraphExecutor::SuccessedState
77 #define ErroredState GraphExecutor::ErroredState
78 #define SuspendedState GraphExecutor::SuspendedState
79 #define KilledState GraphExecutor::KilledState
80 #define StoppedState GraphExecutor::StoppedState
81 #define ReStartedState GraphExecutor::ReStartedState
82 #define LoadingState GraphExecutor::LoadingState
83 #define NumberOfAutomatonStates GraphExecutor::NumberOfAutomatonStates
87 #define UndefinedEvent GraphExecutor::UndefinedEvent
88 #define NewThreadEvent GraphExecutor::NewThreadEvent
89 #define SuspendEvent GraphExecutor::SuspendEvent
90 #define ToResumeEvent GraphExecutor::ToResumeEvent
91 #define ResumeEvent GraphExecutor::ResumeEvent
92 #define KillEvent GraphExecutor::KillEvent
93 #define StopEvent GraphExecutor::StopEvent
94 #define ExecuteEvent GraphExecutor::ExecuteEvent
95 #define SuccessEvent GraphExecutor::SuccessEvent
96 #define ErrorEvent GraphExecutor::ErrorEvent
97 #define ReStartEvent GraphExecutor::ReStartEvent
98 #define ReStartAndSuspendEvent GraphExecutor::ReStartAndSuspendEvent
99 #define NoDataReadyEvent GraphExecutor::NoDataReadyEvent
100 #define SomeDataReadyEvent GraphExecutor::SomeDataReadyEvent
101 #define NotAllDataReadyEvent GraphExecutor::NotAllDataReadyEvent
102 #define AllDataReadyEvent GraphExecutor::AllDataReadyEvent
103 #define ReadyEvent GraphExecutor::ReadyEvent
104 #define SuspendedReadyEvent GraphExecutor::SuspendedReadyEvent
105 #define ResumedReadyEvent GraphExecutor::ResumedReadyEvent
106 #define KilledReadyEvent GraphExecutor::KilledReadyEvent
107 #define StoppedReadyEvent GraphExecutor::StoppedReadyEvent
108 #define ExecutingEvent GraphExecutor::ExecutingEvent
109 #define SuspendedExecutingEvent GraphExecutor::SuspendedExecutingEvent
110 #define ResumedExecutingEvent GraphExecutor::ResumedExecutingEvent
111 #define KilledExecutingEvent GraphExecutor::KilledExecutingEvent
112 #define StoppedExecutingEvent GraphExecutor::StoppedExecutingEvent
113 #define SuccessedExecutingEvent GraphExecutor::SuccessedExecutingEvent
114 #define ErroredExecutingEvent GraphExecutor::ErroredExecutingEvent
115 #define SuspendedSuccessedEvent GraphExecutor::SuspendedSuccessedEvent
116 #define SuspendedErroredEvent GraphExecutor::SuspendedErroredEvent
117 #define ResumedSuccessedEvent GraphExecutor::ResumedSuccessedEvent
118 #define ResumedErroredEvent GraphExecutor::ResumedErroredEvent
119 #define KilledEvent GraphExecutor::KilledEvent
120 #define StoppedEvent GraphExecutor::StoppedEvent
121 #define ToReStartEvent GraphExecutor::ToReStartEvent
122 #define ReStartedEvent GraphExecutor::ReStartedEvent
123 #define ReStartedAndSuspendEvent GraphExecutor::ReStartedAndSuspendEvent
124 #define EndExecuteEvent GraphExecutor::EndExecuteEvent
125 #define NumberOfEvents GraphExecutor::NumberOfEvents
127 GraphExecutor::FiniteStateMachine::FiniteStateMachine() {
128 // cdebug_in << "FiniteStateMachine::FiniteStateMachine" << endl;
130 _ControlStateName[ VoidState ] = "VoidState" ;
131 _ControlStateName[ ToSuspendStartState ]= "ToSuspendStartState" ;
132 _ControlStateName[ ToSuspendState ] = "ToSuspendState" ;
133 _ControlStateName[ ToSuspendDoneState ] = "ToSuspendDoneState" ;
134 _ControlStateName[ ToKillState ] = "ToKillState" ;
135 _ControlStateName[ ToKillDoneState ] = "ToKillDoneState" ;
136 _ControlStateName[ ToStopState ] = "ToStopState" ;
138 _StateName[ UnKnownState ] = "UnKnownState" ;
139 _StateName[ DataUndefState ] = "DataUndefState" ;
140 _StateName[ DataWaitingState ] = "DataWaitingState" ;
141 _StateName[ DataReadyState ] = "DataReadyState" ;
142 _StateName[ SuspendedReadyState ] = "SuspendedReadyState" ;
143 _StateName[ SuspendedReadyToResumeState ] = "SuspendedReadyToResumeState" ;
144 _StateName[ ResumedReadyState ] = "ResumedReadyState" ;
145 _StateName[ KilledReadyState ] = "KilledReadyState" ;
146 _StateName[ StoppedReadyState ] = "StoppedReadyState" ;
147 _StateName[ ExecutingState ] = "ExecutingState" ;
148 _StateName[ SuspendedExecutingState ] = "SuspendedExecutingState" ;
149 _StateName[ ResumedExecutingState ] = "ResumedExecutingState" ;
150 _StateName[ KilledExecutingState ] = "KilledExecutingState" ;
151 _StateName[ StoppedExecutingState ] = "StoppedExecutingState" ;
152 _StateName[ SuccessedExecutingState ] = "SuccessedExecutingState" ;
153 _StateName[ ErroredExecutingState ] = "ErroredExecutingState" ;
154 _StateName[ SuspendedSuccessedState ] = "SuspendedSuccessedState" ;
155 _StateName[ SuspendedErroredState ] = "SuspendedErroredState" ;
156 _StateName[ SuspendedSuccessedToReStartState ] = "SuspendedSuccessedToReStartState" ;
157 _StateName[ SuspendedErroredToReStartState ] = "SuspendedErroredToReStartState" ;
158 _StateName[ ResumedSuccessedState ] = "ResumedSuccessedState" ;
159 _StateName[ ResumedErroredState ] = "ResumedErroredState" ;
160 _StateName[ KilledSuccessedState ] = "KilledSuccessedState" ;
161 _StateName[ KilledErroredState ] = "KilledErroredState" ;
162 _StateName[ StoppedSuccessedState ] = "StoppedSuccessedState" ;
163 _StateName[ StoppedErroredState ] = "StoppedErroredState" ;
164 _StateName[ SuccessedState ] = "SuccessedState" ;
165 _StateName[ ErroredState ] = "ErroredState" ;
166 _StateName[ SuspendedState ] = "SuspendedState" ;
167 _StateName[ KilledState ] = "KilledState" ;
168 _StateName[ StoppedState ] = "StoppedState" ;
169 _StateName[ ReStartedState ] = "ReStartedState" ;
170 _StateName[ LoadingState ] = "LoadingState" ;
172 _EventName[ UndefinedEvent ] = "UndefinedEvent" ;
173 _EventName[ NewThreadEvent ] = "NewThreadEvent" ;
174 _EventName[ SuspendEvent ] = "SuspendEvent" ;
175 _EventName[ ToResumeEvent ] = "ToResumeEvent" ;
176 _EventName[ ResumeEvent ] = "ResumeEvent" ;
177 _EventName[ KillEvent ] = "KillEvent" ;
178 _EventName[ StopEvent ] = "StopEvent" ;
179 _EventName[ ExecuteEvent ] = "ExecuteEvent" ;
180 _EventName[ SuccessEvent ] = "SuccessEvent" ;
181 _EventName[ ErrorEvent ] = "ErrorEvent" ;
182 _EventName[ ToReStartEvent ] = "ToReStartEvent" ;
183 _EventName[ ReStartEvent ] = "ReStartEvent" ;
184 _EventName[ ReStartAndSuspendEvent ] = "ReStartAndSuspendEvent" ;
185 _EventName[ NoDataReadyEvent ] = "NoDataReadyEvent" ;
186 _EventName[ SomeDataReadyEvent ] = "SomeDataReadyEvent" ;
187 _EventName[ NotAllDataReadyEvent ] = "NotAllDataReadyEvent" ;
188 _EventName[ AllDataReadyEvent ] = "AllDataReadyEvent" ;
189 _EventName[ ReadyEvent ] = "ReadyEvent" ;
190 _EventName[ SuspendedReadyEvent ] = "SuspendedReadyEvent" ;
191 _EventName[ ResumedReadyEvent ] = "ResumedReadyEvent" ;
192 _EventName[ KilledReadyEvent ] = "KilledReadyEvent" ;
193 _EventName[ StoppedReadyEvent ] = "StoppedReadyEvent" ;
194 _EventName[ ExecutingEvent ] = "ExecutingEvent" ;
195 _EventName[ SuspendedExecutingEvent ] = "SuspendedExecutingEvent" ;
196 _EventName[ ResumedExecutingEvent ] = "ResumedExecutingEvent" ;
197 _EventName[ KilledExecutingEvent ] = "KilledExecutingEvent" ;
198 _EventName[ StoppedExecutingEvent ] = "StoppedExecutingEvent" ;
199 _EventName[ SuccessedExecutingEvent ] = "SuccessedExecutingEvent" ;
200 _EventName[ ErroredExecutingEvent ] = "ErroredExecutingEvent" ;
201 _EventName[ SuspendedSuccessedEvent ] = "SuspendedSuccessedEvent" ;
202 _EventName[ SuspendedErroredEvent ] = "SuspendedErroredEvent" ;
203 _EventName[ ResumedSuccessedEvent ] = "ResumedSuccessedEvent" ;
204 _EventName[ ResumedErroredEvent ] = "ResumedErroredEvent" ;
205 _EventName[ KilledEvent ] = "KilledEvent" ;
206 _EventName[ StoppedEvent ] = "StoppedEvent" ;
207 _EventName[ ReStartedEvent ] = "ReStartedEvent" ;
208 _EventName[ ReStartedAndSuspendEvent ]= "ReStartedAndSuspendEvent" ;
209 _EventName[ EndExecuteEvent ] = "EndExecuteEvent" ;
211 _ActionName[ ErrorAction ] = "ErrorAction" ;
212 _ActionName[ VoidAction ] = "VoidAction" ;
213 _ActionName[ executeAction ] = "executeAction" ;
214 _ActionName[ ExecuteAction ] = "ExecuteAction" ;
215 _ActionName[ DataWaiting_SomeDataReadyAction ] = "DataWaiting_SomeDataReadyAction" ;
216 _ActionName[ DataUndef_NotAllDataReadyAction ] = "DataUndef_NotAllDataReadyAction";
217 _ActionName[ DataUndef_AllDataReadyAction ] = "DataUndef_AllDataReadyAction" ;
219 _ActionName[ DataReady_SuspendAction ] = "DataReady_SuspendAction" ;
220 _ActionName[ SuspendedReady_ResumeAction ] = "SuspendedReady_ResumeAction" ;
221 _ActionName[ DataReady_KillAction ] = "DataReady_KillAction" ;
222 _ActionName[ DataReady_StopAction ] = "DataReady_StopAction" ;
224 _ActionName[ DataReady_ExecuteAction ] = "DataReady_ExecuteAction" ;
226 _ActionName[ Executing_SuspendAction ] = "Executing_SuspendAction" ;
227 _ActionName[ SuspendedExecuting_ResumeAction ] = "SuspendedExecuting_ResumeAction" ;
228 _ActionName[ Executing_KillAction ] = "Executing_KillAction" ;
229 _ActionName[ Executing_StopAction ] = "Executing_StopAction" ;
231 _ActionName[ Executing_SuccessAction ] = "Executing_SuccessAction" ;
232 _ActionName[ Executing_ErrorAction ] = "Executing_ErrorAction" ;
233 _ActionName[ Successed_SuccessAction ] = "Successed_SuccessAction" ;
234 _ActionName[ Errored_ErrorAction ] = "Errored_ErrorAction" ;
236 _ActionName[ Successed_SuspendAction ] = "Successed_SuspendAction" ;
237 _ActionName[ Errored_SuspendAction ] = "Errored_SuspendAction" ;
238 _ActionName[ SuspendedSuccessed_ResumeAction ] = "SuspendedSuccessed_ResumeAction" ;
239 _ActionName[ SuspendedErrored_ResumeAction ] = "SuspendedErrored_ResumeAction" ;
240 _ActionName[ Successed_KillAction ] = "Successed_KillAction" ;
241 _ActionName[ Errored_KillAction ] = "Errored_KillAction" ;
242 _ActionName[ Successed_StopAction ] = "Successed_StopAction" ;
243 _ActionName[ Errored_StopAction ] = "Errored_StopAction" ;
245 _ActionName[ SuspendedSuccessed_ReStartAction ] = "SuspendedSuccessed_ReStartAction" ;
246 _ActionName[ SuspendedErrored_ReStartAction ] = "SuspendedErrored_ReStartAction" ;
247 _ActionName[ SuspendedSuccessed_ReStartAndSuspendAction ] = "SuspendedSuccessed_ReStartAndSuspendAction" ;
248 _ActionName[ SuspendedErrored_ReStartAndSuspendAction ] = "SuspendedErrored_ReStartAndSuspendAction" ;
250 _GraphStateName[ SUPERV::UndefinedState ] = "UndefinedState" ;
251 _GraphStateName[ SUPERV::NoState ] = "NoState" ;
252 _GraphStateName[ SUPERV::EditingState ] = "EditingState" ;
253 _GraphStateName[ SUPERV::SuspendState ] = "SuspendState" ;
254 _GraphStateName[ SUPERV::WaitingState ] = "WaitingState" ;
255 _GraphStateName[ SUPERV::ReadyState ] = "ReadyState" ;
256 _GraphStateName[ SUPERV::SuspendReadyState ] = "SuspendReadyState" ;
257 _GraphStateName[ SUPERV::RunningState ] = "RunningState" ;
258 _GraphStateName[ SUPERV::DoneState ] = "DoneState" ;
259 _GraphStateName[ SUPERV::ErrorState ] = "ErrorState" ;
260 _GraphStateName[ SUPERV::SuspendDoneState ] = "SuspendDoneState" ;
261 _GraphStateName[ SUPERV::SuspendErroredState ] = "SuspendErroredState" ;
262 _GraphStateName[ SUPERV::KillState ] = "KillState" ;
263 _GraphStateName[ SUPERV::StopState ] = "StopState" ;
266 // NewStates = _TransitionTable[ States ] [ Events ]
267 // associated action = _ActionTable[ NewStates ] [ Events ]
268 for ( i = 0 ; i < NumberOfAutomatonStates ; i++ ) {
269 for ( j = 0 ; j < NumberOfEvents ; j++ ) {
270 // id est = SameState and VoidAction
271 _TransitionTable[ i ][ j ] = (GraphExecutor::AutomatonState ) i ;
272 _ActionTable[ i ][ j ] = GraphExecutor::ErrorAction ;
275 // OneEvent ===> Change of State and associated Action :
276 // _TransitionTable[ OldState ][ OneEvent ] gives a NewState
277 // _Action[ NewState ][ OneEvent ] gives what to do
280 // NoDataReadyEvent :
281 _TransitionTable[ DataUndefState ][ NoDataReadyEvent ] = DataWaitingState ;
282 _ActionTable[ DataWaitingState ][ NoDataReadyEvent ] = VoidAction ;
283 // SomeDataReadyEvent :
284 _TransitionTable[ DataWaitingState ][ SomeDataReadyEvent ] = DataUndefState ;
285 _ActionTable[ DataUndefState ][ SomeDataReadyEvent ] = DataWaiting_SomeDataReadyAction;
286 _TransitionTable[ DataReadyState ][ SomeDataReadyEvent ] = DataUndefState ;
287 _ActionTable[ DataUndefState ][ SomeDataReadyEvent ] = DataWaiting_SomeDataReadyAction;
288 // NotAllDataReadyEvent :
289 _TransitionTable[ DataUndefState ][ NotAllDataReadyEvent ] = DataWaitingState ;
290 _ActionTable[ DataWaitingState ][ NotAllDataReadyEvent ] = DataUndef_NotAllDataReadyAction;
292 _TransitionTable[ DataUndefState ][ AllDataReadyEvent ] = DataReadyState ;
293 _ActionTable[ DataReadyState ][ AllDataReadyEvent ] = DataUndef_AllDataReadyAction ;
295 // DATAS-READY-CONTROL :
297 _TransitionTable[ DataReadyState ][ SuspendEvent ] = SuspendedReadyState ;
298 _ActionTable[ SuspendedReadyState ][ SuspendEvent ] = DataReady_SuspendAction;
300 _TransitionTable[ SuspendedReadyState ][ ToResumeEvent ] = SuspendedReadyToResumeState ;
301 _ActionTable[ SuspendedReadyToResumeState ][ ToResumeEvent ] = VoidAction ;
303 _TransitionTable[ SuspendedReadyToResumeState ][ ResumeEvent ] = ResumedReadyState ;
304 _ActionTable[ ResumedReadyState ][ ResumeEvent] = SuspendedReady_ResumeAction ;
306 _TransitionTable[ SuspendedReadyState ][ KillEvent ] = KilledReadyState ;
308 _TransitionTable[ SuspendedReadyState ][ StopEvent ] = StoppedReadyState ;
310 _TransitionTable[ DataReadyState ][ KillEvent ] = KilledReadyState ;
311 _ActionTable[ KilledReadyState ][ KillEvent] = DataReady_KillAction ;
313 _TransitionTable[ DataReadyState ][ StopEvent ] = StoppedReadyState ;
314 _ActionTable[ StoppedReadyState ][ StopEvent] = DataReady_StopAction ;
318 _TransitionTable[ SuspendedReadyToResumeState ][ ExecuteEvent ] = ExecutingState ;
320 _TransitionTable[ ResumedReadyState ][ ExecuteEvent ] = ExecutingState ;
322 _TransitionTable[ DataReadyState ][ ExecuteEvent ] = ExecutingState ;
324 _TransitionTable[ ReStartedState ][ ExecuteEvent ] = ExecutingState ;
325 _ActionTable[ ExecutingState ][ ExecuteEvent ] = DataReady_ExecuteAction;
329 _TransitionTable[ ExecutingState ][ SuspendEvent ] = SuspendedExecutingState ;
330 _ActionTable[ SuspendedExecutingState ][ SuspendEvent ] = Executing_SuspendAction;
332 _TransitionTable[ SuspendedExecutingState ][ ResumeEvent ] = ResumedExecutingState ;
333 _ActionTable[ ResumedExecutingState ][ ResumeEvent] = SuspendedExecuting_ResumeAction;
335 _TransitionTable[ ResumedExecutingState ][ ExecuteEvent ] = ExecutingState ;
337 _TransitionTable[ SuspendedExecutingState ][ KillEvent ] = KilledExecutingState ;
339 _TransitionTable[ SuspendedExecutingState ][ StopEvent ] = StoppedExecutingState ;
341 _TransitionTable[ ExecutingState ][ KillEvent ] = KilledExecutingState ;
342 _ActionTable[ KilledExecutingState ][ KillEvent] = Executing_KillAction;
343 _TransitionTable[ KilledExecutingState ][ KillEvent ] = KilledState ;
344 _ActionTable[ KilledState ][ KillEvent] = VoidAction;
346 _TransitionTable[ ExecutingState ][ StopEvent ] = StoppedExecutingState ;
347 _ActionTable[ StoppedExecutingState ][ StopEvent] = Executing_StopAction;
348 _TransitionTable[ StoppedExecutingState ][ StopEvent ] = StoppedState ;
349 _ActionTable[ StoppedState ][ StopEvent] = VoidAction;
353 _TransitionTable[ ExecutingState ][ SuccessEvent ] = SuccessedExecutingState ;
354 _ActionTable[ SuccessedExecutingState ][ SuccessEvent ] = Executing_SuccessAction;
355 // SuspendedExecutingState : NO ResumeEvent 13-03-2003
356 _TransitionTable[ SuspendedExecutingState ][ SuccessEvent ] = SuccessedExecutingState ;
357 _ActionTable[ SuccessedExecutingState ][ SuccessEvent ] = Executing_SuccessAction;
359 _TransitionTable[ ExecutingState ][ ErrorEvent ] = ErroredExecutingState ;
360 _ActionTable[ ErroredExecutingState ][ ErrorEvent ] = Executing_ErrorAction;
361 // SuspendedExecutingState : NO ResumeEvent 13-03-2003
362 _TransitionTable[ SuspendedExecutingState ][ ErrorEvent ] = ErroredExecutingState ;
363 _ActionTable[ ErroredExecutingState ][ ErrorEvent ] = Executing_ErrorAction;
366 // SuccessedExecutingState - SuccessEvent
367 _TransitionTable[ SuccessedExecutingState ][ SuccessEvent ] = SuccessedState ;
368 _ActionTable[ SuccessedState ][ SuccessEvent ] = Successed_SuccessAction ;
369 // ErroredExecutingState - ErrorEvent
370 _TransitionTable[ ErroredExecutingState ][ ErrorEvent ] = ErroredState ;
371 _ActionTable[ ErroredState ][ ErrorEvent ] = Errored_ErrorAction ;
373 // SuccessedState - SuspendEvent
374 _TransitionTable[ SuccessedExecutingState ][ SuspendEvent ] = SuspendedSuccessedState ;
375 _ActionTable[ SuspendedSuccessedState ][ SuspendEvent ] = Successed_SuspendAction;
376 // ErroredState - SuspendEvent
377 _TransitionTable[ ErroredExecutingState ][ SuspendEvent ] = SuspendedErroredState ;
378 _ActionTable[ SuspendedErroredState ][ SuspendEvent ] = Errored_SuspendAction;
380 // SuccessedState - KillEvent
381 _TransitionTable[ SuccessedExecutingState ][ KillEvent ] = KilledSuccessedState ;
382 _ActionTable[ KilledSuccessedState ][ KillEvent ] = Successed_KillAction;
383 // ErroredState - KillEvent
384 _TransitionTable[ ErroredExecutingState ][ KillEvent ] = KilledErroredState ;
385 _ActionTable[ KilledErroredState ][ KillEvent ] = Errored_KillAction;
387 // SuccessedState - StopEvent
388 _TransitionTable[ SuccessedExecutingState ][ StopEvent ] = StoppedSuccessedState ;
389 _ActionTable[ StoppedSuccessedState ][ StopEvent ] = Successed_StopAction;
390 // ErroredState - StopEvent
391 _TransitionTable[ ErroredExecutingState ][ StopEvent ] = StoppedErroredState ;
392 _ActionTable[ StoppedErroredState ][ StopEvent ] = Errored_StopAction;
394 // SuspendedSuccessedState - ResumeEvent
395 _TransitionTable[ SuspendedSuccessedState ][ ResumeEvent ] = ResumedSuccessedState ;
396 _ActionTable[ ResumedSuccessedState ][ ResumeEvent ] = SuspendedSuccessed_ResumeAction;
398 _TransitionTable[ ResumedSuccessedState ][ ResumedSuccessedEvent ] = SuccessedState ;
399 _ActionTable[ SuccessedState ][ ResumedSuccessedEvent] = Successed_SuccessAction;
401 // SuspendedErroredState - ResumeEvent
402 _TransitionTable[ SuspendedErroredState ][ ResumeEvent ] = ResumedErroredState ;
403 _ActionTable[ ResumedErroredState ][ ResumeEvent ] = SuspendedErrored_ResumeAction;
404 _TransitionTable[ ResumedErroredState ][ ResumedErroredEvent ] = ErroredState ;
405 _ActionTable[ ErroredState ][ ResumedErroredEvent ] = Errored_ErrorAction;
407 // SuccessedState - KillEvent
408 _TransitionTable[ SuccessedState ][ KillEvent ] = KilledSuccessedState ;
409 _ActionTable[ KilledSuccessedState ][ KillEvent] = Successed_KillAction;
410 _TransitionTable[ KilledSuccessedState ][ KillEvent ] = KilledState ;
411 _ActionTable[ KilledState ][ KillEvent ] = VoidAction;
412 // ErroredState - KillEvent
413 _TransitionTable[ ErroredState ][ KillEvent ] = KilledErroredState ;
414 _ActionTable[ KilledErroredState ][ KillEvent] = Errored_KillAction;
415 _TransitionTable[ KilledErroredState ][ KillEvent ] = KilledState ;
416 _ActionTable[ KilledState ][ KillEvent ] = VoidAction;
418 // SuccessedState - StopEvent
419 _TransitionTable[ SuccessedState ][ StopEvent ] = StoppedSuccessedState ;
420 _ActionTable[ StoppedSuccessedState ][ StopEvent] = Successed_StopAction;
421 _TransitionTable[ StoppedSuccessedState ][ StopEvent ] = StoppedState ;
422 _ActionTable[ StoppedState ][ StopEvent ] = VoidAction;
423 // ErroredState - StopEvent
424 _TransitionTable[ ErroredState ][ StopEvent ] = StoppedErroredState ;
425 _ActionTable[ StoppedErroredState ][ StopEvent] = Errored_StopAction;
426 _TransitionTable[ StoppedErroredState ][ StopEvent ] = StoppedState ;
427 _ActionTable[ StoppedState ][ StopEvent ] = VoidAction;
430 _TransitionTable[ SuspendedSuccessedState ][ ToReStartEvent ] = SuspendedSuccessedToReStartState ;
431 _ActionTable[ SuspendedSuccessedToReStartState ][ ToReStartEvent] = VoidAction ;
433 _TransitionTable[ SuspendedSuccessedToReStartState ][ ReStartEvent ] = ReStartedState ;
434 _TransitionTable[ SuspendedSuccessedToReStartState ][ ReStartAndSuspendEvent ] = ReStartedState ;
436 _TransitionTable[ SuspendedErroredState ][ ToReStartEvent ] = SuspendedErroredToReStartState ;
437 _ActionTable[ SuspendedErroredToReStartState ][ ToReStartEvent] = VoidAction ;
439 _TransitionTable[ SuspendedErroredToReStartState ][ ReStartEvent ] = ReStartedState ;
440 _TransitionTable[ SuspendedErroredToReStartState ][ ReStartAndSuspendEvent ] = ReStartedState ;
442 _ActionTable[ ReStartedState ][ ReStartEvent] = SuspendedSuccessed_ReStartAction;
443 _ActionTable[ ReStartedState ][ ReStartAndSuspendEvent] = SuspendedSuccessed_ReStartAndSuspendAction;
445 pthread_mutex_init( &_MutexJoinWait , NULL ) ;
446 if ( pthread_cond_init( &_JoinWait , NULL ) ) {
447 perror("pthread_cond_init( &_JoinWait , NULL )") ;
451 if ( pthread_create( &_JoinThreadNo , NULL , start_function , this ) ) {
452 char * msg = "Cannot pthread_create " ;
456 pthread_mutex_init( &_MutexPythonWait , NULL ) ;
457 _MutexPythonLocked = false ;
459 _GraphExecutingNumber = 0 ;
460 _PyInitModule = false ;
462 // cdebug_out << "FiniteStateMachine::FiniteStateMachine _TransitionTable "
466 void * start_function( void *p ) {
467 GraphExecutor::FiniteStateMachine *anAutomaton = (GraphExecutor::FiniteStateMachine *) p;
468 if ( pthread_setcanceltype( PTHREAD_CANCEL_ASYNCHRONOUS , NULL ) ) {
469 perror("pthread_setcanceltype ") ;
472 if ( pthread_setcancelstate( PTHREAD_CANCEL_ENABLE , NULL ) ) {
473 perror("pthread_setcancelstate ") ;
476 anAutomaton->JoinThread() ;
477 pthread_exit( PTHREAD_CANCELED ) ;
480 int GraphExecutor::FiniteStateMachine::ExecNumber() {
483 int RetVal = _ExecNumber ;
484 _GraphExecutingNumber += 1 ;
489 void GraphExecutor::FiniteStateMachine::Executed() {
491 _GraphExecutingNumber -= 1 ;
492 if ( _GraphExecutingNumber == 0 ) {
493 map< string , PyObject * >::iterator aPyFunction ;
494 for ( aPyFunction = _MapOfPyFunctions.begin() ; aPyFunction != _MapOfPyFunctions.end() ; aPyFunction++ ) {
495 if ( !strcmp( aPyFunction->first.c_str() , "PyObjRef" ) ||
496 !strcmp( aPyFunction->first.c_str() , "PyObjIor" ) ) {
497 //cout << "GraphExecutor::FiniteStateMachine::Executed " << aPyFunction->first << " keeped ..."<< endl ;
500 //cout << "GraphExecutor::FiniteStateMachine::Executed " << aPyFunction->first << " erased ..."<< endl ;
501 _MapOfPyFunctions.erase( aPyFunction->first ) ;
506 //cout << "GraphExecutor::FiniteStateMachine::Executed _GraphExecutingNumber " << _GraphExecutingNumber
507 // << " != 0 ==> no erase" << endl ;
513 void GraphExecutor::FiniteStateMachine::PyInitModule( bool aPyInitModule ) {
514 _PyInitModule = aPyInitModule ;
517 bool GraphExecutor::FiniteStateMachine::PyInitModule() {
518 bool InitedModule = _PyInitModule ;
519 _PyInitModule = true ;
520 return InitedModule ;
523 void GraphExecutor::FiniteStateMachine::PyLock() {
524 // cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyLock " << &_MutexPythonWait << endl ;
525 if ( pthread_mutex_lock( &_MutexPythonWait ) ) {
526 perror( "GraphExecutor::FiniteStateMachine::PyLock" ) ;
529 _MutexPythonLocked = true ;
530 // cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyLocked " << &_MutexPythonWait << endl ;
533 void GraphExecutor::FiniteStateMachine::PyUnLock() {
534 // cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyUnLock " << &_MutexPythonWait << endl ;
535 if ( pthread_mutex_unlock( &_MutexPythonWait ) ) {
536 perror( "GraphExecutor::FiniteStateMachine::PyUnLock" ) ;
539 _MutexPythonLocked = false ;
540 // cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyUnLocked " << &_MutexPythonWait << endl ;
543 void GraphExecutor::FiniteStateMachine::PyLockReset() {
544 if ( _MutexPythonLocked ) {
549 PyObject * GraphExecutor::FiniteStateMachine::PyFunction( const char * aPyFuncName ) {
551 PyObject * RetVal = NULL ;
552 bool PyObjRefIor = !strcmp( aPyFuncName , "PyObjRef" ) || !strcmp( aPyFuncName , "PyObjIor" ) ;
553 PyObject * PyFunctionMapped = _MapOfPyFunctions[ aPyFuncName ] ;
554 if ( _GraphExecutingNumber > 1 && !PyObjRefIor ) {
555 RetVal = PyFunctionMapped ;
556 //cout << "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' ) --> " ;
558 //cout << RetVal << " ob_refcnt " << RetVal->ob_refcnt ;
566 RetVal = PyFunctionMapped ;
567 //cout << "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' ) --> " ;
568 if ( RetVal && PyObjRefIor ) {
569 //cout << RetVal << " " << RetVal->ob_refcnt << endl ;
572 //cout << RetVal << " " << RetVal->ob_refcnt << endl ;
573 // _MapOfPyFunctions.erase( aPyFuncName ) ;
574 // cout << "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' ) erased --> NULL" << endl ;
577 //cout << " NULL" << endl ;
584 bool GraphExecutor::FiniteStateMachine::PyFunction( const char * aPyFuncName , PyObject * aPyFunction ) {
586 bool RetVal = false ;
587 if ( _MapOfPyFunctions[ aPyFuncName ] != NULL ) {
588 //PyObject * aPyFunc = _MapOfPyFunctions[ aPyFuncName ] ;
589 //cout << "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' , " << aPyFunction
590 // << " ) ob_refcnt " << aPyFunction->ob_refcnt << " already mapped : " << aPyFunc << " ob_refcnt "
591 // << aPyFunc->ob_refcnt << endl ;
594 _MapOfPyFunctions[ aPyFuncName ] = aPyFunction ;
595 //cout << "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' , " << aPyFunction
596 // << " ) ob_refcnt " << aPyFunction->ob_refcnt << " mapped" << endl ;
603 GraphBase::Graph * GraphExecutor::FiniteStateMachine::MapGraph( const char * aGraphName ) {
604 GraphBase::Graph * aGraph = _MapOfGraphs[ aGraphName ] ;
605 //cout << "MapGraph " << aGraphName << " --> " << aGraph << endl ;
609 bool GraphExecutor::FiniteStateMachine::MapGraph( GraphBase::Graph * aGraph , const char * aGraphName ) {
610 if ( MapGraph( aGraphName ) ) {
613 _MapOfGraphs[ aGraphName ] = aGraph ;
617 void GraphExecutor::FiniteStateMachine::EraseGraph( const char * aGraphName ) {
618 _MapOfGraphs.erase( aGraphName ) ;
621 bool GraphExecutor::FiniteStateMachine::GraphName( const char * aGraphName ) {
622 return _MapOfGraphNames[ aGraphName ] ;
625 string GraphExecutor::FiniteStateMachine::GraphInstanceName( const char * aGraphName ) {
626 int GraphInstanceNumber = _MapOfGraphNames[ aGraphName ] ;
627 if ( GraphInstanceNumber ) {
628 _MapOfGraphNames[ aGraphName ] = GraphInstanceNumber + 1 ;
631 GraphInstanceNumber = 0 ;
632 _MapOfGraphNames[ aGraphName ] = GraphInstanceNumber + 1 ;
634 string theGraphInstanceName = string( aGraphName ) ;
635 if ( GraphInstanceNumber ) {
636 theGraphInstanceName += "_" ;
638 // astr << GraphInstanceNumber << ends ;
639 astr << GraphInstanceNumber ;
640 theGraphInstanceName += astr.str() ;
642 //cout << "GraphExecutor::FiniteStateMachine::GraphInstanceName( " << aGraphName << " ) --> "
643 // << theGraphInstanceName << endl ;
644 return theGraphInstanceName ;
648 void GraphExecutor::FiniteStateMachine::JoinThread() {
649 if ( pthread_mutex_lock( &_MutexJoinWait ) ) {
650 perror("FiniteStateMachine:JoinThread pthread_mutex_lock ") ;
653 while ( _JoinThread ) {
654 while ( _ThreadList.size() == 0) {
655 // MESSAGE( pthread_self() << " FiniteStateMachine:Join pthread_cond_wait" );
656 if ( pthread_cond_wait( &_JoinWait , &_MutexJoinWait ) ) {
657 perror("FiniteStateMachine:JoinThread pthread_cond_wait ") ;
660 pthread_t _Thread = _ThreadList.front() ;
661 // MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_cond_waited : " << _Thread )
662 // MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_join : " << _Thread );
663 int joinsts = pthread_join( _Thread , NULL ) ;
665 perror("FiniteStateMachine:JoinThread pthread_join ") ;
666 MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_join : " << _Thread
671 MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_joined : " << _Thread );
672 _ThreadList.pop_front() ;
675 if ( pthread_mutex_unlock( &_MutexJoinWait ) ) {
676 perror("FiniteStateMachine:JoinThread pthread_mutex_unlock ") ;
681 void GraphExecutor::FiniteStateMachine::JoinThread( pthread_t aThread ) {
682 if ( pthread_mutex_lock( &_MutexJoinWait ) ) {
683 perror("Join pthread_mutex_lock ") ;
686 // MESSAGE(pthread_self() << " JoinThread pthread_cond_signal for " << aThread)
687 _ThreadList.push_back( aThread ) ;
688 if ( pthread_cond_signal( &_JoinWait ) ) {
689 perror("Join pthread_cond_signal ") ;
691 // MESSAGE( pthread_self() << " JoinThread pthread_cond_signaled for " << aThread)
693 if ( pthread_mutex_unlock( &_MutexJoinWait ) ) {
694 perror("Join pthread_mutex_unlock ") ;
699 ostream & operator<< (ostream &f ,const GraphExecutor::AutomatonState & aState ) {
701 case GraphExecutor::UnKnownState :
704 case GraphExecutor::DataUndefState :
705 f << "DataUndefState";
707 case GraphExecutor::DataWaitingState :
708 f << "DataWaitingState";
710 case GraphExecutor::DataReadyState :
711 f << "DataReadyState";
713 case GraphExecutor::SuspendedReadyState :
714 f << "SuspendedReadyState";
716 case GraphExecutor::SuspendedReadyToResumeState :
717 f << "SuspendedReadyToResumeState";
719 case GraphExecutor::ResumedReadyState :
720 f << "ResumedReadyState";
722 case GraphExecutor::KilledReadyState :
723 f << "KilledReadyState";
725 case GraphExecutor::StoppedReadyState :
726 f << "StoppedReadyState";
728 case GraphExecutor::ExecutingState :
729 f << "ExecutingState";
731 case GraphExecutor::SuspendedExecutingState :
732 f << "SuspendedExecutingState";
734 case GraphExecutor::ResumedExecutingState :
735 f << "ResumedExecutingState";
737 case GraphExecutor::KilledExecutingState :
738 f << "KilledExecutingState";
740 case GraphExecutor::StoppedExecutingState :
741 f << "StoppedExecutingState";
743 case GraphExecutor::SuccessedExecutingState :
744 f << "SuccessedExecutingState";
746 case GraphExecutor::ErroredExecutingState :
747 f << "ErroredExecutingState";
749 case GraphExecutor::SuspendedSuccessedState :
750 f << "SuspendedSuccessedState";
752 case GraphExecutor::SuspendedErroredState :
753 f << "SuspendedErroredState";
755 case GraphExecutor::ResumedSuccessedState :
756 f << "ResumedSuccessedState";
758 case GraphExecutor::ResumedErroredState :
759 f << "ResumedErroredState";
761 case GraphExecutor::KilledSuccessedState :
762 f << "KilledSuccessedState";
764 case GraphExecutor::KilledErroredState :
765 f << "KilledErroredState";
767 case GraphExecutor::StoppedSuccessedState :
768 f << "StoppedSuccessedState";
770 case GraphExecutor::StoppedErroredState :
771 f << "StoppedErroredState";
773 case GraphExecutor::SuccessedState :
774 f << "SuccessedState";
776 case GraphExecutor::ErroredState :
779 case GraphExecutor::SuspendedState :
780 f << "SuspendedState";
782 case GraphExecutor::KilledState :
785 case GraphExecutor::StoppedState :
788 case GraphExecutor::SuspendedSuccessedToReStartState :
789 f << "SuspendedSuccessedToReStartState";
791 case GraphExecutor::SuspendedErroredToReStartState :
792 f << "SuspendedErroredToReStartState";
794 case GraphExecutor::ReStartedState :
795 f << "ReStartedState";
797 case GraphExecutor::LoadingState :
801 f << "GraphExecutor::AutomatonState_?";