OpenDDS::DCPS::TypeSupportImpl Class Reference

#include <TypeSupportImpl.h>

Inheritance diagram for OpenDDS::DCPS::TypeSupportImpl:

Collaboration diagram for OpenDDS::DCPS::TypeSupportImpl:

Public Member Functions
	TypeSupportImpl ()
	TypeSupportImpl (DDS::DynamicType_ptr type)
virtual	~TypeSupportImpl ()
virtual const MetaStruct &	getMetaStructForType () const =0
virtual DDS::ReturnCode_t	register_type (DDS::DomainParticipant_ptr participant, const char *type_name)
virtual DDS::ReturnCode_t	unregister_type (DDS::DomainParticipant_ptr participant, const char *type_name)
virtual const char *	name () const =0
virtual char *	get_type_name ()
virtual DDS::DynamicType_ptr	get_type () const
DDS::DynamicType_ptr	get_type ()
virtual size_t	key_count () const =0
virtual bool	is_dcps_key (const char *fieldname) const =0
bool	has_dcps_key ()
virtual SerializedSizeBound	serialized_size_bound (const Encoding &encoding) const =0
virtual SerializedSizeBound	key_only_serialized_size_bound (const Encoding &encoding) const =0
virtual Extensibility	base_extensibility () const =0
	Returns the extensibility of just the topic type. More...
virtual Extensibility	max_extensibility () const =0
virtual const XTypes::TypeIdentifier &	getMinimalTypeIdentifier () const =0
virtual const XTypes::TypeMap &	getMinimalTypeMap () const =0
virtual const XTypes::TypeIdentifier &	getCompleteTypeIdentifier () const =0
virtual const XTypes::TypeMap &	getCompleteTypeMap () const =0
void	to_type_info (XTypes::TypeInformation &type_info) const
virtual const XTypes::TypeInformation *	preset_type_info () const
void	add_types (const XTypes::TypeLookupService_rch &tls) const
Public Member Functions inherited from OpenDDS::DCPS::TypeSupport
::DDS::DataWriter	create_datawriter ()
::DDS::DataReader	create_datareader ()
::DDS::DataReader	create_multitopic_datareader ()
::DDS::ReturnCode_t	unregister_type (in ::DDS::DomainParticipant domain, in string type_name)
void	representations_allowed_by_type (inout ::DDS::DataRepresentationIdSeq seq)
	Get allowed representations defined by IDL annotations. More...
Public Member Functions inherited from DDS::TypeSupport
ReturnCode_t	register_type (in DomainParticipant domain, in string type_name)
	OpenDDS::hidden_op_in_java ("return 0;") DynamicType get_type()
Public Member Functions inherited from OpenDDS::DCPS::LocalObjectBase
virtual void	_add_ref ()
virtual void	_remove_ref ()
virtual CORBA::ULong	_refcount_value () const
Public Member Functions inherited from CORBA::LocalObject
virtual	~LocalObject (void)
virtual CORBA::Boolean	_non_existent (void)
virtual char *	_repository_id (void)
virtual CORBA::InterfaceDef_ptr	_get_interface (void)
virtual CORBA::Object_ptr	_get_component (void)
virtual void	_create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::Request_ptr &request, CORBA::Flags req_flags)
virtual void	_create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::ExceptionList_ptr exclist, CORBA::ContextList_ptr ctxtlist, CORBA::Request_ptr &request, CORBA::Flags req_flags)
virtual CORBA::Request_ptr	_request (const char *operation)
CORBA::Policy_ptr	_get_policy (CORBA::PolicyType type)
CORBA::Policy_ptr	_get_cached_policy (TAO_Cached_Policy_Type type)
CORBA::Object_ptr	_set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)
CORBA::PolicyList *	_get_policy_overrides (const CORBA::PolicyTypeSeq &types)
CORBA::Boolean	_validate_connection (CORBA::PolicyList_out inconsistent_policies)
virtual CORBA::ULong	_hash (CORBA::ULong maximum)
virtual CORBA::Boolean	_is_equivalent (CORBA::Object_ptr other_obj)
virtual CORBA::ORB_ptr	_get_orb (void)
virtual TAO::ObjectKey *	_key (void)
Public Member Functions inherited from CORBA::Object
virtual	~Object (void)
virtual TAO_Abstract_ServantBase *	_servant (void) const
virtual CORBA::Boolean	_is_collocated (void) const
virtual CORBA::Boolean	_is_local (void) const
	Object (TAO_Stub *p, CORBA::Boolean collocated=false, TAO_Abstract_ServantBase *servant=0, TAO_ORB_Core *orb_core=0)
	Object (IOP::IOR *ior, TAO_ORB_Core *orb_core)
