OpenDDS::XTypes::DynamicDataBase Class Reference

#include <DynamicDataBase.h>

Inheritance diagram for OpenDDS::XTypes::DynamicDataBase:

Collaboration diagram for OpenDDS::XTypes::DynamicDataBase:

Public Member Functions
	DynamicDataBase ()
	DynamicDataBase (DDS::DynamicType_ptr type)
DDS::ReturnCode_t	get_descriptor (DDS::MemberDescriptor *&value, MemberId id)
DDS::MemberId	get_member_id_by_name (const char *name)
virtual DDS::ReturnCode_t	get_simple_value (DCPS::Value &value, DDS::MemberId id)=0
Public Member Functions inherited from DDS::DynamicData
DDS::ReturnCode_t	get_descriptor (inout MemberDescriptor value, in MemberId id)
DDS::ReturnCode_t	set_descriptor (in MemberId id, in MemberDescriptor value)
boolean	equals (in DynamicData other)
MemberId	get_member_id_by_name (in ObjectName name)
MemberId	get_member_id_at_index (in unsigned long index)
unsigned long	get_item_count ()
DDS::ReturnCode_t	clear_all_values ()
DDS::ReturnCode_t	clear_nonkey_values ()
DDS::ReturnCode_t	clear_value (in MemberId id)
DynamicData	loan_value (in MemberId id)
DDS::ReturnCode_t	return_loaned_value (in DynamicData value)
DynamicData	clone ()
DDS::ReturnCode_t	get_int32_value (inout long value, in MemberId id)
DDS::ReturnCode_t	set_int32_value (in MemberId id, in long value)
DDS::ReturnCode_t	get_uint32_value (inout unsigned long value, in MemberId id)
DDS::ReturnCode_t	set_uint32_value (in MemberId id, in unsigned long value)
DDS::ReturnCode_t	get_int8_value (inout int8 value, in MemberId id)
DDS::ReturnCode_t	set_int8_value (in MemberId id, in int8 value)
DDS::ReturnCode_t	get_uint8_value (inout uint8 value, in MemberId id)
DDS::ReturnCode_t	set_uint8_value (in MemberId id, in uint8 value)
DDS::ReturnCode_t	get_int16_value (inout short value, in MemberId id)
DDS::ReturnCode_t	set_int16_value (in MemberId id, in short value)
DDS::ReturnCode_t	get_uint16_value (inout unsigned short value, in MemberId id)
DDS::ReturnCode_t	set_uint16_value (in MemberId id, in unsigned short value)
DDS::ReturnCode_t	get_int64_value (inout long long value, in MemberId id)
DDS::ReturnCode_t	set_int64_value (in MemberId id, in long long value)
DDS::ReturnCode_t	get_uint64_value (inout unsigned long long value, in MemberId id)
DDS::ReturnCode_t	set_uint64_value (in MemberId id, in unsigned long long value)
DDS::ReturnCode_t	get_float32_value (inout float value, in MemberId id)
DDS::ReturnCode_t	set_float32_value (in MemberId id, in float value)
DDS::ReturnCode_t	get_float64_value (inout double value, in MemberId id)
DDS::ReturnCode_t	set_float64_value (in MemberId id, in double value)
DDS::ReturnCode_t	get_float128_value (inout long double value, in MemberId id)
DDS::ReturnCode_t	set_float128_value (in MemberId id, in long double value)
DDS::ReturnCode_t	get_char8_value (inout char value, in MemberId id)
DDS::ReturnCode_t	set_char8_value (in MemberId id, in char value)
DDS::ReturnCode_t	get_char16_value (inout wchar value, in MemberId id)
DDS::ReturnCode_t	set_char16_value (in MemberId id, in wchar value)
DDS::ReturnCode_t	get_byte_value (inout octet value, in MemberId id)
DDS::ReturnCode_t	set_byte_value (in MemberId id, in octet value)
DDS::ReturnCode_t	get_boolean_value (inout boolean value, in MemberId id)
DDS::ReturnCode_t	set_boolean_value (in MemberId id, in boolean value)
DDS::ReturnCode_t	get_string_value (inout string value, in MemberId id)
DDS::ReturnCode_t	set_string_value (in MemberId id, in string value)
DDS::ReturnCode_t	get_wstring_value (inout wstring value, in MemberId id)
DDS::ReturnCode_t	set_wstring_value (in MemberId id, in wstring value)
DDS::ReturnCode_t	get_complex_value (inout DynamicData value, in MemberId id)
DDS::ReturnCode_t	set_complex_value (in MemberId id, in DynamicData value)
DDS::ReturnCode_t	get_int32_values (inout Int32Seq value, in MemberId id)
DDS::ReturnCode_t	set_int32_values (in MemberId id, in Int32Seq value)
DDS::ReturnCode_t	get_uint32_values (inout UInt32Seq value, in MemberId id)
DDS::ReturnCode_t	set_uint32_values (in MemberId id, in UInt32Seq value)
DDS::ReturnCode_t	get_int8_values (inout Int8Seq value, in MemberId id)
DDS::ReturnCode_t	set_int8_values (in MemberId id, in Int8Seq value)
DDS::ReturnCode_t	get_uint8_values (inout UInt8Seq value, in MemberId id)
DDS::ReturnCode_t	set_uint8_values (in MemberId id, in UInt8Seq value)
DDS::ReturnCode_t	get_int16_values (inout Int16Seq value, in MemberId id)
DDS::ReturnCode_t	set_int16_values (in MemberId id, in Int16Seq value)
DDS::ReturnCode_t	get_uint16_values (inout UInt16Seq value, in MemberId id)
DDS::ReturnCode_t	set_uint16_values (in MemberId id, in UInt16Seq value)
DDS::ReturnCode_t	get_int64_values (inout Int64Seq value, in MemberId id)
DDS::ReturnCode_t	set_int64_values (in MemberId id, in Int64Seq value)
DDS::ReturnCode_t	get_uint64_values (inout UInt64Seq value, in MemberId id)
DDS::ReturnCode_t	set_uint64_values (in MemberId id, in UInt64Seq value)
DDS::ReturnCode_t	get_float32_values (inout Float32Seq value, in MemberId id)
DDS::ReturnCode_t	set_float32_values (in MemberId id, in Float32Seq value)
DDS::ReturnCode_t	get_float64_values (inout Float64Seq value, in MemberId id)
DDS::ReturnCode_t	set_float64_values (in MemberId id, in Float64Seq value)
DDS::ReturnCode_t	get_float128_values (inout Float128Seq value, in MemberId id)
DDS::ReturnCode_t	set_float128_values (in MemberId id, in Float128Seq value)
DDS::ReturnCode_t	get_char8_values (inout CharSeq value, in MemberId id)
DDS::ReturnCode_t	set_char8_values (in MemberId id, in CharSeq value)
DDS::ReturnCode_t	get_char16_values (inout WcharSeq value, in MemberId id)
DDS::ReturnCode_t	set_char16_values (in MemberId id, in WcharSeq value)
DDS::ReturnCode_t	get_byte_values (inout ByteSeq value, in MemberId id)
DDS::ReturnCode_t	set_byte_values (in MemberId id, in ByteSeq value)
DDS::ReturnCode_t	get_boolean_values (inout BooleanSeq value, in MemberId id)
DDS::ReturnCode_t	set_boolean_values (in MemberId id, in BooleanSeq value)
DDS::ReturnCode_t	get_string_values (inout StringSeq value, in MemberId id)
DDS::ReturnCode_t	set_string_values (in MemberId id, in StringSeq value)
DDS::ReturnCode_t	get_wstring_values (inout WstringSeq value, in MemberId id)
DDS::ReturnCode_t	set_wstring_values (in MemberId id, in WstringSeq value)
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

