examples/GraphStream.py

   1
   2 # Generated python file of Graph GraphStream
   3
   4 from SuperV import *
   5 # Graph creation
   6 GraphStream = StreamGraph( 'GraphStream' )
   7 GraphStream.SetStreamParams( 0 , SUPERV.WithoutTrace , 0 )
   8 GraphStream.SetName( 'GraphStream' )
   9 GraphStream.SetAuthor( '' )
  10 GraphStream.SetComment( 'Test of DataStreamPorts in FactoryNodes' )
  11 GraphStream.Coords( 0 , 0 )
  12
  13 # Creation of Factory Nodes
  14
  15 NewDataStream = GraphStream.FNode( 'DataStreamFactory' , 'DataStreamFactory' , 'NewDataStream' )
  16 NewDataStream.SetName( 'NewDataStream' )
  17 NewDataStream.SetAuthor( '' )
  18 NewDataStream.SetContainer( 'FactoryServer' )
  19 NewDataStream.SetComment( 'NewDataStream from DataStreamFactory' )
  20 NewDataStream.Coords( 198 , 0 )
  21 INewDataStreamGate = NewDataStream.GetInPort( 'Gate' )
  22 ONewDataStreamDataStream = NewDataStream.GetOutPort( 'DataStream' )
  23 ONewDataStreamGate = NewDataStream.GetOutPort( 'Gate' )
  24
  25 Add = GraphStream.FNode( 'DataStreamFactory' , 'DataStreamFactory' , 'Add' )
  26 Add.SetName( 'Add' )
  27 Add.SetAuthor( '' )
  28 Add.SetContainer( 'FactoryServer' )
  29 Add.SetComment( 'Add from DataStreamFactory from DataStreamComponent' )
  30 Add.Coords( 7 , 269 )
  31 IAddx = Add.GetInPort( 'x' )
  32 IAddy = Add.GetInPort( 'y' )
  33 IAddGate = Add.GetInPort( 'Gate' )
  34 OAddz = Add.GetOutPort( 'z' )
  35 OAddGate = Add.GetOutPort( 'Gate' )
  36 IAddistream = Add.GetInStreamPort( 'istream' )
  37 IAddistream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
  38 OAddostream = Add.GetOutStreamPort( 'ostream' )
  39 OAddostream.SetNumberOfValues( 0 )
  40 OAddOStream = Add.GetOutStreamPort( 'OStream' )
  41 OAddOStream.SetNumberOfValues( 0 )
  42
  43 Sub = GraphStream.FNode( 'DataStreamFactory' , 'DataStreamFactory' , 'Sub' )
  44 Sub.SetName( 'Sub' )
  45 Sub.SetAuthor( '' )
  46 Sub.SetContainer( 'FactoryServer' )
  47 Sub.SetComment( 'Sub from DataStreamFactory from DataStreamComponent' )
  48 Sub.Coords( 245 , 142 )
  49 ISubx = Sub.GetInPort( 'x' )
  50 ISuby = Sub.GetInPort( 'y' )
  51 ISubGate = Sub.GetInPort( 'Gate' )
  52 OSubz = Sub.GetOutPort( 'z' )
  53 OSubGate = Sub.GetOutPort( 'Gate' )
  54 ISubistream = Sub.GetInStreamPort( 'istream' )
  55 ISubistream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
  56 ISubIstream = Sub.GetInStreamPort( 'Istream' )
  57 ISubIstream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
  58
  59 Mul = GraphStream.FNode( 'DataStreamFactory' , 'DataStreamFactory' , 'Mul' )
  60 Mul.SetName( 'Mul' )
  61 Mul.SetAuthor( '' )
  62 Mul.SetContainer( 'FactoryServer' )
  63 Mul.SetComment( 'Mul from DataStreamFactory from DataStreamComponent' )
  64 Mul.Coords( 465 , 240 )
  65 IMulx = Mul.GetInPort( 'x' )
  66 IMuly = Mul.GetInPort( 'y' )
  67 IMulGate = Mul.GetInPort( 'Gate' )
  68 OMulz = Mul.GetOutPort( 'z' )
  69 OMulGate = Mul.GetOutPort( 'Gate' )
  70
  71 Div = GraphStream.FNode( 'DataStreamFactory' , 'DataStreamFactory' , 'Div' )
  72 Div.SetName( 'Div' )
  73 Div.SetAuthor( '' )
  74 Div.SetContainer( 'FactoryServer' )
  75 Div.SetComment( 'Div from DataStreamFactory from DataStreamComponent' )
  76 Div.Coords( 660 , 142 )
  77 IDivx = Div.GetInPort( 'x' )
  78 IDivy = Div.GetInPort( 'y' )
  79 IDivGate = Div.GetInPort( 'Gate' )
  80 ODivz = Div.GetOutPort( 'z' )
  81 ODivGate = Div.GetOutPort( 'Gate' )
  82 ODivostream = Div.GetOutStreamPort( 'ostream' )
  83 ODivostream.SetNumberOfValues( 0 )
  84
  85 # Creation of Computing Nodes
  86 StreamAdd_ServiceinParameter = []
  87 StreamAdd_ServiceinParameter.append( SALOME_ModuleCatalog.ServicesParameter( 'objref' , 'this' ) )
  88 StreamAdd_ServiceinParameter.append( SALOME_ModuleCatalog.ServicesParameter( 'long' , 'x' ) )
  89 StreamAdd_ServiceinParameter.append( SALOME_ModuleCatalog.ServicesParameter( 'long' , 'y' ) )
  90 StreamAdd_ServiceoutParameter = []
  91 StreamAdd_ServiceoutParameter.append( SALOME_ModuleCatalog.ServicesParameter( 'long' , 'z' ) )
  92 StreamAdd_ServiceinStreamParameter = []
  93 StreamAdd_ServiceinStreamParameter.append( SALOME_ModuleCatalog.ServicesDataStreamParameter( SALOME_ModuleCatalog.DATASTREAM_INTEGER , 'istream' , SALOME_ModuleCatalog.DATASTREAM_ITERATIVE ) )
  94 StreamAdd_ServiceoutStreamParameter = []
  95 StreamAdd_ServiceoutStreamParameter.append( SALOME_ModuleCatalog.ServicesDataStreamParameter( SALOME_ModuleCatalog.DATASTREAM_INTEGER , 'ostream' , SALOME_ModuleCatalog.DATASTREAM_ITERATIVE ) )
  96 StreamAdd_ServiceoutStreamParameter.append( SALOME_ModuleCatalog.ServicesDataStreamParameter( SALOME_ModuleCatalog.DATASTREAM_INTEGER , 'OStream' , SALOME_ModuleCatalog.DATASTREAM_ITERATIVE ) )
  97 StreamAdd_Service = SALOME_ModuleCatalog.Service( 'StreamAdd' , StreamAdd_ServiceinParameter , StreamAdd_ServiceoutParameter , StreamAdd_ServiceinStreamParameter , StreamAdd_ServiceoutStreamParameter , 0 , 0 )
  98 StreamAdd = GraphStream.CNode( StreamAdd_Service )
  99 StreamAdd.SetName( 'StreamAdd' )
 100 StreamAdd.SetAuthor( '' )
 101 StreamAdd.SetComment( 'Compute Node' )
 102 StreamAdd.Coords( 8 , 0 )
 103 IStreamAddthis = StreamAdd.GetInPort( 'this' )
 104 IStreamAddx = StreamAdd.GetInPort( 'x' )
 105 IStreamAddy = StreamAdd.GetInPort( 'y' )
 106 IStreamAddGate = StreamAdd.GetInPort( 'Gate' )
 107 OStreamAddz = StreamAdd.GetOutPort( 'z' )
 108 OStreamAddGate = StreamAdd.GetOutPort( 'Gate' )
 109 IStreamAddistream = StreamAdd.GetInStreamPort( 'istream' )
 110 IStreamAddistream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
 111 OStreamAddostream = StreamAdd.GetOutStreamPort( 'ostream' )
 112 OStreamAddostream.SetNumberOfValues( 0 )
 113 OStreamAddOStream = StreamAdd.GetOutStreamPort( 'OStream' )
 114 OStreamAddOStream.SetNumberOfValues( 0 )
 115
 116 # Creation of Links
 117 LNewDataStreamDataStreamStreamAddthis = GraphStream.Link( ONewDataStreamDataStream , IStreamAddthis )
 118
 119 LAddzSuby = GraphStream.Link( OAddz , ISuby )
 120 LAddzSuby.AddCoord( 1 , 208 , 252 )
 121 LAddzSuby.AddCoord( 2 , 207 , 349 )
 122
 123 LAddzMuly = GraphStream.Link( OAddz , IMuly )
 124
 125 LAddostreamSubistream = GraphStream.StreamLink( OAddostream , ISubistream )
 126 LAddostreamSubistream.AddCoord( 1 , 201 , 237 )
 127 LAddostreamSubistream.AddCoord( 2 , 200 , 378 )
 128
 129 LAddOStreamSubIstream = GraphStream.StreamLink( OAddOStream , ISubIstream )
 130 LAddOStreamSubIstream.AddCoord( 1 , 212 , 267 )
 131 LAddOStreamSubIstream.AddCoord( 2 , 211 , 409 )
 132
 133 LSubzMulx = GraphStream.Link( OSubz , IMulx )
 134 LSubzMulx.AddCoord( 1 , 436 , 320 )
 135 LSubzMulx.AddCoord( 2 , 435 , 223 )
 136
 137 LSubzDivx = GraphStream.Link( OSubz , IDivx )
 138
 139 LMulzDivy = GraphStream.Link( OMulz , IDivy )
 140 LMulzDivy.AddCoord( 1 , 645 , 252 )
 141 LMulzDivy.AddCoord( 2 , 644 , 320 )
 142 LMulzDivy.AddCoord( 3 , 623 , 320 )
 143
 144 # Input datas
 145 IAddx.Input( 3 )
 146 IAddy.Input( 7 )
 147 ISubx.Input( 1 )
 148 IStreamAddx.Input( 1 )
 149 IStreamAddy.Input( 2 )
 150 IAddistream.Input( 1 )
 151
 152 # Output Ports of the graph
 153 #ODivz = Div.GetOutPort( 'z' )
 154 #OStreamAddz = StreamAdd.GetOutPort( 'z' )
 155 GraphStream.PrintPorts()
 156 GraphStream.IsValid()
 157 status = GraphStream.IsExecutable()
 158 if status == 0 :
 159     print 'Input of port IStreamAddistream is required : Ok'
 160 else :
 161     print 'Input of port IStreamAddistream is required : ERROR'
 162 # Following input is required :
 163 IStreamAddistream.Input( 1 )
 164 GraphStream.IsExecutable()
 165
 166 GraphStream.Run()
 167 GraphStream.DoneW()
 168 GraphStream.PrintPorts()
 169 GraphStream.State()
 170
 171 subgraphs = GraphStream.SubGraphsNumber()
 172 i = 1
 173 while i <= subgraphs :
 174     nodes = GraphStream.SubGraphsNodes( i )
 175     j = 0
 176     while j < len(nodes) :
 177         print 'SubGraph',i,nodes[j].Name()
 178         j = j + 1
 179     i = i + 1
 180
 181
 182 substreamgraphs = GraphStream.SubStreamGraphsNumber()
 183 i = 1
 184 while i <= substreamgraphs :
 185     nodes = GraphStream.SubStreamGraphsNodes( i )
 186     j = 0
 187     while j < len(nodes) :
 188         print 'SubStreamGraph',i,nodes[j].Name()
 189         j = j + 1
 190     i = i + 1
 191
 192 GraphStream.Export('/tmp/GraphStream.xml')
 193
 194 GraphStream = StreamGraph( '/tmp/GraphStream.xml' )
 195 GraphStream.Run()
 196 GraphStream.DoneW()
 197 GraphStream.PrintPorts()
 198 print GraphStream.State()
 199
 200 subgraphs = GraphStream.SubGraphsNumber()
 201 i = 1
 202 while i <= subgraphs :
 203     nodes = GraphStream.SubGraphsNodes( i )
 204     j = 0
 205     while j < len(nodes) :
 206         print 'SubGraph',i,nodes[j].Name()
 207         j = j + 1
 208     i = i + 1
 209
 210
 211 substreamgraphs = GraphStream.SubStreamGraphsNumber()
 212 i = 1
 213 while i <= substreamgraphs :
 214     nodes = GraphStream.SubStreamGraphsNodes( i )
 215     j = 0
 216     while j < len(nodes) :
 217         print 'SubStreamGraph',i,nodes[j].Name()
 218         j = j + 1
 219     i = i + 1
 220