virtual TAO_Stub *	_stubobj (void) const
virtual TAO_Stub *	_stubobj (void)
virtual void	_proxy_broker (TAO::Object_Proxy_Broker *proxy_broker)
virtual CORBA::Boolean	marshal (TAO_OutputCDR &cdr)
CORBA::Boolean	is_evaluated (void) const
TAO_ORB_Core *	orb_core (void) const
IOP::IOR *	steal_ior (void)
const IOP::IOR &	ior (void) const
virtual bool	can_convert_to_ior (void) const
virtual char *	convert_to_ior (bool use_omg_ior_format, const char *ior_prefix) const
void	_decr_refcount (void)
virtual CORBA::Boolean	_is_a (const char *logical_type_id)
virtual const char *	_interface_repository_id (void) const
CORBA::Policy_ptr	_get_policy (CORBA::PolicyType type)
CORBA::Policy_ptr	_get_cached_policy (TAO_Cached_Policy_Type type)
CORBA::Object_ptr	_set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)
CORBA::PolicyList *	_get_policy_overrides (const CORBA::PolicyTypeSeq &types)
CORBA::Boolean	_validate_connection (CORBA::PolicyList_out inconsistent_policies)
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
long	ref_count () const
WeakObject *	_get_weak_object () const

Protected Member Functions
void	get_type_from_type_lookup_service ()
Protected Member Functions inherited from CORBA::LocalObject
	LocalObject (void)
Protected Member Functions inherited from CORBA::Object
	Object (int dummy=0)
TAO::Object_Proxy_Broker *	proxy_broker () const
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Protected Attributes
DDS::DynamicType_var	type_
Protected Attributes inherited from CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long >	refcount_

Private Member Functions
void	to_type_info_i (XTypes::TypeIdentifierWithDependencies &ti_with_deps, const XTypes::TypeIdentifier &ti, const XTypes::TypeMap &type_map) const
void	populate_dependencies_i (const XTypes::TypeLookupService_rch &tls, XTypes::EquivalenceKind ek) const

Private Attributes
XTypes::TypeLookupService_rch	type_lookup_service_

Static Private Attributes
static const ACE_CDR::Long	TYPE_INFO_DEPENDENT_COUNT_NOT_PROVIDED = -1

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::LocalObject< TypeSupport >
typedef TypeSupport ::_ptr_type	_ptr_type
typedef TypeSupport ::_var_type	_var_type
Public Types inherited from CORBA::LocalObject
typedef LocalObject_ptr	_ptr_type
typedef LocalObject_var	_var_type
typedef LocalObject_out	_out_type
Public Types inherited from CORBA::Object
typedef Object_ptr	_ptr_type
typedef Object_var	_var_type
typedef Object_out	_out_type
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< TypeSupport >
static _ptr_type	_narrow (CORBA::Object_ptr obj)
Static Public Member Functions inherited from CORBA::LocalObject
static LocalObject_ptr	_duplicate (LocalObject_ptr obj)
static LocalObject_ptr	_nil (void)
static LocalObject_ptr	_narrow (CORBA::Object_ptr obj)
Static Public Member Functions inherited from CORBA::Object
static CORBA::Boolean	marshal (const Object_ptr x, TAO_OutputCDR &cdr)
static void	_tao_any_destructor (void *)
static CORBA::Boolean	is_nil_i (CORBA::Object_ptr obj)
static void	tao_object_initialize (Object *)
static CORBA::Object_ptr	_duplicate (CORBA::Object_ptr obj)
static CORBA::Object_ptr	_nil (void)
static CORBA::Object_ptr	_narrow (CORBA::Object_ptr obj)

Detailed Description