Static Public Member Functions
static bool	has_explicit_keys (DDS::DynamicType *dt)
static bool	exclude_member (DCPS::Sample::Extent ext, bool is_key, bool has_explicit_keys)
static DCPS::Sample::Extent	nested (DCPS::Sample::Extent ext)
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::DynamicData >
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)

Protected Member Functions
bool	is_type_supported (TypeKind tk, const char *func_name)
bool	is_primitive (TypeKind tk) const
bool	is_basic (TypeKind tk) const
bool	is_complex (TypeKind tk) const
bool	get_index_from_id (DDS::MemberId id, ACE_CDR::ULong &index, ACE_CDR::ULong bound) const
bool	enum_string_helper (char *&strInOut, MemberId id)
DDS::ReturnCode_t	check_member (DDS::MemberDescriptor_var &md, DDS::DynamicType_var &type, const char *method, const char *what, DDS::MemberId id, DDS::TypeKind tk)
DDS::DynamicData *	interface_from_this () const
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 ()

Static Protected Member Functions
static CORBA::ULong	bound_total (DDS::TypeDescriptor_var descriptor)
static DDS::MemberId	get_union_default_member (DDS::DynamicType *type)
static bool	discriminator_selects_no_member (DDS::DynamicType *type, ACE_CDR::Long disc)

