Datastream handling adjustments

[modules/superv.git] / src / Supervision / StreamPort_Impl.cxx

diff --git a/src/Supervision/StreamPort_Impl.cxx b/src/Supervision/StreamPort_Impl.cxx
index 21fec367f26c0a5d77f904485d87b2640da2a3b5..3754ec430c7b5d032edc2b7cecf091fe7f6de59c 100644 (file)
--- a/src/Supervision/StreamPort_Impl.cxx
+++ b/src/Supervision/StreamPort_Impl.cxx
@@ -160,6 +160,7 @@ SUPERV::StreamLink_ptr StreamPort_Impl::StreamLink() {
              << iobject->InPort()->Node()->Name() << "( " << iobject->InPort()->Name() << " ) " ) ;
     endService( "StreamPort_Impl::StreamLink" ) ;
   }
+  DataFlowEditor()->UnValid() ;
   return SUPERV::StreamLink::_duplicate( iobject ) ;
 }
 
@@ -198,6 +199,7 @@ bool StreamPort_Impl::SetParams( const SUPERV::KindOfSchema aKindOfSchema ,
     MESSAGE( "OutStreamPort_Impl::SetParams( " << aKindOfSchema << " , " << aKindOfInterpolation
              << " , " << aKindOfExtrapolation << " ) ERROR : OutPort" ) ;
   }
+  DataFlowEditor()->UnValid() ;
 //  endService( "StreamPort_Impl::SetParams" );
   return RetVal ;
 }
@@ -235,6 +237,7 @@ bool StreamPort_Impl::SetNumberOfValues( const long aNumberOfValues ) {
   else {
     MESSAGE( "OutStreamPort_Impl::SetNumberOfValues( " << aNumberOfValues << " ) ERROR : InPort" ) ;
   }
+  DataFlowEditor()->UnValid() ;
 //  endService( "StreamPort_Impl::SetNumberOfValues" );
   return RetVal ;
 }