Definition at line 70 of file TypeSupportImpl.h.

Constructor & Destructor Documentation

TypeSupportImpl() [1/2]

OpenDDS::DCPS::TypeSupportImpl::TypeSupportImpl ( )

inline

Definition at line 73 of file TypeSupportImpl.h.

{}

TypeSupportImpl() [2/2]

OpenDDS::DCPS::TypeSupportImpl::TypeSupportImpl ( DDS::DynamicType_ptr  type )

inlineexplicit

Definition at line 76 of file TypeSupportImpl.h.

References _duplicate(), and name.

  : type_(DDS::DynamicType::_duplicate(type))
  {
  }

~TypeSupportImpl()

OpenDDS::DCPS::TypeSupportImpl::~TypeSupportImpl ( )

virtual

Definition at line 21 of file TypeSupportImpl.cpp.

{}

Member Function Documentation

add_types()

void OpenDDS::DCPS::TypeSupportImpl::add_types

(

const XTypes::TypeLookupService_rch &

tls

)

const

Definition at line 116 of file TypeSupportImpl.cpp.

References OpenDDS::XTypes::EK_COMPLETE, OpenDDS::XTypes::EK_MINIMAL, OpenDDS::STUN::encoding(), OpenDDS::DCPS::Service_Participant::Encoding_Normal, OpenDDS::XTypes::get_typeobject_encoding(), getCompleteTypeMap(), getMinimalTypeMap(), OpenDDS::XTypes::makeTypeIdentifier(), populate_dependencies_i(), preset_type_info(), OpenDDS::DCPS::Encoding::skip_sequence_dheader(), and TheServiceParticipant.

Referenced by OpenDDS::DCPS::DataWriterImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), and get_type_from_type_lookup_service().

{
  using namespace XTypes;
  if (preset_type_info()) {
    // In the case where TypeInformation was pre-set, the participant's TypeLookupService
    // already has the types and dependencies based on responses to RPC requests.
    return;
  }
  const TypeMap& minTypeMap = getMinimalTypeMap();
  tls->add(minTypeMap.begin(), minTypeMap.end());
  const TypeMap& comTypeMap = getCompleteTypeMap();
  tls->add(comTypeMap.begin(), comTypeMap.end());

  if (TheServiceParticipant->type_object_encoding() != Service_Participant::Encoding_Normal) {
    // In this mode we need to be able to recognize TypeIdentifiers received over the network
    // by peers that may have encoded them incorrectly.  Populate the TypeLookupService with
    // additional entries that map the alternate (wrong) TypeIdentifiers to the same TypeObjects.
    Encoding encoding = get_typeobject_encoding();
    encoding.skip_sequence_dheader(true);
    TypeMap altMinMap;
    for (TypeMap::const_iterator iter = minTypeMap.begin(); iter != minTypeMap.end(); ++iter) {
      const TypeObject& minTypeObject = iter->second;
      const TypeIdentifier typeId = makeTypeIdentifier(minTypeObject, &encoding);
      altMinMap[typeId] = minTypeObject;
    }
    tls->add(altMinMap.begin(), altMinMap.end());

    TypeMap altComMap;
    for (TypeMap::const_iterator iter = comTypeMap.begin(); iter != comTypeMap.end(); ++iter) {
      const TypeObject& comTypeObject = iter->second;
      const TypeIdentifier typeId = makeTypeIdentifier(comTypeObject, &encoding);
      altComMap[typeId] = comTypeObject;
    }
    tls->add(altComMap.begin(), altComMap.end());
  }
  populate_dependencies_i(tls, XTypes::EK_MINIMAL);
  populate_dependencies_i(tls, XTypes::EK_COMPLETE);
}

base_extensibility()

virtual Extensibility OpenDDS::DCPS::TypeSupportImpl::base_extensibility ( ) const

pure virtual

Returns the extensibility of just the topic type.

Implemented in OpenDDS::DCPS::TypeSupportImpl_T< NativeType >, and DDS::DynamicTypeSupport.

Referenced by OpenDDS::DCPS::DataWriterImpl::serialize_sample().

get_type() [1/2]

virtual DDS::DynamicType_ptr OpenDDS::DCPS::TypeSupportImpl::get_type ( void  ) const

