#include <DynamicDataXcdrReadImpl.h>

Inheritance diagram for OpenDDS::XTypes::DynamicDataXcdrReadImpl:

[legend]

Collaboration diagram for OpenDDS::XTypes::DynamicDataXcdrReadImpl:

[legend]

Classes
class	ScopedChainManager

Public Member Functions
	DynamicDataXcdrReadImpl ()

	DynamicDataXcdrReadImpl (ACE_Message_Block *chain, const DCPS::Encoding &encoding, DDS::DynamicType_ptr type, DCPS::Sample::Extent ext=DCPS::Sample::Full)

	DynamicDataXcdrReadImpl (DCPS::Serializer &ser, DDS::DynamicType_ptr type, DCPS::Sample::Extent ext=DCPS::Sample::Full)

	DynamicDataXcdrReadImpl (const DynamicDataXcdrReadImpl &other)

DynamicDataXcdrReadImpl &	operator= (const DynamicDataXcdrReadImpl &other)

	~DynamicDataXcdrReadImpl ()

DDS::ReturnCode_t	set_descriptor (MemberId id, DDS::MemberDescriptor *value)

DDS::MemberId	get_member_id_at_index (ACE_CDR::ULong index)

ACE_CDR::ULong	get_item_count ()

DDS::ReturnCode_t	clear_all_values ()

DDS::ReturnCode_t	clear_nonkey_values ()

DDS::ReturnCode_t	clear_value (DDS::MemberId id)

DDS::DynamicData_ptr	loan_value (DDS::MemberId id)

DDS::ReturnCode_t	return_loaned_value (DDS::DynamicData_ptr value)

DDS::DynamicData_ptr	clone ()

DDS::ReturnCode_t	get_int32_value (CORBA::Long &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int32_value (DDS::MemberId, CORBA::Long)

DDS::ReturnCode_t	get_uint32_value (CORBA::ULong &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint32_value (DDS::MemberId, CORBA::ULong)

DDS::ReturnCode_t	get_int8_value (CORBA::Int8 &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int8_value (DDS::MemberId, CORBA::Int8)

DDS::ReturnCode_t	get_uint8_value (CORBA::UInt8 &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint8_value (DDS::MemberId, CORBA::UInt8)

DDS::ReturnCode_t	get_int16_value (CORBA::Short &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int16_value (DDS::MemberId, CORBA::Short)

DDS::ReturnCode_t	get_uint16_value (CORBA::UShort &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint16_value (DDS::MemberId, CORBA::UShort)

DDS::ReturnCode_t	get_int64_value_impl (CORBA::LongLong &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int64_value (DDS::MemberId, CORBA::LongLong)

DDS::ReturnCode_t	get_uint64_value_impl (CORBA::ULongLong &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint64_value (DDS::MemberId, CORBA::ULongLong)

DDS::ReturnCode_t	get_float32_value (CORBA::Float &value, DDS::MemberId id)

DDS::ReturnCode_t	set_float32_value (DDS::MemberId, CORBA::Float)

DDS::ReturnCode_t	get_float64_value (CORBA::Double &value, DDS::MemberId id)

DDS::ReturnCode_t	set_float64_value (DDS::MemberId, CORBA::Double)

DDS::ReturnCode_t	get_float128_value (CORBA::LongDouble &value, DDS::MemberId id)

DDS::ReturnCode_t	set_float128_value (DDS::MemberId, CORBA::LongDouble)

DDS::ReturnCode_t	get_char8_value (CORBA::Char &value, DDS::MemberId id)

DDS::ReturnCode_t	set_char8_value (DDS::MemberId, CORBA::Char)

DDS::ReturnCode_t	get_char16_value (CORBA::WChar &value, DDS::MemberId id)

DDS::ReturnCode_t	set_char16_value (DDS::MemberId, CORBA::WChar)

DDS::ReturnCode_t	get_byte_value (CORBA::Octet &value, DDS::MemberId id)

DDS::ReturnCode_t	set_byte_value (DDS::MemberId, CORBA::Octet)

DDS::ReturnCode_t	get_boolean_value (CORBA::Boolean &value, DDS::MemberId id)

DDS::ReturnCode_t	set_boolean_value (DDS::MemberId, CORBA::Boolean)

DDS::ReturnCode_t	get_string_value (char *&value, DDS::MemberId id)

DDS::ReturnCode_t	set_string_value (DDS::MemberId, const char *)

DDS::ReturnCode_t	get_wstring_value (CORBA::WChar *&value, DDS::MemberId id)

DDS::ReturnCode_t	set_wstring_value (DDS::MemberId, const CORBA::WChar *)

DDS::ReturnCode_t	get_complex_value (DDS::DynamicData_ptr &value, DDS::MemberId id)

DDS::ReturnCode_t	set_complex_value (DDS::MemberId, DDS::DynamicData_ptr)

DDS::ReturnCode_t	get_int32_values (DDS::Int32Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int32_values (DDS::MemberId, const DDS::Int32Seq &)

DDS::ReturnCode_t	get_uint32_values (DDS::UInt32Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint32_values (DDS::MemberId, const DDS::UInt32Seq &)

DDS::ReturnCode_t	get_int8_values (DDS::Int8Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int8_values (DDS::MemberId, const DDS::Int8Seq &)

DDS::ReturnCode_t	get_uint8_values (DDS::UInt8Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint8_values (DDS::MemberId, const DDS::UInt8Seq &)

DDS::ReturnCode_t	get_int16_values (DDS::Int16Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int16_values (DDS::MemberId, const DDS::Int16Seq &)

DDS::ReturnCode_t	get_uint16_values (DDS::UInt16Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint16_values (DDS::MemberId, const DDS::UInt16Seq &)

DDS::ReturnCode_t	get_int64_values (DDS::Int64Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_int64_values (DDS::MemberId, const DDS::Int64Seq &)

DDS::ReturnCode_t	get_uint64_values (DDS::UInt64Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_uint64_values (DDS::MemberId, const DDS::UInt64Seq &)

DDS::ReturnCode_t	get_float32_values (DDS::Float32Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_float32_values (DDS::MemberId, const DDS::Float32Seq &)

DDS::ReturnCode_t	get_float64_values (DDS::Float64Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_float64_values (DDS::MemberId, const DDS::Float64Seq &)

DDS::ReturnCode_t	get_float128_values (DDS::Float128Seq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_float128_values (DDS::MemberId, const DDS::Float128Seq &)

DDS::ReturnCode_t	get_char8_values (DDS::CharSeq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_char8_values (DDS::MemberId, const DDS::CharSeq &)

DDS::ReturnCode_t	get_char16_values (DDS::WcharSeq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_char16_values (DDS::MemberId, const DDS::WcharSeq &)

DDS::ReturnCode_t	get_byte_values (DDS::ByteSeq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_byte_values (DDS::MemberId, const DDS::ByteSeq &)

DDS::ReturnCode_t	get_boolean_values (DDS::BooleanSeq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_boolean_values (DDS::MemberId, const DDS::BooleanSeq &)

DDS::ReturnCode_t	get_string_values (DDS::StringSeq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_string_values (DDS::MemberId, const DDS::StringSeq &)

DDS::ReturnCode_t	get_wstring_values (DDS::WstringSeq &value, DDS::MemberId id)

DDS::ReturnCode_t	set_wstring_values (DDS::MemberId, const DDS::WstringSeq &)

DDS::DynamicType_ptr	type ()

bool	check_xcdr1_mutable (DDS::DynamicType_ptr dt)

CORBA::Boolean	equals (DDS::DynamicData_ptr other)

DDS::ReturnCode_t	get_simple_value (DCPS::Value &value, DDS::MemberId id)

Public Member Functions inherited from OpenDDS::XTypes::DynamicDataBase
	DynamicDataBase ()

	DynamicDataBase (DDS::DynamicType_ptr type)

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

DDS::ReturnCode_t	set_descriptor (DDS::MemberId id, DDS::MemberDescriptor *value)

DDS::MemberId	get_member_id_by_name (const char *name)

DDS::DynamicType_ptr	type ()

DDS::Boolean	equals (DDS::DynamicData_ptr other)

DDS::DynamicData_ptr	loan_value (DDS::MemberId id)

DDS::ReturnCode_t	return_loaned_value (DDS::DynamicData_ptr other)

DDS::DynamicData_ptr	clone ()

DDS::ReturnCode_t	get_int64_value (DDS::Int64 &value, DDS::MemberId id)

virtual DDS::ReturnCode_t	get_int64_value_impl (DDS::Int64 &value, DDS::MemberId id)=0

DDS::ReturnCode_t	get_uint64_value (DDS::UInt64 &value, DDS::MemberId id)

virtual DDS::ReturnCode_t	get_uint64_value_impl (DDS::UInt64 &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)

DDS::ReturnCode_t	clear_value (in MemberId id)

DynamicData	loan_value (in MemberId id)

DDS::ReturnCode_t	return_loaned_value (in DynamicData value)

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

Private Member Functions
void	copy (const DynamicDataXcdrReadImpl &other)

bool	skip_all ()

void	setup_stream (ACE_Message_Block *chain)

template<typename ValueType >
bool	read_value (ValueType &value, TypeKind tk)

bool	exclude_struct_member (MemberId id, DDS::MemberDescriptor_var &md) const
	Check if a member with a given id is excluded from struct sample. More...

bool	exclude_union_member (MemberId id) const
	Check if a member with a given Id is excluded from a union sample. More...

template<TypeKind ValueTypeKind, typename ValueType >
DDS::ReturnCode_t	get_single_value (ValueType &value, MemberId id, TypeKind enum_or_bitmask=TK_NONE, LBound lower=0, LBound upper=0)

template<TypeKind CharKind, TypeKind StringKind, typename ToCharT , typename CharT >
DDS::ReturnCode_t	get_char_common (CharT &value, MemberId id)
	Common method to read a single char8 or char16 value. More...

template<typename UIntType , TypeKind UIntTypeKind>
bool	get_boolean_from_bitmask (ACE_CDR::ULong index, ACE_CDR::Boolean &value)

DDS::ReturnCode_t	skip_to_struct_member (DDS::MemberDescriptor *member_desc, MemberId id)

bool	get_from_struct_common_checks (const DDS::MemberDescriptor_var &md, MemberId id, TypeKind kind, bool is_sequence=false)

DDS::MemberDescriptor *	get_union_selected_member ()
	Return the member descriptor for the selected member from a union data or null. More...

DDS::MemberDescriptor *	get_from_union_common_checks (MemberId id, const char *func_name)

bool	skip_to_map_element (MemberId id)

template<typename SequenceType >
bool	read_values (SequenceType &value, TypeKind elem_tk)

template<TypeKind ElementTypeKind, typename SequenceType >
DDS::ReturnCode_t	get_sequence_values (SequenceType &value, MemberId id, TypeKind enum_or_bitmask=TK_NONE, LBound lower=0, LBound upper=0)
	Common method to read a value sequence of any type (primitive, string, wstring). More...

bool	skip (const char func_name, const char description, size_t n, int size=1)

bool	read_discriminator (const DDS::DynamicType_ptr disc_type, DDS::ExtensibilityKind union_ek, ACE_CDR::Long &label)

bool	skip_struct_member_at_index (ACE_CDR::ULong index, ACE_CDR::ULong &num_skipped)

bool	skip_member (DDS::DynamicType_ptr member_type)

bool	skip_collection_member (DDS::DynamicType_ptr coll_type)

bool	skip_aggregated_member (DDS::DynamicType_ptr type)
	Skip a member which is a structure or a union. More...

void	release_chains ()

bool	get_primitive_size (DDS::DynamicType_ptr dt, ACE_CDR::ULong &size) const

bool	has_optional_member (bool &has_optional) const

typedef	OPENDDS_SET (DCPS::String) DynamicTypeNameSet
	A set of strings used to prevent infinite recursion when checking for XCDR1 Mutable. More...

bool	check_xcdr1_mutable_i (DDS::DynamicType_ptr dt, DynamicTypeNameSet &dtns)

typedef	OPENDDS_VECTOR (ACE_Message_Block *) IntermediateChains

const IntermediateChains &	get_intermediate_chains () const


template<TypeKind MemberTypeKind, typename MemberType >
DDS::ReturnCode_t	get_value_from_struct (MemberType &value, MemberId id, TypeKind enum_or_bitmask=TK_NONE, LBound lower=0, LBound upper=0)

template<TypeKind MemberTypeKind, typename MemberType >
DDS::ReturnCode_t	get_value_from_union (MemberType &value, MemberId id, TypeKind enum_or_bitmask=TK_NONE, LBound lower=0, LBound upper=0)

template<TypeKind ElementTypeKind, typename ElementType >
bool	get_value_from_collection (ElementType &value, MemberId id, TypeKind collection_tk, TypeKind enum_or_bitmask=TK_NONE, LBound lower=0, LBound upper=0)


bool	skip_to_sequence_element (MemberId id, DDS::DynamicType_ptr coll_type=0)

bool	skip_to_array_element (MemberId id, DDS::DynamicType_ptr coll_type=0)


template<TypeKind ElementTypeKind, typename SequenceType >
DDS::ReturnCode_t	get_values_from_struct (SequenceType &value, MemberId id, TypeKind enum_or_bitmask, LBound lower, LBound upper)

template<TypeKind ElementTypeKind, typename SequenceType >
bool	get_values_from_union (SequenceType &value, MemberId id, TypeKind enum_or_bitmask, LBound lower, LBound upper)

template<TypeKind ElementTypeKind, typename SequenceType >
bool	get_values_from_sequence (SequenceType &value, MemberId id, TypeKind enum_or_bitmask, LBound lower, LBound upper)

template<TypeKind ElementTypeKind, typename SequenceType >
bool	get_values_from_array (SequenceType &value, MemberId id, TypeKind enum_or_bitmask, LBound lower, LBound upper)

template<TypeKind ElementTypeKind, typename SequenceType >
bool	get_values_from_map (SequenceType &value, MemberId id, TypeKind enum_or_bitmask, LBound lower, LBound upper)


bool	skip_sequence_member (DDS::DynamicType_ptr type)

bool	skip_array_member (DDS::DynamicType_ptr type)

bool	skip_map_member (DDS::DynamicType_ptr type)

Private Attributes
ACE_Message_Block *	chain_

DCPS::Encoding	encoding_

DCPS::Sample::Extent	extent_

bool	reset_align_state_

DCPS::Serializer::RdState	align_state_

DCPS::Serializer	strm_

IntermediateChains	chains_to_release

ACE_CDR::ULong	item_count_
	Cache the number of items (i.e., members or elements) in the data it holds. More...

Static Private Attributes
static const ACE_CDR::ULong	ITEM_COUNT_INVALID = ACE_UINT32_MAX

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

Static Public Member Functions inherited from OpenDDS::XTypes::DynamicDataBase
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)

Public Attributes inherited from DDS::DynamicData
readonly attribute DynamicType	type

Protected Member Functions inherited from OpenDDS::XTypes::DynamicDataBase
bool	is_type_supported (TypeKind tk, const char *func_name)
	Verify that a given type is primitive or string or wstring. More...

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 &member_desc, DDS::DynamicType_var &member_type, const char method, const char action, DDS::MemberId id, DDS::TypeKind tk=TK_NONE)

DDS::ReturnCode_t	check_member (DDS::DynamicType_var &member_type, const char method, const char action, DDS::MemberId id, DDS::TypeKind tk=TK_NONE)

DDS::ReturnCode_t	get_selected_union_branch (DDS::Int32 disc, bool &found_selected_member, DDS::MemberDescriptor_var &selected_md) const

DDS::ReturnCode_t	get_selected_union_branch (bool &found_selected_member, DDS::MemberDescriptor_var &selected_md)

bool	discriminator_selects_no_member (DDS::Int32 disc) const

DDS::DynamicData *	interface_from_this () const

DDS::ReturnCode_t	unsupported_method (const char *method_name, bool warning=false) 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 inherited from OpenDDS::XTypes::DynamicDataBase
static DDS::MemberId	get_union_default_member (DDS::DynamicType *type)

Protected Attributes inherited from OpenDDS::XTypes::DynamicDataBase
DDS::DynamicType_var	type_
	The actual (i.e., non-alias) DynamicType of the associated type. More...

DDS::TypeDescriptor_var	type_desc_

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

Detailed Description

Definition at line 22 of file DynamicDataXcdrReadImpl.h.

Constructor & Destructor Documentation

◆ DynamicDataXcdrReadImpl() [1/4]

OpenDDS::XTypes::DynamicDataXcdrReadImpl::DynamicDataXcdrReadImpl ( )

Definition at line 51 of file DynamicDataXcdrReadImpl.cpp.

Referenced by clone(), and get_complex_value().

   : chain_(0)
   , encoding_(DCPS::Encoding::KIND_XCDR2)
   , extent_(DCPS::Sample::Full)
   , reset_align_state_(false)
   , strm_(0, encoding_)
   , item_count_(ITEM_COUNT_INVALID)
 {}

◆ DynamicDataXcdrReadImpl() [2/4]

OpenDDS::XTypes::DynamicDataXcdrReadImpl::DynamicDataXcdrReadImpl	(	ACE_Message_Block *	chain,
		const DCPS::Encoding &	encoding,
		DDS::DynamicType_ptr	type,
		DCPS::Sample::Extent	ext = `DCPS::Sample::Full`
	)

This creates a duplicated ACE_Message_Block chain from the provided chain. The duplicated chain is released when the object is destroyed. Caller is responsible for the release of the input message block chain.

Definition at line 60 of file DynamicDataXcdrReadImpl.cpp.

References encoding_, OpenDDS::DCPS::Encoding::xcdr_version(), OpenDDS::DCPS::Encoding::XCDR_VERSION_1, and OpenDDS::DCPS::Encoding::XCDR_VERSION_2.

   : DynamicDataBase(type)
   , chain_(chain->duplicate())
   , encoding_(encoding)
   , extent_(ext)
   , reset_align_state_(false)
   , strm_(chain_, encoding_)
   , item_count_(ITEM_COUNT_INVALID)
 {
   if (encoding_.xcdr_version() != DCPS::Encoding::XCDR_VERSION_1 &&
       encoding_.xcdr_version() != DCPS::Encoding::XCDR_VERSION_2) {
     throw std::runtime_error("DynamicDataXcdrReadImpl only supports XCDR1 and XCDR2");
   }
 }

◆ DynamicDataXcdrReadImpl() [3/4]

OpenDDS::XTypes::DynamicDataXcdrReadImpl::DynamicDataXcdrReadImpl	(	DCPS::Serializer &	ser,
		DDS::DynamicType_ptr	type,
		DCPS::Sample::Extent	ext = `DCPS::Sample::Full`
	)

Use this when you want to pass the alignment state of a given Serializer object over. A typical use case would be when a part of the data has already been consumed from ser and you want to give the remaining to DynamicData.

Definition at line 78 of file DynamicDataXcdrReadImpl.cpp.

References align_state_, encoding_, OpenDDS::DCPS::Serializer::rdstate(), strm_, OpenDDS::DCPS::Encoding::xcdr_version(), OpenDDS::DCPS::Encoding::XCDR_VERSION_1, and OpenDDS::DCPS::Encoding::XCDR_VERSION_2.

   : DynamicDataBase(type)
   , chain_(ser.current()->duplicate())
   , encoding_(ser.encoding())
   , extent_(ext)
   , reset_align_state_(true)
   , align_state_(ser.rdstate())
   , strm_(chain_, encoding_)
   , item_count_(ITEM_COUNT_INVALID)
 {
   if (encoding_.xcdr_version() != DCPS::Encoding::XCDR_VERSION_1 &&
       encoding_.xcdr_version() != DCPS::Encoding::XCDR_VERSION_2) {
     throw std::runtime_error("DynamicDataXcdrReadImpl only supports XCDR1 and XCDR2");
   }
 
   strm_.rdstate(align_state_);
 }

◆ DynamicDataXcdrReadImpl() [4/4]

OpenDDS::XTypes::DynamicDataXcdrReadImpl::DynamicDataXcdrReadImpl ( const DynamicDataXcdrReadImpl & other )

Definition at line 97 of file DynamicDataXcdrReadImpl.cpp.

References copy().

   : CORBA::Object()
   , DDS::DynamicData()
   , CORBA::LocalObject()
   , RcObject()
   , DynamicDataBase()
   , chain_(0)
   , strm_(0, other.encoding_)
 {
   copy(other);
 }

◆ ~DynamicDataXcdrReadImpl()

OpenDDS::XTypes::DynamicDataXcdrReadImpl::~DynamicDataXcdrReadImpl ( )

Definition at line 117 of file DynamicDataXcdrReadImpl.cpp.

References chain_, and ACE_Message_Block::release().

 {
   ACE_Message_Block::release(chain_);
 }

Member Function Documentation

◆ check_xcdr1_mutable()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::check_xcdr1_mutable ( DDS::DynamicType_ptr dt )

Definition at line 2118 of file DynamicDataXcdrReadImpl.cpp.

References check_xcdr1_mutable_i().

Referenced by OpenDDS::DCPS::RecorderImpl::get_dynamic_data().

 {
   DynamicTypeNameSet dtns;
   return check_xcdr1_mutable_i(dt, dtns);
 }

◆ check_xcdr1_mutable_i()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::check_xcdr1_mutable_i	(	DDS::DynamicType_ptr	dt,
		DynamicTypeNameSet &	dtns
	)

private

Definition at line 2830 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, encoding_, TAO::String_var< charT >::in(), OpenDDS::DCPS::Encoding::kind(), OpenDDS::DCPS::Encoding::KIND_XCDR1, LM_NOTICE, DDS::MUTABLE, OpenDDS::DCPS::LogLevel::Notice, DDS::RETCODE_OK, and value.

Referenced by check_xcdr1_mutable().

 {
   DDS::TypeDescriptor_var descriptor;
   if (dt->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   if (dtns.find(descriptor->name()) != dtns.end()) {
     return true;
   }
   if (descriptor->extensibility_kind() == DDS::MUTABLE &&
       encoding_.kind() == DCPS::Encoding::KIND_XCDR1) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::check_xcdr1_mutable: "
                  "XCDR1 mutable is not currently supported in OpenDDS\n"));
     }
     return false;
   }
   dtns.insert(descriptor->name());
   for (ACE_CDR::ULong i = 0; i < dt->get_member_count(); ++i) {
     DDS::DynamicTypeMember_var dtm;
     if (dt->get_member_by_index(dtm, i) != DDS::RETCODE_OK) {
       if (DCPS::log_level >= DCPS::LogLevel::Notice) {
         ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::check_xcdr1_mutable: "
                   "Failed to get member from DynamicType\n"));
       }
       return false;
     }
     DDS::MemberDescriptor_var descriptor;
     if (dtm->get_descriptor(descriptor) != DDS::RETCODE_OK) {
       return false;
     }
     if (!check_xcdr1_mutable_i(descriptor->type(), dtns)) {
       return false;
     }
   }
   return true;
 }

◆ clear_all_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::clear_all_values ( )

Implements DDS::DynamicData.

Definition at line 626 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED.

 {
   return DDS::RETCODE_UNSUPPORTED;
 }

◆ clear_nonkey_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::clear_nonkey_values ( )

Implements DDS::DynamicData.

Definition at line 631 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED.

 {
   return DDS::RETCODE_UNSUPPORTED;
 }

◆ clear_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::clear_value ( DDS::MemberId id )

Definition at line 636 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED.

 {
   return DDS::RETCODE_UNSUPPORTED;
 }

◆ clone()

DDS::DynamicData_ptr OpenDDS::XTypes::DynamicDataXcdrReadImpl::clone ( void )

Implements DDS::DynamicData.

Definition at line 654 of file DynamicDataXcdrReadImpl.cpp.

References chain_, DynamicDataXcdrReadImpl(), OpenDDS::DCPS::Serializer::encoding(), extent_, strm_, and OpenDDS::XTypes::DynamicDataBase::type_.

 {
   return new DynamicDataXcdrReadImpl(chain_, strm_.encoding(), type_, extent_);
 }

◆ copy()

void OpenDDS::XTypes::DynamicDataXcdrReadImpl::copy ( const DynamicDataXcdrReadImpl & other )

private

Definition at line 122 of file DynamicDataXcdrReadImpl.cpp.

References align_state_, chain_, ACE_Message_Block::duplicate(), encoding_, extent_, item_count_, ACE_Message_Block::release(), reset_align_state_, strm_, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by DynamicDataXcdrReadImpl(), and operator=().

 {
   ACE_Message_Block::release(chain_);
   chain_ = other.chain_->duplicate();
   encoding_ = other.encoding_;
   extent_ = other.extent_;
   reset_align_state_ = other.reset_align_state_;
   align_state_ = other.align_state_;
   strm_ = other.strm_;
   type_ = other.type_;
   item_count_ = other.item_count_;
 }

◆ equals()

CORBA::Boolean OpenDDS::XTypes::DynamicDataXcdrReadImpl::equals ( DDS::DynamicData_ptr other )

Definition at line 2124 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, and LM_ERROR.

 {
   // FUTURE: Implement this.
   ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: DynamicDataXcdrReadImpl::equals: Not implemented\n"));
   return false;
 }

◆ exclude_struct_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::exclude_struct_member	(	MemberId	id,
		DDS::MemberDescriptor_var &	md
	)		const

private

Check if a member with a given id is excluded from struct sample.

Definition at line 701 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, OpenDDS::XTypes::DynamicDataBase::exclude_member(), extent_, OpenDDS::XTypes::DynamicDataBase::has_explicit_keys(), LM_NOTICE, OpenDDS::DCPS::LogLevel::Notice, DDS::RETCODE_OK, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_complex_value(), get_value_from_struct(), and get_values_from_struct().

 {
   DDS::DynamicTypeMember_var dtm;
   if (type_->get_member(dtm, id) != DDS::RETCODE_OK) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::exclude_struct_member:"
                  " Failed to get DynamicTypeMember for member with ID %d\n", id));
 
     }
     return false;
   }
   if (dtm->get_descriptor(md) != DDS::RETCODE_OK) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::exclude_struct_member:"
                  " Failed to get MemberDescriptor for member with ID %d\n", id));
     }
     return false;
   }
   return exclude_member(extent_, md->is_key(), has_explicit_keys(type_));
 }

◆ exclude_union_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::exclude_union_member ( MemberId id ) const

private

Check if a member with a given Id is excluded from a union sample.

Definition at line 856 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, OpenDDS::XTypes::DISCRIMINATOR_ID, extent_, OpenDDS::DCPS::Sample::Full, OpenDDS::DCPS::Sample::KeyOnly, LM_NOTICE, OpenDDS::DCPS::LogLevel::Notice, DDS::RETCODE_OK, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_complex_value(), get_value_from_union(), and get_values_from_union().

 {
   if (extent_ == DCPS::Sample::Full) {
     return false;
   }
 
   if (id != DISCRIMINATOR_ID) {
     return true;
   }
 
   if (extent_ == DCPS::Sample::KeyOnly) {
     // Discriminator not marked as key is not included in a KeyOnly sample.
     DDS::DynamicTypeMember_var disc_dtm;
     if (type_->get_member(disc_dtm, DISCRIMINATOR_ID) != DDS::RETCODE_OK) {
       if (DCPS::log_level >= DCPS::LogLevel::Notice) {
         ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::exclude_union_member:"
                    " Failed to get DynamicTypeMember for discriminator\n"));
       }
       return false;
     }
     DDS::MemberDescriptor_var disc_md;
     if (disc_dtm->get_descriptor(disc_md) != DDS::RETCODE_OK) {
       if (DCPS::log_level >= DCPS::LogLevel::Notice) {
         ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::exclude_union_member:"
                    " Failed to get MemberDescriptor for discriminator\n"));
       }
       return false;
     }
     if (!disc_md->is_key()) {
       return true;
     }
   }
   return false;
 }

◆ get_boolean_from_bitmask()

template<typename UIntType , TypeKind UIntTypeKind>

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_boolean_from_bitmask	(	ACE_CDR::ULong	index,
		ACE_CDR::Boolean &	value
	)

private

Definition at line 1397 of file DynamicDataXcdrReadImpl.cpp.

References read_value().

 {
   UIntType bitmask;
   if (!read_value(bitmask, UIntTypeKind)) {
     return false;
   }
 
   value = ((1ULL << index) & bitmask) ? true : false;
   return true;
 }

◆ get_boolean_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_boolean_value	(	CORBA::Boolean &	value,
		DDS::MemberId	id
	)

Definition at line 1408 of file DynamicDataXcdrReadImpl.cpp.

Referenced by get_simple_value().

 {
   ScopedChainManager chain_manager(*this);
 
   const TypeKind tk = type_->get_kind();
   bool good = true;
 
   switch (tk) {
   case TK_BOOLEAN:
     good = strm_ >> ACE_InputCDR::to_boolean(value);
     break;
   case TK_BITMASK:
     {
       DDS::TypeDescriptor_var descriptor;
       if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
         return DDS::RETCODE_ERROR;
       }
       const LBound bit_bound = descriptor->bound()[0];
       ACE_CDR::ULong index;
       if (!get_index_from_id(id, index, bit_bound)) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_boolean_value -")
                      ACE_TEXT(" Id %d is not valid in a bitmask with bit_bound %d\n"),
                      id, bit_bound));
         }
         good = false;
         break;
       }
 
       // Bit with index 0 is the least-significant bit of the representing integer.
       if (bit_bound >= 1 && bit_bound <= 8) {
         ACE_CDR::UInt8 bitmask;
         ACE_InputCDR::to_uint8 to_uint8(bitmask);
         if (!read_value(to_uint8, TK_UINT8)) {
           good = false;
         } else {
           value = ((1 << index) & bitmask) ? true : false;
         }
       } else if (bit_bound >= 9 && bit_bound <= 16) {
         good = get_boolean_from_bitmask<ACE_CDR::UInt16, TK_UINT16>(index, value);
       } else if (bit_bound >= 17 && bit_bound <= 32) {
         good = get_boolean_from_bitmask<ACE_CDR::UInt32, TK_UINT32>(index, value);
       } else {
         good = get_boolean_from_bitmask<ACE_CDR::UInt64, TK_UINT64>(index, value);
       }
       break;
     }
   case TK_STRUCTURE:
     {
       ACE_InputCDR::to_boolean to_bool(value);
       const DDS::ReturnCode_t rc = get_value_from_struct<TK_BOOLEAN>(to_bool, id, extent_);
       if (rc == DDS::RETCODE_NO_DATA) {
         return rc;
       }
       good = rc == DDS::RETCODE_OK;
       break;
     }
   case TK_UNION:
     {
       ACE_InputCDR::to_boolean to_bool(value);
       const DDS::ReturnCode_t rc = get_value_from_union<TK_BOOLEAN>(to_bool, id);
       if (rc == DDS::RETCODE_NO_DATA) {
         return rc;
       }
       good = rc == DDS::RETCODE_OK;
       break;
     }
   case TK_SEQUENCE:
   case TK_ARRAY:
   case TK_MAP:
     {
       ACE_InputCDR::to_boolean to_bool(value);
       good = get_value_from_collection<TK_BOOLEAN>(to_bool, id, tk);
       break;
     }
   default:
     good = false;
     break;
   }
 
   if (!good && DCPS::DCPS_debug_level >= 1) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_boolean_value -")
                ACE_TEXT(" Failed to read DynamicData object of type %C\n"), typekind_to_string(tk)));
   }
   return good ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
 }

