src/yacsloader_swig/Test/testFEDyn.py

   1 import pilot
   2 import SALOMERuntime
   3 import loader
   4
   5 SALOMERuntime.RuntimeSALOME.setRuntime()
   6 r=SALOMERuntime.getSALOMERuntime()
   7 p=r.createProc("prTest1")
   8 td=p.createType("double","double")
   9 ti=p.createType("int","int")
  10 cont=p.createContainer("gg","HPSalome")
  11 ti=p.createType("int","int")
  12 tsi=p.createSequenceTc("seqint","seqint",ti)
  13 # Level0
  14 n0=r.createScriptNode("","n0")
  15 o0=n0.edAddOutputPort("o0",tsi)
  16 n0.setScript("o0=[ elt for elt in range(6) ]")
  17 p.edAddChild(n0)
  18 n1=r.createForEachLoopDyn("n1",ti)
  19 n1.setWeight(3)
  20 n10=r.createScriptNode("","n10")
  21 n10.setExecutionMode("remote")
  22 n10.setContainer(cont)
  23 n1.edAddChild(n10)
  24 n10.setScript("""
  25 import time
  26 time.sleep(2)
  27 o2=2*i1
  28 """)
  29 n10.setWeight(4.)
  30 i1=n10.edAddInputPort("i1",ti)
  31 o2=n10.edAddOutputPort("o2",ti)
  32 p.edAddChild(n1)
  33 p.edAddLink(o0,n1.edGetSeqOfSamplesPort())
  34 p.edAddLink(n1.edGetSamplePort(),i1)
  35 p.edAddCFLink(n0,n1)
  36 n2=r.createScriptNode("","n2")
  37 n2.setScript("o4=i3")
  38 i3=n2.edAddInputPort("i3",tsi)
  39 o4=n2.edAddOutputPort("o4",tsi)
  40 n2.setScript("o4=i3")
  41 p.edAddChild(n2)
  42 p.edAddCFLink(n1,n2)
  43 p.edAddLink(o2,i3)