inlinevirtual

Definition at line 101 of file TypeSupportImpl.h.

Referenced by OpenDDS::DCPS::DataWriterImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), OpenDDS::DCPS::TypeSupportImpl_T< NativeType >::get_type(), OpenDDS::DCPS::MetaStructImpl< XTypes::DynamicSample >::getValue(), and OpenDDS::XTypes::DynamicDataReaderImpl::install_type_support().

  {
    return DDS::DynamicType::_duplicate(type_);
  }

get_type() [2/2]

DDS::DynamicType_ptr OpenDDS::DCPS::TypeSupportImpl::get_type ( void  )

inline

Definition at line 107 of file TypeSupportImpl.h.

References OpenDDS::XTypes::key_count().

  {
    return DDS::DynamicType::_duplicate(type_);
  }

get_type_from_type_lookup_service()

void OpenDDS::DCPS::TypeSupportImpl::get_type_from_type_lookup_service ( )

protected

Definition at line 187 of file TypeSupportImpl.cpp.

References add_types(), getCompleteTypeIdentifier(), getCompleteTypeMap(), getMinimalTypeIdentifier(), getMinimalTypeMap(), OpenDDS::DCPS::GUID_UNKNOWN, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::XTypes::DynamicTypeImpl::set_complete_type_identifier(), OpenDDS::XTypes::DynamicTypeImpl::set_complete_type_map(), OpenDDS::XTypes::DynamicTypeImpl::set_minimal_type_identifier(), OpenDDS::XTypes::DynamicTypeImpl::set_minimal_type_map(), type_, and type_lookup_service_.

{
  if (!type_) {
    if (!type_lookup_service_) {
      type_lookup_service_ = make_rch<XTypes::TypeLookupService>();
      add_types(type_lookup_service_);
    }

    const XTypes::TypeIdentifier& cti = getCompleteTypeIdentifier();
    const XTypes::TypeMap& ctm = getCompleteTypeMap();
    const XTypes::TypeIdentifier& mti = getMinimalTypeIdentifier();
    const XTypes::TypeMap& mtm = getMinimalTypeMap();
    XTypes::DynamicTypeImpl* dt = dynamic_cast<XTypes::DynamicTypeImpl*>(
      type_lookup_service_->type_identifier_to_dynamic(cti, GUID_UNKNOWN));
    if (dt) {
      dt->set_complete_type_identifier(cti);
      dt->set_complete_type_map(ctm);
      dt->set_minimal_type_identifier(mti);
      dt->set_minimal_type_map(mtm);
    }
    type_ = dt;
  }
}

get_type_name()

char * OpenDDS::DCPS::TypeSupportImpl::get_type_name ( )

virtual

NOTE: This one implements the IDL TypeSupport method so it returns a CORBA String that the caller must take ownership of.

Implements DDS::TypeSupport.

Definition at line 45 of file TypeSupportImpl.cpp.

References TAO::String_var< charT >::_retn(), ACE_ERROR, OpenDDS::XTypes::EK_COMPLETE, OpenDDS::XTypes::EK_MINIMAL, OpenDDS::XTypes::equivalence_hash_to_string(), OpenDDS::DCPS::LogLevel::Error, OpenDDS::XTypes::TypeIdentifier::kind(), LM_ERROR, OpenDDS::DCPS::log_level, and name().

{
  CORBA::String_var type = name();
  return type._retn();
}

getCompleteTypeIdentifier()

virtual const XTypes::TypeIdentifier& OpenDDS::DCPS::TypeSupportImpl::getCompleteTypeIdentifier ( ) const

pure virtual

Implemented in DDS::DynamicTypeSupport.

Referenced by get_type_from_type_lookup_service(), populate_dependencies_i(), and to_type_info().

getCompleteTypeMap()

virtual const XTypes::TypeMap& OpenDDS::DCPS::TypeSupportImpl::getCompleteTypeMap ( ) const

pure virtual

Implemented in DDS::DynamicTypeSupport.

Referenced by add_types(), get_type_from_type_lookup_service(), populate_dependencies_i(), and to_type_info().

getMetaStructForType()

