from SuperV import *
# Graph creation
GraphStream = StreamGraph( 'GraphStream' )
+GraphStream.SetStreamParams( 0 , SUPERV.WithoutTrace , 0 )
GraphStream.SetName( 'GraphStream' )
GraphStream.SetAuthor( '' )
-GraphStream.SetComment( 'Test of DataStreamPorts in FactoryNodes and ComputingNode' )
+GraphStream.SetComment( 'Test of DataStreamPorts in FactoryNodes' )
GraphStream.Coords( 0 , 0 )
# Creation of Factory Nodes
NewDataStream.SetName( 'NewDataStream' )
NewDataStream.SetAuthor( '' )
NewDataStream.SetContainer( 'FactoryServer' )
-NewDataStream.SetComment( '' )
-NewDataStream.Coords( 0 , 0 )
+NewDataStream.SetComment( 'NewDataStream from DataStreamFactory' )
+NewDataStream.Coords( 198 , 0 )
INewDataStreamGate = NewDataStream.GetInPort( 'Gate' )
ONewDataStreamDataStream = NewDataStream.GetOutPort( 'DataStream' )
ONewDataStreamGate = NewDataStream.GetOutPort( 'Gate' )
Add.SetAuthor( '' )
Add.SetContainer( 'FactoryServer' )
Add.SetComment( 'Add from DataStreamFactory from DataStreamComponent' )
-Add.Coords( 15 , 241 )
+Add.Coords( 7 , 269 )
IAddx = Add.GetInPort( 'x' )
IAddy = Add.GetInPort( 'y' )
IAddGate = Add.GetInPort( 'Gate' )
OAddz = Add.GetOutPort( 'z' )
OAddGate = Add.GetOutPort( 'Gate' )
IAddistream = Add.GetInStreamPort( 'istream' )
+IAddistream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
OAddostream = Add.GetOutStreamPort( 'ostream' )
+OAddostream.SetNumberOfValues( 0 )
OAddOStream = Add.GetOutStreamPort( 'OStream' )
+OAddOStream.SetNumberOfValues( 0 )
Sub = GraphStream.FNode( 'DataStreamFactory' , 'DataStreamFactory' , 'Sub' )
Sub.SetName( 'Sub' )
Sub.SetAuthor( '' )
Sub.SetContainer( 'FactoryServer' )
Sub.SetComment( 'Sub from DataStreamFactory from DataStreamComponent' )
-Sub.Coords( 227 , 99 )
+Sub.Coords( 245 , 142 )
ISubx = Sub.GetInPort( 'x' )
ISuby = Sub.GetInPort( 'y' )
ISubGate = Sub.GetInPort( 'Gate' )
OSubz = Sub.GetOutPort( 'z' )
OSubGate = Sub.GetOutPort( 'Gate' )
ISubistream = Sub.GetInStreamPort( 'istream' )
+ISubistream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
ISubIstream = Sub.GetInStreamPort( 'Istream' )
+ISubIstream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
Mul = GraphStream.FNode( 'DataStreamFactory' , 'DataStreamFactory' , 'Mul' )
Mul.SetName( 'Mul' )
Mul.SetAuthor( '' )
Mul.SetContainer( 'FactoryServer' )
Mul.SetComment( 'Mul from DataStreamFactory from DataStreamComponent' )
-Mul.Coords( 444 , 241 )
+Mul.Coords( 465 , 240 )
IMulx = Mul.GetInPort( 'x' )
IMuly = Mul.GetInPort( 'y' )
IMulGate = Mul.GetInPort( 'Gate' )
Div.SetAuthor( '' )
Div.SetContainer( 'FactoryServer' )
Div.SetComment( 'Div from DataStreamFactory from DataStreamComponent' )
-Div.Coords( 634 , 98 )
+Div.Coords( 660 , 142 )
IDivx = Div.GetInPort( 'x' )
IDivy = Div.GetInPort( 'y' )
IDivGate = Div.GetInPort( 'Gate' )
ODivz = Div.GetOutPort( 'z' )
ODivGate = Div.GetOutPort( 'Gate' )
ODivostream = Div.GetOutStreamPort( 'ostream' )
+ODivostream.SetNumberOfValues( 0 )
# Creation of Computing Nodes
StreamAdd_ServiceinParameter = []
StreamAdd = GraphStream.CNode( StreamAdd_Service )
StreamAdd.SetName( 'StreamAdd' )
StreamAdd.SetAuthor( '' )
-StreamAdd.SetComment( '' )
-StreamAdd.Coords( 0 , 0 )
+StreamAdd.SetComment( 'Compute Node' )
+StreamAdd.Coords( 8 , 0 )
IStreamAddthis = StreamAdd.GetInPort( 'this' )
IStreamAddx = StreamAdd.GetInPort( 'x' )
IStreamAddy = StreamAdd.GetInPort( 'y' )
OStreamAddz = StreamAdd.GetOutPort( 'z' )
OStreamAddGate = StreamAdd.GetOutPort( 'Gate' )
IStreamAddistream = StreamAdd.GetInStreamPort( 'istream' )
+IStreamAddistream.SetParams( SUPERV.SCHENULL , SUPERV.INTERNULL , SUPERV.EXTRANULL )
OStreamAddostream = StreamAdd.GetOutStreamPort( 'ostream' )
+OStreamAddostream.SetNumberOfValues( 0 )
OStreamAddOStream = StreamAdd.GetOutStreamPort( 'OStream' )
+OStreamAddOStream.SetNumberOfValues( 0 )
# Creation of Links
LNewDataStreamDataStreamStreamAddthis = GraphStream.Link( ONewDataStreamDataStream , IStreamAddthis )
LAddzSuby = GraphStream.Link( OAddz , ISuby )
-LAddzSuby.AddCoord( 1 , 189 , 207 )
-LAddzSuby.AddCoord( 2 , 189 , 350 )
+LAddzSuby.AddCoord( 1 , 208 , 252 )
+LAddzSuby.AddCoord( 2 , 207 , 349 )
LAddzMuly = GraphStream.Link( OAddz , IMuly )
-LAddostreamSubistream = GraphStream.Link( OAddostream , ISubistream )
+LAddostreamSubistream = GraphStream.StreamLink( OAddostream , ISubistream )
LAddostreamSubistream.AddCoord( 1 , 201 , 237 )
LAddostreamSubistream.AddCoord( 2 , 200 , 378 )
-LAddOStreamSubIstream = GraphStream.Link( OAddOStream , ISubIstream )
+LAddOStreamSubIstream = GraphStream.StreamLink( OAddOStream , ISubIstream )
LAddOStreamSubIstream.AddCoord( 1 , 212 , 267 )
LAddOStreamSubIstream.AddCoord( 2 , 211 , 409 )
LSubzMulx = GraphStream.Link( OSubz , IMulx )
-LSubzMulx.AddCoord( 1 , 420 , 322 )
-LSubzMulx.AddCoord( 2 , 419 , 180 )
+LSubzMulx.AddCoord( 1 , 436 , 320 )
+LSubzMulx.AddCoord( 2 , 435 , 223 )
LSubzDivx = GraphStream.Link( OSubz , IDivx )
LMulzDivy = GraphStream.Link( OMulz , IDivy )
-LMulzDivy.AddCoord( 1 , 622 , 207 )
-LMulzDivy.AddCoord( 2 , 623 , 320 )
+LMulzDivy.AddCoord( 1 , 645 , 252 )
+LMulzDivy.AddCoord( 2 , 644 , 320 )
+LMulzDivy.AddCoord( 3 , 623 , 320 )
# Input datas
IAddx.Input( 3 )
# Output Ports of the graph
#ODivz = Div.GetOutPort( 'z' )
#OStreamAddz = StreamAdd.GetOutPort( 'z' )
-
GraphStream.PrintPorts()
GraphStream.IsValid()
status = GraphStream.IsExecutable()
GraphStream.PrintPorts()
GraphStream.State()
+subgraphs = GraphStream.SubGraphsNumber()
+i = 1
+while i <= subgraphs :
+ nodes = GraphStream.SubGraphsNodes( i )
+ j = 0
+ while j < len(nodes) :
+ print 'SubGraph',i,nodes[j].Name()
+ j = j + 1
+ i = i + 1
+
+
+substreamgraphs = GraphStream.SubStreamGraphsNumber()
+i = 1
+while i <= substreamgraphs :
+ nodes = GraphStream.SubStreamGraphsNodes( i )
+ j = 0
+ while j < len(nodes) :
+ print 'SubStreamGraph',i,nodes[j].Name()
+ j = j + 1
+ i = i + 1
+
GraphStream.Export('/tmp/GraphStream.xml')
GraphStream = StreamGraph( '/tmp/GraphStream.xml' )
GraphStream.Run()
GraphStream.DoneW()
GraphStream.PrintPorts()
-GraphStream.State()
+print GraphStream.State()
+
+subgraphs = GraphStream.SubGraphsNumber()
+i = 1
+while i <= subgraphs :
+ nodes = GraphStream.SubGraphsNodes( i )
+ j = 0
+ while j < len(nodes) :
+ print 'SubGraph',i,nodes[j].Name()
+ j = j + 1
+ i = i + 1
+
+
+substreamgraphs = GraphStream.SubStreamGraphsNumber()
+i = 1
+while i <= substreamgraphs :
+ nodes = GraphStream.SubStreamGraphsNodes( i )
+ j = 0
+ while j < len(nodes) :
+ print 'SubStreamGraph',i,nodes[j].Name()
+ j = j + 1
+ i = i + 1
+