◆ get_boolean_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_boolean_values	(	DDS::BooleanSeq &	value,
		DDS::MemberId	id
	)

Definition at line 2094 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_BOOLEAN>(value, id);
 }

◆ get_byte_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_byte_value	(	CORBA::Octet &	value,
		DDS::MemberId	id
	)

Definition at line 1390 of file DynamicDataXcdrReadImpl.cpp.

Referenced by get_simple_value().

 {
   ACE_InputCDR::to_octet to_octet(value);
   return get_single_value<TK_BYTE>(to_octet, id);
 }

◆ get_byte_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_byte_values	(	DDS::ByteSeq &	value,
		DDS::MemberId	id
	)

Definition at line 2089 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_BYTE>(value, id);
 }

◆ get_char16_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_char16_value	(	CORBA::WChar &	value,
		DDS::MemberId	id
	)

Definition at line 1381 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED, and value.

Referenced by get_simple_value().

 {
 #ifdef DDS_HAS_WCHAR
   return get_char_common<TK_CHAR16, TK_STRING16, ACE_InputCDR::to_wchar>(value, id);
 #else
   return DDS::RETCODE_UNSUPPORTED;
 #endif
 }

◆ get_char16_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_char16_values	(	DDS::WcharSeq &	value,
		DDS::MemberId	id
	)

Definition at line 2080 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED, and value.

 {
 #ifdef DDS_HAS_WCHAR
   return get_sequence_values<TK_CHAR16>(value, id);
 #else
   return DDS::RETCODE_UNSUPPORTED;
 #endif
 }

◆ get_char8_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_char8_value	(	CORBA::Char &	value,
		DDS::MemberId	id
	)

Definition at line 1376 of file DynamicDataXcdrReadImpl.cpp.

References value.

Referenced by get_simple_value().

 {
   return get_char_common<TK_CHAR8, TK_STRING8, ACE_InputCDR::to_char>(value, id);
 }

◆ get_char8_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_char8_values	(	DDS::CharSeq &	value,
		DDS::MemberId	id
	)

Definition at line 2075 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_CHAR8>(value, id);
 }

◆ get_char_common()

template<TypeKind CharKind, TypeKind StringKind, typename ToCharT , typename CharT >

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_char_common	(	CharT &	value,
		MemberId	id
	)

private

Common method to read a single char8 or char16 value.

Definition at line 1297 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, extent_, OpenDDS::XTypes::DynamicDataBase::get_index_from_id(), LM_ERROR, DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, ACE_OS::strlen(), strm_, OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::TK_STRUCTURE, OpenDDS::XTypes::TK_UNION, OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   ScopedChainManager chain_manager(*this);
 
   const TypeKind tk = type_->get_kind();
   bool good = true;
 
   switch (tk) {
   case CharKind:
     {
       ToCharT wrap(value);
       good = strm_ >> wrap;
       break;
     }
   case StringKind:
     {
       CharT* str;
       if (!(strm_ >> str)) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_char_common -")
                      ACE_TEXT(" Failed to read wstring with ID %d\n"), id));
         }
         good = false;
         break;
       }
       ACE_CDR::ULong index;
       const size_t str_len = ACE_OS::strlen(str);
       if (!get_index_from_id(id, index, static_cast<ACE_CDR::ULong>(str_len))) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_char_common -")
                      ACE_TEXT(" ID %d is not valid in a string (or wstring) with length %d\n"),
                      id, str_len));
         }
         good = false;
       } else {
         value = str[index];
       }
       break;
     }
   case TK_STRUCTURE:
     {
       ToCharT wrap(value);
       const DDS::ReturnCode_t rc = get_value_from_struct<CharKind>(wrap, id, extent_);
       if (rc == DDS::RETCODE_NO_DATA) {
         return rc;
       }
       good = rc == DDS::RETCODE_OK;
       break;
     }
   case TK_UNION:
     {
       ToCharT wrap(value);
       const DDS::ReturnCode_t rc = get_value_from_union<CharKind>(wrap, id);
       if (rc == DDS::RETCODE_NO_DATA) {
         return rc;
       }
       good = rc == DDS::RETCODE_OK;
       break;
     }
   case TK_SEQUENCE:
   case TK_ARRAY:
   case TK_MAP:
     {
       ToCharT wrap(value);
       good = get_value_from_collection<CharKind>(wrap, id, tk);
       break;
     }
   default:
     good = false;
     break;
   }
 
   if (!good && DCPS::DCPS_debug_level >= 1) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_char_common -")
                ACE_TEXT(" Failed to read DynamicData object of type %C\n"), typekind_to_string(tk)));
   }
   return good ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
 }

