OpenDDS::XTypes::DynamicDataReaderImpl Class Reference

#include <DynamicDataReaderImpl.h>

Inheritance diagram for OpenDDS::XTypes::DynamicDataReaderImpl:

Collaboration diagram for OpenDDS::XTypes::DynamicDataReaderImpl:

Public Types
typedef DCPS::DataReaderImpl_T< DynamicSample >	Base
Public Types inherited from OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >
typedef DDSTraits< DynamicSample >	TraitsType
typedef MarshalTraits< DynamicSample >	MarshalTraitsType
typedef TraitsType::MessageSequenceType	MessageSequenceType
typedef RcHandle< SharedInstanceMap >	SharedInstanceMap_rch
typedef TraitsType::DataReaderType	Interface
typedef OpenDDS::DCPS::Cached_Allocator_With_Overflow< MessageTypeMemoryBlock, ACE_Thread_Mutex >	DataAllocator
Public Types inherited from OpenDDS::DCPS::LocalObject< DDSTraits< DynamicSample >::DataReaderType >
typedef DDSTraits< DynamicSample >::DataReaderType ::_ptr_type	_ptr_type
typedef DDSTraits< DynamicSample >::DataReaderType ::_var_type	_var_type
Public Types inherited from CORBA::LocalObject
typedef LocalObject_ptr	_ptr_type
typedef LocalObject_var	_var_type
typedef LocalObject_out	_out_type
Public Types inherited from CORBA::Object
typedef Object_ptr	_ptr_type
typedef Object_var	_var_type
typedef Object_out	_out_type
Public Types inherited from OpenDDS::DCPS::DataReaderImpl
typedef std::pair< GUID_t, WriterInfo::WriterState >	WriterStatePair
Public Types inherited from OpenDDS::DCPS::LocalObject< DataReaderEx >
typedef DataReaderEx ::_ptr_type	_ptr_type
typedef DataReaderEx ::_var_type	_var_type
Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::Entity >
typedef DDS::Entity ::_ptr_type	_ptr_type
typedef DDS::Entity ::_var_type	_var_type
Public Types inherited from OpenDDS::DCPS::TransportClient
enum	{ ASSOC_OK = 1, ASSOC_ACTIVE = 2 }

Public Member Functions
DDS::ReturnCode_t	read_next_sample (DDS::DynamicData *&dyn, DDS::SampleInfo &si)
DDS::ReturnCode_t	take_next_sample (DDS::DynamicData *&dyn, DDS::SampleInfo &si)
DDS::InstanceHandle_t	lookup_instance (DDS::DynamicData *dyn)
DDS::ReturnCode_t	get_key_value (DDS::DynamicData *&dyn, DDS::InstanceHandle_t ih)
void	install_type_support (DCPS::TypeSupportImpl *typesupport)
void	imbue_type (DynamicSample &sample)
Public Member Functions inherited from OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >
typedef	OPENDDS_MAP_CMP_T (DynamicSample, DDS::InstanceHandle_t, typename TraitsType::LessThanType) InstanceMap
typedef	OPENDDS_MAP (DDS::InstanceHandle_t, typename InstanceMap::iterator) ReverseInstanceMap
CORBA::Boolean	_is_a (const char *type_id)
const char *	_interface_repository_id () const
CORBA::Boolean	marshal (TAO_OutputCDR &)
	DataReaderImpl_T ()
