summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authordengg <dengg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2006-03-23 22:09:57 +0000
committerdengg <dengg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2006-03-23 22:09:57 +0000
commit284ef9953894c90f7feca5e8005f8910f327f991 (patch)
tree0507239ce8e2f34c6dca5332479a1b7c12fd0028
parenta576d4d2528b106287cd5fc7fec8a471d10c521a (diff)
downloadATCD-284ef9953894c90f7feca5e8005f8910f327f991.tar.gz
*** empty log message ***
-rw-r--r--TAO/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp18
1 files changed, 18 insertions, 0 deletions
diff --git a/TAO/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp b/TAO/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp
index abd299dac1a..3ecf25cf581 100644
--- a/TAO/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp
+++ b/TAO/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp
@@ -149,6 +149,12 @@ CIAO::NodeApplication_Impl::finishLaunch_i (
add_connection);
break;
+ case Deployment::rtecEventConsumer:
+ this->handle_es_consumer_connection (
+ connections[i],
+ add_connection);
+ break;
+
default:
ACE_DEBUG ((LM_DEBUG,
"CIAO (%P|%t) - NodeApplication_Impl.cpp, "
@@ -866,6 +872,12 @@ handle_publisher_es_connection (
// @@@
// comp->ciao_disconnect_es (connection.portName.in (),
// event_service);
+ ACE_DEBUG ((LM_DEBUG,
+ "CIAO (%P|%t) - NodeApplication_Impl.cpp, "
+ "CIAO::NodeApplication_Impl::handle_publisher_es_connection: "
+ "[%s : %s] publisher port disconnected from ciao event service. \n",
+ connection.instanceName.in (),
+ connection.portName.in ()));
event_service->disconnect_event_supplier (sid.c_str ());
}
}
@@ -935,6 +947,12 @@ handle_es_consumer_connection (
}
else // remove the connection
{
+ ACE_DEBUG ((LM_DEBUG,
+ "CIAO (%P|%t) - NodeApplication_Impl.cpp, "
+ "CIAO::NodeApplication_Impl::handle_es_consumer_connection: "
+ "[%s : %s] consumer port disconnected from ciao event service. \n",
+ connection.instanceName.in (),
+ connection.portName.in ()));
event_service->disconnect_event_consumer (cid.c_str ());
}
}