◆ get_complex_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_complex_value	(	DDS::DynamicData_ptr &	value,
		DDS::MemberId	id
	)

Definition at line 1514 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::APPENDABLE, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::DISCRIMINATOR_ID, DynamicDataXcdrReadImpl(), exclude_struct_member(), exclude_union_member(), extent_, OpenDDS::XTypes::get_base_type(), get_from_union_common_checks(), OpenDDS::DCPS::Sample::KeyOnly, LM_ERROR, LM_NOTICE, DDS::MUTABLE, OpenDDS::XTypes::DynamicDataBase::nested(), OpenDDS::DCPS::LogLevel::Notice, OpenDDS::DCPS::Serializer::read_parameter_id(), CORBA::release(), DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::skip_delimiter(), skip_to_array_element(), skip_to_map_element(), skip_to_sequence_element(), skip_to_struct_member(), strm_, OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::TK_STRUCTURE, OpenDDS::XTypes::TK_UNION, OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   ScopedChainManager chain_manager(*this);
 
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return DDS::RETCODE_ERROR;
   }
 
   const TypeKind tk = type_->get_kind();
   bool good = true;
 
   switch (tk) {
   case TK_STRUCTURE:
     {
       DDS::MemberDescriptor_var md;
       if (exclude_struct_member(id, md)) {
         if (DCPS::log_level >= DCPS::LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_complex_value:"
                      " Attempted to read an excluded member from a %C struct sample\n",
                      extent_ == DCPS::Sample::KeyOnly ? "KeyOnly" : "NestedKeyOnly"));
         }
         return DDS::RETCODE_NO_DATA;
       }
 
       const DDS::ReturnCode_t rc = skip_to_struct_member(md, id);
       if (rc == DDS::RETCODE_NO_DATA) {
         return rc;
       } else if (rc == DDS::RETCODE_OK) {
         DDS::DynamicType_ptr member_type = md->type();
         if (!member_type) {
           good = false;
         } else {
           CORBA::release(value);
           value = new DynamicDataXcdrReadImpl(strm_, member_type, nested(extent_));
         }
       } else {
         good = false;
       }
       break;
     }
   case TK_UNION:
     {
       if (exclude_union_member(id)) {
         if (DCPS::log_level >= DCPS::LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_complex_value:"
                      " Attempted to read an excluded member from a %C union sample\n",
                      extent_ == DCPS::Sample::KeyOnly ? "KeyOnly" : "NestedKeyOnly"));
         }
         good = false;
         break;
       }
 
       if (id == DISCRIMINATOR_ID) {
         if (descriptor->extensibility_kind() == DDS::APPENDABLE || descriptor->extensibility_kind() == DDS::MUTABLE) {
           if (!strm_.skip_delimiter()) {
             good = false;
             break;
           }
         }
 
         const DDS::DynamicType_var disc_type = get_base_type(descriptor->discriminator_type());
         if (descriptor->extensibility_kind() == DDS::MUTABLE) {
           unsigned id;
           size_t size;
           bool must_understand;
           if (!strm_.read_parameter_id(id, size, must_understand)) {
             good = false;
             break;
           }
         }
         CORBA::release(value);
         value = new DynamicDataXcdrReadImpl(strm_, disc_type, nested(extent_));
         break;
       }
 
       DDS::MemberDescriptor_var md = get_from_union_common_checks(id, "get_complex_value");
       if (!md) {
         good = false;
         break;
       }
 
       if (descriptor->extensibility_kind() == DDS::MUTABLE) {
         unsigned id;
         size_t size;
         bool must_understand;
         if (!strm_.read_parameter_id(id, size, must_understand)) {
           good = false;
           break;
         }
       }
       const DDS::DynamicType_ptr member_type = md->type();
       if (!member_type) {
         good = false;
       } else {
         CORBA::release(value);
         value = new DynamicDataXcdrReadImpl(strm_, member_type, nested(extent_));
       }
       break;
     }
   case TK_SEQUENCE:
   case TK_ARRAY:
   case TK_MAP:
     {
       if ((tk == TK_SEQUENCE && !skip_to_sequence_element(id)) ||
           (tk == TK_ARRAY && !skip_to_array_element(id)) ||
           (tk == TK_MAP && !skip_to_map_element(id))) {
         good = false;
       } else {
         CORBA::release(value);
         value = new DynamicDataXcdrReadImpl(strm_, descriptor->element_type(), nested(extent_));
       }
       break;
     }
   default:
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_complex_value -")
                  ACE_TEXT(" Called on an unsupported type (%C)\n"), typekind_to_string(tk)));
     }
     good = false;
     break;
   }
   return good ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
 }

◆ get_float128_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_float128_value	(	CORBA::LongDouble &	value,
		DDS::MemberId	id
	)

Definition at line 1291 of file DynamicDataXcdrReadImpl.cpp.

References value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_FLOAT128>(value, id);
 }

◆ get_float128_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_float128_values	(	DDS::Float128Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2070 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_FLOAT128>(value, id);
 }

◆ get_float32_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_float32_value	(	CORBA::Float &	value,
		DDS::MemberId	id
	)

Definition at line 1281 of file DynamicDataXcdrReadImpl.cpp.

References value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_FLOAT32>(value, id);
 }

◆ get_float32_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_float32_values	(	DDS::Float32Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2060 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_FLOAT32>(value, id);
 }

◆ get_float64_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_float64_value	(	CORBA::Double &	value,
		DDS::MemberId	id
	)

Definition at line 1286 of file DynamicDataXcdrReadImpl.cpp.

References value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_FLOAT64>(value, id);
 }

◆ get_float64_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_float64_values	(	DDS::Float64Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2065 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_FLOAT64>(value, id);
 }

◆ get_from_struct_common_checks()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_from_struct_common_checks	(	const DDS::MemberDescriptor_var &	md,
		MemberId	id,
		TypeKind	kind,
		bool	is_sequence = `false`
	)

private

Definition at line 2236 of file DynamicDataXcdrReadImpl.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::get_base_type(), LM_DEBUG, DDS::RETCODE_OK, OpenDDS::XTypes::TK_SEQUENCE, and OpenDDS::XTypes::typekind_to_string().

Referenced by get_value_from_struct(), and get_values_from_struct().

 {
   const DDS::DynamicType_ptr member_dt = md->type();
   if (!member_dt) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_from_struct_common_checks -")
                  ACE_TEXT(" Could not get DynamicType for member with ID %d\n"), id));
     }
     return false;
   }
 
   const DDS::DynamicType_var member_type = get_base_type(member_dt);
   const TypeKind member_kind = member_type->get_kind();
 
   if ((!is_sequence && member_kind != kind) || (is_sequence && member_kind != TK_SEQUENCE)) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_from_struct_common_checks -")
                  ACE_TEXT(" Member with ID %d has kind %C, not %C\n"),
                  id, typekind_to_string(member_kind),
                  is_sequence ? typekind_to_string(TK_SEQUENCE) : typekind_to_string(kind)));
     }
     return false;
   }
 
   if (member_kind == TK_SEQUENCE) {
     DDS::TypeDescriptor_var member_td;
     if (member_type->get_descriptor(member_td) != DDS::RETCODE_OK) {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_from_struct_common_checks -")
                    ACE_TEXT(" Could not get type descriptor for member %d\n"),
                    id));
       }
       return false;
     }
     const TypeKind elem_kind = get_base_type(member_td->element_type())->get_kind();
     if (elem_kind != kind) {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_from_struct_common_checks -")
                    ACE_TEXT(" Member with ID %d is a sequence of %C, not %C\n"),
                    id, typekind_to_string(elem_kind), typekind_to_string(kind)));
       }
       return false;
     }
   }
 
   return true;
 }

◆ get_from_union_common_checks()

DDS::MemberDescriptor * OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_from_union_common_checks	(	MemberId	id,
		const char *	func_name
	)

private

Definition at line 826 of file DynamicDataXcdrReadImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, get_union_selected_member(), LM_DEBUG, LM_ERROR, and OpenDDS::XTypes::MEMBER_ID_INVALID.

Referenced by get_complex_value(), get_value_from_union(), and get_values_from_union().

 {
   DDS::MemberDescriptor_var md = get_union_selected_member();
   if (!md) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::%C - Could not find")
                  ACE_TEXT(" MemberDescriptor for the selected union member\n"), func_name));
     }
     return 0;
   }
 
   if (md->id() == MEMBER_ID_INVALID) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::%C - Union has no selected member\n"), func_name));
     }
     return 0;
   }
 
   if (md->id() != id) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::%C -")
                  ACE_TEXT(" ID of the selected member (%d) is not the requested ID (%d)\n"),
                  func_name, md->id(), id));
     }
     return 0;
   }
 
   return md._retn();
 }

◆ get_int16_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int16_value	(	CORBA::Short &	value,
		DDS::MemberId	id
	)

Definition at line 1261 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_ENUM, and value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_INT16>(value, id, TK_ENUM, 9, 16);
 }

◆ get_int16_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int16_values	(	DDS::Int16Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2040 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_ENUM, and value.

 {
   return get_sequence_values<TK_INT16>(value, id, TK_ENUM, 9, 16);
 }

◆ get_int32_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int32_value	(	CORBA::Long &	value,
		DDS::MemberId	id
	)

Definition at line 1237 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_ENUM, and value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_INT32>(value, id, TK_ENUM,
                                     static_cast<LBound>(17), static_cast<LBound>(32));
 }

◆ get_int32_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int32_values	(	DDS::Int32Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2020 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_ENUM, and value.

 {
   return get_sequence_values<TK_INT32>(value, id, TK_ENUM, 17, 32);
 }

◆ get_int64_value_impl()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int64_value_impl	(	CORBA::LongLong &	value,
		DDS::MemberId	id
	)

Definition at line 1271 of file DynamicDataXcdrReadImpl.cpp.

References value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_INT64>(value, id);
 }

◆ get_int64_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int64_values	(	DDS::Int64Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2050 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_INT64>(value, id);
 }

◆ get_int8_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int8_value	(	CORBA::Int8 &	value,
		DDS::MemberId	id
	)

Definition at line 1249 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_ENUM.

Referenced by get_simple_value().

 {
   ACE_InputCDR::to_int8 to_int8(value);
   return get_single_value<TK_INT8>(to_int8, id, TK_ENUM, 1, 8);
 }

◆ get_int8_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_int8_values	(	DDS::Int8Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2030 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_ENUM, and value.

 {
   return get_sequence_values<TK_INT8>(value, id, TK_ENUM, 1, 8);
 }

◆ get_intermediate_chains()

const IntermediateChains& OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_intermediate_chains ( ) const

inlineprivate

Definition at line 533 of file DynamicDataXcdrReadImpl.h.

Referenced by skip_aggregated_member().

533 { return chains_to_release; }

OpenDDS::XTypes::DynamicDataXcdrReadImpl::chains_to_release

IntermediateChains chains_to_release

Definition: DynamicDataXcdrReadImpl.h:558

◆ get_item_count()

ACE_CDR::ULong OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_item_count ( )

Implements DDS::DynamicData.

Definition at line 374 of file DynamicDataXcdrReadImpl.cpp.

Referenced by get_member_id_at_index().

 {
   if (item_count_ != ITEM_COUNT_INVALID) {
     return item_count_;
   }
 
   ScopedChainManager chain_manager(*this);
 
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return 0;
   }
 
   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 1;
   case TK_STRING8:
   case TK_STRING16:
     {
       ACE_CDR::ULong bytes;
       if (!(strm_ >> bytes)) {
         return 0;
       }
       return (type_->get_kind() == TK_STRING8) ? bytes : bytes/2;
     }
   case TK_BITMASK:
     return descriptor->bound()[0];
   case TK_STRUCTURE:
     {
       bool has_optional;
       if (!has_optional_member(has_optional)) {
         return 0;
       }
 
       if (extent_ != DCPS::Sample::Full) {
         const bool struct_has_explicit_keys = has_explicit_keys(type_);
         if (struct_has_explicit_keys) {
           ACE_CDR::ULong num_explicit_keys = 0;
           for (ACE_CDR::ULong i = 0; i < type_->get_member_count(); ++i) {
             DDS::DynamicTypeMember_var dtm;
             if (type_->get_member_by_index(dtm, i) != DDS::RETCODE_OK) {
               return 0;
             }
             DDS::MemberDescriptor_var md;
             if (dtm->get_descriptor(md) != DDS::RETCODE_OK) {
               return 0;
             }
             if (md->is_key()) {
               ++num_explicit_keys;
             }
           }
           return num_explicit_keys;
         } else if (extent_ == DCPS::Sample::KeyOnly) {
           return 0;
         }
       }
 
       // Full sample or NestedKeyOnly sample with no explicit key.
       if (!has_optional) {
         return type_->get_member_count();
       }
 
       // Optional members can be omitted, so we need to count members one by one.
       ACE_CDR::ULong actual_count = 0;
       const DDS::ExtensibilityKind ek = descriptor->extensibility_kind();
       if (ek == DDS::FINAL || ek == DDS::APPENDABLE) {
         if (ek == DDS::APPENDABLE) {
           if (!strm_.skip_delimiter()) {
             return 0;
           }
         }
         for (ACE_CDR::ULong i = 0; i < type_->get_member_count(); ++i) {
           ACE_CDR::ULong num_skipped;
           if (!skip_struct_member_at_index(i, num_skipped)) {
             actual_count = 0;
             break;
           }
           actual_count += num_skipped;
         }
       } else { // Mutable
         size_t dheader = 0;
         if (!strm_.read_delimiter(dheader)) {
           return 0;
         }
 
         const size_t end_of_struct = strm_.rpos() + dheader;
         while (strm_.rpos() < end_of_struct) {
           ACE_CDR::ULong member_id;
           size_t member_size;
           bool must_understand;
           if (!strm_.read_parameter_id(member_id, member_size, must_understand)) {
             actual_count = 0;
             break;
           }
 
           DDS::DynamicTypeMember_var dtm;
           if (type_->get_member(dtm, member_id) != DDS::RETCODE_OK) {
             actual_count = 0;
             break;
           }
           DDS::MemberDescriptor_var descriptor;
           if (dtm->get_descriptor(descriptor) != DDS::RETCODE_OK) {
             actual_count = 0;
             break;
           }
           const DDS::DynamicType_ptr mt = descriptor->type();
           if (!mt) {
             actual_count = 0;
             break;
           }
           const DDS::DynamicType_var member = get_base_type(mt);
           if (member->get_kind() == TK_SEQUENCE) {
             if (!skip_sequence_member(member)) {
               actual_count = 0;
               break;
             }
           } else if (!strm_.skip(member_size)) {
             actual_count = 0;
             break;
           }
           ++actual_count;
         }
       }
       return actual_count;
     }
   case TK_UNION:
     {
       if (extent_ == DCPS::Sample::KeyOnly) {
         DDS::DynamicTypeMember_var disc_dtm;
         if (type_->get_member(disc_dtm, DISCRIMINATOR_ID) != DDS::RETCODE_OK) {
           return 0;
         }
         DDS::MemberDescriptor_var disc_md;
         if (disc_dtm->get_descriptor(disc_md) != DDS::RETCODE_OK) {
           return 0;
         }
         if (!disc_md->is_key()) {
           return 0;
         }
       }
       if (extent_ != DCPS::Sample::Full) {
         return 1;
       }
 
       const DDS::ExtensibilityKind ek = descriptor->extensibility_kind();
       if (ek == DDS::APPENDABLE || ek == DDS::MUTABLE) {
         if (!strm_.skip_delimiter()) {
           return 0;
         }
       }
       const DDS::DynamicType_var disc_type = get_base_type(descriptor->discriminator_type());
       const DDS::ExtensibilityKind extend = descriptor->extensibility_kind();
       ACE_CDR::Long label;
       if (!read_discriminator(disc_type, extend, label)) {
         return 0;
       }
 
       DDS::DynamicTypeMembersById_var members;
       if (type_->get_all_members(members) != DDS::RETCODE_OK) {
         return 0;
       }
       DynamicTypeMembersByIdImpl* members_impl = dynamic_cast<DynamicTypeMembersByIdImpl*>(members.in());
       if (!members_impl) {
         return 0;
       }
       for (DynamicTypeMembersByIdImpl::const_iterator it = members_impl->begin(); it != members_impl->end(); ++it) {
         DDS::MemberDescriptor_var md;
         if (it->second->get_descriptor(md) != DDS::RETCODE_OK) {
           return 0;
         }
         if (md->is_default_label()) {
           return 2;
         }
         const DDS::UnionCaseLabelSeq& labels = md->label();
         for (ACE_CDR::ULong i = 0; i < labels.length(); ++i) {
           if (label == labels[i]) {
             return 2;
           }
         }
       }
       return 1;
     }
   case TK_SEQUENCE:
     {
       const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
       if (!is_primitive(elem_type->get_kind())) {
         if (!strm_.skip_delimiter()) {
           return 0;
         }
       }
       ACE_CDR::ULong length;
       if (!(strm_ >> length)) {
         return 0;
       }
       return length;
     }
   case TK_ARRAY:
     return bound_total(type_desc_);
   case TK_MAP:
     {
       const DDS::DynamicType_var key_type = get_base_type(descriptor->key_element_type());
       const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
       if (is_primitive(key_type->get_kind()) &&
           is_primitive(elem_type->get_kind())) {
         ACE_CDR::ULong length;
         if (!(strm_ >> length)) {
           return 0;
         }
         return length;
       }
 
       size_t dheader;
       if (!strm_.read_delimiter(dheader)) {
         return 0;
       }
       const size_t end_of_map = strm_.rpos() + dheader;
 
       ACE_CDR::ULong length = 0;
       while (strm_.rpos() < end_of_map) {
         if (!skip_member(key_type) || !skip_member(elem_type)) {
           length = 0;
           break;
         }
         ++length;
       }
       return length;
     }
   }
 
   if (DCPS::DCPS_debug_level >= 1) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_item_count -")
                ACE_TEXT(" Calling on an unexpected type %C\n"), typekind_to_string(tk)));
   }
   return 0;
 }

