*** empty log message ***

[modules/superv.git] / src / GraphExecutor / DataFlowExecutor_InNodeThreads.cxx

diff --git a/src/GraphExecutor/DataFlowExecutor_InNodeThreads.cxx b/src/GraphExecutor/DataFlowExecutor_InNodeThreads.cxx
index ff45c77aece1a4a65bb20c8a1a518846529e0167..7f7094b23e7e7c31e48b486af3f81b68d97305fe 100644 (file)
--- a/src/GraphExecutor/DataFlowExecutor_InNodeThreads.cxx
+++ b/src/GraphExecutor/DataFlowExecutor_InNodeThreads.cxx
@@ -46,6 +46,8 @@ using namespace std;
 
 #include "DataFlowExecutor_OutNode.hxx"
 
+#include "Graph_Impl.hxx"
+
 //static char *containerName = "FactoryServer" ;
 
 int GraphExecutor::InNode::SendEvent( const GraphExecutor::NodeEvent anEvent ) {  
@@ -1071,6 +1073,11 @@ int GraphExecutor::InNode::DataReady_ExecuteAction() {
     }
   }
   else if ( CORBA::is_nil( Component() ) ) {
+    ostringstream astr ;
+    astr << "Graph " << _OutNode->Name() << " Node " << Name()
+         << " : load of component " << ComponentName() << " in container "
+         << Computer() ;
+    _OutNode->ObjImpl()->sendMessage( NOTIF_STEP, astr.str().c_str() ) ;
     Err = !_OutNode->StartComponent( ThreadNo() , Computer() ,
                                      my_strdup( ComponentName() ) ,
                                      myContainer , myObjComponent ) ;
@@ -1098,6 +1105,9 @@ int GraphExecutor::InNode::DataReady_ExecuteAction() {
     }
     else {
       if ( !Err ) {
+        ostringstream astr ;
+        astr << "Graph " << _OutNode->Name() << " Run of Node " << Name() ;
+        _OutNode->ObjImpl()->sendMessage( NOTIF_STEP, astr.str().c_str() ) ;
         cdebug << ThreadNo() << " Run( '" << ServiceName() << "'" ;
         for ( i = 0 ; i < (int ) ServiceInParameter().length() ; i++ ) {
           cdebug << " , " << InParametersList[ i ].Name << "[kind"
@@ -1385,6 +1395,10 @@ int GraphExecutor::InNode::DataReady_ExecuteAction() {
 //    sleep( 1 ) ;
 //  }
 
+  ostringstream astr ;
+  astr << "Graph " << _OutNode->Name() << " Node " << Name() << " is done : "
+       << Automaton()->StateName( State() ) ;
+  _OutNode->ObjImpl()->sendMessage( NOTIF_STEP, astr.str().c_str() ) ;
   if ( Err ) {
     if ( ControlState() == SUPERV::ToKillState ||
          ControlState() == SUPERV::ToKillDoneState ||