Superv/Python/GraphStreamsXmlTest.py

   1 from SuperV import *
   2
   3 FlowGraph = Graph( 'FlowGraph' )
   4 Add = FlowGraph.FNode( 'AddComponent' , 'AddComponent' , 'Add' )
   5
   6 Sub = FlowGraph.FNode( 'SubComponent' , 'SubComponent' , 'Sub' )
   7 Addz = Add.GetOutStreamPort( 'z' )
   8 if Addz != None :
   9     print "Error : GetOutStreamPort of a FlowPort in a FlowGraph"
  10 else :
  11     print 'None : Ok'
  12
  13 Addz = Add.Port( 'z' )
  14 try :
  15     Suby = FlowGraph.StreamLink( Addz , Sub.Port( 'y' ) )
  16     print "Error : creation of a StreamLink in a FlowGraph"
  17 except :
  18     print "Ok"
  19
  20 links = FlowGraph.StreamLinks()
  21 if len(links) != 0 :
  22     print "Error : StreamLinks in a FlowGraph"
  23
  24 ports = FlowGraph.StreamPorts()
  25 if len( ports ) != 0 :
  26     print "Error : StreamPorts in a FlowGraph"
  27
  28 links = Add.StreamLinks()
  29 if len(links) != 0 :
  30     print "Error : StreamLinks in a FlowNode"
  31
  32 ports = Add.StreamPorts()
  33 if len( ports ) != 0 :
  34     print "Error : StreamPorts in a FlowNode"
  35
  36 try :
  37     FlowGraph.SetStreamParams( 100 , SUPERV.WithoutTrace , 10. )
  38 except :
  39     print "No SetStreamParams Ok"
  40
  41 try :
  42     Timeout,DataStreamTrace,DeltaTime = FlowGraph.StreamParams()
  43 except :
  44     print "No StreamParams Ok"
  45
  46
  47
  48
  49 from SuperV import *
  50 GraphStreams = StreamGraph( '/home/Salome2/SUPERV_DataStream/SUPERV_SRC/examples/GraphStreams.xml')
  51
  52 GraphStreams.PrintPorts()
  53 GraphStreams.PrintLinks()
  54
  55 exec GraphStreams.ListNodes()
  56 Add.PrintPorts()
  57 Add.PrintLinks()
  58
  59 exec Loop.ListPorts()
  60 ILoopIndex.Print()
  61 OLoopIndex.Print()
  62 exec EndLoop.ListPorts()
  63 IEndLoopGate.Print()
  64 OEndLoopx_Sub.Print()
  65 exec Add.ListPorts()
  66 IAddx.Print()
  67 IAddistream.Print()
  68 OAddOStream.Print()
  69 exec Sub.ListPorts()
  70 exec Mul.ListPorts()
  71 exec Div.ListPorts()
  72 exec Add_1.ListPorts()
  73 exec Sub_1.ListPorts()
  74 exec Mul_1.ListPorts()
  75 exec Div_1.ListPorts()
  76 exec  Add.ListLinks()
  77 LLoopIndexAddx.Print()
  78 LAddzMuly.Print()
  79 LDiv_1ostreamAddistream.Print()
  80 LAddOStreamSubIstream.Print()
  81
  82
  83 GraphStreams.IsExecutable()
  84
  85 GraphStreams.Run()
  86 GraphStreams.DoneW()
  87 GraphStreams.PrintPorts()
  88
  89
  90
  91 subgraphs = GraphStreams.SubGraphsNumber()
  92 i = 1
  93 while i <= subgraphs :
  94     nodes = GraphStreams.SubGraphsNodes( i )
  95     j = 0
  96     while j < len(nodes) :
  97         print 'SubGraph',i,nodes[j].Name()
  98         j = j + 1
  99     i = i + 1
 100
 101
 102 substreamgraphs = GraphStreams.SubStreamGraphsNumber()
 103 i = 1
 104 while i <= substreamgraphs :
 105     nodes = GraphStreams.SubStreamGraphsNodes( i )
 106     j = 0
 107     while j < len(nodes) :
 108         print 'SubStreamGraph',i,nodes[j].Name()
 109         j = j + 1
 110     i = i + 1
 111