◆ get_member_id_at_index()

DDS::MemberId OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_member_id_at_index ( ACE_CDR::ULong index )

Definition at line 165 of file DynamicDataXcdrReadImpl.cpp.

 {
   if (item_count_ == ITEM_COUNT_INVALID) {
     get_item_count();
   }
   if (index >= item_count_) {
     return MEMBER_ID_INVALID;
   }
 
   ScopedChainManager chain_manager(*this);
 
   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:
 #ifdef DDS_HAS_WCHAR
   case TK_CHAR16:
 #endif
   case TK_ENUM:
     // Value of enum or primitive types can be indicated by Id MEMBER_ID_INVALID
     // or by index 0 (Section 7.5.2.11.1).
     if (index != 0 && DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_member_id_at_index:"
                  " Received invalid index (%d) for type %C\n", index, typekind_to_string(tk)));
     }
     return MEMBER_ID_INVALID;
   case TK_STRING8:
 #ifdef DDS_HAS_WCHAR
   case TK_STRING16:
 #endif
   case TK_BITMASK:
   case TK_SEQUENCE:
   case TK_ARRAY:
   case TK_MAP:
     return index;
   case TK_STRUCTURE:
     {
       DDS::TypeDescriptor_var descriptor;
       if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
         return MEMBER_ID_INVALID;
       }
       const DDS::ExtensibilityKind ek = descriptor->extensibility_kind();
       if (ek == DDS::APPENDABLE || ek == DDS::MUTABLE) {
         if (!strm_.skip_delimiter()) {
           return MEMBER_ID_INVALID;
         }
       }
 
       if (ek == DDS::FINAL || ek == DDS::APPENDABLE) {
         bool has_optional;
         if (!has_optional_member(has_optional)) {
           return MEMBER_ID_INVALID;
         }
 
         if (extent_ != DCPS::Sample::Full) {
           const bool struct_has_explicit_keys = has_explicit_keys(type_);
           if (struct_has_explicit_keys) {
             // All and only explicit keys will be present in the binary stream.
             // Index of the next member in the binary stream.
             ACE_CDR::ULong curr_index = 0;
             for (ACE_CDR::ULong i = 0; i < type_->get_member_count(); ++i) {
               DDS::DynamicTypeMember_var dtm;
               if (type_->get_member_by_index(dtm, i) != DDS::RETCODE_OK) {
                 return MEMBER_ID_INVALID;
               }
               DDS::MemberDescriptor_var md;
               if (dtm->get_descriptor(md) != DDS::RETCODE_OK) {
                 return MEMBER_ID_INVALID;
               }
               if (exclude_member(extent_, md->is_key(), struct_has_explicit_keys)) {
                 continue;
               }
               if (curr_index == index) {
                 return md->id();
               }
               ++curr_index;
             }
             // Should never reach here!
             return MEMBER_ID_INVALID;
           } else if (extent_ == DCPS::Sample::KeyOnly) {
             return MEMBER_ID_INVALID;
           }
         }
 
         // A Full sample or a NestedKeyOnly sample with no explicit key.
         if (!has_optional) {
           DDS::DynamicTypeMember_var member;
           if (type_->get_member_by_index(member, index) != DDS::RETCODE_OK) {
             return MEMBER_ID_INVALID;
           }
           return member->get_id();
         } else {
           MemberId id = MEMBER_ID_INVALID;
           ACE_CDR::ULong total_skipped = 0;
           for (ACE_CDR::ULong i = 0; i < type_->get_member_count(); ++i) {
             ACE_CDR::ULong num_skipped;
             if (!skip_struct_member_at_index(i, num_skipped)) {
               break;
             }
             total_skipped += num_skipped;
             if (total_skipped == index + 1) {
               DDS::DynamicTypeMember_var member;
               if (type_->get_member_by_index(member, i) == DDS::RETCODE_OK) {
                 id = member->get_id();
               }
               break;
             }
           }
           return id;
         }
       } else { // Mutable
         ACE_CDR::ULong member_id;
         size_t member_size;
         bool must_understand;
         bool good = true;
         for (unsigned i = 0; i < index; ++i) {
           if (!strm_.read_parameter_id(member_id, member_size, must_understand)) {
             good = false;
             break;
           }
 
           DDS::DynamicTypeMember_var dtm;
           if (type_->get_member(dtm, member_id) != DDS::RETCODE_OK) {
             good = false;
             break;
           }
           DDS::MemberDescriptor_var descriptor;
           if (dtm->get_descriptor(descriptor) != DDS::RETCODE_OK) {
             good = false;
             break;
           }
           const DDS::DynamicType_ptr mt = descriptor->type();
           if (!mt) {
             good = false;
             break;
           }
           const DDS::DynamicType_var member = get_base_type(mt);
           if (member->get_kind() == TK_SEQUENCE) {
             if (!skip_sequence_member(member)) {
               good = false;
               break;
             }
           } else if (!strm_.skip(member_size)) {
             good = false;
             break;
           }
         }
 
         if (!good || !strm_.read_parameter_id(member_id, member_size, must_understand)) {
           member_id = MEMBER_ID_INVALID;
         }
         return member_id;
       }
     }
   case TK_UNION:
     {
       if (extent_ == DCPS::Sample::KeyOnly) {
         DDS::DynamicTypeMember_var disc_dtm;
         if (type_->get_member(disc_dtm, DISCRIMINATOR_ID) != DDS::RETCODE_OK) {
           return MEMBER_ID_INVALID;
         }
         DDS::MemberDescriptor_var disc_md;
         if (disc_dtm->get_descriptor(disc_md) != DDS::RETCODE_OK) {
           return MEMBER_ID_INVALID;
         }
         if (!disc_md->is_key()) {
           // The sample is empty.
           return MEMBER_ID_INVALID;
         }
       }
 
       if (index == 0) {
         return DISCRIMINATOR_ID;
       }
 
       if (extent_ != DCPS::Sample::Full) {
         // KeyOnly or NestedKeyOnly sample can only contain discriminator.
         return MEMBER_ID_INVALID;
       }
 
       // Get the Id of the selected member.
       DDS::MemberDescriptor_var selected_md = get_union_selected_member();
       if (!selected_md) {
         return MEMBER_ID_INVALID;
       }
 
       return selected_md->id();
     }
   }
 
   if (DCPS::DCPS_debug_level >= 1) {
     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_member_id_at_index -")
                ACE_TEXT(" Calling on an unexpected type %C\n"), typekind_to_string(tk)));
   }
   return MEMBER_ID_INVALID;
 }

◆ get_primitive_size()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_primitive_size	(	DDS::DynamicType_ptr	dt,
		ACE_CDR::ULong &	size
	)		const

private

Definition at line 2794 of file DynamicDataXcdrReadImpl.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 skip_array_member(), skip_map_member(), skip_sequence_member(), skip_to_array_element(), skip_to_map_element(), and skip_to_sequence_element().

 {
   size = 0;
 
   switch (dt->get_kind()) {
   case TK_BOOLEAN:
   case TK_BYTE:
   case TK_INT8:
   case TK_UINT8:
   case TK_CHAR8:
     size = 1;
     break;
   case TK_INT16:
   case TK_UINT16:
   case TK_CHAR16:
     size = 2;
     break;
   case TK_INT32:
   case TK_UINT32:
   case TK_FLOAT32:
     size = 4;
     break;
   case TK_INT64:
   case TK_UINT64:
   case TK_FLOAT64:
     size = 8;
     break;
   case TK_FLOAT128:
     size = 16;
     break;
   default:
     return false;
   }
   return true;
 }

◆ get_sequence_values()

template<TypeKind ElementTypeKind, typename SequenceType >

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_sequence_values	(	SequenceType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask = `TK_NONE`,
		LBound	lower = `0`,
		LBound	upper = `0`
	)

private

Common method to read a value sequence of any type (primitive, string, wstring).

Definition at line 1968 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::DynamicDataBase::is_type_supported(), LM_ERROR, DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::TK_STRUCTURE, OpenDDS::XTypes::TK_UNION, OpenDDS::XTypes::DynamicDataBase::type_, OpenDDS::XTypes::typekind_to_string(), and value.

 {
   if (!is_type_supported(ElementTypeKind, "get_sequence_values")) {
     return DDS::RETCODE_ERROR;
   }
 
   ScopedChainManager chain_manager(*this);
 
   const TypeKind tk = type_->get_kind();
   bool good = true;
 
   switch (tk) {
   case TK_STRUCTURE:
     {
       const DDS::ReturnCode_t rc =
         get_values_from_struct<ElementTypeKind>(value, id, enum_or_bitmask, lower, upper);
       if (rc == DDS::RETCODE_NO_DATA) {
         return rc;
       }
       good = rc == DDS::RETCODE_OK;
     }
     break;
   case TK_UNION:
     good = get_values_from_union<ElementTypeKind>(value, id, enum_or_bitmask, lower, upper);
     break;
   case TK_SEQUENCE:
     good = get_values_from_sequence<ElementTypeKind>(value, id, enum_or_bitmask, lower, upper);
     break;
   case TK_ARRAY:
     good = get_values_from_array<ElementTypeKind>(value, id, enum_or_bitmask, lower, upper);
     break;
   case TK_MAP:
     good = get_values_from_map<ElementTypeKind>(value, id, enum_or_bitmask, lower, upper);
     break;
   default:
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_sequence_values -")
                  ACE_TEXT(" A sequence<%C> can't be read as a member of type %C"),
                  typekind_to_string(ElementTypeKind), typekind_to_string(tk)));
     }
     return DDS::RETCODE_ERROR;
   }
 
   if (!good && DCPS::DCPS_debug_level >= 1) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_sequence_values -")
                ACE_TEXT(" Failed to read sequence<%C> from a DynamicData object of type %C\n"),
                typekind_to_string(ElementTypeKind), typekind_to_string(tk)));
   }
   return good ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
 }

◆ get_simple_value()

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

virtual

Reimplemented from OpenDDS::XTypes::DynamicDataBase.

Definition at line 2906 of file DynamicDataXcdrReadImpl.cpp.

 {
   DDS::DynamicTypeMember_var dtm;
   if (type_->get_member(dtm, id) != DDS::RETCODE_OK) {
     return DDS::RETCODE_ERROR;
   }
   DDS::MemberDescriptor_var md;
   if (dtm->get_descriptor(md) != DDS::RETCODE_OK) {
     return DDS::RETCODE_ERROR;
   }
   DDS::DynamicType_var member_type = get_base_type(md->type());
   const TypeKind member_kind = member_type->get_kind();
   switch (member_kind) {
   case TK_BOOLEAN:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_boolean_value);
   case TK_BYTE:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_byte_value);
   case TK_INT8:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_int8_value);
   case TK_INT16:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_int16_value);
   case TK_INT32:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_int32_value);
   case TK_INT64:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_int64_value_impl);
   case TK_UINT8:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_uint8_value);
   case TK_UINT16:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_uint16_value);
   case TK_UINT32:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_uint32_value);
   case TK_UINT64:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_uint64_value_impl);
   case TK_FLOAT32:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_float32_value);
   case TK_FLOAT64:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_float64_value);
   case TK_FLOAT128:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_float128_value);
   case TK_CHAR8:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_char8_value);
   case TK_CHAR16:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_char16_value);
   case TK_ENUM:
   case TK_STRING8:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_string_value);
   case TK_STRING16:
     return get_some_value(value, id, *this, &DynamicDataXcdrReadImpl::get_wstring_value);
   default:
     return DDS::RETCODE_UNSUPPORTED;
   }
 }

◆ get_single_value()

template<TypeKind ValueTypeKind, typename ValueType >

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_single_value	(	ValueType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask = `TK_NONE`,
		LBound	lower = `0`,
		LBound	upper = `0`
	)

private

Read a single value of type primitive (except char8, char16, and boolean), string, or wstring.

Definition at line 1168 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::is_primitive(), OpenDDS::XTypes::DynamicDataBase::is_type_supported(), LM_ERROR, read_value(), DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::TK_STRUCTURE, OpenDDS::XTypes::TK_UNION, OpenDDS::XTypes::DynamicDataBase::type_, OpenDDS::XTypes::typekind_to_string(), and value.

 {
   if (!is_type_supported(ValueTypeKind, "get_single_value")) {
     return DDS::RETCODE_ERROR;
   }
 
   ScopedChainManager chain_manager(*this);
 
   const TypeKind tk = type_->get_kind();
   bool good = true;
 
   // This is an extension to the XTypes spec where the value of a bitmask DynamicData
   // can be read as a whole as a unsigned integer.
   if (tk == enum_or_bitmask) {
     // Per XTypes spec, the value of a DynamicData object of primitive type or TK_ENUM is
     // accessed with MEMBER_ID_INVALID Id. However, there is only a single value in such
     // a DynamicData object, and checking for MEMBER_ID_INVALID from the input is perhaps
     // unnecessary. So, we read the value immediately here.
     DDS::TypeDescriptor_var descriptor;
     if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
       return DDS::RETCODE_ERROR;
     }
     const LBound bit_bound = descriptor->bound()[0];
     good = bit_bound >= lower && bit_bound <= upper && read_value(value, ValueTypeKind);
   } else {
     switch (tk) {
     case ValueTypeKind:
       good = is_primitive(tk) && read_value(value, ValueTypeKind);
       break;
     case TK_STRUCTURE:
       {
         const DDS::ReturnCode_t rc =
           get_value_from_struct<ValueTypeKind>(value, id, enum_or_bitmask, lower, upper);
         if (rc == DDS::RETCODE_NO_DATA) {
           return rc;
         }
         good = rc == DDS::RETCODE_OK;
       }
       break;
     case TK_UNION:
       {
         const DDS::ReturnCode_t rc =
           get_value_from_union<ValueTypeKind>(value, id, enum_or_bitmask, lower, upper);
         if (rc == DDS::RETCODE_NO_DATA) {
           return rc;
         }
         good = rc == DDS::RETCODE_OK;
       }
       break;
     case TK_SEQUENCE:
     case TK_ARRAY:
     case TK_MAP:
       good = get_value_from_collection<ValueTypeKind>(value, id, tk, enum_or_bitmask, lower, upper);
       break;
     default:
       good = false;
       break;
     }
   }
 
   if (!good && DCPS::DCPS_debug_level >= 1) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_single_value -")
                ACE_TEXT(" Failed to read a value of %C from a DynamicData object of type %C\n"),
                typekind_to_string(ValueTypeKind), typekind_to_string(tk)));
   }
   return good ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
 }

◆ get_string_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_string_value	(	char *&	value,
		DDS::MemberId	id
	)

Definition at line 1495 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::DynamicDataBase::enum_string_helper(), DDS::RETCODE_OK, CORBA::string_free(), and value.

Referenced by get_simple_value().

 {
   if (enum_string_helper(value, id)) {
     return DDS::RETCODE_OK;
   }
   CORBA::string_free(value);
   return get_single_value<TK_STRING8>(value, id);
 }

◆ get_string_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_string_values	(	DDS::StringSeq &	value,
		DDS::MemberId	id
	)

Definition at line 2099 of file DynamicDataXcdrReadImpl.cpp.

References value.

 {
   return get_sequence_values<TK_STRING8>(value, id);
 }

◆ get_uint16_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint16_value	(	CORBA::UShort &	value,
		DDS::MemberId	id
	)

Definition at line 1266 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK, and value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_UINT16>(value, id, TK_BITMASK, 9, 16);
 }

◆ get_uint16_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint16_values	(	DDS::UInt16Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2045 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK, and value.

 {
   return get_sequence_values<TK_UINT16>(value, id, TK_BITMASK, 9, 16);
 }

◆ get_uint32_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint32_value	(	CORBA::ULong &	value,
		DDS::MemberId	id
	)

Definition at line 1243 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK, and value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_UINT32>(value, id, TK_BITMASK,
                                      static_cast<LBound>(17), static_cast<LBound>(32));
 }

