merge from branch DEV tag mergeto_trunk_04apr08

[modules/yacs.git] / src / yacsorb / CORBAEngineTest.py

diff --git a/src/yacsorb/CORBAEngineTest.py b/src/yacsorb/CORBAEngineTest.py
new file mode 100644 (file)
index 0000000..123d2be
--- /dev/null
+++ b/src/yacsorb/CORBAEngineTest.py
@@ -0,0 +1,124 @@
+import time
+
+import salome
+salome.salome_init()
+
+import YACS_ORB
+comp = salome.lcc.FindOrLoadComponent( "YACSContainer","YACS" )
+yacsgen = comp._narrow(YACS_ORB.YACS_Gen)
+
+# -----------------------------------------------------------------------------
+# --- schema OK
+
+procEx = yacsgen.LoadProc("samples/legendre7.xml")
+procEx.setExecMode(YACS_ORB.CONTINUE)
+procEx.Run()
+
+# --- wait until executor is paused, finished or stopped
+
+isRunning = 1
+while isRunning:
+    time.sleep(0.5)
+    state = procEx.getExecutorState()
+    isRunning = (state < 304)
+    print "executorState: ", state
+    pass
+
+procEx.saveState("res.xml")
+numids,names = procEx.getIds()
+
+dico = {}
+i=0
+for name in names:
+    dico[name] = numids[i]
+    i+=1
+    pass
+
+print procEx.getOutPortValue(dico["poly_7"],"Pn")
+print procEx.getInPortValue(dico["poly_7"],"x")
+print procEx.getInPortValue(dico["poly_7"],"notAPort")
+print procEx.getInPortValue(dico["Legendre.loopIter"],"nsteps")
+
+# -----------------------------------------------------------------------------
+# --- schema with errors (echoSrv must be launched)
+
+procEx = yacsgen.LoadProc("samples/aschema.xml")
+procEx.setExecMode(YACS_ORB.CONTINUE)
+procEx.Run()
+
+# --- wait until executor is paused, finised or stopped
+
+isRunning = 1
+while isRunning:
+    time.sleep(0.5)
+    state = procEx.getExecutorState()
+    isRunning = (state < 304)
+    print "executorState: ", state
+    pass
+
+procEx.saveState("res2.xml")
+numids,names = procEx.getIds()
+
+dico = {}
+i=0
+for name in names:
+    dico[name] = numids[i]
+    i+=1
+    pass
+
+print procEx.getErrorDetails(dico["c1"])
+print procEx.getErrorDetails(dico["node13"])
+
+# -----------------------------------------------------------------------------
+# --- schema with errors
+
+procEx = yacsgen.LoadProc("samples/triangle5error.xml")
+procEx.setExecMode(YACS_ORB.CONTINUE)
+procEx.setStopOnError(1,"execError2.xml")
+#procEx.unsetStopOnError()
+procEx.Run()
+
+isRunning = 1
+while isRunning:
+    time.sleep(0.5)
+    state = procEx.getExecutorState()
+    isRunning = (state < 304)
+    print "executorState: ", state
+    pass
+
+#procEx.resumeCurrentBreakPoint()
+
+procEx.saveState("res3.xml")
+
+# -----------------------------------------------------------------------------
+# --- schema with breakpoints
+
+procEx = yacsgen.LoadProc("samples/legendre7.xml")
+procEx.setListOfBreakPoints(["Legendre.loopIter.deuxIter.iter2"])
+procEx.setExecMode(YACS_ORB.STOPBEFORENODES)
+procEx.Run()
+
+isRunning = 1
+while isRunning:
+    time.sleep(0.5)
+    state = procEx.getExecutorState()
+    isRunning = (state < 304)
+    print "executorState: ", state
+    pass
+
+procEx.saveState("partialExec.xml")
+
+procEx = yacsgen.LoadProc("samples/legendre7.xml")
+procEx.setExecMode(YACS_ORB.CONTINUE)
+procEx.RunFromState("partialExec.xml")
+
+isRunning = 1
+while isRunning:
+    time.sleep(0.5)
+    state = procEx.getExecutorState()
+    isRunning = (state < 304)
+    print "executorState: ", state
+    pass
+
+procEx.saveState("finishExec.xml")
+