Salome HOME
Traces
[modules/superv.git] / src / GraphExecutor / DataFlowExecutor_FiniteStateMachine.cxx
1 //  SUPERV GraphExecutor : contains classes that permit execution of graphs and particularly the execution automaton
2 //
3 //  Copyright (C) 2003  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 //  CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS 
5 // 
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. 
10 // 
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. 
15 // 
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 
19 // 
20 //  See http://www.opencascade.org/SALOME/ or email : webmaster.salome@opencascade.org 
21 //
22 //
23 //
24 //  File   : DataFlowBase_FiniteStateMachine.cxx
25 //  Author : Jean Rahuel, CEA
26 //  Module : SUPERV
27 //  $Header:
28
29 using namespace std;
30 #include <stdlib.h>
31 #include <iostream>
32 #include <unistd.h>
33 #include <stdio.h>
34
35 #include "DataFlowExecutor_FiniteStateMachine.hxx"
36
37 void * start_function( void *p ) ;
38
39 // ControlStates :
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
47
48 #if 0
49 // States :
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
84 #endif
85
86 // Events :
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
126
127 GraphExecutor::FiniteStateMachine::FiniteStateMachine() {
128   MESSAGE( "FiniteStateMachine::FiniteStateMachine" ) ;
129
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" ;
137
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" ;
171
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" ;
210
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" ;
218
219   _ActionName[ DataReady_SuspendAction ] = "DataReady_SuspendAction" ;
220   _ActionName[ SuspendedReady_ResumeAction ] = "SuspendedReady_ResumeAction" ;
221   _ActionName[ DataReady_KillAction ] = "DataReady_KillAction" ;
222   _ActionName[ DataReady_StopAction ] = "DataReady_StopAction" ;
223
224   _ActionName[ DataReady_ExecuteAction ] = "DataReady_ExecuteAction" ;
225
226   _ActionName[ Executing_SuspendAction ] = "Executing_SuspendAction" ;
227   _ActionName[ SuspendedExecuting_ResumeAction ] = "SuspendedExecuting_ResumeAction" ;
228   _ActionName[ Executing_KillAction ] = "Executing_KillAction" ;
229   _ActionName[ Executing_StopAction ] = "Executing_StopAction" ;
230
231   _ActionName[ Executing_SuccessAction ] = "Executing_SuccessAction" ;
232   _ActionName[ Executing_ErrorAction ] = "Executing_ErrorAction" ;
233   _ActionName[ Successed_SuccessAction ] = "Successed_SuccessAction" ;
234   _ActionName[ Errored_ErrorAction ] = "Errored_ErrorAction" ;
235
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" ;
244
245   _ActionName[ SuspendedSuccessed_ReStartAction ] = "SuspendedSuccessed_ReStartAction" ;
246   _ActionName[ SuspendedErrored_ReStartAction ] = "SuspendedErrored_ReStartAction" ;
247   _ActionName[ SuspendedSuccessed_ReStartAndSuspendAction ] = "SuspendedSuccessed_ReStartAndSuspendAction" ;
248   _ActionName[ SuspendedErrored_ReStartAndSuspendAction ] = "SuspendedErrored_ReStartAndSuspendAction" ;
249
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" ;
264
265   int i , j ;
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 ;
273     }
274   }
275 // OneEvent ===> Change of State and associated Action :
276 //               _TransitionTable[ OldState ][ OneEvent ] gives a NewState
277 //               _Action[ NewState ][ OneEvent ] gives what to do
278
279 // INPUT-DATAS :
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;
291 // AllDataReadyEvent
292   _TransitionTable[ DataUndefState ][ AllDataReadyEvent ] = DataReadyState ;
293   _ActionTable[ DataReadyState ][ AllDataReadyEvent ] = DataUndef_AllDataReadyAction ;
294
295 // DATAS-READY-CONTROL :
296 // SuspendEvent
297   _TransitionTable[ DataReadyState ][ SuspendEvent ] = SuspendedReadyState ;
298   _ActionTable[ SuspendedReadyState ][ SuspendEvent ] = DataReady_SuspendAction;
299 // ResumeEvent
300   _TransitionTable[ SuspendedReadyState ][ ToResumeEvent ] = SuspendedReadyToResumeState ;
301   _ActionTable[ SuspendedReadyToResumeState ][ ToResumeEvent ] = VoidAction ;
302
303   _TransitionTable[ SuspendedReadyToResumeState ][ ResumeEvent ] = ResumedReadyState ;
304   _ActionTable[ ResumedReadyState ][ ResumeEvent] = SuspendedReady_ResumeAction ;
305 // KillEvent
306   _TransitionTable[ SuspendedReadyState ][ KillEvent ] = KilledReadyState ;
307 // StopEvent
308   _TransitionTable[ SuspendedReadyState ][ StopEvent ] = StoppedReadyState ;
309 // KillEvent
310   _TransitionTable[ DataReadyState ][ KillEvent ] = KilledReadyState ;
311   _ActionTable[ KilledReadyState ][ KillEvent] = DataReady_KillAction ;
312 // StopEvent
313   _TransitionTable[ DataReadyState ][ StopEvent ] = StoppedReadyState ;
314   _ActionTable[ StoppedReadyState ][ StopEvent] = DataReady_StopAction ;
315
316 // RUN :
317 // ExecuteEvent
318   _TransitionTable[ SuspendedReadyToResumeState ][ ExecuteEvent ] = ExecutingState ;
319 // ExecuteEvent
320   _TransitionTable[ ResumedReadyState ][ ExecuteEvent ] = ExecutingState ;
321 // ExecuteEvent
322   _TransitionTable[ DataReadyState ][ ExecuteEvent ] = ExecutingState ;
323 // ExecuteEvent
324   _TransitionTable[ ReStartedState ][ ExecuteEvent ] = ExecutingState ;
325   _ActionTable[ ExecutingState ][ ExecuteEvent ] = DataReady_ExecuteAction;
326
327 // RUN-CONTROL :
328 // SuspendEvent
329   _TransitionTable[ ExecutingState ][ SuspendEvent ] = SuspendedExecutingState ;
330   _ActionTable[ SuspendedExecutingState ][ SuspendEvent ] = Executing_SuspendAction;
331 // ResumeEvent
332   _TransitionTable[ SuspendedExecutingState ][ ResumeEvent ] = ResumedExecutingState ;
333   _ActionTable[ ResumedExecutingState ][ ResumeEvent] = SuspendedExecuting_ResumeAction;
334 // ExecuteEvent
335   _TransitionTable[ ResumedExecutingState ][ ExecuteEvent ] = ExecutingState ;
336 // KillEvent
337   _TransitionTable[ SuspendedExecutingState ][ KillEvent ] = KilledExecutingState ;
338 // StopEvent
339   _TransitionTable[ SuspendedExecutingState ][ StopEvent ] = StoppedExecutingState ;
340 // KillEvent
341   _TransitionTable[ ExecutingState ][ KillEvent ] = KilledExecutingState ;
342   _ActionTable[ KilledExecutingState ][ KillEvent] = Executing_KillAction;
343   _TransitionTable[ KilledExecutingState ][ KillEvent ] = KilledState ;
344   _ActionTable[ KilledState ][ KillEvent] = VoidAction;
345 // StopEvent
346   _TransitionTable[ ExecutingState ][ StopEvent ] = StoppedExecutingState ;
347   _ActionTable[ StoppedExecutingState ][ StopEvent] = Executing_StopAction;
348   _TransitionTable[ StoppedExecutingState ][ StopEvent ] = StoppedState ;
349   _ActionTable[ StoppedState ][ StopEvent] = VoidAction;
350
351 // DONE :
352 // SuccessEvent
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;
358 //JR 24.03.2005 : Debug for PAL8176 : abort of GOTONode
359 // ErrorEvent
360   _TransitionTable[ SuccessedState ][ ErrorEvent ] = ErroredExecutingState ;
361   _ActionTable[ ErroredExecutingState ][ ErrorEvent ] = Executing_ErrorAction;
362 // ErrorEvent
363   _TransitionTable[ ExecutingState ][ ErrorEvent ] = ErroredExecutingState ;
364   _ActionTable[ ErroredExecutingState ][ ErrorEvent ] = Executing_ErrorAction;
365 // SuspendedExecutingState : NO ResumeEvent 13-03-2003
366   _TransitionTable[ SuspendedExecutingState ][ ErrorEvent ] = ErroredExecutingState ;
367   _ActionTable[ ErroredExecutingState ][ ErrorEvent ] = Executing_ErrorAction;
368
369 // DONE-CONTROL :
370 // SuccessedExecutingState - SuccessEvent
371   _TransitionTable[ SuccessedExecutingState ][ SuccessEvent ] = SuccessedState ;
372   _ActionTable[ SuccessedState ][ SuccessEvent ] = Successed_SuccessAction ;
373 // ErroredExecutingState - ErrorEvent
374   _TransitionTable[ ErroredExecutingState ][ ErrorEvent ] = ErroredState ;
375   _ActionTable[ ErroredState ][ ErrorEvent ] = Errored_ErrorAction ;
376
377 // SuccessedState - SuspendEvent
378   _TransitionTable[ SuccessedExecutingState ][ SuspendEvent ] = SuspendedSuccessedState ;
379   _ActionTable[ SuspendedSuccessedState ][ SuspendEvent ] = Successed_SuspendAction;
380 // ErroredState - SuspendEvent
381   _TransitionTable[ ErroredExecutingState ][ SuspendEvent ] = SuspendedErroredState ;
382   _ActionTable[ SuspendedErroredState ][ SuspendEvent ] = Errored_SuspendAction;
383
384 // SuccessedState - KillEvent
385   _TransitionTable[ SuccessedExecutingState ][ KillEvent ] = KilledSuccessedState ;
386   _ActionTable[ KilledSuccessedState ][ KillEvent ] = Successed_KillAction;
387 // ErroredState - KillEvent
388   _TransitionTable[ ErroredExecutingState ][ KillEvent ] = KilledErroredState ;
389   _ActionTable[ KilledErroredState ][ KillEvent ] = Errored_KillAction;
390
391 // SuccessedState - StopEvent
392   _TransitionTable[ SuccessedExecutingState ][ StopEvent ] = StoppedSuccessedState ;
393   _ActionTable[ StoppedSuccessedState ][ StopEvent ] = Successed_StopAction;
394 // ErroredState - StopEvent
395   _TransitionTable[ ErroredExecutingState ][ StopEvent ] = StoppedErroredState ;
396   _ActionTable[ StoppedErroredState ][ StopEvent ] = Errored_StopAction;
397
398 // SuspendedSuccessedState - ResumeEvent
399   _TransitionTable[ SuspendedSuccessedState ][ ResumeEvent ] = ResumedSuccessedState ;
400   _ActionTable[ ResumedSuccessedState ][ ResumeEvent ] = SuspendedSuccessed_ResumeAction;
401
402   _TransitionTable[ ResumedSuccessedState ][ ResumedSuccessedEvent ] = SuccessedState ;
403   _ActionTable[ SuccessedState ][ ResumedSuccessedEvent] = Successed_SuccessAction;
404
405 // SuspendedErroredState - ResumeEvent
406   _TransitionTable[ SuspendedErroredState ][ ResumeEvent ] = ResumedErroredState ;
407   _ActionTable[ ResumedErroredState ][ ResumeEvent ] = SuspendedErrored_ResumeAction;
408   _TransitionTable[ ResumedErroredState ][ ResumedErroredEvent ] = ErroredState ;
409   _ActionTable[ ErroredState ][ ResumedErroredEvent ] = Errored_ErrorAction;
410
411 // SuccessedState - KillEvent
412   _TransitionTable[ SuccessedState ][ KillEvent ] = KilledSuccessedState ;
413   _ActionTable[ KilledSuccessedState ][ KillEvent] = Successed_KillAction;
414   _TransitionTable[ KilledSuccessedState ][ KillEvent ] = KilledState ;
415   _ActionTable[ KilledState ][ KillEvent ] = VoidAction;
416 // ErroredState - KillEvent
417   _TransitionTable[ ErroredState ][ KillEvent ] = KilledErroredState ;
418   _ActionTable[ KilledErroredState ][ KillEvent] = Errored_KillAction;
419   _TransitionTable[ KilledErroredState ][ KillEvent ] = KilledState ;
420   _ActionTable[ KilledState ][ KillEvent ] = VoidAction;
421
422 // SuccessedState - StopEvent
423   _TransitionTable[ SuccessedState ][ StopEvent ] = StoppedSuccessedState ;
424   _ActionTable[ StoppedSuccessedState ][ StopEvent] = Successed_StopAction;
425   _TransitionTable[ StoppedSuccessedState ][ StopEvent ] = StoppedState ;
426   _ActionTable[ StoppedState ][ StopEvent ] = VoidAction;
427 // ErroredState - StopEvent
428   _TransitionTable[ ErroredState ][ StopEvent ] = StoppedErroredState ;
429   _ActionTable[ StoppedErroredState ][ StopEvent] = Errored_StopAction;
430   _TransitionTable[ StoppedErroredState ][ StopEvent ] = StoppedState ;
431   _ActionTable[ StoppedState ][ StopEvent ] = VoidAction;
432
433 // ReStartEvent
434   _TransitionTable[ SuspendedSuccessedState ][ ToReStartEvent ] = SuspendedSuccessedToReStartState ;
435   _ActionTable[ SuspendedSuccessedToReStartState ][ ToReStartEvent] = VoidAction ;
436
437   _TransitionTable[ SuspendedSuccessedToReStartState ][ ReStartEvent ] = ReStartedState ;
438   _TransitionTable[ SuspendedSuccessedToReStartState ][ ReStartAndSuspendEvent ] = ReStartedState ;
439 // ReStartEvent
440   _TransitionTable[ SuspendedErroredState ][ ToReStartEvent ] = SuspendedErroredToReStartState ;
441   _ActionTable[ SuspendedErroredToReStartState ][ ToReStartEvent] = VoidAction ;
442
443   _TransitionTable[ SuspendedErroredToReStartState ][ ReStartEvent ] = ReStartedState ;
444   _TransitionTable[ SuspendedErroredToReStartState ][ ReStartAndSuspendEvent ] = ReStartedState ;
445
446   _ActionTable[ ReStartedState ][ ReStartEvent] = SuspendedSuccessed_ReStartAction;
447   _ActionTable[ ReStartedState ][ ReStartAndSuspendEvent] = SuspendedSuccessed_ReStartAndSuspendAction;
448
449   pthread_mutex_init( &_MutexJoinWait , NULL ) ;
450   if ( pthread_cond_init( &_JoinWait , NULL ) ) {
451     perror("pthread_cond_init( &_JoinWait , NULL )") ;
452     exit( 0 ) ;
453   }
454   _JoinThread = true ;
455   if ( pthread_create( &_JoinThreadNo , NULL , start_function , this ) ) {
456     char * msg = "Cannot pthread_create " ;
457     perror( msg ) ;
458   }
459
460   pthread_mutex_init( &_MutexPythonWait , NULL ) ;
461   _MutexPythonLocked = false ;
462   _ExecNumber = 0 ;
463   _GraphExecutingNumber = 0 ;
464   _PyInitModule = false ;
465   _DbgFileNumber = 0 ;
466   MESSAGE( "FiniteStateMachine::FiniteStateMachine _TransitionTable " ) ;
467 }
468
469 void * start_function( void *p ) {
470   GraphExecutor::FiniteStateMachine *anAutomaton = (GraphExecutor::FiniteStateMachine *) p;
471   if ( pthread_setcanceltype( PTHREAD_CANCEL_ASYNCHRONOUS , NULL ) ) {
472     perror("pthread_setcanceltype ") ;
473     exit(0) ;
474   }
475   if ( pthread_setcancelstate( PTHREAD_CANCEL_ENABLE , NULL ) ) {
476     perror("pthread_setcancelstate ") ;
477     exit(0) ;
478   }
479   anAutomaton->JoinThread() ;
480   pthread_exit( PTHREAD_CANCELED ) ;
481 }
482
483 int GraphExecutor::FiniteStateMachine::ExecNumber() {
484   PyLock() ;
485   _ExecNumber += 1 ;
486   int RetVal = _ExecNumber ;
487   _GraphExecutingNumber += 1 ;
488   PyUnLock() ;
489   return RetVal ;
490 }
491
492 void GraphExecutor::FiniteStateMachine::Executed() {
493   PyLock() ;
494   _GraphExecutingNumber -= 1 ;
495   if ( _GraphExecutingNumber == 0 ) {
496     map< string , PyObject * >::iterator aPyFunction ;
497     for ( aPyFunction = _MapOfPyFunctions.begin() ; aPyFunction != _MapOfPyFunctions.end() ; aPyFunction++ ) {
498       if ( !strcmp( aPyFunction->first.c_str() , "PyObjRef" ) ||
499            !strcmp( aPyFunction->first.c_str() , "PyObjIor" ) ) {
500         MESSAGE( "GraphExecutor::FiniteStateMachine::Executed " << aPyFunction->first << " keeped ..."
501                  ) ;
502       }
503       else {
504         MESSAGE( "GraphExecutor::FiniteStateMachine::Executed " << aPyFunction->first << " erased ..."
505                ) ;
506         _MapOfPyFunctions.erase( aPyFunction->first ) ;
507       }
508     }
509   }
510   else {
511     MESSAGE( "GraphExecutor::FiniteStateMachine::Executed _GraphExecutingNumber "
512               << _GraphExecutingNumber << " != 0 ==> no erase" ) ;
513   }
514   PyUnLock() ;
515   return ;
516 }
517
518 void GraphExecutor::FiniteStateMachine::PyInitModule( bool aPyInitModule ) {
519   _PyInitModule = aPyInitModule ;
520 }
521
522 bool GraphExecutor::FiniteStateMachine::PyInitModule() {
523   bool InitedModule = _PyInitModule ;
524   _PyInitModule = true ;
525   return InitedModule ;
526 }
527
528 void GraphExecutor::FiniteStateMachine::PyLock() {
529 //  cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyLock " << &_MutexPythonWait << endl ;
530   if ( pthread_mutex_lock( &_MutexPythonWait ) ) {
531     perror( "GraphExecutor::FiniteStateMachine::PyLock" ) ;
532     exit( 0 ) ;
533   }
534   _MutexPythonLocked = true ;
535 //  cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyLocked " << &_MutexPythonWait << endl ;
536 }
537
538 void GraphExecutor::FiniteStateMachine::PyUnLock() {
539 //  cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyUnLock " << &_MutexPythonWait << endl ;
540   if ( pthread_mutex_unlock( &_MutexPythonWait ) ) {
541     perror( "GraphExecutor::FiniteStateMachine::PyUnLock" ) ;
542     exit( 0 ) ;
543   }
544   _MutexPythonLocked = false ;
545 //  cout << pthread_self() << " GraphExecutor::FiniteStateMachine::PyUnLocked " << &_MutexPythonWait << endl ;
546 }
547
548 void GraphExecutor::FiniteStateMachine::PyLockReset() {
549   if ( _MutexPythonLocked ) {
550     PyUnLock() ;
551   }
552 }
553
554 #define PyFunctionTrace 0
555 PyObject * GraphExecutor::FiniteStateMachine::PyFunction( const char * aPyFuncName ) {
556   
557   PyObject * RetVal = NULL ;
558   bool PyObjRefIor = !strcmp( aPyFuncName , "PyObjRef" ) || !strcmp( aPyFuncName , "PyObjIor" ) ;
559   PyObject * PyFunctionMapped = _MapOfPyFunctions[ aPyFuncName ] ;
560   if ( _GraphExecutingNumber > 1 && !PyObjRefIor ) {
561     RetVal = PyFunctionMapped ;
562 #if PyFunctionTrace
563     MESSAGE( "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' ) --> " ) ;
564     if ( RetVal ) {
565       MESSAGE( RetVal << " ob_refcnt " << RetVal->ob_refcnt ) ;
566     }
567     else {
568       MESSAGE( " NULL" ) ;
569     }
570 #endif
571   }
572   else {
573     RetVal = PyFunctionMapped ;
574 #if PyFunctionTrace
575     MESSAGE( "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' ) --> " ) ;
576     if ( RetVal && PyObjRefIor ) {
577       MESSAGE( RetVal << " " << RetVal->ob_refcnt ) ;
578     }
579     else if ( RetVal ) {
580       MESSAGE( RetVal << " " << RetVal->ob_refcnt ) ;
581     }
582     else {
583       MESSAGE( " NULL" ) ;
584     }
585 #endif
586   }
587   
588   return RetVal ;
589 }
590
591 bool GraphExecutor::FiniteStateMachine::PyFunction( const char * aPyFuncName , PyObject * aPyFunction ) {
592   
593   bool RetVal = false ;
594   if ( _MapOfPyFunctions[ aPyFuncName ] != NULL ) {
595 #if PyFunctionTrace
596     PyObject * aPyFunc = _MapOfPyFunctions[ aPyFuncName ] ;
597     MESSAGE( "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' , aPyFunction "
598              << aPyFunction << " ) ob_refcnt " << aPyFunction->ob_refcnt << " already mapped : "
599              << aPyFunc << " ob_refcnt " << aPyFunc->ob_refcnt ) ;
600 #endif
601   }
602   else {
603     _MapOfPyFunctions[ aPyFuncName ] = aPyFunction ;
604 #if PyFunctionTrace
605     MESSAGE( "GraphExecutor::FiniteStateMachine::PyFunction( '" << aPyFuncName << "' ) " << aPyFunction
606              << " ) ob_refcnt " << aPyFunction->ob_refcnt << " mapped" ) ;
607 #endif
608     RetVal = true ;
609   }
610   
611   return RetVal ;
612 }
613
614 bool GraphExecutor::FiniteStateMachine::ErasePyFunction( const char * aPyFuncName ) {
615   
616 #if PyFunctionTrace
617   MESSAGE( "GraphExecutor::FiniteStateMachine::ErasePyFunction( '" << aPyFuncName << "' )" ) ;
618 #endif
619   if ( _MapOfPyFunctions[ aPyFuncName ] != NULL ) {
620     _MapOfPyFunctions.erase( aPyFuncName ) ;
621     return true ;
622   }  
623   return false ;
624 }
625
626 /*
627 GraphBase::Graph * GraphExecutor::FiniteStateMachine::MapGraph( const char * aGraphName ) {
628   GraphBase::Graph * aGraph = _MapOfGraphs[ aGraphName ] ;
629   //cout << "MapGraph " << aGraphName << " --> " << aGraph << endl ;
630   return aGraph ;
631 }
632
633 bool GraphExecutor::FiniteStateMachine::MapGraph( GraphBase::Graph * aGraph , const char * aGraphName ) {
634   if ( MapGraph( aGraphName ) ) {
635     return false ;
636   }
637   _MapOfGraphs[ aGraphName ] = aGraph ;
638   return true ;
639 }
640
641 void GraphExecutor::FiniteStateMachine::EraseGraph( const char * aGraphName ) {
642   _MapOfGraphs.erase( aGraphName ) ;
643 }
644
645 bool GraphExecutor::FiniteStateMachine::GraphName( const char * aGraphName ) {
646   return  _MapOfGraphNames[ aGraphName ] ;
647 }
648
649 string GraphExecutor::FiniteStateMachine::GraphInstanceName( const char * aGraphName ) {
650   int GraphInstanceNumber = _MapOfGraphNames[ aGraphName ] ;
651   if ( GraphInstanceNumber ) {
652     _MapOfGraphNames[ aGraphName ] = GraphInstanceNumber + 1 ;
653   }
654   else {
655     GraphInstanceNumber = 0 ;
656     _MapOfGraphNames[ aGraphName ] = GraphInstanceNumber + 1 ;
657   }
658   string theGraphInstanceName = string( aGraphName ) ;
659   if ( GraphInstanceNumber ) {
660     theGraphInstanceName += "_" ;
661     ostringstream astr ;
662 //    astr << GraphInstanceNumber << ends ;
663     astr << GraphInstanceNumber ;
664     theGraphInstanceName += astr.str() ;
665   }
666   //cout << "GraphExecutor::FiniteStateMachine::GraphInstanceName( " << aGraphName << " ) --> "
667     //   << theGraphInstanceName << endl ;
668   return theGraphInstanceName ;
669 }
670 */
671
672 void GraphExecutor::FiniteStateMachine::JoinThread() {
673   if ( pthread_mutex_lock( &_MutexJoinWait ) ) {
674     perror("FiniteStateMachine:JoinThread pthread_mutex_lock ") ;
675     exit( 0 ) ;
676   }
677   while ( _JoinThread ) {
678     while ( _ThreadList.size() == 0) {
679 //      MESSAGE( pthread_self() << " FiniteStateMachine:Join pthread_cond_wait" );
680       if ( pthread_cond_wait( &_JoinWait , &_MutexJoinWait ) ) {
681         perror("FiniteStateMachine:JoinThread pthread_cond_wait ") ;
682       }
683     }
684     pthread_t _Thread = _ThreadList.front() ;
685 //    MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_cond_waited : " << _Thread )
686 //    MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_join : " << _Thread );
687     int joinsts = pthread_join( _Thread , NULL ) ;
688     if ( joinsts ) {
689       perror("FiniteStateMachine:JoinThread pthread_join ") ;
690       MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_join : " << _Thread
691                << " Error" );
692       exit( 0 ) ;
693     }
694     else {
695 //      MESSAGE( pthread_self() << " FiniteStateMachine:JoinThread pthread_joined : " << _Thread );
696       _ThreadList.pop_front() ;
697     }
698   }
699   if ( pthread_mutex_unlock( &_MutexJoinWait ) ) {
700     perror("FiniteStateMachine:JoinThread pthread_mutex_unlock ") ;
701     exit( 0 ) ;
702   }
703 }
704
705 void GraphExecutor::FiniteStateMachine::JoinThread( pthread_t aThread ) {
706   if ( pthread_mutex_lock( &_MutexJoinWait ) ) {
707     perror("Join pthread_mutex_lock ") ;
708     exit( 0 ) ;
709   }
710 //  MESSAGE(pthread_self() << " JoinThread pthread_cond_signal for " << aThread)
711   _ThreadList.push_back( aThread ) ;
712   if ( pthread_cond_signal( &_JoinWait ) ) {
713     perror("Join pthread_cond_signal ") ;
714   }
715 //  MESSAGE( pthread_self() << " JoinThread pthread_cond_signaled for " << aThread)
716
717   if ( pthread_mutex_unlock( &_MutexJoinWait ) ) {
718     perror("Join pthread_mutex_unlock ") ;
719     exit( 0 ) ;
720   }
721 }
722
723 ostream & operator<< (ostream &f ,const GraphExecutor::AutomatonState & aState ) {
724   switch (aState) {
725   case GraphExecutor::UnKnownState :
726     f << "UnKnownState";
727     break;
728   case GraphExecutor::DataUndefState :
729     f << "DataUndefState";
730     break;
731   case GraphExecutor::DataWaitingState :
732     f << "DataWaitingState";
733     break;
734   case GraphExecutor::DataReadyState :
735     f << "DataReadyState";
736     break;
737   case GraphExecutor::SuspendedReadyState :
738     f << "SuspendedReadyState";
739     break;
740   case GraphExecutor::SuspendedReadyToResumeState :
741     f << "SuspendedReadyToResumeState";
742     break;
743   case GraphExecutor::ResumedReadyState :
744     f << "ResumedReadyState";
745     break;
746   case GraphExecutor::KilledReadyState :
747     f << "KilledReadyState";
748     break;
749   case GraphExecutor::StoppedReadyState :
750     f << "StoppedReadyState";
751     break;
752   case GraphExecutor::ExecutingState :
753     f << "ExecutingState";
754     break;
755   case GraphExecutor::SuspendedExecutingState :
756     f << "SuspendedExecutingState";
757     break;
758   case GraphExecutor::ResumedExecutingState :
759     f << "ResumedExecutingState";
760     break;
761   case GraphExecutor::KilledExecutingState :
762     f << "KilledExecutingState";
763     break;
764   case GraphExecutor::StoppedExecutingState :
765     f << "StoppedExecutingState";
766     break;
767   case GraphExecutor::SuccessedExecutingState :
768     f << "SuccessedExecutingState";
769     break;
770   case GraphExecutor::ErroredExecutingState :
771     f << "ErroredExecutingState";
772     break;
773   case GraphExecutor::SuspendedSuccessedState :
774     f << "SuspendedSuccessedState";
775     break;
776   case GraphExecutor::SuspendedErroredState :
777     f << "SuspendedErroredState";
778     break;
779   case GraphExecutor::ResumedSuccessedState :
780     f << "ResumedSuccessedState";
781     break;
782   case GraphExecutor::ResumedErroredState :
783     f << "ResumedErroredState";
784     break;
785   case GraphExecutor::KilledSuccessedState :
786     f << "KilledSuccessedState";
787     break;
788   case GraphExecutor::KilledErroredState :
789     f << "KilledErroredState";
790     break;
791   case GraphExecutor::StoppedSuccessedState :
792     f << "StoppedSuccessedState";
793     break;
794   case GraphExecutor::StoppedErroredState :
795     f << "StoppedErroredState";
796     break;
797   case GraphExecutor::SuccessedState :
798     f << "SuccessedState";
799     break;
800   case GraphExecutor::ErroredState :
801     f << "ErroredState";
802     break;
803   case GraphExecutor::SuspendedState :
804     f << "SuspendedState";
805     break;
806   case GraphExecutor::KilledState :
807     f << "KilledState";
808     break;
809   case GraphExecutor::StoppedState :
810     f << "StoppedState";
811     break;
812   case GraphExecutor::SuspendedSuccessedToReStartState :
813     f << "SuspendedSuccessedToReStartState";
814     break;
815   case GraphExecutor::SuspendedErroredToReStartState :
816     f << "SuspendedErroredToReStartState";
817     break;
818   case GraphExecutor::ReStartedState :
819     f << "ReStartedState";
820     break;
821   case GraphExecutor::LoadingState :
822     f << "LoadingState";
823     break;
824   default :
825     f << "GraphExecutor::AutomatonState_?";
826     break;
827   }
828
829   return f;
830 }
831