◆ get_uint32_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint32_values	(	DDS::UInt32Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2025 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK, and value.

 {
   return get_sequence_values<TK_UINT32>(value, id, TK_BITMASK, 17, 32);
 }

◆ get_uint64_value_impl()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint64_value_impl	(	CORBA::ULongLong &	value,
		DDS::MemberId	id
	)

Definition at line 1276 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK, and value.

Referenced by get_simple_value().

 {
   return get_single_value<TK_UINT64>(value, id, TK_BITMASK, 33, 64);
 }

◆ get_uint64_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint64_values	(	DDS::UInt64Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2055 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK, and value.

 {
   return get_sequence_values<TK_UINT64>(value, id, TK_BITMASK, 33, 64);
 }

◆ get_uint8_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint8_value	(	CORBA::UInt8 &	value,
		DDS::MemberId	id
	)

Definition at line 1255 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK.

Referenced by get_simple_value().

 {
   ACE_InputCDR::to_uint8 to_uint8(value);
   return get_single_value<TK_UINT8>(to_uint8, id, TK_BITMASK, 1, 8);
 }

◆ get_uint8_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_uint8_values	(	DDS::UInt8Seq &	value,
		DDS::MemberId	id
	)

Definition at line 2035 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::TK_BITMASK, and value.

 {
   return get_sequence_values<TK_UINT8>(value, id, TK_BITMASK, 1, 8);
 }

◆ get_union_selected_member()

DDS::MemberDescriptor * OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_union_selected_member ( )

private

Return the member descriptor for the selected member from a union data or null.

Definition at line 769 of file DynamicDataXcdrReadImpl.cpp.

References DDS::APPENDABLE, OpenDDS::XTypes::DynamicTypeMembersByIdImpl::begin(), OpenDDS::XTypes::DynamicTypeMembersByIdImpl::end(), OpenDDS::XTypes::get_base_type(), OpenDDS::XTypes::Sequence< T >::length(), DDS::MUTABLE, read_discriminator(), DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::skip_delimiter(), strm_, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_from_union_common_checks(), and get_member_id_at_index().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return 0;
   }
 
   const DDS::ExtensibilityKind ek = descriptor->extensibility_kind();
   if (ek == DDS::APPENDABLE || ek == DDS::MUTABLE) {
     if (!strm_.skip_delimiter()) {
       return 0;
     }
   }
 
   const DDS::DynamicType_var disc_type = get_base_type(descriptor->discriminator_type());
   ACE_CDR::Long label;
   if (!read_discriminator(disc_type, ek, label)) {
     return 0;
   }
 
   DDS::DynamicTypeMembersById_var members;
   if (type_->get_all_members(members) != DDS::RETCODE_OK) {
     return 0;
   }
   DynamicTypeMembersByIdImpl* members_impl = dynamic_cast<DynamicTypeMembersByIdImpl*>(members.in());
   if (!members_impl) {
     return 0;
   }
 
   bool has_default = false;
   DDS::MemberDescriptor_var default_member;
   for (DynamicTypeMembersByIdImpl::const_iterator it = members_impl->begin(); it != members_impl->end(); ++it) {
     DDS::MemberDescriptor_var md;
     if (it->second->get_descriptor(md) != DDS::RETCODE_OK) {
       return 0;
     }
     const DDS::UnionCaseLabelSeq& labels = md->label();
     for (ACE_CDR::ULong i = 0; i < labels.length(); ++i) {
       if (label == labels[i]) {
         return md._retn();
       }
     }
 
     if (md->is_default_label()) {
       has_default = true;
       default_member = md;
     }
   }
 
   if (has_default) {
     return default_member._retn();;
   }
 
   // The union has no selected member.
   return 0;
 }

◆ get_value_from_collection()

template<TypeKind ElementTypeKind, typename ElementType >

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_value_from_collection	(	ElementType &	value,
		MemberId	id,
		TypeKind	collection_tk,
		TypeKind	enum_or_bitmask = `TK_NONE`,
		LBound	lower = `0`,
		LBound	upper = `0`
	)

private

Reading a value of type primitive, string, or wstring as a member of a struct, union, or a collection (sequence, array, map). TK_ENUM should be passed to enum_or_bitmask if is a 8-bit, 16-bit, or 32-bit signed integer type. In that case, and should be set to form the bit_bound range of the enum type that matches the number of bits of value. For instance, if we are reading a 8-bit integer, then is TK_ENUM, lower is 1 and upper is 8. This allows reading an enum with a particular bit bound as an integer with the matching size. Similarly, if we are reading an unsigned integer, set enum_or_bitmask to TK_BITMASK, and lower and upper to form a corresponding range for the bitmask's bit bound.

Definition at line 1104 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::get_base_type(), LM_ERROR, read_value(), DDS::RETCODE_OK, skip_to_array_element(), skip_to_map_element(), skip_to_sequence_element(), OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
   const TypeKind elem_tk = elem_type->get_kind();
 
   if (elem_tk != ElementTypeKind && elem_tk != enum_or_bitmask) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_value_from_collection -")
                  ACE_TEXT(" Could not read a value of type %C from %C with element type %C\n"),
                  typekind_to_string(ElementTypeKind), typekind_to_string(collection_tk),
                  typekind_to_string(elem_tk)));
     }
     return false;
   }
 
   if (elem_tk == enum_or_bitmask) {
     DDS::TypeDescriptor_var td;
     if (elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
       return false;
     }
     const LBound bit_bound = td->bound()[0];
     if (bit_bound < lower || bit_bound > upper) {
       return false;
     }
   }
 
   switch (collection_tk) {
   case TK_SEQUENCE:
     if (!skip_to_sequence_element(id)) {
       return false;
     }
     break;
   case TK_ARRAY:
     if (!skip_to_array_element(id)) {
       return false;
     }
     break;
   case TK_MAP:
     if (!skip_to_map_element(id)) {
       return false;
     }
     break;
   default:
     return false;
   }
 
   return read_value(value, ElementTypeKind);
 }

◆ get_value_from_struct()

template<TypeKind MemberTypeKind, typename MemberType >

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_value_from_struct	(	MemberType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask = `TK_NONE`,
		LBound	lower = `0`,
		LBound	upper = `0`
	)

private

Reading a value of type primitive, string, or wstring as a member of a struct, union, or a collection (sequence, array, map). TK_ENUM should be passed to enum_or_bitmask if is a 8-bit, 16-bit, or 32-bit signed integer type. In that case, and should be set to form the bit_bound range of the enum type that matches the number of bits of value. For instance, if we are reading a 8-bit integer, then is TK_ENUM, lower is 1 and upper is 8. This allows reading an enum with a particular bit bound as an integer with the matching size. Similarly, if we are reading an unsigned integer, set enum_or_bitmask to TK_BITMASK, and lower and upper to form a corresponding range for the bitmask's bit bound.

Definition at line 723 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, exclude_struct_member(), extent_, OpenDDS::XTypes::get_base_type(), get_from_struct_common_checks(), OpenDDS::DCPS::Sample::KeyOnly, LM_NOTICE, OpenDDS::DCPS::LogLevel::Notice, read_value(), DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, and skip_to_struct_member().

 {
   DDS::MemberDescriptor_var md;
   if (exclude_struct_member(id, md)) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_value_from_struct:"
                  " Attempted to read an excluded member from a %C sample\n",
                  extent_ == DCPS::Sample::KeyOnly ? "KeyOnly" : "NestedKeyOnly"));
     }
     return DDS::RETCODE_NO_DATA;
   }
 
   DDS::ReturnCode_t rc;
   if (get_from_struct_common_checks(md, id, MemberTypeKind)) {
     rc = skip_to_struct_member(md, id);
     if (rc != DDS::RETCODE_OK) {
       return rc;
     }
     return read_value(value, MemberTypeKind) ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
   }
 
   if (get_from_struct_common_checks(md, id, enum_or_bitmask)) {
     const DDS::DynamicType_ptr member_type = md->type();
     if (member_type) {
       DDS::TypeDescriptor_var td;
       rc = get_base_type(member_type)->get_descriptor(td);
       if (rc != DDS::RETCODE_OK) {
         return rc;
       }
       const LBound bit_bound = td->bound()[0];
       if (bit_bound >= lower && bit_bound <= upper) {
         rc = skip_to_struct_member(md, id);
         if (rc != DDS::RETCODE_OK) {
           return rc;
         }
         if (read_value(value, MemberTypeKind)) {
           return DDS::RETCODE_OK;
         }
       }
     }
   }
 
   return DDS::RETCODE_ERROR;
 }

◆ get_value_from_union()

template<TypeKind MemberTypeKind, typename MemberType >

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_value_from_union	(	MemberType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask = `TK_NONE`,
		LBound	lower = `0`,
		LBound	upper = `0`
	)

private

Reading a value of type primitive, string, or wstring as a member of a struct, union, or a collection (sequence, array, map). TK_ENUM should be passed to enum_or_bitmask if is a 8-bit, 16-bit, or 32-bit signed integer type. In that case, and should be set to form the bit_bound range of the enum type that matches the number of bits of value. For instance, if we are reading a 8-bit integer, then is TK_ENUM, lower is 1 and upper is 8. This allows reading an enum with a particular bit bound as an integer with the matching size. Similarly, if we are reading an unsigned integer, set enum_or_bitmask to TK_BITMASK, and lower and upper to form a corresponding range for the bitmask's bit bound.

Definition at line 892 of file DynamicDataXcdrReadImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), DDS::APPENDABLE, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::DISCRIMINATOR_ID, exclude_union_member(), OpenDDS::XTypes::get_base_type(), get_from_union_common_checks(), LM_DEBUG, LM_ERROR, LM_NOTICE, DDS::MUTABLE, OpenDDS::DCPS::LogLevel::Notice, OpenDDS::DCPS::Serializer::read_parameter_id(), read_value(), DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::skip_delimiter(), strm_, type(), OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   if (exclude_union_member(id)) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_value_from_union:"
                  " Reading an excluded member with Id %u\n", id));
     }
     return DDS::RETCODE_NO_DATA;
   }
 
   DDS::TypeDescriptor_var descriptor;
   DDS::ReturnCode_t rc = type_->get_descriptor(descriptor);
   if (rc != DDS::RETCODE_OK) {
     return rc;
   }
 
   DDS::DynamicType_var member_type;
   if (id == DISCRIMINATOR_ID) {
     const DDS::ExtensibilityKind ek = descriptor->extensibility_kind();
     if (ek == DDS::APPENDABLE || ek == DDS::MUTABLE) {
       if (!strm_.skip_delimiter()) {
         return DDS::RETCODE_ERROR;
       }
     }
     member_type = get_base_type(descriptor->discriminator_type());
   } else {
     DDS::MemberDescriptor_var md = get_from_union_common_checks(id, "get_value_from_union");
     if (!md) {
       return DDS::RETCODE_ERROR;
     }
 
     const DDS::DynamicType_ptr type = md->type();
     if (!type) {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_value_from_union -")
                    ACE_TEXT(" Could not get DynamicType of the selected member\n")));
       }
       return DDS::RETCODE_ERROR;
     }
     member_type = get_base_type(type);
   }
 
   const TypeKind member_tk = member_type->get_kind();
   if (member_tk != MemberTypeKind && member_tk != enum_or_bitmask) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_value_from_union -")
                  ACE_TEXT(" Could not read a value of type %C from type %C\n"),
                  typekind_to_string(MemberTypeKind), typekind_to_string(member_tk)));
     }
     return DDS::RETCODE_ERROR;
   }
 
   if (descriptor->extensibility_kind() == DDS::MUTABLE) {
     unsigned member_id;
     size_t member_size;
     bool must_understand;
     if (!strm_.read_parameter_id(member_id, member_size, must_understand)) {
       return DDS::RETCODE_ERROR;
     }
   }
 
   if (member_tk == MemberTypeKind) {
     return read_value(value, MemberTypeKind) ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
   }
 
   DDS::TypeDescriptor_var td;
   rc = member_type->get_descriptor(td);
   if (rc != DDS::RETCODE_OK) {
     return rc;
   }
   const LBound bit_bound = td->bound()[0];
   return bit_bound >= lower && bit_bound <= upper &&
     read_value(value, MemberTypeKind) ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
 }

◆ get_values_from_array()

template<TypeKind ElementTypeKind, typename SequenceType >

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_array	(	SequenceType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask,
		LBound	lower,
		LBound	upper
	)

private

Templates for reading a sequence of primitives, strings or wstrings as a member (or an element) of a given containing type. See get_value_from_struct and the similar methods for the use of enum_or_bitmask, lower, upper.

Definition at line 1878 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::get_base_type(), LM_ERROR, read_values(), DDS::RETCODE_OK, skip_to_array_element(), OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
   if (elem_type->get_kind() != TK_SEQUENCE) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_array -")
                  ACE_TEXT(" Could not read a sequence of %C from an array of %C\n"),
                  typekind_to_string(ElementTypeKind), typekind_to_string(elem_type->get_kind())));
     }
     return false;
   }
 
   DDS::TypeDescriptor_var td;
   if (elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
     return false;
   }
   const DDS::DynamicType_var nested_elem_type = get_base_type(td->element_type());
   const TypeKind nested_elem_tk = nested_elem_type->get_kind();
   if (nested_elem_tk == ElementTypeKind) {
     return skip_to_array_element(id) && read_values(value, nested_elem_tk);
   } else if (nested_elem_tk == enum_or_bitmask) {
     DDS::TypeDescriptor_var td;
     if (nested_elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
       return false;
     }
     const LBound bit_bound = td->bound()[0];
     return bit_bound >= lower && bit_bound <= upper &&
       skip_to_array_element(id) && read_values(value, nested_elem_tk);
   }
 
   if (DCPS::DCPS_debug_level >= 1) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_array -")
                ACE_TEXT(" Could not read a sequence of %C from an array of sequence of %C\n"),
                typekind_to_string(ElementTypeKind), typekind_to_string(nested_elem_tk)));
   }
   return false;
 }

◆ get_values_from_map()

template<TypeKind ElementTypeKind, typename SequenceType >

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_map	(	SequenceType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask,
		LBound	lower,
		LBound	upper
	)

private

Templates for reading a sequence of primitives, strings or wstrings as a member (or an element) of a given containing type. See get_value_from_struct and the similar methods for the use of enum_or_bitmask, lower, upper.

Definition at line 1923 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::get_base_type(), LM_ERROR, read_values(), DDS::RETCODE_OK, skip_to_map_element(), OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
   if (elem_type->get_kind() != TK_SEQUENCE) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_map -")
                  ACE_TEXT(" Getting sequence<%C> from a map with element type of %C\n"),
                  typekind_to_string(ElementTypeKind), typekind_to_string(elem_type->get_kind())));
     }
     return false;
   }
 
   DDS::TypeDescriptor_var td;
   if (elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
     return false;
   }
   const DDS::DynamicType_var nested_elem_type = get_base_type(td->element_type());
   const TypeKind nested_elem_tk = nested_elem_type->get_kind();
   if (nested_elem_tk == ElementTypeKind) {
     return skip_to_map_element(id) && read_values(value, nested_elem_tk);
   } else if (nested_elem_tk == enum_or_bitmask) {
     DDS::TypeDescriptor_var td;
     if (nested_elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
       return false;
     }
     const LBound bit_bound = td->bound()[0];
     return bit_bound >= lower && bit_bound <= upper &&
       skip_to_map_element(id) && read_values(value, nested_elem_tk);
   }
 
   if (DCPS::DCPS_debug_level >= 1) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_map -")
                ACE_TEXT(" Could not read a sequence of %C from a map with element type sequence of %C\n"),
                typekind_to_string(ElementTypeKind), typekind_to_string(nested_elem_tk)));
   }
   return false;
 }

◆ get_values_from_sequence()

template<TypeKind ElementTypeKind, typename SequenceType >

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_sequence	(	SequenceType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask,
		LBound	lower,
		LBound	upper
	)

private

Templates for reading a sequence of primitives, strings or wstrings as a member (or an element) of a given containing type. See get_value_from_struct and the similar methods for the use of enum_or_bitmask, lower, upper.

Definition at line 1826 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::get_base_type(), LM_ERROR, read_values(), DDS::RETCODE_OK, skip_to_sequence_element(), OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
   const TypeKind elem_tk = elem_type->get_kind();
 
   if (elem_tk == ElementTypeKind) {
     return read_values(value, ElementTypeKind);
   } else if (elem_tk == enum_or_bitmask) {
     // Read from a sequence of enums or bitmasks.
     DDS::TypeDescriptor_var td;
     if (elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
       return false;
     }
     const LBound bit_bound = td->bound()[0];
     return bit_bound >= lower && bit_bound <= upper && read_values(value, enum_or_bitmask);
   } else if (elem_tk == TK_SEQUENCE) {
     DDS::TypeDescriptor_var td;
     if (elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
       return false;
     }
     const DDS::DynamicType_var nested_elem_type = get_base_type(td->element_type());
     const TypeKind nested_elem_tk = nested_elem_type->get_kind();
     if (nested_elem_tk == ElementTypeKind) {
       // Read from a sequence of sequences of ElementTypeKind.
       return skip_to_sequence_element(id) && read_values(value, ElementTypeKind);
     } else if (nested_elem_tk == enum_or_bitmask) {
       // Read from a sequence of sequences of enums or bitmasks.
       DDS::TypeDescriptor_var td;
       if (nested_elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
         return false;
       }
       const LBound bit_bound = td->bound()[0];
       return bit_bound >= lower && bit_bound <= upper &&
         skip_to_sequence_element(id) && read_values(value, enum_or_bitmask);
     }
   }
 
   if (DCPS::DCPS_debug_level >= 1) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_sequence -")
                ACE_TEXT(" Could not read a sequence of %C from an incompatible type\n"),
                typekind_to_string(ElementTypeKind)));
   }
   return false;
 }

◆ get_values_from_struct()

template<TypeKind ElementTypeKind, typename SequenceType >

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_struct	(	SequenceType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask,
		LBound	lower,
		LBound	upper
	)

private

Templates for reading a sequence of primitives, strings or wstrings as a member (or an element) of a given containing type. See get_value_from_struct and the similar methods for the use of enum_or_bitmask, lower, upper.