virtual const MetaStruct& OpenDDS::DCPS::TypeSupportImpl::getMetaStructForType ( ) const

pure virtual

Implemented in DDS::DynamicTypeSupport.

Referenced by OpenDDS::DCPS::MultiTopicDataReaderBase::metaStructFor().

getMinimalTypeIdentifier()

virtual const XTypes::TypeIdentifier& OpenDDS::DCPS::TypeSupportImpl::getMinimalTypeIdentifier ( ) const

pure virtual

Implemented in DDS::DynamicTypeSupport.

Referenced by get_type_from_type_lookup_service(), populate_dependencies_i(), and to_type_info().

getMinimalTypeMap()

virtual const XTypes::TypeMap& OpenDDS::DCPS::TypeSupportImpl::getMinimalTypeMap ( ) const

pure virtual

Implemented in DDS::DynamicTypeSupport.

Referenced by add_types(), get_type_from_type_lookup_service(), populate_dependencies_i(), and to_type_info().

has_dcps_key()

bool OpenDDS::DCPS::TypeSupportImpl::has_dcps_key ( )

inline

Implements OpenDDS::DCPS::TypeSupport.

Definition at line 116 of file TypeSupportImpl.h.

References OpenDDS::STUN::encoding(), OpenDDS::DCPS::getCompleteTypeIdentifier(), OpenDDS::DCPS::getCompleteTypeMap(), OpenDDS::DCPS::getMinimalTypeIdentifier(), OpenDDS::DCPS::getMinimalTypeMap(), OpenDDS::XTypes::key_count(), and OpenDDS::XTypes::max_extensibility().

  {
    return key_count();
  }

is_dcps_key()

virtual bool OpenDDS::DCPS::TypeSupportImpl::is_dcps_key ( const char *  fieldname ) const

pure virtual

Implemented in OpenDDS::DCPS::TypeSupportImpl_T< NativeType >, and DDS::DynamicTypeSupport.

Referenced by OpenDDS::DCPS::FilterEvaluator::has_non_key_fields().

key_count()

virtual size_t OpenDDS::DCPS::TypeSupportImpl::key_count ( ) const

pure virtual

Implemented in OpenDDS::DCPS::TypeSupportImpl_T< NativeType >, and DDS::DynamicTypeSupport.

key_only_serialized_size_bound()

virtual SerializedSizeBound OpenDDS::DCPS::TypeSupportImpl::key_only_serialized_size_bound ( const Encoding &  encoding ) const

pure virtual

Implemented in OpenDDS::DCPS::TypeSupportImpl_T< NativeType >, and DDS::DynamicTypeSupport.

max_extensibility()

virtual Extensibility OpenDDS::DCPS::TypeSupportImpl::max_extensibility ( ) const

pure virtual

Between the topic type and its nested types, return the extensibility that is furthest right in (final, appenable, mutable).

Implemented in OpenDDS::DCPS::TypeSupportImpl_T< NativeType >, and DDS::DynamicTypeSupport.

Referenced by OpenDDS::DCPS::DataWriterImpl::setup_serialization().

name()

virtual const char* OpenDDS::DCPS::TypeSupportImpl::name ( ) const

pure virtual

Implemented in OpenDDS::DCPS::TypeSupportImpl_T< NativeType >, and DDS::DynamicTypeSupport.

Referenced by OpenDDS::DCPS::DataWriterImpl::get_or_create_instance_handle(), get_type_name(), populate_dependencies_i(), register_type(), OpenDDS::DCPS::DataWriterImpl::setup_serialization(), and to_type_info_i().

populate_dependencies_i()

void OpenDDS::DCPS::TypeSupportImpl::populate_dependencies_i ( const XTypes::TypeLookupService_rch &  tls, XTypes::EquivalenceKind  ek  ) const

private

Definition at line 155 of file TypeSupportImpl.cpp.

References OpenDDS::XTypes::Sequence< T >::append(), OpenDDS::XTypes::compute_dependencies(), OpenDDS::XTypes::EK_COMPLETE, OpenDDS::XTypes::EK_MINIMAL, OpenDDS::XTypes::get_typeobject_encoding(), getCompleteTypeIdentifier(), getCompleteTypeMap(), getMinimalTypeIdentifier(), getMinimalTypeMap(), OpenDDS::XTypes::has_type_object(), name(), OpenDDS::DCPS::OPENDDS_SET(), and OpenDDS::DCPS::serialized_size().

