diff options
author | dengg <dengg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2006-03-23 22:09:57 +0000 |
---|---|---|
committer | dengg <dengg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2006-03-23 22:09:57 +0000 |
commit | 284ef9953894c90f7feca5e8005f8910f327f991 (patch) | |
tree | 0507239ce8e2f34c6dca5332479a1b7c12fd0028 | |
parent | a576d4d2528b106287cd5fc7fec8a471d10c521a (diff) | |
download | ATCD-284ef9953894c90f7feca5e8005f8910f327f991.tar.gz |
*** empty log message ***
-rw-r--r-- | TAO/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp | 18 |
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 ()); } } |