Definition at line 1688 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, exclude_struct_member(), extent_, OpenDDS::XTypes::get_base_type(), OpenDDS::XTypes::DynamicDataBase::get_descriptor(), get_from_struct_common_checks(), OpenDDS::DCPS::Sample::KeyOnly, LM_NOTICE, OpenDDS::DCPS::LogLevel::Notice, read_values(), DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, and skip_to_struct_member().

 {
   DDS::MemberDescriptor_var md;
   if (exclude_struct_member(id, md)) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_values_from_struct:"
                  " Attempted to read a member not included in a %C sample\n",
                  extent_ == DCPS::Sample::KeyOnly ? "KeyOnly" : "NestedKeyOnly"));
     }
     return DDS::RETCODE_NO_DATA;
   }
 
   if (get_from_struct_common_checks(md, id, ElementTypeKind, true)) {
     const DDS::ReturnCode_t rc = skip_to_struct_member(md, id);
     if (rc != DDS::RETCODE_OK) {
       return rc;
     }
     return read_values(value, ElementTypeKind) ? DDS::RETCODE_OK : DDS::RETCODE_ERROR;
   }
 
   if (get_from_struct_common_checks(md, id, enum_or_bitmask, true)) {
     const DDS::DynamicType_ptr member_type = md->type();
     if (member_type) {
       DDS::TypeDescriptor_var td;
       DDS::ReturnCode_t rc = get_base_type(member_type)->get_descriptor(td);
       if (rc != DDS::RETCODE_OK) {
         return rc;
       }
       DDS::TypeDescriptor_var etd;
       rc = get_base_type(td->element_type())->get_descriptor(etd);
       if (rc != DDS::RETCODE_OK) {
         return rc;
       }
       const LBound bit_bound = etd->bound()[0];
       if (bit_bound >= lower && bit_bound <= upper) {
         const DDS::ReturnCode_t rc = skip_to_struct_member(md, id);
         if (rc != DDS::RETCODE_OK) {
           return rc;
         }
         if (read_values(value, enum_or_bitmask)) {
           return DDS::RETCODE_OK;
         }
       }
     }
   }
 
   return DDS::RETCODE_ERROR;
 }

◆ get_values_from_union()

template<TypeKind ElementTypeKind, typename SequenceType >

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_values_from_union	(	SequenceType &	value,
		MemberId	id,
		TypeKind	enum_or_bitmask,
		LBound	lower,
		LBound	upper
	)

private

Templates for reading a sequence of primitives, strings or wstrings as a member (or an element) of a given containing type. See get_value_from_struct and the similar methods for the use of enum_or_bitmask, lower, upper.

Definition at line 1739 of file DynamicDataXcdrReadImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::DISCRIMINATOR_ID, exclude_union_member(), OpenDDS::XTypes::get_base_type(), get_from_union_common_checks(), LM_DEBUG, LM_ERROR, LM_NOTICE, DDS::MUTABLE, OpenDDS::DCPS::LogLevel::Notice, OpenDDS::DCPS::Serializer::read_parameter_id(), read_values(), DDS::RETCODE_OK, strm_, OpenDDS::XTypes::TK_SEQUENCE, OpenDDS::XTypes::DynamicDataBase::type_, and OpenDDS::XTypes::typekind_to_string().

 {
   if (id == DISCRIMINATOR_ID) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_values_from_union:"
                  " Attempted to read discriminator as a sequence\n"));
     }
     return false;
   }
 
   if (exclude_union_member(id)) {
     if (DCPS::log_level >= DCPS::LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::get_values_from_union:"
                  " Attempted to read an excluded member with Id %u\n", id));
     }
     return false;
   }
 
   DDS::MemberDescriptor_var md = get_from_union_common_checks(id, "get_values_from_union");
   if (!md) {
     return false;
   }
 
   const DDS::DynamicType_ptr member_type = md->type();
   if (!member_type) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_union -")
                  ACE_TEXT(" Could not get DynamicType of the selected member\n")));
     }
     return false;
   }
 
   DDS::DynamicType_var selected_type = get_base_type(member_type);
   const TypeKind selected_tk = selected_type->get_kind();
   if (selected_tk != TK_SEQUENCE) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_union -")
                  ACE_TEXT(" The selected member is not a sequence, but %C\n"),
                  typekind_to_string(selected_tk)));
     }
     return false;
   }
 
   DDS::TypeDescriptor_var td;
   if (selected_type->get_descriptor(td) != DDS::RETCODE_OK) {
     return false;
   }
   const DDS::DynamicType_var elem_type = get_base_type(td->element_type());
   const TypeKind elem_tk = elem_type->get_kind();
   if (elem_tk != ElementTypeKind && elem_tk != enum_or_bitmask) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::get_values_from_union -")
                  ACE_TEXT(" Could not read a sequence of %C from a sequence of %C\n"),
                  typekind_to_string(ElementTypeKind), typekind_to_string(elem_tk)));
     }
     return false;
   }
 
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   if (descriptor->extensibility_kind() == DDS::MUTABLE) {
     unsigned member_id;
     size_t member_size;
     bool must_understand;
     if (!strm_.read_parameter_id(member_id, member_size, must_understand)) {
       return false;
     }
   }
 
   if (elem_tk == ElementTypeKind) {
     return read_values(value, ElementTypeKind);
   }
 
   // Reset.
   td = 0;
   if (elem_type->get_descriptor(td) != DDS::RETCODE_OK) {
     return false;
   }
   const LBound bit_bound = td->bound()[0];
   return bit_bound >= lower && bit_bound <= upper && read_values(value, enum_or_bitmask);
 }

◆ get_wstring_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_wstring_value	(	CORBA::WChar *&	value,
		DDS::MemberId	id
	)

Definition at line 1504 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED, value, and CORBA::wstring_free().

Referenced by get_simple_value().

 {
 #ifdef DDS_HAS_WCHAR
   CORBA::wstring_free(value);
   return get_single_value<TK_STRING16>(value, id);
 #else
   return DDS::RETCODE_UNSUPPORTED;
 #endif
 }

◆ get_wstring_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::get_wstring_values	(	DDS::WstringSeq &	value,
		DDS::MemberId	id
	)

Definition at line 2104 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED, and value.

 {
 #ifdef DDS_HAS_WCHAR
   return get_sequence_values<TK_STRING16>(value, id);
 #else
   return DDS::RETCODE_UNSUPPORTED;
 #endif
 }

◆ has_optional_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::has_optional_member ( bool & has_optional ) const

private

Definition at line 140 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_OK, OpenDDS::XTypes::TK_STRUCTURE, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_item_count(), and get_member_id_at_index().

 {
   if (type_->get_kind() != TK_STRUCTURE) {
     return false;
   }
 
   const ACE_CDR::ULong count = type_->get_member_count();
   for (unsigned i = 0; i < count; ++i) {
     DDS::DynamicTypeMember_var member;
     if (type_->get_member_by_index(member, i) != DDS::RETCODE_OK) {
       return false;
     }
     DDS::MemberDescriptor_var descriptor;
     if (member->get_descriptor(descriptor) != DDS::RETCODE_OK) {
       return false;
     }
     if (descriptor->is_optional()) {
       has_optional = true;
       return true;
     }
   }
   has_optional = false;
   return true;
 }

◆ loan_value()

DDS::DynamicData_ptr OpenDDS::XTypes::DynamicDataXcdrReadImpl::loan_value ( DDS::MemberId id )

Definition at line 641 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, and LM_ERROR.

 {
   ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: DynamicDataXcdrReadImpl::loan_value: Not implemented\n"));
   return 0;
 }

◆ OPENDDS_SET()

typedef OpenDDS::XTypes::DynamicDataXcdrReadImpl::OPENDDS_SET ( DCPS::String )

private

A set of strings used to prevent infinite recursion when checking for XCDR1 Mutable.

◆ OPENDDS_VECTOR()

typedef OpenDDS::XTypes::DynamicDataXcdrReadImpl::OPENDDS_VECTOR ( ACE_Message_Block * )

private

◆ operator=()

DynamicDataXcdrReadImpl & OpenDDS::XTypes::DynamicDataXcdrReadImpl::operator= ( const DynamicDataXcdrReadImpl & other )

Definition at line 109 of file DynamicDataXcdrReadImpl.cpp.

References copy().

 {
   if (this != &other) {
     copy(other);
   }
   return *this;
 }

◆ read_discriminator()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::read_discriminator	(	const DDS::DynamicType_ptr	disc_type,
		DDS::ExtensibilityKind	union_ek,
		ACE_CDR::Long &	label
	)

private

Definition at line 2577 of file DynamicDataXcdrReadImpl.cpp.

Referenced by get_item_count(), get_union_selected_member(), and skip_all().

 {
   if (union_ek == DDS::MUTABLE) {
     unsigned id;
     size_t size;
     bool must_understand;
     if (!strm_.read_parameter_id(id, size, must_understand)) { return false; }
   }
 
   const TypeKind disc_tk = disc_type->get_kind();
   switch (disc_tk) {
   case TK_BOOLEAN:
     {
       ACE_CDR::Boolean value;
       if (!(strm_ >> ACE_InputCDR::to_boolean(value))) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_BYTE:
     {
       ACE_CDR::Octet value;
       if (!(strm_ >> ACE_InputCDR::to_octet(value))) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_CHAR8:
     {
       ACE_CDR::Char value;
       if (!(strm_ >> ACE_InputCDR::to_char(value))) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_CHAR16:
     {
       ACE_CDR::WChar value;
       if (!(strm_ >> ACE_InputCDR::to_wchar(value))) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_INT8:
     {
       ACE_CDR::Int8 value;
       if (!(strm_ >> ACE_InputCDR::to_int8(value))) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_UINT8:
     {
       ACE_CDR::UInt8 value;
       if (!(strm_ >> ACE_InputCDR::to_uint8(value))) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_INT16:
     {
       ACE_CDR::Short value;
       if (!(strm_ >> value)) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_UINT16:
     {
       ACE_CDR::UShort value;
       if (!(strm_ >> value)) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_INT32:
     return strm_ >> label;
   case TK_UINT32:
     {
       ACE_CDR::ULong value;
       if (!(strm_ >> value)) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_INT64:
     {
       ACE_CDR::LongLong value;
       if (!(strm_ >> value)) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_UINT64:
     {
       ACE_CDR::ULongLong value;
       if (!(strm_ >> value)) { return false; }
       label = static_cast<ACE_CDR::Long>(value);
       return true;
     }
   case TK_ENUM:
     {
       DDS::TypeDescriptor_var disc_td;
       if (disc_type->get_descriptor(disc_td) != DDS::RETCODE_OK) {
         return false;
       }
       const ACE_CDR::ULong bit_bound = disc_td->bound()[0];
       if (bit_bound >= 1 && bit_bound <= 8) {
         ACE_CDR::Int8 value;
         if (!(strm_ >> ACE_InputCDR::to_int8(value))) { return false; }
         label = static_cast<ACE_CDR::Long>(value);
       } else if (bit_bound >= 9 && bit_bound <= 16) {
         ACE_CDR::Short value;
         if (!(strm_ >> value)) { return false; }
         label = static_cast<ACE_CDR::Long>(value);
       } else {
         return strm_ >> label;
       }
       return true;
     }
   default:
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::read_discriminator - Union has")
                  ACE_TEXT(" unsupported discriminator type (%C)\n"), typekind_to_string(disc_tk)));
     }
     return false;
   }
 }

◆ read_value()

template<typename ValueType >

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::read_value	(	ValueType &	value,
		TypeKind	tk
	)

private

Reading a single value as a given type. For instance, an enum with bit bound of 32 is read as an 32-bit integer and thus TK_INT32 should be passed to tk.

Definition at line 660 of file DynamicDataXcdrReadImpl.cpp.

Referenced by get_boolean_from_bitmask(), get_boolean_value(), get_single_value(), get_value_from_collection(), get_value_from_struct(), and get_value_from_union().

 {
   switch (tk) {
   case TK_INT32:
   case TK_UINT32:
   case TK_INT16:
   case TK_UINT16:
   case TK_INT64:
   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_BYTE:
   case TK_BOOLEAN:
   case TK_STRING8:
   case TK_STRING16:
     if (strm_ >> value) {
       return true;
     }
     break;
   default:
     if (log_level >= LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::read_value: "
                  "Calling on an unexpected type %C\n", typekind_to_string(tk)));
     }
     return false;
   }
 
   if (log_level >= LogLevel::Notice) {
     ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::read_value: "
                "failed to deserialize type %C\n", typekind_to_string(tk)));
   }
   return false;
 }

◆ read_values()

template<typename SequenceType >

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::read_values	(	SequenceType &	value,
		TypeKind	elem_tk
	)

private

Read a sequence with element type elem_tk and store the result in value, which is a sequence of primitives or strings or wstrings. Sequence of enums or bitmasks are read as a sequence of signed and unsigned integers, respectively. In that case, elem_tk is set to TK_ENUM or TK_BITMASK.

Definition at line 1640 of file DynamicDataXcdrReadImpl.cpp.

Referenced by get_values_from_array(), get_values_from_map(), get_values_from_sequence(), get_values_from_struct(), and get_values_from_union().

 {
   using OpenDDS::DCPS::operator>>;
 
   switch(elem_tk) {
   case TK_INT32:
   case TK_UINT32:
   case TK_INT16:
   case TK_UINT16:
   case TK_INT64:
   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_BYTE:
   case TK_BOOLEAN:
   case TK_STRING8:
   case TK_STRING16:
     if (strm_ >> value) {
       return true;
     }
     break;
   case TK_ENUM:
   case TK_BITMASK:
     if (strm_.skip_delimiter() && strm_ >> value) {
       return true;
     }
     break;
   default:
     if (log_level >= LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::read_values: "
                  "Calling on an unexpected element type %C\n", typekind_to_string(elem_tk)));
     }
     return false;
   }
 
   if (log_level >= LogLevel::Notice) {
     ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::read_values: "
                "failed to deserialize element type %C\n", typekind_to_string(elem_tk)));
   }
   return false;
 }

◆ release_chains()

void OpenDDS::XTypes::DynamicDataXcdrReadImpl::release_chains ( )

private

Definition at line 2569 of file DynamicDataXcdrReadImpl.cpp.

References chains_to_release, and ACE_Message_Block::release().

 {
   for (ACE_CDR::ULong i = 0; i < chains_to_release.size(); ++i) {
     ACE_Message_Block::release(chains_to_release[i]);
   }
   chains_to_release.clear();
 }

◆ return_loaned_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::return_loaned_value ( DDS::DynamicData_ptr value )

Definition at line 647 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, LM_ERROR, and DDS::RETCODE_UNSUPPORTED.

 {
   ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: DynamicDataXcdrReadImpl::return_loaned_value: Not implemented\n"));
   return DDS::RETCODE_UNSUPPORTED;
 }

◆ set_boolean_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_boolean_value	(	DDS::MemberId	,
		CORBA::Boolean
	)

inline

Definition at line 169 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_boolean_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_boolean_values	(	DDS::MemberId	,
		const DDS::BooleanSeq &
	)

inline

Definition at line 313 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_byte_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_byte_value	(	DDS::MemberId	,
		CORBA::Octet
	)

inline

Definition at line 161 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_byte_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_byte_values	(	DDS::MemberId	,
		const DDS::ByteSeq &
	)

inline

Definition at line 305 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_char16_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_char16_value	(	DDS::MemberId	,
		CORBA::WChar
	)

inline

Definition at line 153 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_char16_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_char16_values	(	DDS::MemberId	,
		const DDS::WcharSeq &
	)

inline

Definition at line 297 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_char8_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_char8_value	(	DDS::MemberId	,
		CORBA::Char
	)

inline

Definition at line 145 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_char8_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_char8_values	(	DDS::MemberId	,
		const DDS::CharSeq &
	)

inline

Definition at line 289 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_complex_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_complex_value	(	DDS::MemberId	,
		DDS::DynamicData_ptr
	)

inline

Definition at line 193 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_descriptor()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_descriptor	(	MemberId	id,
		DDS::MemberDescriptor *	value
	)

Definition at line 135 of file DynamicDataXcdrReadImpl.cpp.

References DDS::RETCODE_UNSUPPORTED.

 {
   return DDS::RETCODE_UNSUPPORTED;
 }

◆ set_float128_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_float128_value	(	DDS::MemberId	,
		CORBA::LongDouble
	)

inline

Definition at line 137 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_float128_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_float128_values	(	DDS::MemberId	,
		const DDS::Float128Seq &
	)

inline

Definition at line 281 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_float32_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_float32_value	(	DDS::MemberId	,
		CORBA::Float
	)

inline

Definition at line 121 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_float32_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_float32_values	(	DDS::MemberId	,
		const DDS::Float32Seq &
	)

inline

Definition at line 265 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_float64_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_float64_value	(	DDS::MemberId	,
		CORBA::Double
	)

inline

Definition at line 129 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_float64_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_float64_values	(	DDS::MemberId	,
		const DDS::Float64Seq &
	)

inline

Definition at line 273 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int16_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int16_value	(	DDS::MemberId	,
		CORBA::Short
	)

inline

Definition at line 91 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int16_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int16_values	(	DDS::MemberId	,
		const DDS::Int16Seq &
	)

inline

Definition at line 233 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int32_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int32_value	(	DDS::MemberId	,
		CORBA::Long
	)

inline

Definition at line 59 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int32_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int32_values	(	DDS::MemberId	,
		const DDS::Int32Seq &
	)

inline

Definition at line 201 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int64_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int64_value	(	DDS::MemberId	,
		CORBA::LongLong
	)

inline

Definition at line 106 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int64_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int64_values	(	DDS::MemberId	,
		const DDS::Int64Seq &
	)

inline

Definition at line 249 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int8_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int8_value	(	DDS::MemberId	,
		CORBA::Int8
	)

inline

Definition at line 75 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_int8_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_int8_values	(	DDS::MemberId	,
		const DDS::Int8Seq &
	)

inline