Referenced by add_types().

{
  if (ek != XTypes::EK_MINIMAL && ek != XTypes::EK_COMPLETE) {
    return;
  }

  OPENDDS_SET(XTypes::TypeIdentifier) dependencies;
  const XTypes::TypeIdentifier& type_id = ek == XTypes::EK_MINIMAL ?
    getMinimalTypeIdentifier() : getCompleteTypeIdentifier();
  const XTypes::TypeMap& type_map = ek == XTypes::EK_MINIMAL ?
    getMinimalTypeMap() : getCompleteTypeMap();

  XTypes::compute_dependencies(type_map, type_id, dependencies);

  XTypes::TypeIdentifierWithSizeSeq deps_with_size;
  OPENDDS_SET(XTypes::TypeIdentifier)::const_iterator it = dependencies.begin();
  for (; it != dependencies.end(); ++it) {
    XTypes::TypeMap::const_iterator iter = type_map.find(*it);
    if (iter != type_map.end()) {
      const size_t tobj_size = serialized_size(XTypes::get_typeobject_encoding(), iter->second);
      XTypes::TypeIdentifierWithSize ti_with_size(*it, static_cast<ACE_CDR::ULong>(tobj_size));
      deps_with_size.append(ti_with_size);
    } else if (XTypes::has_type_object(*it)) {
      log_ti_not_found("populate_dependencies_i", name(), *it);
    }
  }
  tls->add_type_dependencies(type_id, deps_with_size);
}

preset_type_info()

virtual const XTypes::TypeInformation* OpenDDS::DCPS::TypeSupportImpl::preset_type_info ( ) const

inlinevirtual

Reimplemented in DDS::DynamicTypeSupport.

Definition at line 136 of file TypeSupportImpl.h.

Referenced by add_types(), and to_type_info().

  {
    return 0;
  }

register_type()

DDS::ReturnCode_t OpenDDS::DCPS::TypeSupportImpl::register_type ( DDS::DomainParticipant_ptr  participant, const char *  type_name  )

virtual

Definition at line 25 of file TypeSupportImpl.cpp.

References name(), and Registered_Data_Types.

{
  const char* const type =
    (!type_name || !type_name[0]) ? name() : type_name;
  return Registered_Data_Types->register_type(participant, type, this);
}

serialized_size_bound()

virtual SerializedSizeBound OpenDDS::DCPS::TypeSupportImpl::serialized_size_bound ( const Encoding &  encoding ) const

pure virtual

Implemented in OpenDDS::DCPS::TypeSupportImpl_T< NativeType >, and DDS::DynamicTypeSupport.

to_type_info()

void OpenDDS::DCPS::TypeSupportImpl::to_type_info

(

XTypes::TypeInformation &

type_info

)

const

Definition at line 97 of file TypeSupportImpl.cpp.

References OpenDDS::XTypes::TypeInformation::complete, getCompleteTypeIdentifier(), getCompleteTypeMap(), getMinimalTypeIdentifier(), getMinimalTypeMap(), OpenDDS::XTypes::TypeIdentifier::kind(), OpenDDS::XTypes::TypeInformation::minimal, preset_type_info(), OpenDDS::XTypes::TK_NONE, and to_type_info_i().

Referenced by OpenDDS::DCPS::DataWriterImpl::enable(), and OpenDDS::DCPS::DataReaderImpl::enable().

{
  const XTypes::TypeInformation* const preset = preset_type_info();
  if (preset) {
    type_info = *preset;
    return;
  }

  to_type_info_i(type_info.minimal, getMinimalTypeIdentifier(), getMinimalTypeMap());

  // Properly populate the complete member if complete TypeObjects are generated.
  const XTypes::TypeIdentifier& complete_ti = getCompleteTypeIdentifier();
  if (complete_ti.kind() != XTypes::TK_NONE) {
    to_type_info_i(type_info.complete, complete_ti, getCompleteTypeMap());
  } else {
    type_info.complete = XTypes::TypeIdentifierWithDependencies();
  }
}

