diff options
Diffstat (limited to 'CIAO/ciao/Servant_Impl_Utils_T.cpp')
| -rw-r--r-- | CIAO/ciao/Servant_Impl_Utils_T.cpp | 165 |
1 files changed, 0 insertions, 165 deletions
diff --git a/CIAO/ciao/Servant_Impl_Utils_T.cpp b/CIAO/ciao/Servant_Impl_Utils_T.cpp deleted file mode 100644 index 7738d2a7208..00000000000 --- a/CIAO/ciao/Servant_Impl_Utils_T.cpp +++ /dev/null @@ -1,165 +0,0 @@ -// $Id$ - -#ifndef CIAO_SERVANT_IMPL_UTILS_T_C -#define CIAO_SERVANT_IMPL_UTILS_T_C - -#include "Servant_Impl_Base.h" -#include "ciao/Cookies.h" - -namespace CIAO -{ - template<typename T_var> - void - Servant_Impl_Base::describe_simplex_receptacle ( - const char *port_name, - const char *port_type_repo_id, - T_var &connection, - ::Components::ReceptacleDescriptions_var &descriptions, - CORBA::ULong slot) - { - ::Components::ReceptacleDescription *elem = 0; - ACE_NEW (elem, - ::OBV_Components::ReceptacleDescription); - ::Components::ReceptacleDescription_var safe_elem = elem; - - elem->name (port_name); - elem->type_id (port_type_repo_id); - elem->is_multiple (false); - elem->connections ().length (1UL); - - ::Components::ConnectionDescription *conn = 0; - ACE_NEW (conn, ::OBV_Components::ConnectionDescription); - ::Components::ConnectionDescription_var safe_conn = conn; - - conn->ck (0); - conn->objref (connection.in ()); - - elem->connections ()[0UL] = safe_conn._retn (); - descriptions[slot] = safe_elem._retn (); - } - - template<typename T_var> - void - Servant_Impl_Base::describe_multiplex_receptacle ( - const char *port_name, - const char *port_type_repo_id, - ACE_Array_Map<ptrdiff_t, T_var> &objrefs, - ::Components::ReceptacleDescriptions_var &descriptions, - CORBA::ULong slot - ) - { - ::Components::ReceptacleDescription *elem = 0; - ACE_NEW (elem, - ::OBV_Components::ReceptacleDescription); - ::Components::ReceptacleDescription_var safe_elem = elem; - - elem->name (port_name); - elem->type_id (port_type_repo_id); - elem->is_multiple (true); - elem->connections ().length (objrefs.size ()); - - CORBA::ULong seq_slot = 0UL; - ::Components::ConnectionDescription *conn = 0; - - typedef typename ACE_Array_Map<ptrdiff_t, T_var>::const_iterator - CONST_ITERATOR; - - for (CONST_ITERATOR iter = objrefs.begin (); - iter != objrefs.end (); - ++iter, ++seq_slot) - { - ACE_NEW (conn, - ::OBV_Components::ConnectionDescription); - ::Components::ConnectionDescription_var safe_conn = conn; - - ::Components::Cookie *key_cookie = 0; - ACE_NEW (key_cookie, - CIAO::Cookie_Impl (iter->first)); - - // Valuetype member set operation calls add_ref. - conn->ck (key_cookie); - CORBA::remove_ref (key_cookie); - - conn->objref (iter->second.in ()); - - elem->connections ()[seq_slot] = safe_conn._retn (); - } - - descriptions[slot] = safe_elem._retn (); - } - - template<typename T_var> - void - Servant_Impl_Base::describe_pub_event_source ( - const char *port_name, - const char *port_type_repo_id, - ACE_Array_Map<ptrdiff_t, T_var> &consumers, - ::Components::PublisherDescriptions_var &descriptions, - CORBA::ULong slot - ) - { - ::Components::PublisherDescription *elem = 0; - ACE_NEW (elem, - ::OBV_Components::PublisherDescription); - ::Components::PublisherDescription_var safe_elem = elem; - - elem->name (port_name); - elem->type_id (port_type_repo_id); - elem->consumer ().length (consumers.size ()); - - ptrdiff_t map_slot = 0UL; - ::Components::SubscriberDescription *sub = 0; - - typedef typename ACE_Array_Map<ptrdiff_t, T_var>::const_iterator - CONST_ITERATOR; - - for (CONST_ITERATOR iter = consumers.begin (); - iter != consumers.end (); - ++iter, ++map_slot) - { - ACE_NEW (sub, - ::OBV_Components::SubscriberDescription); - ::Components::SubscriberDescription_var safe_sub = sub; - - ::Components::Cookie *key_cookie = 0; - ACE_NEW (key_cookie, - CIAO::Cookie_Impl (iter->first)); - - // Valuetype member set operation calls add_ref. - sub->ck (key_cookie); - CORBA::remove_ref (key_cookie); - - sub->consumer (iter->second.in ()); - - elem->consumer ()[map_slot] = safe_sub._retn (); - } - - descriptions[slot] = safe_elem._retn (); - } - - template<typename T_var> - void - Servant_Impl_Base::describe_emit_event_source ( - const char *port_name, - const char *port_type_repo_id, - T_var &consumer_ref, - ::Components::EmitterDescriptions_var &descriptions, - CORBA::ULong slot - ) - { - ::Components::EmitterDescription *elem = 0; - ACE_NEW (elem, - ::OBV_Components::EmitterDescription); - ::Components::EmitterDescription_var safe_elem = elem; - - elem->name (port_name); - elem->type_id (port_type_repo_id); - - // Valuetype 'set' call increments the reference count. - elem->consumer (consumer_ref.in ()); - - descriptions[slot] = safe_elem._retn (); - } -} - -#endif /* CIAO_SERVANT_IMPL_T_C */ |