Definition at line 217 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_string_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_string_value	(	DDS::MemberId	,
		const char *
	)

inline

Definition at line 177 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_string_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_string_values	(	DDS::MemberId	,
		const DDS::StringSeq &
	)

inline

Definition at line 321 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint16_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint16_value	(	DDS::MemberId	,
		CORBA::UShort
	)

inline

Definition at line 99 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint16_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint16_values	(	DDS::MemberId	,
		const DDS::UInt16Seq &
	)

inline

Definition at line 241 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint32_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint32_value	(	DDS::MemberId	,
		CORBA::ULong
	)

inline

Definition at line 67 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint32_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint32_values	(	DDS::MemberId	,
		const DDS::UInt32Seq &
	)

inline

Definition at line 209 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint64_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint64_value	(	DDS::MemberId	,
		CORBA::ULongLong
	)

inline

Definition at line 113 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint64_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint64_values	(	DDS::MemberId	,
		const DDS::UInt64Seq &
	)

inline

Definition at line 257 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint8_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint8_value	(	DDS::MemberId	,
		CORBA::UInt8
	)

inline

Definition at line 83 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_uint8_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_uint8_values	(	DDS::MemberId	,
		const DDS::UInt8Seq &
	)

inline

Definition at line 225 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_wstring_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_wstring_value	(	DDS::MemberId	,
		const CORBA::WChar *
	)

inline

Definition at line 185 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ set_wstring_values()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::set_wstring_values	(	DDS::MemberId	,
		const DDS::WstringSeq &
	)

inline

Definition at line 329 of file DynamicDataXcdrReadImpl.h.

References DDS::RETCODE_UNSUPPORTED.

   {
     return DDS::RETCODE_UNSUPPORTED;
   }

◆ setup_stream()

void OpenDDS::XTypes::DynamicDataXcdrReadImpl::setup_stream ( ACE_Message_Block * chain )

private

Setup the strm_ object so that it has the correct alignment state.

Definition at line 1159 of file DynamicDataXcdrReadImpl.cpp.

References align_state_, encoding_, OpenDDS::DCPS::Serializer::rdstate(), reset_align_state_, and strm_.

 {
   strm_ = DCPS::Serializer(chain, encoding_);
   if (reset_align_state_) {
     strm_.rdstate(align_state_);
   }
 }

◆ skip()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip	(	const char *	func_name,
		const char *	description,
		size_t	n,
		int	size = `1`
	)

private

Definition at line 2783 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_ERROR, OpenDDS::DCPS::Serializer::skip(), and strm_.

Referenced by skip_all(), skip_array_member(), skip_collection_member(), skip_map_member(), skip_member(), and skip_sequence_member().

 {
   if (!strm_.skip(n, size)) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::%C - %C\n"), func_name, description));
     }
     return false;
   }
   return true;
 }

◆ skip_aggregated_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_aggregated_member ( DDS::DynamicType_ptr type )

private

Skip a member which is a structure or a union.

Definition at line 2549 of file DynamicDataXcdrReadImpl.cpp.

References chains_to_release, OpenDDS::DCPS::Serializer::current(), ACE_Message_Block::duplicate(), encoding_, get_intermediate_chains(), OpenDDS::DCPS::Serializer::rdstate(), skip_all(), and strm_.

Referenced by skip_member().

 {
   DynamicDataXcdrReadImpl nested_data(strm_, member_type);
   if (!nested_data.skip_all()) {
     return false;
   }
 
   // Collect the intermediate message block chains that were created recursively
   // when skipping nested_data.
   const IntermediateChains& chains = nested_data.get_intermediate_chains();
   chains_to_release.insert(chains_to_release.end(), chains.begin(), chains.end());
 
   ACE_Message_Block* const result_chain = nested_data.strm_.current()->duplicate();
   strm_ = DCPS::Serializer(result_chain, encoding_);
   const DCPS::Serializer::RdState curr_state = nested_data.strm_.rdstate();
   strm_.rdstate(curr_state);
   chains_to_release.push_back(result_chain);
   return true;
 }

◆ skip_all()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_all ( )

private

Skip the whole data corresponding to this type if it is a struct or union. This is called by a containing type when it wants to skip a member which is an object of this type.

Definition at line 2696 of file DynamicDataXcdrReadImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), DDS::APPENDABLE, OpenDDS::XTypes::DynamicTypeMembersByIdImpl::begin(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Serializer::encoding(), OpenDDS::XTypes::DynamicTypeMembersByIdImpl::end(), OpenDDS::XTypes::extensibility(), OpenDDS::XTypes::get_base_type(), OpenDDS::DCPS::Encoding::kind(), OpenDDS::DCPS::Encoding::KIND_XCDR2, OpenDDS::XTypes::Sequence< T >::length(), LM_DEBUG, LM_ERROR, DDS::MUTABLE, OpenDDS::DCPS::Serializer::read_delimiter(), read_discriminator(), DDS::RETCODE_OK, skip(), skip_member(), skip_struct_member_at_index(), strm_, OpenDDS::XTypes::TK_STRUCTURE, OpenDDS::XTypes::TK_UNION, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by skip_aggregated_member(), skip_to_array_element(), and skip_to_sequence_element().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   const TypeKind tk = type_->get_kind();
   if (tk != TK_STRUCTURE && tk != TK_UNION) {
     return false;
   }
 
   const DDS::ExtensibilityKind extensibility = descriptor->extensibility_kind();
   if (strm_.encoding().kind() == DCPS::Encoding::KIND_XCDR2 && (extensibility == DDS::APPENDABLE || extensibility == DDS::MUTABLE)) {
     size_t dheader;
     if (!strm_.read_delimiter(dheader)) {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_all - Failed to read")
                    ACE_TEXT(" DHEADER of the DynamicData object\n")));
       }
       return false;
     }
     return skip("skip_all", "Failed to skip the whole DynamicData object\n", dheader);
   } else {
     if (tk == TK_STRUCTURE) {
       const ACE_CDR::ULong member_count = type_->get_member_count();
       bool good = true;
       for (ACE_CDR::ULong i = 0; i < member_count; ++i) {
         ACE_CDR::ULong num_skipped;
         if (!skip_struct_member_at_index(i, num_skipped)) {
           good = false;
           break;
         }
       }
       return good;
     } else { // Union
       const DDS::DynamicType_var disc_type = get_base_type(descriptor->discriminator_type());
       ACE_CDR::Long label;
       if (!read_discriminator(disc_type, extensibility, label)) {
         return false;
       }
 
       DDS::DynamicTypeMembersById_var members;
       if (type_->get_all_members(members) != DDS::RETCODE_OK) {
         return false;
       }
       DynamicTypeMembersByIdImpl* members_impl = dynamic_cast<DynamicTypeMembersByIdImpl*>(members.in());
       if (!members_impl) {
         return false;
       }
 
       bool has_default = false;
       DDS::MemberDescriptor_var default_member;
       for (DynamicTypeMembersByIdImpl::const_iterator it = members_impl->begin(); it != members_impl->end(); ++it) {
         DDS::MemberDescriptor_var md;
         if (it->second->get_descriptor(md) != DDS::RETCODE_OK) {
           return false;
         }
         const DDS::UnionCaseLabelSeq& labels = md->label();
         for (ACE_CDR::ULong i = 0; i < labels.length(); ++i) {
           if (label == labels[i]) {
             const DDS::DynamicType_ptr selected_member = md->type();
             bool good = selected_member && skip_member(selected_member);
             return good;
           }
         }
 
         if (md->is_default_label()) {
           has_default = true;
           default_member = md;
         }
       }
 
       if (has_default) {
         const DDS::DynamicType_ptr default_dt = default_member->type();
         bool good = default_dt && skip_member(default_dt);
         return good;
       }
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_all - Skip a union with no")
                    ACE_TEXT(" selected member and a discriminator with value %d\n"), label));
       }
       return true;
     }
   }
 }

◆ skip_array_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_array_member ( DDS::DynamicType_ptr type )

private

Skip a member which is a sequence, array, or map.

Definition at line 2462 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::bound_total(), OpenDDS::XTypes::get_base_type(), get_primitive_size(), DDS::RETCODE_OK, skip(), and skip_collection_member().

Referenced by skip_member().

 {
   DDS::TypeDescriptor_var descriptor;
   if (array_type->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
   const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
 
   ACE_CDR::ULong primitive_size = 0;
   if (get_primitive_size(elem_type, primitive_size)) {
     return skip("skip_array_member", "Failed to skip a primitive array member",
                 bound_total(descriptor), primitive_size);
   } else {
     return skip_collection_member(array_type);
   }
 }

◆ skip_collection_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_collection_member ( DDS::DynamicType_ptr coll_type )

private

Skip a non-primitive collection member. That is, a sequence or an array of non-primitive elements, or a map with at least either key type or value type is non-primitive.

Definition at line 2516 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Serializer::encoding(), OpenDDS::DCPS::Encoding::kind(), OpenDDS::DCPS::Encoding::KIND_XCDR2, LM_ERROR, LM_NOTICE, OpenDDS::DCPS::LogLevel::Notice, OpenDDS::DCPS::Serializer::read_delimiter(), skip(), skip_to_array_element(), skip_to_sequence_element(), strm_, OpenDDS::XTypes::TK_ARRAY, OpenDDS::XTypes::TK_MAP, OpenDDS::XTypes::TK_SEQUENCE, and OpenDDS::XTypes::typekind_to_string().

Referenced by skip_array_member(), skip_map_member(), and skip_sequence_member().

 {
   const TypeKind kind = coll_type->get_kind();
   if (kind == TK_SEQUENCE || kind == TK_ARRAY || kind == TK_MAP) {
     const char* kind_str = typekind_to_string(kind);
     if (strm_.encoding().kind() == DCPS::Encoding::KIND_XCDR2) {
       size_t dheader;
       if (!strm_.read_delimiter(dheader)) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_collection_member -")
                      ACE_TEXT(" Failed to deserialize DHEADER of a non-primitive %C member\n"),
                      kind_str));
         }
         return false;
       }
       const DCPS::String err_msg = DCPS::String("Failed to skip a non-primitive ") + kind_str + " member";
       return skip("skip_collection_member", err_msg.c_str(), dheader);
     } else if (kind == TK_SEQUENCE) {
       return skip_to_sequence_element(0, coll_type);
     } else if (kind == TK_ARRAY) {
       return skip_to_array_element(0, coll_type);
     } else if (kind == TK_MAP) {
       if (DCPS::log_level >= DCPS::LogLevel::Notice) {
         ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::skip_collection_member: "
                    "DynamicData does not currently support XCDR1 maps\n"));
       }
       return false;
     }
   }
 
   return false;
 }

◆ skip_map_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_map_member ( DDS::DynamicType_ptr type )

private

Skip a member which is a sequence, array, or map.

Definition at line 2479 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::get_base_type(), get_primitive_size(), LM_ERROR, DDS::RETCODE_OK, skip(), skip_collection_member(), and strm_.

Referenced by skip_member().

 {
   DDS::TypeDescriptor_var descriptor;
   if (map_type->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
   const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
   const DDS::DynamicType_var key_type = get_base_type(descriptor->key_element_type());
 
   ACE_CDR::ULong key_primitive_size = 0, elem_primitive_size = 0;
   if (get_primitive_size(key_type, key_primitive_size) &&
       get_primitive_size(elem_type, elem_primitive_size)) {
     ACE_CDR::ULong length;
     if (!(strm_ >> length)) {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_map_member -")
                    ACE_TEXT(" Failed to deserialize length of a primitive map member\n")));
       }
       return false;
     }
 
     for (unsigned i = 0; i < length; ++i) {
       if (!skip("skip_map_member", "Failed to skip a key of a primitive map member",
                 1, key_primitive_size)) {
         return false;
       }
       if (!skip("skip_map_member", "Failed to skip an element of a primitive map member",
                 1, elem_primitive_size)) {
         return false;
       }
     }
     return true;
   } else {
     return skip_collection_member(map_type);
   }
 }

◆ skip_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_member ( DDS::DynamicType_ptr member_type )

private

Skip a member with the given type. The member can be a part of any containing type, such as a member in a struct or union, an element in a sequence or array, etc. Note that this assumes any header preceding this type, e.g. EMHEADER if this is a member of a mutable struct, is already consumed, and the read pointer is pointing to the actual data of the member.

Definition at line 2317 of file DynamicDataXcdrReadImpl.cpp.

Referenced by get_item_count(), skip_all(), skip_struct_member_at_index(), skip_to_array_element(), skip_to_map_element(), and skip_to_sequence_element().

 {
   const DDS::DynamicType_var member_type = get_base_type(type);
   const TypeKind member_kind = member_type->get_kind();
 
   switch (member_kind) {
   case TK_BOOLEAN:
   case TK_BYTE:
   case TK_INT8:
   case TK_UINT8:
   case TK_CHAR8:
     if (!skip("skip_member", "Failed to skip a member of size 1 byte", 1, 1)) {
       return false;
     }
     break;
   case TK_INT16:
   case TK_UINT16:
   case TK_CHAR16:
     if (!skip("skip_member", "Failed to skip a member of size 2 bytes", 1, 2)) {
       return false;
     }
     break;
   case TK_INT32:
   case TK_UINT32:
   case TK_FLOAT32:
     if (!skip("skip_member", "Failed to skip a member of size 4 bytes", 1, 4)) {
       return false;
     }
     break;
   case TK_INT64:
   case TK_UINT64:
   case TK_FLOAT64:
     if (!skip("skip_member", "Failed to skip a member of size 8 bytes", 1, 8)) {
       return false;
     }
     break;
   case TK_FLOAT128:
     if (!skip("skip_member", "Failed to skip a member of size 16 bytes", 1, 16)) {
       return false;
     }
     break;
   case TK_STRING8:
   case TK_STRING16:
     {
       const char* str_kind = member_kind == TK_STRING8 ? "string" : "wstring";
       ACE_CDR::ULong bytes;
       if (!(strm_ >> bytes)) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_member -")
                      ACE_TEXT(" Failed to read length of a %C member\n"), str_kind));
         }
         return false;
       }
 
       const DCPS::String err_msg = DCPS::String("Failed to skip a ") + str_kind + " member";
       if (!skip("skip_member", err_msg.c_str(), bytes)) {
         return false;
       }
       break;
     }
   case TK_ENUM:
   case TK_BITMASK:
     {
       DDS::TypeDescriptor_var member_td;
       if (member_type->get_descriptor(member_td) != DDS::RETCODE_OK) {
         return false;
       }
       const ACE_CDR::ULong bit_bound = member_td->bound()[0];
       const char* err_msg = member_kind == TK_ENUM ?
         "Failed to skip an enum member" : "Failed to skip a bitmask member";
 
       if (bit_bound >= 1 && bit_bound <= 8) {
         if (!skip("skip_member", err_msg, 1, 1)) {
           return false;
         }
       } else if (bit_bound >= 9 && bit_bound <= 16) {
         if (!skip("skip_member", err_msg, 1, 2)) {
           return false;
         }
       } else if (bit_bound >= 17 && bit_bound <= 32) {
         if (!skip("skip_member", err_msg, 1, 4)) {
           return false;
         }
       } else if (bit_bound >= 33 && bit_bound <= 64 && member_kind == TK_BITMASK) {
         if (!skip("skip_member", err_msg, 1, 8)) {
           return false;
         }
       } else {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_member - Found a%C")
                      ACE_TEXT(" member with bit bound %d\n"),
                      member_kind == TK_ENUM ? "n enum" : " bitmask", bit_bound));
         }
         return false;
       }
       break;
     }
   case TK_STRUCTURE:
   case TK_UNION:
     return skip_aggregated_member(member_type);
   case TK_SEQUENCE:
     return skip_sequence_member(member_type);
   case TK_ARRAY:
     return skip_array_member(member_type);
   case TK_MAP:
     return skip_map_member(member_type);
   default:
     {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_member -")
                    ACE_TEXT(" Found a member of kind %C\n"), typekind_to_string(member_kind)));
       }
       return false;
     }
   }
 
   return true;
 }

◆ skip_sequence_member()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_sequence_member ( DDS::DynamicType_ptr type )

private

Skip a member which is a sequence, array, or map.

Definition at line 2436 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::XTypes::get_base_type(), get_primitive_size(), LM_ERROR, DDS::RETCODE_OK, skip(), skip_collection_member(), and strm_.

Referenced by get_item_count(), get_member_id_at_index(), and skip_member().

 {
   DDS::TypeDescriptor_var descriptor;
   if (seq_type->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
   const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
 
   ACE_CDR::ULong primitive_size = 0;
   if (get_primitive_size(elem_type, primitive_size)) {
     ACE_CDR::ULong length;
     if (!(strm_ >> length)) {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_sequence_member -")
                    ACE_TEXT(" Failed to deserialize a primitive sequence member\n")));
       }
       return false;
     }
 
     return skip("skip_sequence_member", "Failed to skip a primitive sequence member",
                 length, primitive_size);
   } else {
     return skip_collection_member(seq_type);
   }
 }

◆ skip_struct_member_at_index()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_struct_member_at_index	(	ACE_CDR::ULong	index,
		ACE_CDR::ULong &	num_skipped
	)

private

Skip a member of a final or appendable struct at the given index.

