#include "DataFlowBase_Service.hxx"
-#include "DataFlowBase_InPort.hxx"
-#include "DataFlowBase_OutPort.hxx"
+#include "DataFlowBase_InDataStreamPort.hxx"
+#include "DataFlowBase_OutDataStreamPort.hxx"
namespace GraphBase {
int _NodeOutPortsSize ;
vector<OutPort *> _NodeOutPorts;
+ int _DataStreamInPortsNumber ;
+ int _DataStreamOutPortsNumber ;
+
public:
PortsOfNode() ;
const SALOME_ModuleCatalog::Service& NodeService ,
const char *const * NodeName ,
const SUPERV::KindOfNode aKind ,
-// const bool DataFlowOrComputing ,
-// const bool WithGateArg ,
-// const bool WithInGate ,
-// const bool WithOutGate ,
int * Graph_prof_debug ,
ofstream * Graph_fdebug ) ;
const SUPERV::KindOfNode aKind ,
const char * InputParameterName ,
const char * InputParameterType ,
+ SUPERV::KindOfPort aKindOfPort ,
+// const int DataStreamInPortsNumber ,
int * Graph_prof_debug ,
ofstream * Graph_fdebug ) ;
OutPort * AddOutPort( CORBA::ORB_ptr ORB ,
const SUPERV::KindOfNode aKind ,
const char * OutputParameterName ,
const char * InputParameterType ,
+ SUPERV::KindOfPort aKindOfPort ,
+// const int DataStreamOutPortsNumber ,
int * Graph_prof_debug ,
ofstream * Graph_fdebug ) ;
-// void InOutPort( InPort * InputPort , OutPort * OutputPort ) ;
void DelInPort( const char * InputParameterName ) ;
void DelOutPort( const char * OutputParameterName ) ;
+ int IncrDataStreamInPorts() {
+ _DataStreamInPortsNumber++ ;
+ return _DataStreamInPortsNumber ;
+ } ;
+ int DecrDataStreamInPorts() {
+ _DataStreamInPortsNumber-- ;
+ return _DataStreamInPortsNumber ;
+ } ;
+ int IncrDataStreamOutPorts() {
+ _DataStreamOutPortsNumber++ ;
+ return _DataStreamOutPortsNumber ;
+ } ;
+ int DecrDataStreamOutPorts() {
+ _DataStreamOutPortsNumber-- ;
+ return _DataStreamOutPortsNumber ;
+ } ;
+ int DataStreamInPortsNumber() {
+ return _DataStreamInPortsNumber ;
+ } ;
+ int DataStreamOutPortsNumber() {
+ return _DataStreamOutPortsNumber ;
+ } ;
+ void DataStreamInPortsNumber( int aDataStreamInPortsNumber ) {
+ _DataStreamInPortsNumber = aDataStreamInPortsNumber ;
+ } ;
+ void DataStreamOutPortsNumber(int aDataStreamOutPortsNumber ) {
+ _DataStreamOutPortsNumber = aDataStreamOutPortsNumber ;
+ } ;
+ int HasDataStream() const {
+ return _DataStreamInPortsNumber + _DataStreamOutPortsNumber ;
+ } ;
+
const int GetNodeInPortsSize() const { return _NodeInPortsSize ; } ;
const InPort * GetNodeInLoop() const {
return _NodeInPorts[0] ; } ;
InPort * GetChangeInPort( const char *name ) ;
OutPort * GetChangeOutPort( const char *name ) ;
-// void ListPorts( ostream & , const bool klink = true ) const ;
void ListPorts( ostream & , const bool klink = true ) const ;
};