Protected Attributes
DDS::DynamicType_var	type_
	The actual (i.e., non-alias) DynamicType of the associated type. More...
Protected Attributes inherited from CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long >	refcount_

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::DynamicData >
typedef DDS::DynamicData ::_ptr_type	_ptr_type
typedef DDS::DynamicData ::_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
Public Attributes inherited from DDS::DynamicData
readonly attribute DynamicType	type

Detailed Description

Definition at line 26 of file DynamicDataBase.h.

Constructor & Destructor Documentation

DynamicDataBase() [1/2]

OpenDDS::XTypes::DynamicDataBase::DynamicDataBase

(

)

Definition at line 17 of file DynamicDataBase.cpp.

{}

DynamicDataBase() [2/2]

OpenDDS::XTypes::DynamicDataBase::DynamicDataBase

(

DDS::DynamicType_ptr

type

)

Definition at line 19 of file DynamicDataBase.cpp.

  : type_(get_base_type(type))
{}

Member Function Documentation

bound_total()

CORBA::ULong OpenDDS::XTypes::DynamicDataBase::bound_total ( DDS::TypeDescriptor_var  descriptor )

staticprotected

Definition at line 251 of file DynamicDataBase.cpp.

Referenced by OpenDDS::XTypes::DynamicDataImpl::clear_value(), OpenDDS::XTypes::DynamicDataImpl::get_complex_from_collection(), OpenDDS::XTypes::DynamicDataImpl::get_item_count(), OpenDDS::XTypes::DynamicDataImpl::get_member_id_at_index(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_collection(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_array(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_array(), and OpenDDS::XTypes::DynamicDataImpl::set_values_to_array().

{
  CORBA::ULong total = 1;
  const DDS::BoundSeq& bounds = descriptor->bound();
  for (CORBA::ULong i = 0; i < bounds.length(); ++i) {
    total *= bounds[i];
  }
  return total;
}

check_member()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataBase::check_member ( DDS::MemberDescriptor_var &  md, DDS::DynamicType_var &  type, const char *  method, const char *  what, DDS::MemberId  id, DDS::TypeKind  tk  )

protected

Definition at line 202 of file DynamicDataBase.cpp.

References ACE_ERROR, OpenDDS::XTypes::bitmask_bound(), OpenDDS::XTypes::enum_bound(), OpenDDS::XTypes::get_base_type(), get_descriptor(), TAO::String_var< charT >::in(), is_basic(), LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_OK, OpenDDS::XTypes::TK_BITMASK, OpenDDS::XTypes::TK_ENUM, type_, and OpenDDS::XTypes::typekind_to_string().

Referenced by OpenDDS::XTypes::DynamicDataImpl::get_value_from_struct(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_union(), and OpenDDS::XTypes::DynamicDataImpl::set_value_to_struct().

{
  DDS::ReturnCode_t rc = get_descriptor(md, id);
  if (rc != DDS::RETCODE_OK) {
    return rc;
  }
  type = get_base_type(md->type());
  if (!type) {
    return DDS::RETCODE_BAD_PARAMETER;
  }

  const TypeKind type_kind = type->get_kind();
  TypeKind cmp_type_kind = type_kind;
  switch (type_kind) {
  case TK_ENUM:
    rc = enum_bound(type, cmp_type_kind);
    if (rc != DDS::RETCODE_OK) {
      return rc;
    }
    break;
  case TK_BITMASK:
    rc = bitmask_bound(type, cmp_type_kind);
    if (rc != DDS::RETCODE_OK) {
      return rc;
    }
    break;
  }

  bool invalid_tk = true;
  if (is_basic(cmp_type_kind)) {
    invalid_tk = cmp_type_kind != tk;
  }
  if (invalid_tk) {
    if (DCPS::log_level >= DCPS::LogLevel::Notice) {
      const CORBA::String_var member_name = md->name();
      const CORBA::String_var type_name = type_->get_name();
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: %C: "
        "trying to %C %C.%C id %u kind %C (%C) as an invalid kind %C\n",
        method, what, type_name.in(), member_name.in(), id,
        typekind_to_string(cmp_type_kind), typekind_to_string(type_kind),
        typekind_to_string(tk)));
    }
    return DDS::RETCODE_BAD_PARAMETER;
  }
  return DDS::RETCODE_OK;
}

discriminator_selects_no_member()

bool OpenDDS::XTypes::DynamicDataBase::discriminator_selects_no_member ( DDS::DynamicType *  type, ACE_CDR::Long  disc  )

staticprotected

Definition at line 299 of file DynamicDataBase.cpp.

References OpenDDS::XTypes::DISCRIMINATOR_ID, DDS::DynamicType::get_member_by_index(), DDS::DynamicType::get_member_count(), OpenDDS::XTypes::Sequence< T >::length(), and DDS::RETCODE_OK.

Referenced by OpenDDS::XTypes::DynamicDataImpl::set_complex_to_union(), and OpenDDS::XTypes::DynamicDataImpl::set_value_to_union().

{
  const ACE_CDR::ULong members = type->get_member_count();
  for (ACE_CDR::ULong i = 0; i < members; ++i) {
    DDS::DynamicTypeMember_var member;
    if (type->get_member_by_index(member, i) != DDS::RETCODE_OK) {
      return false;
    }
    if (member->get_id() == DISCRIMINATOR_ID) {
      continue;
    }
    DDS::MemberDescriptor_var mdesc;
    if (member->get_descriptor(mdesc) != DDS::RETCODE_OK) {
      return false;
    }
    if (mdesc->is_default_label()) {
      return false;
    }
    const DDS::UnionCaseLabelSeq& lseq = mdesc->label();
    for (ACE_CDR::ULong lbl = 0; lbl < lseq.length(); ++lbl) {
      if (lseq[lbl] == disc) {
        return false;
      }
    }
  }
  return true;
}

enum_string_helper()

bool OpenDDS::XTypes::DynamicDataBase::enum_string_helper ( char *&  strInOut, MemberId  id  )

protected

Definition at line 180 of file DynamicDataBase.cpp.

References OpenDDS::XTypes::get_enum_value(), OpenDDS::XTypes::get_enumerator_name(), OpenDDS::XTypes::get_member_type(), DDS::RETCODE_OK, CORBA::string_free(), OpenDDS::XTypes::TK_ENUM, and type_.

Referenced by OpenDDS::XTypes::DynamicDataImpl::get_string_value(), and OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_string_value().

{
  DDS::DynamicType_var mtype;
  DDS::ReturnCode_t rc = get_member_type(mtype, type_, id);
  if (rc != DDS::RETCODE_OK || mtype->get_kind() != TK_ENUM) {
    return false;
  }
  DDS::Int32 valAsInt;
  rc = get_enum_value(valAsInt, mtype, this, id);
  if (rc != DDS::RETCODE_OK) {
    return false;
  }
  DDS::String8_var valAsStr;
  rc = get_enumerator_name(valAsStr, valAsInt, mtype);
  if (rc != DDS::RETCODE_OK) {
    return false;
  }
  CORBA::string_free(strInOut);
  strInOut = valAsStr._retn();
  return true;
}

exclude_member()

bool OpenDDS::XTypes::DynamicDataBase::exclude_member ( DCPS::Sample::Extent  ext, bool  is_key, bool  has_explicit_keys  )

inlinestatic

Definition at line 68 of file DynamicDataBase.h.

References OpenDDS::XTypes::is_key(), OpenDDS::DCPS::Sample::KeyOnly, and OpenDDS::DCPS::Sample::NestedKeyOnly.

Referenced by OpenDDS::XTypes::DynamicDataXcdrReadImpl::exclude_struct_member(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_member_id_at_index(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_structure_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_structure_xcdr2(), and OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_struct_member().

{
  // see Fields::Iterator and explicit_keys_only() in opendds_idl's dds_generator.h
  const bool explicit_keys_only = ext == DCPS::Sample::KeyOnly || (ext == DCPS::Sample::NestedKeyOnly && has_explicit_keys);
  return explicit_keys_only && !is_key;
}

get_descriptor()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataBase::get_descriptor	(	DDS::MemberDescriptor *&	value,
		MemberId	id
	)

Definition at line 30 of file DynamicDataBase.cpp.

References DDS::RETCODE_ERROR, DDS::RETCODE_OK, and type_.

Referenced by check_member(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_value_from_struct(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_struct(), OpenDDS::XTypes::print_struct(), and OpenDDS::XTypes::print_union().

{
  DDS::DynamicTypeMember_var dtm;
  if (type_->get_member(dtm, id) != DDS::RETCODE_OK) {
    return DDS::RETCODE_ERROR;
  }
  return dtm->get_descriptor(value);
}

get_index_from_id()

bool OpenDDS::XTypes::DynamicDataBase::get_index_from_id ( DDS::MemberId  id, ACE_CDR::ULong &  index, ACE_CDR::ULong  bound  ) const

protected

Definition at line 154 of file DynamicDataBase.cpp.

References OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_BITMASK, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::TK_STRING16, OpenDDS::XTypes::TK_STRING8, and type_.

Referenced by OpenDDS::XTypes::DynamicDataImpl::get_boolean_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_boolean_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_char_common(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_array_element(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_map_element(), and OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_sequence_element().

{
  // The mapping from id to index must be consistent with get_member_id_at_index
  // for these types. In particular, index and id are equal given that it doesn't
  // go out of bound.
  switch (type_->get_kind()) {
  case TK_STRING8:
  case TK_STRING16:
  case TK_SEQUENCE:
  case TK_MAP:
    if (bound == 0 || id < bound) {
      index = id;
      return true;
    }
    break;
  case TK_BITMASK:
  case TK_ARRAY:
    if (id < bound) {
      index = id;
      return true;
    }
  }
  return false;
}

get_member_id_by_name()

DDS::MemberId OpenDDS::XTypes::DynamicDataBase::get_member_id_by_name

(

const char *

name

)

Definition at line 39 of file DynamicDataBase.cpp.

References ACE_ERROR, LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::XTypes::MEMBER_ID_INVALID, OpenDDS::DCPS::LogLevel::Notice, DDS::RETCODE_OK, OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_BITMASK, OpenDDS::XTypes::TK_BOOLEAN, OpenDDS::XTypes::TK_BYTE, OpenDDS::XTypes::TK_CHAR16, OpenDDS::XTypes::TK_CHAR8, OpenDDS::XTypes::TK_ENUM, OpenDDS::XTypes::TK_FLOAT128, OpenDDS::XTypes::TK_FLOAT32, OpenDDS::XTypes::TK_FLOAT64, OpenDDS::XTypes::TK_INT16, OpenDDS::XTypes::TK_INT32, OpenDDS::XTypes::TK_INT64, OpenDDS::XTypes::TK_INT8, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::TK_STRING16, OpenDDS::XTypes::TK_STRING8, OpenDDS::XTypes::TK_STRUCTURE, OpenDDS::XTypes::TK_UINT16, OpenDDS::XTypes::TK_UINT32, OpenDDS::XTypes::TK_UINT64, OpenDDS::XTypes::TK_UINT8, OpenDDS::XTypes::TK_UNION, type_, and OpenDDS::XTypes::typekind_to_string().

{
  const TypeKind tk = type_->get_kind();
  switch (tk) {
  case TK_BOOLEAN:
  case TK_BYTE:
  case TK_INT16:
  case TK_INT32:
  case TK_INT64:
  case TK_UINT16:
  case TK_UINT32:
  case TK_UINT64:
  case TK_FLOAT32:
  case TK_FLOAT64:
  case TK_FLOAT128:
  case TK_INT8:
  case TK_UINT8:
  case TK_CHAR8:
  case TK_CHAR16:
  case TK_ENUM:
    return MEMBER_ID_INVALID;
  case TK_STRING8:
  case TK_STRING16:
  case TK_SEQUENCE:
  case TK_ARRAY:
    // Elements of string, sequence, array must be accessed by index.
    return MEMBER_ID_INVALID;
  case TK_MAP:
    // Values in map can be accessed by strings which is converted from map keys.
    // But need to find out how this conversion works. In the meantime, only allow
    // accessing map using index.
    return MEMBER_ID_INVALID;
  case TK_BITMASK:
  case TK_STRUCTURE:
  case TK_UNION: {
    DDS::DynamicTypeMember_var member;
    if (type_->get_member_by_name(member, name) != DDS::RETCODE_OK) {
      return MEMBER_ID_INVALID;
    }
    DDS::MemberDescriptor_var descriptor;
    if (member->get_descriptor(descriptor) != DDS::RETCODE_OK) {
      return MEMBER_ID_INVALID;
    }
    if (tk == TK_BITMASK) {
      // Bitmask's flags don't have ID, so use index instead.
      return descriptor->index();
    } else {
      return descriptor->id();
    }
  }
  }
  if (DCPS::log_level >= DCPS::LogLevel::Notice) {
    ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataBase::get_member_id_by_name:"
               " Calling on an unexpected type %C\n", typekind_to_string(tk)));
  }
  return MEMBER_ID_INVALID;
}

get_simple_value()

virtual DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataBase::get_simple_value ( DCPS::Value &  value, DDS::MemberId  id  )

pure virtual

Implemented in OpenDDS::XTypes::DynamicDataXcdrReadImpl, and OpenDDS::XTypes::DynamicDataImpl.

Referenced by OpenDDS::DCPS::MetaStructImpl< XTypes::DynamicSample >::getValue(), and OpenDDS::DCPS::MetaStructImpl< XTypes::DynamicSample >::getValueImpl().

get_union_default_member()

DDS::MemberId OpenDDS::XTypes::DynamicDataBase::get_union_default_member ( DDS::DynamicType *  type )

staticprotected

Definition at line 261 of file DynamicDataBase.cpp.

References OpenDDS::XTypes::DISCRIMINATOR_ID, DDS::DynamicType::get_member_by_index(), DDS::DynamicType::get_member_count(), OpenDDS::XTypes::Sequence< T >::length(), OpenDDS::XTypes::MEMBER_ID_INVALID, and DDS::RETCODE_OK.

{
  //FUTURE: non-zero defaults for union discriminators are not currently represented
  // in the MemberDescriptors created by converting CompleteTypeObject to DynamicType.
  // When they are supported, change disc_default below to a value derived from the
  // 'type' parameter.  Note that 64-bit discriminators are not represented in TypeObject.
  static const ACE_CDR::Long disc_default = 0;
  DDS::MemberId default_branch = MEMBER_ID_INVALID;
  const ACE_CDR::ULong members = type->get_member_count();
  for (ACE_CDR::ULong i = 0; i < members; ++i) {
    DDS::DynamicTypeMember_var member;
    if (type->get_member_by_index(member, i) != DDS::RETCODE_OK) {
      return MEMBER_ID_INVALID;
    }
    if (member->get_id() == DISCRIMINATOR_ID) {
      continue;
    }
    DDS::MemberDescriptor_var mdesc;
    if (member->get_descriptor(mdesc) != DDS::RETCODE_OK) {
      return MEMBER_ID_INVALID;
    }
    if (mdesc->is_default_label()) {
      default_branch = mdesc->id();
    } else {
      const DDS::UnionCaseLabelSeq& lseq = mdesc->label();
      for (ACE_CDR::ULong lbl = 0; lbl < lseq.length(); ++lbl) {
        if (lseq[lbl] == disc_default) {
          return mdesc->id();
        }
      }
    }
  }
  // Reaching this point means that there is no explicit label for the default
  // value of the discriminator.  If there is a default branch, its member is
  // selected.  Otherwise the 'MEMBER_ID_INVALID' constant is returned.
  return default_branch;
}

has_explicit_keys()

bool OpenDDS::XTypes::DynamicDataBase::has_explicit_keys ( DDS::DynamicType *  dt )

static

Definition at line 327 of file DynamicDataBase.cpp.

References DDS::DynamicType::get_descriptor(), DDS::DynamicType::get_member_by_index(), DDS::DynamicType::get_member_count(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, and DDS::RETCODE_OK.

Referenced by OpenDDS::XTypes::DynamicDataXcdrReadImpl::exclude_struct_member(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_item_count(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_member_id_at_index(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_structure_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_union_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_structure_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_union_xcdr2(), and OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_struct_member().

{
  // see dds_generator.h struct_has_explicit_keys() in opendds_idl
  DDS::TypeDescriptor_var type_descriptor;
  DDS::ReturnCode_t ret = dt->get_descriptor(type_descriptor);
  if (ret != DDS::RETCODE_OK) {
    return false;
  }
  DDS::DynamicType* const base = type_descriptor->base_type();
  if (base && has_explicit_keys(base)) {
    return true;
  }

  for (ACE_CDR::ULong i = 0; i < dt->get_member_count(); ++i) {
    DDS::DynamicTypeMember_var member;
    ret = dt->get_member_by_index(member, i);
    if (ret != DDS::RETCODE_OK) {
      return false;
    }
    DDS::MemberDescriptor_var descriptor;
    ret = member->get_descriptor(descriptor);
    if (ret != DDS::RETCODE_OK) {
      return false;
    }
    if (descriptor->is_key()) {
      return true;
    }
  }
  return false;
}

interface_from_this()

DDS::DynamicData * OpenDDS::XTypes::DynamicDataBase::interface_from_this ( ) const

protected

Similar idea to std::shared_from_this(), provide a type compatible with parameter passing rules for IDL interfaces that are arguments to operations. Doesn't change the reference count.

Definition at line 23 of file DynamicDataBase.cpp.

Referenced by OpenDDS::XTypes::DynamicDataImpl::get_simple_value_enum().

{
  // Operations defined in IDL interfaces don't use pointer-to-const
  // parameter types.
  return const_cast<DynamicDataBase*>(this);
}

is_basic()

bool OpenDDS::XTypes::DynamicDataBase::is_basic ( TypeKind  tk ) const

protected

Definition at line 134 of file DynamicDataBase.cpp.

References is_primitive(), OpenDDS::XTypes::TK_STRING16, and OpenDDS::XTypes::TK_STRING8.

Referenced by check_member(), and is_type_supported().

{
  return is_primitive(tk) || tk == TK_STRING8 || tk == TK_STRING16;
}

is_complex()

bool OpenDDS::XTypes::DynamicDataBase::is_complex ( TypeKind  tk ) const

protected

Definition at line 139 of file DynamicDataBase.cpp.

References OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_BITSET, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::TK_STRUCTURE, and OpenDDS::XTypes::TK_UNION.

{
  switch (tk) {
  case TK_ARRAY:
  case TK_SEQUENCE:
  case TK_MAP:
  case TK_STRUCTURE:
  case TK_UNION:
  case TK_BITSET:
    return true;
  default:
    return false;
  }
}

is_primitive()

bool OpenDDS::XTypes::DynamicDataBase::is_primitive ( TypeKind  tk ) const

protected

Definition at line 110 of file DynamicDataBase.cpp.

References OpenDDS::XTypes::TK_BOOLEAN, OpenDDS::XTypes::TK_BYTE, OpenDDS::XTypes::TK_CHAR16, OpenDDS::XTypes::TK_CHAR8, OpenDDS::XTypes::TK_FLOAT128, OpenDDS::XTypes::TK_FLOAT32, OpenDDS::XTypes::TK_FLOAT64, OpenDDS::XTypes::TK_INT16, OpenDDS::XTypes::TK_INT32, OpenDDS::XTypes::TK_INT64, OpenDDS::XTypes::TK_INT8, OpenDDS::XTypes::TK_UINT16, OpenDDS::XTypes::TK_UINT32, OpenDDS::XTypes::TK_UINT64, and OpenDDS::XTypes::TK_UINT8.

Referenced by OpenDDS::XTypes::DynamicDataImpl::clear_all_values(), OpenDDS::XTypes::DynamicDataImpl::clear_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_item_count(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_single_value(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_self(), is_basic(), and OpenDDS::XTypes::DynamicDataImpl::set_single_value().

{
  switch (tk) {
  case TK_BOOLEAN:
  case TK_BYTE:
  case TK_INT8:
  case TK_UINT8:
  case TK_CHAR8:
  case TK_INT16:
  case TK_UINT16:
  case TK_CHAR16:
  case TK_INT32:
  case TK_UINT32:
  case TK_FLOAT32:
  case TK_INT64:
  case TK_UINT64:
  case TK_FLOAT64:
  case TK_FLOAT128:
    return true;
  default:
    return false;
  }
}

is_type_supported()

bool OpenDDS::XTypes::DynamicDataBase::is_type_supported ( TypeKind  tk, const char *  func_name  )

protected

Verify that a given type is primitive or string or wstring.

Definition at line 97 of file DynamicDataBase.cpp.

References ACE_ERROR, is_basic(), LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, and OpenDDS::XTypes::typekind_to_string().

Referenced by OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_sequence_values(), OpenDDS::XTypes::DynamicDataImpl::get_single_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_single_value(), OpenDDS::XTypes::DynamicDataImpl::set_sequence_values(), and OpenDDS::XTypes::DynamicDataImpl::set_single_value().

{
  if (!is_basic(tk)) {
    if (DCPS::log_level >= DCPS::LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataBase::is_type_supported:"
                 " Called function %C on an unsupported type (%C)\n",
                 func_name, typekind_to_string(tk)));
    }
    return false;
  }
  return true;
}

nested()

DCPS::Sample::Extent OpenDDS::XTypes::DynamicDataBase::nested ( DCPS::Sample::Extent  ext )

inlinestatic

Definition at line 75 of file DynamicDataBase.h.

References OpenDDS::DCPS::Sample::KeyOnly, OpenDDS::DCPS::Sample::NestedKeyOnly, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_complex_value(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_structure_xcdr2(), and OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_structure_xcdr2().

{
  return ext == DCPS::Sample::KeyOnly ? DCPS::Sample::NestedKeyOnly : ext;
}

Member Data Documentation

type_

DDS::DynamicType_var OpenDDS::XTypes::DynamicDataBase::type_

protected

The actual (i.e., non-alias) DynamicType of the associated type.

Definition at line 65 of file DynamicDataBase.h.

Referenced by check_member(), OpenDDS::XTypes::DynamicDataImpl::check_seqmem_in_sequence_and_array(), OpenDDS::XTypes::DynamicDataImpl::check_seqmem_in_struct_and_union(), OpenDDS::XTypes::DynamicDataImpl::clear_all_values(), OpenDDS::XTypes::DynamicDataImpl::clear_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::clone(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::copy(), enum_string_helper(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::exclude_struct_member(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::exclude_union_member(), OpenDDS::XTypes::DynamicDataImpl::get_boolean_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_boolean_value(), OpenDDS::XTypes::DynamicDataImpl::get_char_common(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_char_common(), OpenDDS::XTypes::DynamicDataImpl::get_complex_from_aggregated(), OpenDDS::XTypes::DynamicDataImpl::get_complex_from_collection(), OpenDDS::XTypes::DynamicDataImpl::get_complex_from_union(), OpenDDS::XTypes::DynamicDataImpl::get_complex_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_complex_value(), get_descriptor(), get_index_from_id(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_item_count(), OpenDDS::XTypes::DynamicDataImpl::get_item_count(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::get_largest_complex_index(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::get_largest_sequence_index(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::get_largest_single_index(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_member_id_at_index(), OpenDDS::XTypes::DynamicDataImpl::get_member_id_at_index(), get_member_id_by_name(), OpenDDS::XTypes::DynamicDataImpl::get_sequence_size(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_sequence_values(), OpenDDS::XTypes::DynamicDataImpl::get_simple_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_simple_value(), OpenDDS::XTypes::DynamicDataImpl::get_simple_value_enum(), OpenDDS::XTypes::DynamicDataImpl::get_single_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_single_value(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_union_selected_member(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_bitmask(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_collection(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_value_from_collection(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_enum(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_self(), OpenDDS::XTypes::DynamicDataImpl::get_value_from_union(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_value_from_union(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_array(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_map(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_sequence(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_union(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::has_optional_member(), OpenDDS::XTypes::DynamicDataImpl::insert_discriminator(), OpenDDS::XTypes::DynamicDataImpl::insert_valid_discriminator(), OpenDDS::XTypes::DynamicDataImpl::is_default_member_selected(), OpenDDS::XTypes::DynamicDataImpl::read_discriminator(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::reconstruct_string_value(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::select_union_member(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_array(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_bitmask_value(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_enum_value(), OpenDDS::XTypes::DynamicDataImpl::serialize_i(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_selected_member_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_sequence(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_string_value(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_structure_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialize_union_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_array(), OpenDDS::XTypes::DynamicDataImpl::serialized_size_i(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_selected_member_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_sequence(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_structure_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::DataContainer::serialized_size_union_xcdr2(), OpenDDS::XTypes::DynamicDataImpl::set_boolean_value(), OpenDDS::XTypes::DynamicDataImpl::set_char_common(), OpenDDS::XTypes::DynamicDataImpl::set_complex_to_collection(), OpenDDS::XTypes::DynamicDataImpl::set_complex_to_struct(), OpenDDS::XTypes::DynamicDataImpl::set_complex_to_union(), OpenDDS::XTypes::DynamicDataImpl::set_complex_value(), OpenDDS::XTypes::DynamicDataImpl::set_sequence_values(), OpenDDS::XTypes::DynamicDataImpl::set_single_value(), OpenDDS::XTypes::DynamicDataImpl::set_string_value(), OpenDDS::XTypes::DynamicDataImpl::set_value_to_collection(), OpenDDS::XTypes::DynamicDataImpl::set_value_to_union(), OpenDDS::XTypes::DynamicDataImpl::set_values_to_array(), OpenDDS::XTypes::DynamicDataImpl::set_values_to_sequence(), OpenDDS::XTypes::DynamicDataImpl::set_values_to_union(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_all(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_struct_member_at_index(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_array_element(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_map_element(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_sequence_element(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_struct_member(), OpenDDS::XTypes::DynamicDataImpl::type(), OpenDDS::XTypes::DynamicDataXcdrReadImpl::type(), and OpenDDS::XTypes::DynamicDataImpl::write_discriminator().

---

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

• DynamicDataBase.h
• DynamicDataBase.cpp