virtual	~DataReaderImpl_T ()
virtual DDS::ReturnCode_t	enable_specific ()
virtual DDS::ReturnCode_t	read (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::ReturnCode_t	take (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::ReturnCode_t	take (AbstractSamples &samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
DDS::ReturnCode_t	take (AbstractSamples &, DDS::SampleStateMask, DDS::ViewStateMask, DDS::InstanceStateMask)
OpenDDS_Dcps_Export DDS::ReturnCode_t	take (AbstractSamples &samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::ReturnCode_t	read_w_condition (MessageSequenceType &received_data, DDS::SampleInfoSeq &sample_info, ::CORBA::Long max_samples, DDS::ReadCondition_ptr a_condition)
virtual DDS::ReturnCode_t	take_w_condition (MessageSequenceType &received_data, DDS::SampleInfoSeq &sample_info, ::CORBA::Long max_samples, DDS::ReadCondition_ptr a_condition)
virtual DDS::ReturnCode_t	read_next_sample (DynamicSample &received_data, DDS::SampleInfo &sample_info_ref)
virtual DDS::ReturnCode_t	take_next_sample (DynamicSample &received_data, DDS::SampleInfo &sample_info_ref)
virtual DDS::ReturnCode_t	read_instance (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::ReturnCode_t	take_instance (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::ReturnCode_t	read_instance_w_condition (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::ReadCondition_ptr a_condition)
virtual DDS::ReturnCode_t	take_instance_w_condition (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::ReadCondition_ptr a_condition)
virtual DDS::ReturnCode_t	read_next_instance (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::ReturnCode_t	take_next_instance (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::ReturnCode_t	read_next_instance_w_condition (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::ReadCondition_ptr a_condition)
virtual DDS::ReturnCode_t	take_next_instance_w_condition (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq, ::CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::ReadCondition_ptr a_condition)
virtual DDS::ReturnCode_t	return_loan (MessageSequenceType &received_data, DDS::SampleInfoSeq &info_seq)
virtual DDS::ReturnCode_t	get_key_value (DynamicSample &key_holder, DDS::InstanceHandle_t handle)
virtual DDS::InstanceHandle_t	lookup_instance (const DynamicSample &instance_data)
virtual void	lookup_instance (const OpenDDS::DCPS::ReceivedDataSample &sample, OpenDDS::DCPS::SubscriptionInstance_rch &instance)
virtual DDS::ReturnCode_t	auto_return_loan (void *seq)
void	release_loan (MessageSequenceType &received_data)
bool	contains_sample_filtered (DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states, const FilterEvaluator &evaluator, const DDS::StringSeq &params)
DDS::ReturnCode_t	read_generic (GenericBundle &gen, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states, bool adjust_ref_count=false)
DDS::ReturnCode_t	read_generic (GenericBundle &, DDS::SampleStateMask, DDS::ViewStateMask, DDS::InstanceStateMask, bool)
OpenDDS_Dcps_Export DDS::ReturnCode_t	read_generic (GenericBundle &gen, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states, bool adjust_ref_count)
DDS::InstanceHandle_t	lookup_instance_generic (const void *data)
DDS::ReturnCode_t	read_instance_generic (void *&data, DDS::SampleInfo &info, DDS::InstanceHandle_t instance, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
DDS::ReturnCode_t	read_next_instance_generic (void *&data, DDS::SampleInfo &info, DDS::InstanceHandle_t previous_instance, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
DDS::InstanceHandle_t	store_synthetic_data (const DynamicSample &sample, DDS::ViewStateKind view, const SystemTimePoint &timestamp=SystemTimePoint::now())
void	set_instance_state_i (DDS::InstanceHandle_t instance, DDS::InstanceHandle_t publication_handle, DDS::InstanceStateKind state, const SystemTimePoint &timestamp, const GUID_t &publication_id)
virtual void	qos_change (const DDS::DataReaderQos &qos)
void	set_marshal_skip_serialize (bool value)
bool	get_marshal_skip_serialize () const
void	release_all_instances ()
	Release all instances held by the reader. More...
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)
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)
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
Public Member Functions inherited from OpenDDS::DCPS::DataReaderImpl
typedef	OPENDDS_MAP (DDS::InstanceHandle_t, SubscriptionInstance_rch) SubscriptionInstanceMapType
typedef	OPENDDS_SET (DDS::InstanceHandle_t) InstanceSet
typedef	OPENDDS_SET (SubscriptionInstance_rch) SubscriptionInstanceSet
typedef	OPENDDS_MAP_CMP (GUID_t, WriterStats, GUID_tKeyLessThan) StatsMapType
	Type of collection of statistics for writers to this reader. More...
	DataReaderImpl ()
virtual	~DataReaderImpl ()
virtual DDS::InstanceHandle_t	get_instance_handle ()
virtual void	add_association (const GUID_t &yourId, const WriterAssociation &writer, bool active)
virtual void	transport_assoc_done (int flags, const GUID_t &remote_id)
virtual void	remove_associations (const WriterIdSeq &writers, bool callback)
virtual void	update_incompatible_qos (const IncompatibleQosStatus &status)
virtual void	signal_liveliness (const GUID_t &remote_participant)
DDS::DataReaderListener_ptr	listener_for (DDS::StatusKind kind)
void	writer_became_alive (WriterInfo &info, const MonotonicTimePoint &when)
void	writer_became_dead (WriterInfo &info)
void	writer_removed (WriterInfo &info)
virtual void	cleanup ()
void	init (TopicDescriptionImpl *a_topic_desc, const DDS::DataReaderQos &qos, DDS::DataReaderListener_ptr a_listener, const DDS::StatusMask &mask, DomainParticipantImpl *participant, SubscriberImpl *subscriber)
virtual DDS::ReadCondition_ptr	create_readcondition (DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
virtual DDS::QueryCondition_ptr	create_querycondition (DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states, const char *query_expression, const DDS::StringSeq &query_parameters)
virtual DDS::ReturnCode_t	delete_readcondition (DDS::ReadCondition_ptr a_condition)
virtual DDS::ReturnCode_t	delete_contained_entities ()
virtual DDS::ReturnCode_t	set_qos (const DDS::DataReaderQos &qos)
virtual DDS::ReturnCode_t	get_qos (DDS::DataReaderQos &qos)
virtual DDS::ReturnCode_t	set_listener (DDS::DataReaderListener_ptr a_listener, DDS::StatusMask mask)
virtual DDS::DataReaderListener_ptr	get_listener ()
virtual DDS::TopicDescription_ptr	get_topicdescription ()
virtual DDS::Subscriber_ptr	get_subscriber ()
virtual DDS::ReturnCode_t	get_sample_rejected_status (DDS::SampleRejectedStatus &status)
virtual DDS::ReturnCode_t	get_liveliness_changed_status (DDS::LivelinessChangedStatus &status)
virtual DDS::ReturnCode_t	get_requested_deadline_missed_status (DDS::RequestedDeadlineMissedStatus &status)
virtual DDS::ReturnCode_t	get_requested_incompatible_qos_status (DDS::RequestedIncompatibleQosStatus &status)
virtual DDS::ReturnCode_t	get_subscription_matched_status (DDS::SubscriptionMatchedStatus &status)
virtual DDS::ReturnCode_t	get_sample_lost_status (DDS::SampleLostStatus &status)
virtual DDS::ReturnCode_t	wait_for_historical_data (const DDS::Duration_t &max_wait)
virtual DDS::ReturnCode_t	get_matched_publications (DDS::InstanceHandleSeq &publication_handles)
virtual DDS::ReturnCode_t	get_matched_publication_data (DDS::PublicationBuiltinTopicData &publication_data, DDS::InstanceHandle_t publication_handle)
virtual DDS::ReturnCode_t	enable ()
virtual void	get_latency_stats (LatencyStatisticsSeq &stats)
virtual void	reset_latency_stats ()
	Clear any intermediate statistical values. More...
virtual CORBA::Boolean	statistics_enabled ()
virtual void	statistics_enabled (CORBA::Boolean statistics_enabled)
void	writer_activity (const DataSampleHeader &header)
	update liveliness info for this writer. More...
virtual void	data_received (const ReceivedDataSample &sample)
	process a message that has been received - could be control or a data sample. More...
void	transport_discovery_change ()
virtual bool	check_transport_qos (const TransportInst &inst)
bool	have_sample_states (DDS::SampleStateMask sample_states) const
bool	have_view_states (DDS::ViewStateMask view_states) const
bool	have_instance_states (DDS::InstanceStateMask instance_states) const
bool	contains_sample (DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
void	process_latency (const ReceivedDataSample &sample)
void	notify_latency (GUID_t writer)
size_t	get_depth () const
size_t	get_n_chunks () const
void	liveliness_lost ()
void	remove_all_associations ()
void	notify_subscription_disconnected (const WriterIdSeq &pubids)
void	notify_subscription_reconnected (const WriterIdSeq &pubids)
void	notify_subscription_lost (const WriterIdSeq &pubids)
void	notify_liveliness_change ()
bool	is_bit () const
bool	has_zero_copies ()
void	release_instance (DDS::InstanceHandle_t handle)
	Release the instance with the handle. More...
void	state_updated (DDS::InstanceHandle_t handle)
ACE_Reactor_Timer_Interface *	get_reactor ()
GUID_t	get_topic_id ()
GUID_t	get_dp_id ()
typedef	OPENDDS_VECTOR (DDS::InstanceHandle_t) InstanceHandleVec
void	get_instance_handles (InstanceHandleVec &instance_handles)
typedef	OPENDDS_VECTOR (WriterStatePair) WriterStatePairVec
void	get_writer_states (WriterStatePairVec &writer_states)
void	update_ownership_strength (const GUID_t &pub_id, const CORBA::Long &ownership_strength)
OwnershipManagerPtr	ownership_manager ()
void	enable_filtering (ContentFilteredTopicImpl *cft)
DDS::ContentFilteredTopic_ptr	get_cf_topic () const
void	enable_multi_topic (MultiTopicImpl *mt)
void	update_subscription_params (const DDS::StringSeq &params) const
typedef	OPENDDS_VECTOR (void *) GenericSeq
void	set_instance_state (DDS::InstanceHandle_t instance, DDS::InstanceStateKind state, const SystemTimePoint &timestamp=SystemTimePoint::now(), const GUID_t &guid=GUID_UNKNOWN)
void	begin_access ()
void	end_access ()
void	get_ordered_data (GroupRakeData &data, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
void	accept_coherent (const GUID_t &writer_id, const GUID_t &publisher_id)
void	reject_coherent (const GUID_t &writer_id, const GUID_t &publisher_id)
void	coherent_change_received (const GUID_t &publisher_id, Coherent_State &result)
void	coherent_changes_completed (DataReaderImpl *reader)
void	reset_coherent_info (const GUID_t &writer_id, const GUID_t &publisher_id)
void	set_subscriber_qos (const DDS::SubscriberQos &qos)
void	reset_ownership (DDS::InstanceHandle_t instance)
virtual RcHandle< EntityImpl >	parent () const
void	disable_transport ()
virtual void	register_for_writer (const GUID_t &, const GUID_t &, const GUID_t &, const TransportLocatorSeq &, DiscoveryListener *)
virtual void	unregister_for_writer (const GUID_t &, const GUID_t &, const GUID_t &)
virtual void	update_locators (const GUID_t &remote, const TransportLocatorSeq &locators)
virtual DCPS::WeakRcHandle< ICE::Endpoint >	get_ice_endpoint ()
GUID_t	get_guid () const
void	return_handle (DDS::InstanceHandle_t handle)
const ValueDispatcher *	get_value_dispatcher () const
const StatsMapType &	raw_latency_statistics () const
	Expose the statistics container. More...
unsigned int &	raw_latency_buffer_size ()
	Configure the size of the raw data collection buffer. More...
DataCollector< double >::OnFull &	raw_latency_buffer_type ()
	Configure the type of the raw data collection buffer. More...
Public Member Functions inherited from OpenDDS::DCPS::DataReaderEx
void	get_latency_stats (inout LatencyStatisticsSeq stats)
	Obtain a sequence of statistics summaries. More...
Public Member Functions inherited from DDS::DataReader
ReadCondition	create_readcondition (in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states)
QueryCondition	create_querycondition (in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states, in string query_expression, in StringSeq query_parameters)
ReturnCode_t	delete_readcondition (in ReadCondition a_condition)
ReturnCode_t	set_qos (in DataReaderQos qos)
ReturnCode_t	get_qos (inout DataReaderQos qos)
ReturnCode_t	set_listener (in DataReaderListener a_listener, in StatusMask mask)
ReturnCode_t	get_sample_rejected_status (inout SampleRejectedStatus status)
ReturnCode_t	get_liveliness_changed_status (inout LivelinessChangedStatus status)
ReturnCode_t	get_requested_deadline_missed_status (inout RequestedDeadlineMissedStatus status)
ReturnCode_t	get_requested_incompatible_qos_status (inout RequestedIncompatibleQosStatus status)
ReturnCode_t	get_subscription_matched_status (inout SubscriptionMatchedStatus status)
ReturnCode_t	get_sample_lost_status (inout SampleLostStatus status)
ReturnCode_t	wait_for_historical_data (in Duration_t max_wait)
ReturnCode_t	get_matched_publications (inout InstanceHandleSeq publication_handles)
ReturnCode_t	get_matched_publication_data (inout PublicationBuiltinTopicData publication_data, in InstanceHandle_t publication_handle)
Public Member Functions inherited from OpenDDS::DCPS::DataReaderCallbacks
	DataReaderCallbacks ()
virtual	~DataReaderCallbacks ()
Public Member Functions inherited from OpenDDS::DCPS::EntityImpl
	EntityImpl ()
virtual	~EntityImpl ()
bool	is_enabled () const
virtual DDS::StatusCondition_ptr	get_statuscondition ()
virtual DDS::StatusMask	get_status_changes ()
virtual DDS::DomainId_t	get_domain_id ()
virtual GUID_t	get_id () const
void	set_status_changed_flag (DDS::StatusKind status, bool status_changed_flag)
void	notify_status_condition ()
virtual void	transport_config (const TransportConfig_rch &cfg)
TransportConfig_rch	transport_config () const
void	set_observer (Observer_rch observer, Observer::Event e)
Observer_rch	get_observer (Observer::Event e)
Public Member Functions inherited from OpenDDS::DCPS::TransportClient
void	use_datalink (const GUID_t &remote_id, const DataLink_rch &link)
	TransportClient ()
virtual	~TransportClient ()
void	enable_transport (bool reliable, bool durable)
void	enable_transport_using_config (bool reliable, bool durable, const TransportConfig_rch &tc)
bool	swap_bytes () const
bool	cdr_encapsulation () const
const TransportLocatorSeq &	connection_info () const
void	populate_connection_info ()
bool	is_reliable () const
bool	associate (const AssociationData &peer, bool active)
void	disassociate (const GUID_t &peerId)
void	stop_associating ()
void	stop_associating (const GUID_t *repos, CORBA::ULong length)
void	send_final_acks ()
void	transport_stop ()
void	register_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid, const TransportLocatorSeq &locators, OpenDDS::DCPS::DiscoveryListener *listener)
void	unregister_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid)
void	register_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid, const TransportLocatorSeq &locators, DiscoveryListener *listener)
void	unregister_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid)
void	update_locators (const GUID_t &remote, const TransportLocatorSeq &locators)
WeakRcHandle< ICE::Endpoint >	get_ice_endpoint ()
bool	send_response (const GUID_t &peer, const DataSampleHeader &header, Message_Block_Ptr payload)
void	send (SendStateDataSampleList send_list, ACE_UINT64 transaction_id=0)
SendControlStatus	send_w_control (SendStateDataSampleList send_list, const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination)
SendControlStatus	send_control (const DataSampleHeader &header, Message_Block_Ptr msg)
SendControlStatus	send_control_to (const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination)
bool	remove_sample (const DataSampleElement *sample)
bool	remove_all_msgs ()
void	terminate_send_if_suspended ()
bool	associated_with (const GUID_t &remote) const
bool	pending_association_with (const GUID_t &remote) const
GUID_t	repo_id () const
void	data_acked (const GUID_t &remote)
bool	is_leading (const GUID_t &reader_id) const
Public Member Functions inherited from OpenDDS::DCPS::TransportReceiveListener
virtual	~TransportReceiveListener ()

Private Attributes
DDS::DynamicType_var	type_

Additional Inherited Members
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDSTraits< DynamicSample >::DataReaderType >
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)
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DataReaderEx >
static _ptr_type	_narrow (CORBA::Object_ptr obj)
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::Entity >
static _ptr_type	_narrow (CORBA::Object_ptr obj)
Public Attributes inherited from OpenDDS::DCPS::DataReaderEx
attribute boolean	statistics_enabled
	Statistics gathering enable state. More...
Protected Types inherited from OpenDDS::DCPS::DataReaderImpl
typedef ACE_Reverse_Lock< ACE_Recursive_Thread_Mutex >	Reverse_Lock_t
Protected Member Functions inherited from OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >
virtual RcHandle< MessageHolder >	dds_demarshal (const OpenDDS::DCPS::ReceivedDataSample &sample, DDS::InstanceHandle_t publication_handle, OpenDDS::DCPS::SubscriptionInstance_rch &instance, bool &just_registered, bool &filtered, OpenDDS::DCPS::MarshalingType marshaling_type, bool full_copy)
virtual void	dispose_unregister (const OpenDDS::DCPS::ReceivedDataSample &sample, DDS::InstanceHandle_t publication_handle, OpenDDS::DCPS::SubscriptionInstance_rch &instance)
virtual void	purge_data (OpenDDS::DCPS::SubscriptionInstance_rch instance)
virtual void	release_instance_i (DDS::InstanceHandle_t handle)
virtual void	state_updated_i (DDS::InstanceHandle_t handle)
Protected Member Functions inherited from CORBA::LocalObject
	LocalObject (void)
Protected Member Functions inherited from CORBA::Object
	Object (int dummy=0)
TAO::Object_Proxy_Broker *	proxy_broker () const
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()
Protected Member Functions inherited from OpenDDS::DCPS::DataReaderImpl
typedef	OPENDDS_SET (DDS::InstanceHandle_t) HandleSet
typedef	OPENDDS_MAP (CORBA::ULong, HandleSet) LookupMap
void	initialize_lookup_maps ()
void	update_lookup_maps (const SubscriptionInstanceMapType::iterator &input)
void	remove_from_lookup_maps (DDS::InstanceHandle_t handle)
const HandleSet &	lookup_matching_instances (CORBA::ULong sample_states, CORBA::ULong view_states, CORBA::ULong instance_states) const
DataReaderListener_ptr	get_ext_listener ()
virtual void	remove_associations_i (const WriterIdSeq &writers, bool callback)
void	prepare_to_delete ()
DDS::ReturnCode_t	setup_deserialization ()
	Setup deserialization options. More...
RcHandle< SubscriberImpl >	get_subscriber_servant ()
void	post_read_or_take ()
void	sample_info (DDS::SampleInfo &sample_info, const ReceivedDataElement *ptr)
CORBA::Long	total_samples () const
void	set_sample_lost_status (const DDS::SampleLostStatus &status)
void	set_sample_rejected_status (const DDS::SampleRejectedStatus &status)
SubscriptionInstance_rch	get_handle_instance (DDS::InstanceHandle_t handle)
DDS::InstanceHandle_t	get_next_handle (const DDS::BuiltinTopicKey_t &key)
bool	has_readcondition (DDS::ReadCondition_ptr a_condition)
bool	filter_sample (const DataSampleHeader &header)
bool	ownership_filter_instance (const SubscriptionInstance_rch &instance, const GUID_t &pubid)
bool	time_based_filter_instance (const SubscriptionInstance_rch &instance, MonotonicTimePoint &now, MonotonicTimePoint &deadline)
void	accept_sample_processing (const SubscriptionInstance_rch &instance, const DataSampleHeader &header, bool is_new_instance)
void	notify_read_conditions ()
	Data has arrived into the cache, unblock waiting ReadConditions. More...
virtual void	add_link (const DataLink_rch &link, const GUID_t &peer)
typedef	OPENDDS_SET (Encoding::Kind) EncodingKinds
Protected Member Functions inherited from OpenDDS::DCPS::EntityImpl
DDS::ReturnCode_t	set_enabled ()
void	set_deleted (bool state)
bool	get_deleted () const
DDS::InstanceHandle_t	get_entity_instance_handle (const GUID_t &id, const RcHandle< DomainParticipantImpl > &participant)
Protected Member Functions inherited from OpenDDS::DCPS::TransportClient
void	cdr_encapsulation (bool encap)
Protected Member Functions inherited from OpenDDS::DCPS::TransportReceiveListener
	TransportReceiveListener ()
Static Protected Member Functions inherited from OpenDDS::DCPS::DataReaderImpl
static CORBA::ULong	to_combined_states (CORBA::ULong sample_states, CORBA::ULong view_states, CORBA::ULong instance_states)
static void	split_combined_states (CORBA::ULong combined, CORBA::ULong &sample_states, CORBA::ULong &view_states, CORBA::ULong &instance_states)
Protected Attributes inherited from CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long >	refcount_
Protected Attributes inherited from OpenDDS::DCPS::DataReaderImpl
LookupMap	combined_state_lookup_
SubscriptionInstanceMapType	instances_
	: document why the instances_ container is mutable. More...
ACE_Recursive_Thread_Mutex	instances_lock_
bool	has_subscription_id_
ACE_Thread_Mutex	subscription_id_mutex_
ConditionVariable< ACE_Thread_Mutex >	subscription_id_condition_
unique_ptr< ReceivedDataAllocator >	rd_allocator_
DDS::DataReaderQos	qos_
DDS::DataReaderQos	passed_qos_
DDS::SampleRejectedStatus	sample_rejected_status_
DDS::SampleLostStatus	sample_lost_status_
ACE_Recursive_Thread_Mutex	sample_lock_
	lock protecting sample container as well as statuses. More...
Reverse_Lock_t	reverse_sample_lock_
WeakRcHandle< DomainParticipantImpl >	participant_servant_
TopicDescriptionPtr< TopicImpl >	topic_servant_
TypeSupportImpl *	type_support_
GUID_t	topic_id_
bool	is_exclusive_ownership_
ACE_Thread_Mutex	content_filtered_topic_mutex_
TopicDescriptionPtr< ContentFilteredTopicImpl >	content_filtered_topic_
TopicDescriptionPtr< MultiTopicImpl >	multi_topic_
bool	coherent_
	Is accessing to Group coherent changes ? More...
GroupRakeData	group_coherent_ordered_data_
	Ordered group samples. More...
DDS::SubscriberQos	subqos_
EncodingKinds	decoding_modes_
Security::SecurityConfig_rch	security_config_
DDS::DynamicType_var	dynamic_type_
TransportMessageBlockAllocator	mb_alloc_
Protected Attributes inherited from OpenDDS::DCPS::EntityImpl
AtomicBool	enabled_
	The flag indicates the entity is enabled. More...
AtomicBool	entity_deleted_
	The flag indicates the entity is being deleted. More...
Static Protected Attributes inherited from OpenDDS::DCPS::DataReaderImpl
static const CORBA::ULong	MAX_SAMPLE_STATE_FLAG = DDS::NOT_READ_SAMPLE_STATE
static const CORBA::ULong	MAX_SAMPLE_STATE_MASK = (MAX_SAMPLE_STATE_FLAG << 1) - 1
static const CORBA::ULong	MAX_SAMPLE_STATE_BITS = 2u
static const CORBA::ULong	MAX_VIEW_STATE_FLAG = DDS::NOT_NEW_VIEW_STATE
static const CORBA::ULong	MAX_VIEW_STATE_MASK = (MAX_VIEW_STATE_FLAG << 1) - 1
static const CORBA::ULong	MAX_VIEW_STATE_BITS = 2u
static const CORBA::ULong	MAX_INSTANCE_STATE_FLAG = DDS::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE
static const CORBA::ULong	MAX_INSTANCE_STATE_MASK = (MAX_INSTANCE_STATE_FLAG << 1) - 1
static const CORBA::ULong	MAX_INSTANCE_STATE_BITS = 3u
static const CORBA::ULong	COMBINED_VIEW_STATE_SHIFT = MAX_INSTANCE_STATE_BITS
static const CORBA::ULong	COMBINED_SAMPLE_STATE_SHIFT = COMBINED_VIEW_STATE_SHIFT + MAX_VIEW_STATE_BITS

Detailed Description

Definition at line 50 of file DynamicDataReaderImpl.h.

Member Typedef Documentation

Base

typedef DCPS::DataReaderImpl_T<DynamicSample> OpenDDS::XTypes::DynamicDataReaderImpl::Base

Definition at line 55 of file DynamicDataReaderImpl.h.

Member Function Documentation

get_key_value()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataReaderImpl::get_key_value ( DDS::DynamicData *&  dyn, DDS::InstanceHandle_t  ih  )

inline

Definition at line 87 of file DynamicDataReaderImpl.h.

References OpenDDS::XTypes::DynamicSample::get_dynamic_data(), get_key_value(), CORBA::release(), and DDS::RETCODE_OK.

    {
      DynamicSample ds(dyn);
      const DDS::ReturnCode_t rc = Base::get_key_value(ds, ih);
      if (rc == DDS::RETCODE_OK) {
        CORBA::release(dyn);
        DDS::DynamicData_var result = ds.get_dynamic_data(0);
        dyn = result._retn();
      }
      return rc;
    }

imbue_type()

void OpenDDS::XTypes::DynamicDataReaderImpl::imbue_type

(

DynamicSample &

sample

)

Definition at line 50 of file DynamicDataReaderImpl.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::dynamic_hook().

  {
    const DDS::DynamicData_var data = new DynamicDataImpl(type_);
    ds = DynamicSample(data);
  }

install_type_support()

void OpenDDS::XTypes::DynamicDataReaderImpl::install_type_support ( DCPS::TypeSupportImpl *  typesupport )

virtual

Reimplemented from OpenDDS::DCPS::DataReaderImpl.

Definition at line 45 of file DynamicDataReaderImpl.cpp.

References OpenDDS::DCPS::TypeSupportImpl::get_type().

  {
    type_ = ts->get_type();
  }

lookup_instance()

DDS::InstanceHandle_t OpenDDS::XTypes::DynamicDataReaderImpl::lookup_instance ( DDS::DynamicData *  dyn )

inline

Definition at line 81 of file DynamicDataReaderImpl.h.

References lookup_instance().

    {
      DynamicSample ds(dyn);
      return Base::lookup_instance(ds);
    }

read_next_sample()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataReaderImpl::read_next_sample ( DDS::DynamicData *&  dyn, DDS::SampleInfo &  si  )

inline

Definition at line 57 of file DynamicDataReaderImpl.h.

References OpenDDS::XTypes::DynamicSample::get_dynamic_data(), read_next_sample(), CORBA::release(), and DDS::RETCODE_OK.

    {
      DynamicSample ds(dyn);
      const DDS::ReturnCode_t rc = Base::read_next_sample(ds, si);
      if (rc == DDS::RETCODE_OK) {
        CORBA::release(dyn);
        DDS::DynamicData_var result = ds.get_dynamic_data(0);
        dyn = result._retn();
      }
      return rc;
    }

take_next_sample()

DDS::ReturnCode_t OpenDDS::XTypes::DynamicDataReaderImpl::take_next_sample ( DDS::DynamicData *&  dyn, DDS::SampleInfo &  si  )

inline

Definition at line 69 of file DynamicDataReaderImpl.h.

References OpenDDS::XTypes::DynamicSample::get_dynamic_data(), CORBA::release(), DDS::RETCODE_OK, and take_next_sample().

    {
      DynamicSample ds(dyn);
      const DDS::ReturnCode_t rc = Base::take_next_sample(ds, si);
      if (rc == DDS::RETCODE_OK) {
        CORBA::release(dyn);
        DDS::DynamicData_var result = ds.get_dynamic_data(0);
        dyn = result._retn();
      }
      return rc;
    }

Member Data Documentation

type_

DDS::DynamicType_var OpenDDS::XTypes::DynamicDataReaderImpl::type_

private

Definition at line 103 of file DynamicDataReaderImpl.h.

---

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

• DynamicDataReaderImpl.h
• DynamicDataReaderImpl.cpp