Definition at line 2285 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Serializer::encoding(), OpenDDS::DCPS::Encoding::kind(), OpenDDS::DCPS::Encoding::KIND_XCDR2, LM_ERROR, DDS::RETCODE_OK, skip_member(), strm_, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_item_count(), get_member_id_at_index(), skip_all(), and skip_to_struct_member().

 {
   DDS::DynamicTypeMember_var member;
   if (type_->get_member_by_index(member, index) != DDS::RETCODE_OK) {
     if (DCPS::DCPS_debug_level >= 1) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_struct_member_at_index -")
                  ACE_TEXT(" Failed to get DynamicTypeMember for member index %d\n"), index));
     }
     return false;
   }
 
   DDS::MemberDescriptor_var md;
   if (member->get_descriptor(md) != DDS::RETCODE_OK) {
     return false;
   }
   if (strm_.encoding().kind() == DCPS::Encoding::KIND_XCDR2 && md->is_optional()) {
     ACE_CDR::Boolean present;
     if (!(strm_ >> ACE_InputCDR::to_boolean(present))) {
       return false;
     }
     // Optional member that is omitted is not counted as a skipped member.
     if (!present) {
       num_skipped = 0;
       return true;
     }
   }
 
   num_skipped = 1;
   const DDS::DynamicType_ptr member_type = md->type();
   return member_type && skip_member(member_type);
 }

◆ skip_to_array_element()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_array_element	(	MemberId	id,
		DDS::DynamicType_ptr	coll_type = `0`
	)

private

Skip to an element with a given ID in a sequence or array, or skip the entire collection.

Definition at line 1012 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::bound_total(), OpenDDS::XTypes::get_base_type(), OpenDDS::XTypes::DynamicDataBase::get_index_from_id(), get_primitive_size(), DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::skip(), skip_all(), OpenDDS::DCPS::Serializer::skip_delimiter(), skip_member(), strm_, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_complex_value(), get_value_from_collection(), get_values_from_array(), and skip_collection_member().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   DDS::DynamicType_var elem_type;
   bool skip_all = false;
   DDS::TypeDescriptor_var coll_descriptor;
 
   if (!coll_type) {
     elem_type = get_base_type(descriptor->element_type());
     coll_type = type_;
     if (coll_type->get_descriptor(coll_descriptor) != DDS::RETCODE_OK) {
       return false;
     }
   } else {
     if (coll_type->get_descriptor(coll_descriptor) != DDS::RETCODE_OK) {
       return false;
     }
     elem_type = get_base_type(coll_descriptor->element_type());
     skip_all = true;
   }
 
   const ACE_CDR::ULong length = bound_total(coll_descriptor);
 
   ACE_CDR::ULong size;
   if (get_primitive_size(elem_type, size)) {
     ACE_CDR::ULong index;
     return get_index_from_id(id, index, length) && strm_.skip(index, size);
   } else {
     if (!strm_.skip_delimiter()) {
       return false;
     }
     ACE_CDR::ULong index;
     if (skip_all) {
       index = length;
     } else if (!get_index_from_id(id, index, length)) {
       return false;
     }
     for (ACE_CDR::ULong i = 0; i < index; ++i) {
       if (!skip_member(elem_type)) {
         return false;
       }
     }
     return true;
   }
 }

◆ skip_to_map_element()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_map_element ( MemberId id )

private

Skip to an element with a given ID in a map. The key associated with that element is also skipped.

Definition at line 1062 of file DynamicDataXcdrReadImpl.cpp.

References ACE_UINT32_MAX, OpenDDS::XTypes::get_base_type(), OpenDDS::XTypes::DynamicDataBase::get_index_from_id(), get_primitive_size(), OpenDDS::DCPS::Serializer::read_delimiter(), DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::rpos(), OpenDDS::DCPS::Serializer::skip(), skip_member(), strm_, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_complex_value(), get_value_from_collection(), and get_values_from_map().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   const DDS::DynamicType_var key_type = get_base_type(descriptor->key_element_type());
   const DDS::DynamicType_var elem_type = get_base_type(descriptor->element_type());
   ACE_CDR::ULong key_size, elem_size;
 
   if (get_primitive_size(key_type, key_size) &&
       get_primitive_size(elem_type, elem_size)) {
     ACE_CDR::ULong length, index;
     if (!(strm_ >> length) || !get_index_from_id(id, index, length)) {
       return false;
     }
 
     for (ACE_CDR::ULong i = 0; i < index; ++i) {
       if (!strm_.skip(1, key_size) || !strm_.skip(1, elem_size)) {
         return false;
       }
     }
     return strm_.skip(1, key_size);
   } else {
     size_t dheader;
     ACE_CDR::ULong index;
     if (!strm_.read_delimiter(dheader) || !get_index_from_id(id, index, ACE_UINT32_MAX)) {
       return false;
     }
     const size_t end_of_map = strm_.rpos() + dheader;
 
     for (ACE_CDR::ULong i = 0; i < index; ++i) {
       if (strm_.rpos() >= end_of_map || !skip_member(key_type) || !skip_member(elem_type)) {
         return false;
       }
     }
     return (strm_.rpos() < end_of_map) && skip_member(key_type);
   }
 }

◆ skip_to_sequence_element()

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_sequence_element	(	MemberId	id,
		DDS::DynamicType_ptr	coll_type = `0`
	)

private

Skip to an element with a given ID in a sequence or array, or skip the entire collection.

Definition at line 968 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::get_base_type(), OpenDDS::XTypes::DynamicDataBase::get_index_from_id(), get_primitive_size(), DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::skip(), skip_all(), OpenDDS::DCPS::Serializer::skip_delimiter(), skip_member(), strm_, and OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_complex_value(), get_value_from_collection(), get_values_from_sequence(), and skip_collection_member().

 {
   DDS::TypeDescriptor_var descriptor;
   if (type_->get_descriptor(descriptor) != DDS::RETCODE_OK) {
     return false;
   }
 
   DDS::DynamicType_var elem_type;
   bool skip_all = false;
   if (!coll_type) {
     elem_type = get_base_type(descriptor->element_type());
   } else {
     DDS::TypeDescriptor_var descriptor;
     if (coll_type->get_descriptor(descriptor) != DDS::RETCODE_OK) {
       return false;
     }
     elem_type = get_base_type(descriptor->element_type());
     skip_all = true;
   }
   ACE_CDR::ULong size;
   if (get_primitive_size(elem_type, size)) {
     ACE_CDR::ULong length, index;
     return (strm_ >> length) &&
       get_index_from_id(id, index, length) &&
       strm_.skip(index, size);
   } else {
     ACE_CDR::ULong length, index;
     if (!strm_.skip_delimiter() || !(strm_ >> length)) {
       return false;
     }
     if (skip_all) {
       index = length;
     } else if (!get_index_from_id(id, index, length)) {
       return false;
     }
     for (ACE_CDR::ULong i = 0; i < index; ++i) {
       if (!skip_member(elem_type)) {
         return false;
       }
     }
     return true;
   }
 }

◆ skip_to_struct_member()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataXcdrReadImpl::skip_to_struct_member	(	DDS::MemberDescriptor *	member_desc,
		MemberId	id
	)

private

Skip to a member with a given ID in a struct.

Definition at line 2131 of file DynamicDataXcdrReadImpl.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::APPENDABLE, OpenDDS::DCPS::DCPS_debug_level, encoding_, OpenDDS::XTypes::DynamicDataBase::exclude_member(), extent_, DDS::FINAL, OpenDDS::XTypes::DynamicDataBase::has_explicit_keys(), DDS::MemberDescriptor::index, LM_ERROR, LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, OpenDDS::DCPS::Serializer::read_delimiter(), OpenDDS::DCPS::Serializer::read_parameter_id(), DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::rpos(), OpenDDS::DCPS::Serializer::skip(), skip_struct_member_at_index(), strm_, OpenDDS::XTypes::DynamicDataBase::type_, OpenDDS::DCPS::Encoding::xcdr_version(), and OpenDDS::DCPS::Encoding::XCDR_VERSION_2.

Referenced by get_complex_value(), get_value_from_struct(), and get_values_from_struct().

 {
   DDS::TypeDescriptor_var descriptor;
   DDS::ReturnCode_t rc = type_->get_descriptor(descriptor);
   if (rc != DDS::RETCODE_OK) {
     return rc;
   }
 
   const DDS::ExtensibilityKind ek = descriptor->extensibility_kind();
   if (ek == DDS::FINAL || ek == DDS::APPENDABLE) {
     size_t dheader = 0;
     const bool xcdr2_appendable = encoding_.xcdr_version() == DCPS::Encoding::XCDR_VERSION_2 &&
       ek == DDS::APPENDABLE;
     if (xcdr2_appendable && !strm_.read_delimiter(dheader)) {
       if (log_level >= LogLevel::Notice) {
         ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::skip_to_struct_member: "
                    "Failed to read DHEADER for member ID %d\n", id));
       }
       return DDS::RETCODE_ERROR;
     }
     const size_t end_of_struct = strm_.rpos() + dheader;
 
     for (ACE_CDR::ULong i = 0; i < member_desc->index(); ++i) {
       DDS::DynamicTypeMember_var dtm;
       rc = type_->get_member_by_index(dtm, i);
       if (rc != DDS::RETCODE_OK) {
         if (DCPS::log_level >= DCPS::LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::skip_to_struct_member:"
                      " Failed to get DynamicTypeMember for member at index %d\n", i));
         }
         return rc;
       }
       DDS::MemberDescriptor_var md;
       rc = dtm->get_descriptor(md);
       if (rc != DDS::RETCODE_OK) {
         if (DCPS::log_level >= DCPS::LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DynamicDataXcdrReadImpl::skip_to_struct_member:"
                      " Failed to get MemberDescriptor for member at index %d\n", i));
         }
         return rc;
       }
       if (exclude_member(extent_, md->is_key(), has_explicit_keys(type_))) {
         // This member is not present in the sample, don't need to do anything.
         continue;
       }
 
       ACE_CDR::ULong num_skipped;
       if (!skip_struct_member_at_index(i, num_skipped)) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_to_struct_member -")
                      ACE_TEXT(" Failed to skip member at index %d\n"), i));
         }
         return DDS::RETCODE_ERROR;
       }
       if (xcdr2_appendable && strm_.rpos() >= end_of_struct) {
         return DDS::RETCODE_NO_DATA;
       }
     }
     return DDS::RETCODE_OK;
   } else {
     size_t dheader = 0;
     if (!strm_.read_delimiter(dheader)) {
       if (DCPS::DCPS_debug_level >= 1) {
         ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_to_struct_member -")
                    ACE_TEXT(" Failed to read DHEADER for member ID %d\n"), id));
       }
       return DDS::RETCODE_ERROR;
     }
 
     const size_t end_of_struct = strm_.rpos() + dheader;
     while (true) {
       if (strm_.rpos() >= end_of_struct) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_to_struct_member -")
                      ACE_TEXT(" Could not find a member with ID %d\n"), id));
         }
         return DDS::RETCODE_NO_DATA;
       }
 
       ACE_CDR::ULong member_id;
       size_t member_size;
       bool must_understand;
       if (!strm_.read_parameter_id(member_id, member_size, must_understand)) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_to_struct_member -")
                      ACE_TEXT(" Failed to read EMHEADER while finding member ID %d\n"), id));
         }
         return DDS::RETCODE_ERROR;
       }
 
       if (member_id == id) {
         return DDS::RETCODE_OK;
       }
 
       if (!strm_.skip(member_size)) {
         if (DCPS::DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DynamicDataXcdrReadImpl::skip_to_struct_member -")
                      ACE_TEXT(" Failed to skip a member with ID %d\n"), member_id));
         }
         return DDS::RETCODE_ERROR;
       }
     }
   }
 }

◆ type()

DDS::DynamicType_ptr OpenDDS::XTypes::DynamicDataXcdrReadImpl::type ( void )

Definition at line 2113 of file DynamicDataXcdrReadImpl.cpp.

References OpenDDS::XTypes::DynamicDataBase::type_.

Referenced by get_value_from_union(), OpenDDS::XTypes::print_dynamic_data(), and OpenDDS::XTypes::print_members().

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

Member Data Documentation

◆ align_state_

DCPS::Serializer::RdState OpenDDS::XTypes::DynamicDataXcdrReadImpl::align_state_

private

The alignment state that a Serializer object associated with this DynamicData object will be set to.

Definition at line 548 of file DynamicDataXcdrReadImpl.h.

Referenced by copy(), DynamicDataXcdrReadImpl(), and setup_stream().

◆ chain_

ACE_Message_Block* OpenDDS::XTypes::DynamicDataXcdrReadImpl::chain_

private

A duplicate of the original message block chain passed from the constructor. This is released in the destructor.

Definition at line 537 of file DynamicDataXcdrReadImpl.h.

Referenced by clone(), copy(), and ~DynamicDataXcdrReadImpl().

◆ chains_to_release

IntermediateChains OpenDDS::XTypes::DynamicDataXcdrReadImpl::chains_to_release

private

Message block chains created during each get_*_value or get_*_values method's execution that need to be released when the method ends. Those chains are created when the method skips a nested aggregated type (i.e., struct and union) by calling skip_aggregated_member().

Definition at line 558 of file DynamicDataXcdrReadImpl.h.

Referenced by release_chains(), and skip_aggregated_member().

◆ encoding_

DCPS::Encoding OpenDDS::XTypes::DynamicDataXcdrReadImpl::encoding_

private

Definition at line 539 of file DynamicDataXcdrReadImpl.h.

Referenced by check_xcdr1_mutable_i(), copy(), DynamicDataXcdrReadImpl(), setup_stream(), skip_aggregated_member(), and skip_to_struct_member().

◆ extent_

DCPS::Sample::Extent OpenDDS::XTypes::DynamicDataXcdrReadImpl::extent_

private

Definition at line 540 of file DynamicDataXcdrReadImpl.h.

Referenced by clone(), copy(), exclude_struct_member(), exclude_union_member(), get_boolean_value(), get_char_common(), get_complex_value(), get_item_count(), get_member_id_at_index(), get_value_from_struct(), get_values_from_struct(), and skip_to_struct_member().

◆ item_count_

ACE_CDR::ULong OpenDDS::XTypes::DynamicDataXcdrReadImpl::item_count_

private

Cache the number of items (i.e., members or elements) in the data it holds.

Definition at line 563 of file DynamicDataXcdrReadImpl.h.

Referenced by copy(), get_item_count(), and get_member_id_at_index().

◆ ITEM_COUNT_INVALID

const ACE_CDR::ULong OpenDDS::XTypes::DynamicDataXcdrReadImpl::ITEM_COUNT_INVALID = ACE_UINT32_MAX

staticprivate

Definition at line 560 of file DynamicDataXcdrReadImpl.h.

Referenced by get_item_count(), and get_member_id_at_index().

◆ reset_align_state_

bool OpenDDS::XTypes::DynamicDataXcdrReadImpl::reset_align_state_

private

Indicate whether the alignment state of a Serializer object associated with this DynamicData needs to be reset.

Definition at line 544 of file DynamicDataXcdrReadImpl.h.

Referenced by copy(), and setup_stream().

◆ strm_

DCPS::Serializer OpenDDS::XTypes::DynamicDataXcdrReadImpl::strm_

private

Each public interface creates a new Serializer object with a message block chain that is a duplicate from chain_.

Definition at line 552 of file DynamicDataXcdrReadImpl.h.

Referenced by clone(), copy(), DynamicDataXcdrReadImpl(), get_boolean_value(), get_char_common(), get_complex_value(), get_item_count(), get_member_id_at_index(), get_union_selected_member(), get_value_from_union(), get_values_from_union(), read_discriminator(), read_value(), read_values(), setup_stream(), skip(), skip_aggregated_member(), skip_all(), skip_collection_member(), skip_map_member(), skip_member(), skip_sequence_member(), skip_struct_member_at_index(), skip_to_array_element(), skip_to_map_element(), skip_to_sequence_element(), and skip_to_struct_member().

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

Classes

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DynamicDataXcdrReadImpl() [1/4]

◆ DynamicDataXcdrReadImpl() [2/4]

◆ DynamicDataXcdrReadImpl() [3/4]

◆ DynamicDataXcdrReadImpl() [4/4]

◆ ~DynamicDataXcdrReadImpl()

Member Function Documentation

◆ check_xcdr1_mutable()

◆ check_xcdr1_mutable_i()

◆ clear_all_values()

◆ clear_nonkey_values()

◆ clear_value()

◆ clone()

◆ copy()

◆ equals()

◆ exclude_struct_member()

◆ exclude_union_member()

◆ get_boolean_from_bitmask()

◆ get_boolean_value()

◆ get_boolean_values()

◆ get_byte_value()

◆ get_byte_values()

◆ get_char16_value()

◆ get_char16_values()

◆ get_char8_value()

◆ get_char8_values()

◆ get_char_common()

◆ get_complex_value()

◆ get_float128_value()

◆ get_float128_values()

◆ get_float32_value()

◆ get_float32_values()

◆ get_float64_value()

◆ get_float64_values()

◆ get_from_struct_common_checks()

◆ get_from_union_common_checks()

◆ get_int16_value()

◆ get_int16_values()

◆ get_int32_value()

◆ get_int32_values()

◆ get_int64_value_impl()

◆ get_int64_values()

◆ get_int8_value()

◆ get_int8_values()

◆ get_intermediate_chains()

◆ get_item_count()

◆ get_member_id_at_index()

◆ get_primitive_size()

◆ get_sequence_values()

◆ get_simple_value()

◆ get_single_value()

◆ get_string_value()

◆ get_string_values()

◆ get_uint16_value()

◆ get_uint16_values()

◆ get_uint32_value()

◆ get_uint32_values()

◆ get_uint64_value_impl()

◆ get_uint64_values()

◆ get_uint8_value()

◆ get_uint8_values()

◆ get_union_selected_member()

◆ get_value_from_collection()

◆ get_value_from_struct()

◆ get_value_from_union()

◆ get_values_from_array()

◆ get_values_from_map()

◆ get_values_from_sequence()

◆ get_values_from_struct()

◆ get_values_from_union()

◆ get_wstring_value()

◆ get_wstring_values()

◆ has_optional_member()