to_type_info_i()

void OpenDDS::DCPS::TypeSupportImpl::to_type_info_i ( XTypes::TypeIdentifierWithDependencies &  ti_with_deps, const XTypes::TypeIdentifier &  ti, const XTypes::TypeMap &  type_map  ) const

private

Definition at line 70 of file TypeSupportImpl.cpp.

References OpenDDS::XTypes::TypeIdentifierWithDependencies::dependent_typeid_count, OpenDDS::STUN::encoding(), OpenDDS::DCPS::Service_Participant::Encoding_WriteOldFormat, OpenDDS::XTypes::get_typeobject_encoding(), OpenDDS::XTypes::makeTypeIdentifier(), name(), OpenDDS::DCPS::serialized_size(), OpenDDS::DCPS::Encoding::skip_sequence_dheader(), TheServiceParticipant, OpenDDS::XTypes::TypeIdentifierWithSize::type_id, TYPE_INFO_DEPENDENT_COUNT_NOT_PROVIDED, OpenDDS::XTypes::TypeIdentifierWithDependencies::typeid_with_size, and OpenDDS::XTypes::TypeIdentifierWithSize::typeobject_serialized_size.

Referenced by to_type_info().

{
  const XTypes::TypeMap::const_iterator pos = type_map.find(ti);

  if (pos == type_map.end()) {
    log_ti_not_found("to_type_info_i", name(), ti);
    ti_with_deps.typeid_with_size.type_id = XTypes::TypeIdentifier();
    ti_with_deps.typeid_with_size.typeobject_serialized_size = 0;
  } else if (TheServiceParticipant->type_object_encoding() == Service_Participant::Encoding_WriteOldFormat) {
    Encoding encoding = XTypes::get_typeobject_encoding();
    encoding.skip_sequence_dheader(true);
    const XTypes::TypeObject& to = pos->second;
    ti_with_deps.typeid_with_size.type_id = makeTypeIdentifier(to, &encoding);
    const size_t sz = serialized_size(encoding, to);
    ti_with_deps.typeid_with_size.typeobject_serialized_size = static_cast<unsigned>(sz);
  } else {
    ti_with_deps.typeid_with_size.type_id = ti;
    const XTypes::TypeObject& to = pos->second;
    const size_t sz = serialized_size(XTypes::get_typeobject_encoding(), to);
    ti_with_deps.typeid_with_size.typeobject_serialized_size = static_cast<unsigned>(sz);
  }

  ti_with_deps.dependent_typeid_count = TYPE_INFO_DEPENDENT_COUNT_NOT_PROVIDED;
}

unregister_type()

DDS::ReturnCode_t OpenDDS::DCPS::TypeSupportImpl::unregister_type ( DDS::DomainParticipant_ptr  participant, const char *  type_name  )

virtual

Definition at line 34 of file TypeSupportImpl.cpp.

References Registered_Data_Types, and DDS::RETCODE_BAD_PARAMETER.

{
  if (type_name == 0 || type_name[0] == '\0') {
    return DDS::RETCODE_BAD_PARAMETER;
  } else {
    return Registered_Data_Types->unregister_type(participant, type_name, this);
  }
}

Member Data Documentation

type_

DDS::DynamicType_var OpenDDS::DCPS::TypeSupportImpl::type_

protected

Definition at line 147 of file TypeSupportImpl.h.

Referenced by get_type_from_type_lookup_service().

TYPE_INFO_DEPENDENT_COUNT_NOT_PROVIDED

const ACE_CDR::Long OpenDDS::DCPS::TypeSupportImpl::TYPE_INFO_DEPENDENT_COUNT_NOT_PROVIDED = -1

staticprivate

Definition at line 151 of file TypeSupportImpl.h.

Referenced by to_type_info_i().

type_lookup_service_

XTypes::TypeLookupService_rch OpenDDS::DCPS::TypeSupportImpl::type_lookup_service_

private

Definition at line 161 of file TypeSupportImpl.h.

Referenced by get_type_from_type_lookup_service().

---

The documentation for this class was generated from the following files:

• TypeSupportImpl.h
• TypeSupportImpl.cpp