#include <DataWriterImpl_T.h>

Inheritance diagram for OpenDDS::DCPS::DataWriterImpl_T< MessageType >:

[legend]

Collaboration diagram for OpenDDS::DCPS::DataWriterImpl_T< MessageType >:

[legend]

Public Member Functions
	DataWriterImpl_T ()

virtual	~DataWriterImpl_T ()

DDS::InstanceHandle_t	register_instance (const MessageType &instance)

DDS::InstanceHandle_t	register_instance_w_timestamp (const MessageType &instance, const DDS::Time_t &timestamp)

DDS::ReturnCode_t	unregister_instance (const MessageType &instance, DDS::InstanceHandle_t handle)

DDS::ReturnCode_t	unregister_instance_w_timestamp (const MessageType &instance_data, DDS::InstanceHandle_t instance_handle, const DDS::Time_t &timestamp)

DDS::ReturnCode_t	write (const MessageType &instance_data, DDS::InstanceHandle_t handle)

DDS::ReturnCode_t	write_w_timestamp (const MessageType &instance_data, DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp)

DDS::ReturnCode_t	dispose (const MessageType &instance_data, DDS::InstanceHandle_t instance_handle)

DDS::ReturnCode_t	dispose_w_timestamp (const MessageType &instance_data, DDS::InstanceHandle_t instance_handle, const DDS::Time_t &source_timestamp)

DDS::ReturnCode_t	get_key_value (MessageType &key_holder, DDS::InstanceHandle_t handle)

DDS::InstanceHandle_t	lookup_instance (const MessageType &instance_data)

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

Public Member Functions inherited from OpenDDS::DCPS::DataWriterImpl
typedef	OPENDDS_MAP_CMP (GUID_t, SequenceNumber, GUID_tKeyLessThan) RepoIdToSequenceMap

	DataWriterImpl ()

virtual	~DataWriterImpl ()

void	set_marshal_skip_serialize (bool value)

bool	get_marshal_skip_serialize () const

DataAllocator *	data_allocator () const

virtual DDS::InstanceHandle_t	get_instance_handle ()

virtual DDS::ReturnCode_t	set_qos (const DDS::DataWriterQos &qos)

virtual DDS::ReturnCode_t	get_qos (DDS::DataWriterQos &qos)

virtual DDS::ReturnCode_t	set_listener (DDS::DataWriterListener_ptr a_listener, DDS::StatusMask mask)

virtual DDS::DataWriterListener_ptr	get_listener ()

virtual DDS::Topic_ptr	get_topic ()

virtual DDS::ReturnCode_t	wait_for_acknowledgments (const DDS::Duration_t &max_wait)

virtual DDS::Publisher_ptr	get_publisher ()

virtual DDS::ReturnCode_t	get_liveliness_lost_status (DDS::LivelinessLostStatus &status)

virtual DDS::ReturnCode_t	get_offered_deadline_missed_status (DDS::OfferedDeadlineMissedStatus &status)

virtual DDS::ReturnCode_t	get_offered_incompatible_qos_status (DDS::OfferedIncompatibleQosStatus &status)

virtual DDS::ReturnCode_t	get_publication_matched_status (DDS::PublicationMatchedStatus &status)

TimeDuration	liveliness_check_interval (DDS::LivelinessQosPolicyKind kind)

bool	participant_liveliness_activity_after (const MonotonicTimePoint &tv)

virtual DDS::ReturnCode_t	assert_liveliness ()

DDS::ReturnCode_t	assert_liveliness_by_participant ()

typedef	OPENDDS_VECTOR (DDS::InstanceHandle_t) InstanceHandleVec

void	get_instance_handles (InstanceHandleVec &instance_handles)

void	get_readers (RepoIdSet &readers)

virtual DDS::ReturnCode_t	get_matched_subscriptions (DDS::InstanceHandleSeq &subscription_handles)

virtual DDS::ReturnCode_t	get_matched_subscription_data (DDS::SubscriptionBuiltinTopicData &subscription_data, DDS::InstanceHandle_t subscription_handle)

virtual DDS::ReturnCode_t	enable ()

virtual void	add_association (const GUID_t &yourId, const ReaderAssociation &reader, bool active)

virtual void	transport_assoc_done (int flags, const GUID_t &remote_id)

virtual void	remove_associations (const ReaderIdSeq &readers, bool callback)

virtual void	replay_durable_data_for (const GUID_t &remote_sub_id)

virtual void	update_incompatible_qos (const IncompatibleQosStatus &status)

virtual void	update_subscription_params (const GUID_t &readerId, const DDS::StringSeq &params)

void	cleanup ()

void	init (TopicImpl topic_servant, const DDS::DataWriterQos &qos, DDS::DataWriterListener_ptr a_listener, const DDS::StatusMask &mask, WeakRcHandle< DomainParticipantImpl > participant_servant, PublisherImpl publisher_servant)

void	send_all_to_flush_control (ACE_Guard< ACE_Recursive_Thread_Mutex > &guard)

DDS::ReturnCode_t	register_instance_i (DDS::InstanceHandle_t &handle, Message_Block_Ptr data, const DDS::Time_t &source_timestamp)

DDS::ReturnCode_t	register_instance_from_durable_data (DDS::InstanceHandle_t &handle, Message_Block_Ptr data, const DDS::Time_t &source_timestamp)

DDS::ReturnCode_t	unregister_instance_i (DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp)

void	unregister_instances (const DDS::Time_t &source_timestamp)

DDS::ReturnCode_t	write (Message_Block_Ptr sample, DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp, GUIDSeq filter_out, const void real_data)

DDS::ReturnCode_t	write_sample (const Sample &sample, DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp, GUIDSeq *filter_out)

DDS::ReturnCode_t	dispose (DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp)

DDS::ReturnCode_t	num_samples (DDS::InstanceHandle_t handle, size_t &size)

ACE_UINT64	get_unsent_data (SendStateDataSampleList &list)

SendStateDataSampleList	get_resend_data ()

GUID_t	get_dp_id ()

void	unregister_all ()

void	data_delivered (const DataSampleElement *sample)

void	transport_discovery_change ()

void	control_delivered (const Message_Block_Ptr &sample)

bool	should_ack () const
	Does this writer have samples to be acknowledged? More...

AckToken	create_ack_token (DDS::Duration_t max_wait) const
	Create an AckToken for ack operations. More...

virtual void	retrieve_inline_qos_data (TransportSendListener::InlineQosData &qos_data) const

virtual bool	check_transport_qos (const TransportInst &inst)

bool	coherent_changes_pending ()
	Are coherent changes pending? More...

void	begin_coherent_changes ()
	Starts a coherent change set; should only be called once. More...

void	end_coherent_changes (const GroupCoherentSamples &group_samples)
	Ends a coherent change set; should only be called once. More...

char const *	get_type_name () const

void	data_dropped (const DataSampleElement *element, bool dropped_by_transport)

void	control_dropped (const Message_Block_Ptr &sample, bool dropped_by_transport)

ACE_Recursive_Thread_Mutex &	get_lock () const

DDS::DataWriterListener_ptr	listener_for (DDS::StatusKind kind)

virtual int	handle_timeout (const ACE_Time_Value &tv, const void *arg)
	Handle the assert liveliness timeout. More...

void	send_suspended_data ()

void	remove_all_associations ()

virtual void	register_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid, const TransportLocatorSeq &locators, DiscoveryListener *listener)

virtual void	unregister_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid)

virtual void	update_locators (const GUID_t &remote, const TransportLocatorSeq &locators)

void	notify_publication_disconnected (const ReaderIdSeq &subids)

void	notify_publication_reconnected (const ReaderIdSeq &subids)

void	notify_publication_lost (const ReaderIdSeq &subids)

DDS::ReturnCode_t	create_sample_data_message (Message_Block_Ptr data, DDS::InstanceHandle_t instance_handle, DataSampleHeader &header_data, Message_Block_Ptr &message, const DDS::Time_t &source_timestamp, bool content_filter)

bool	persist_data ()

void	wait_pending ()
	Wait for pending data and control messages to drain. More...

void	set_wait_pending_deadline (const MonotonicTimePoint &deadline)

DDS::InstanceHandle_t	get_next_handle ()

virtual RcHandle< EntityImpl >	parent () const

bool	filter_out (const DataSampleElement &elt, const OPENDDS_STRING &filterClassName, const FilterEvaluator &evaluator, const DDS::StringSeq &expression_params) const

DataBlockLockPool::DataBlockLock *	get_db_lock ()

PublicationInstance_rch	get_handle_instance (DDS::InstanceHandle_t handle)

virtual WeakRcHandle< ICE::Endpoint >	get_ice_endpoint ()

GUID_t	get_guid () const

SequenceNumber	get_max_sn () const

const ValueDispatcher *	get_value_dispatcher () const

DDS::ReturnCode_t	get_key_value (Sample_rch &sample, DDS::InstanceHandle_t handle)

DDS::InstanceHandle_t	lookup_instance (const Sample &sample)

DDS::InstanceHandle_t	register_instance_w_timestamp (const Sample &sample, const DDS::Time_t &timestamp)

DDS::ReturnCode_t	unregister_instance_w_timestamp (const Sample &sample, DDS::InstanceHandle_t instance_handle, const DDS::Time_t &timestamp)

DDS::ReturnCode_t	dispose_w_timestamp (const Sample &sample, DDS::InstanceHandle_t instance_handle, const DDS::Time_t &source_timestamp)

Public Member Functions inherited from DDS::DataWriter
ReturnCode_t	set_qos (in DataWriterQos qos)

ReturnCode_t	get_qos (inout DataWriterQos qos)

ReturnCode_t	set_listener (in DataWriterListener a_listener, in StatusMask mask)

ReturnCode_t	wait_for_acknowledgments (in Duration_t max_wait)

ReturnCode_t	get_liveliness_lost_status (inout LivelinessLostStatus status)

ReturnCode_t	get_offered_deadline_missed_status (inout OfferedDeadlineMissedStatus status)

ReturnCode_t	get_offered_incompatible_qos_status (inout OfferedIncompatibleQosStatus status)

ReturnCode_t	get_publication_matched_status (inout PublicationMatchedStatus status)

ReturnCode_t	get_matched_subscriptions (inout InstanceHandleSeq subscription_handles)

ReturnCode_t	get_matched_subscription_data (inout SubscriptionBuiltinTopicData subscription_data, in InstanceHandle_t subscription_handle)

Public Member Functions inherited from OpenDDS::DCPS::DataWriterCallbacks
	DataWriterCallbacks ()

virtual	~DataWriterCallbacks ()

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 ()

virtual void	add_link (const DataLink_rch &link, const GUID_t &peer)

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::TransportSendListener
virtual	~TransportSendListener ()

virtual void	data_acked (const GUID_t &)

virtual SendControlStatus	send_control_customized (const DataLinkSet_rch &links, const DataSampleHeader &header, ACE_Message_Block msg, void extra)

Private Types
typedef Sample_T< MessageType >	SampleType

Friends
class	::DDS_TEST

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::LocalObject< DDSTraits< MessageType >::DataWriterType >
typedef DDSTraits< MessageType >::DataWriterType ::_ptr_type	_ptr_type

typedef DDSTraits< MessageType >::DataWriterType ::_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::DataWriterImpl
typedef Dynamic_Cached_Allocator_With_Overflow< ACE_Thread_Mutex >	DataAllocator

Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::DataWriter >
typedef DDS::DataWriter ::_ptr_type	_ptr_type

typedef DDS::DataWriter ::_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 }

Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDSTraits< MessageType >::DataWriterType >
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< DDS::DataWriter >
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::DataWriterImpl
Atomic< int >	data_dropped_count_
	Statistics counter. More...

Atomic< int >	data_delivered_count_

MessageTracker	controlTracker

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::DataWriterImpl
void	check_and_set_repo_id (const GUID_t &id)

SequenceNumber	get_next_sn ()

SequenceNumber	get_next_sn_i ()

DataWriterListener_ptr	get_ext_listener ()

DDS::ReturnCode_t	wait_for_specific_ack (const AckToken &token)

void	prepare_to_delete ()

DDS::ReturnCode_t	setup_serialization ()

ACE_Message_Block *	serialize_sample (const Sample &sample)

typedef	OPENDDS_MAP_CMP (GUID_t, ReaderInfo, GUID_tKeyLessThan) RepoIdToReaderInfoMap

virtual SendControlStatus	send_control (const DataSampleHeader &header, Message_Block_Ptr msg)

TypeSupportImpl *	get_type_support () const

DDS::ReturnCode_t	instance_must_exist (const char *method_name, const Sample &sample, DDS::InstanceHandle_t &instance_handle, bool remove=false)

DDS::ReturnCode_t	get_or_create_instance_handle (DDS::InstanceHandle_t &handle, const Sample &sample, const DDS::Time_t &source_timestamp)

DDS::ReturnCode_t	write_w_timestamp (const Sample &sample, DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp)

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::TransportSendListener
	TransportSendListener ()

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

Protected Attributes inherited from OpenDDS::DCPS::DataWriterImpl
size_t	n_chunks_
	The number of chunks for the cached allocator. More...

size_t	association_chunk_multiplier_
	The multiplier for allocators affected by associations. More...

CORBA::String_var	type_name_
	The type name of associated topic. More...

DDS::DataWriterQos	qos_
	The qos policy list of this datawriter. More...

DDS::DataWriterQos	passed_qos_

WeakRcHandle< DomainParticipantImpl >	participant_servant_

ACE_Thread_Mutex	reader_info_lock_

RepoIdToReaderInfoMap	reader_info_

bool	skip_serialize_

class OpenDDS::DCPS::DataWriterImpl::EncodingMode	encoding_mode_

Security::SecurityConfig_rch	security_config_

DDS::Security::PermissionsHandle	participant_permissions_handle_

DDS::DynamicType_var	dynamic_type_

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...

Detailed Description

template<typename MessageType>
class OpenDDS::DCPS::DataWriterImpl_T< MessageType >

Servant for DataWriter interface of the MessageType data type.

See the DDS specification, OMG formal/2015-04-10, for a description of this interface.

Definition at line 34 of file DataWriterImpl_T.h.

Member Typedef Documentation

◆ SampleType

template<typename MessageType >

typedef Sample_T<MessageType> OpenDDS::DCPS::DataWriterImpl_T< MessageType >::SampleType

private

Definition at line 128 of file DataWriterImpl_T.h.

Constructor & Destructor Documentation

◆ DataWriterImpl_T()

template<typename MessageType >

OpenDDS::DCPS::DataWriterImpl_T< MessageType >::DataWriterImpl_T ( )

inline

Definition at line 43 of file DataWriterImpl_T.h.

44 {

45 }

◆ ~DataWriterImpl_T()

template<typename MessageType >

virtual OpenDDS::DCPS::DataWriterImpl_T< MessageType >::~DataWriterImpl_T ( )

inlinevirtual

Definition at line 47 of file DataWriterImpl_T.h.

48 {

49 }

Member Function Documentation

◆ dispose()

template<typename MessageType >

DDS::ReturnCode_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::dispose	(	const MessageType &	instance_data,
		DDS::InstanceHandle_t	instance_handle
	)

inline

Definition at line 97 of file DataWriterImpl_T.h.

References dispose_w_timestamp(), and OpenDDS::DCPS::TimePoint_T< SystemClock >::now().

   {
     return dispose_w_timestamp(instance_data, instance_handle, SystemTimePoint::now().to_dds_time());
   }

◆ dispose_w_timestamp()

template<typename MessageType >

DDS::ReturnCode_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::dispose_w_timestamp	(	const MessageType &	instance_data,
		DDS::InstanceHandle_t	instance_handle,
		const DDS::Time_t &	source_timestamp
	)

inline

Definition at line 102 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::DataWriterImpl::dispose_w_timestamp(), and OpenDDS::DCPS::Sample::KeyOnly.

   {
     const SampleType sample(instance_data, Sample::KeyOnly);
     return DataWriterImpl::dispose_w_timestamp(sample, instance_handle, source_timestamp);
   }

◆ get_key_value()

template<typename MessageType >

DDS::ReturnCode_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::get_key_value	(	MessageType &	key_holder,
		DDS::InstanceHandle_t	handle
	)

inline

Definition at line 111 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::dynamic_rchandle_cast(), and OpenDDS::DCPS::DataWriterImpl::get_key_value().

   {
     Sample_rch sample;
     const DDS::ReturnCode_t rc = DataWriterImpl::get_key_value(sample, handle);
     if (sample) {
       key_holder = dynamic_rchandle_cast<SampleType>(sample)->data();
     }
     return rc;
   }

◆ lookup_instance()

template<typename MessageType >

DDS::InstanceHandle_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::lookup_instance ( const MessageType & instance_data )

inline

Definition at line 121 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::Sample::KeyOnly, and OpenDDS::DCPS::DataWriterImpl::lookup_instance().

   {
     const SampleType sample(instance_data, Sample::KeyOnly);
     return DataWriterImpl::lookup_instance(sample);
   }

◆ register_instance()

template<typename MessageType >

DDS::InstanceHandle_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::register_instance ( const MessageType & instance )

inline

Definition at line 51 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::TimePoint_T< SystemClock >::now(), and register_instance_w_timestamp().

   {
     return register_instance_w_timestamp(instance, SystemTimePoint::now().to_dds_time());
   }

◆ register_instance_w_timestamp()

template<typename MessageType >

DDS::InstanceHandle_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::register_instance_w_timestamp	(	const MessageType &	instance,
		const DDS::Time_t &	timestamp
	)

inline

Definition at line 56 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::Sample::KeyOnly, and OpenDDS::DCPS::DataWriterImpl::register_instance_w_timestamp().

   {
     const SampleType sample(instance, Sample::KeyOnly);
     return DataWriterImpl::register_instance_w_timestamp(sample, timestamp);
   }

◆ unregister_instance()

template<typename MessageType >

DDS::ReturnCode_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::unregister_instance	(	const MessageType &	instance,
		DDS::InstanceHandle_t	handle
	)

inline

Definition at line 63 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::TimePoint_T< SystemClock >::now(), and unregister_instance_w_timestamp().

   {
     return unregister_instance_w_timestamp(instance, handle, SystemTimePoint::now().to_dds_time());
   }

◆ unregister_instance_w_timestamp()

template<typename MessageType >

DDS::ReturnCode_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::unregister_instance_w_timestamp	(	const MessageType &	instance_data,
		DDS::InstanceHandle_t	instance_handle,
		const DDS::Time_t &	timestamp
	)

inline

Definition at line 68 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::Sample::KeyOnly, and OpenDDS::DCPS::DataWriterImpl::unregister_instance_w_timestamp().

   {
     const SampleType sample(instance_data, Sample::KeyOnly);
     return DataWriterImpl::unregister_instance_w_timestamp(sample, instance_handle, timestamp);
   }

◆ write()

template<typename MessageType >

DDS::ReturnCode_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::write	(	const MessageType &	instance_data,
		DDS::InstanceHandle_t	handle
	)

inline

Definition at line 80 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::TimePoint_T< SystemClock >::now(), and write_w_timestamp().

   {
     return write_w_timestamp(instance_data, handle, SystemTimePoint::now().to_dds_time());
   }

◆ write_w_timestamp()

template<typename MessageType >

DDS::ReturnCode_t OpenDDS::DCPS::DataWriterImpl_T< MessageType >::write_w_timestamp	(	const MessageType &	instance_data,
		DDS::InstanceHandle_t	handle,
		const DDS::Time_t &	source_timestamp
	)

inline

Definition at line 88 of file DataWriterImpl_T.h.

References OpenDDS::DCPS::DataWriterImpl::write_w_timestamp().

   {
     const SampleType sample(instance_data);
     return DataWriterImpl::write_w_timestamp(sample, handle, source_timestamp);
   }

Friends And Related Function Documentation

◆ ::DDS_TEST

template<typename MessageType >

friend class ::DDS_TEST

friend

Definition at line 132 of file DataWriterImpl_T.h.

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

DataWriterImpl_T.h

Public Member Functions

Private Types

Friends

Additional Inherited Members

Detailed Description

template<typename MessageType> class OpenDDS::DCPS::DataWriterImpl_T< MessageType >

Member Typedef Documentation

◆ SampleType

Constructor & Destructor Documentation

◆ DataWriterImpl_T()

◆ ~DataWriterImpl_T()

Member Function Documentation

◆ dispose()

◆ dispose_w_timestamp()

◆ get_key_value()

◆ lookup_instance()

◆ register_instance()

◆ register_instance_w_timestamp()

◆ unregister_instance()

◆ unregister_instance_w_timestamp()

◆ write()

◆ write_w_timestamp()

Friends And Related Function Documentation

◆ ::DDS_TEST

template<typename MessageType>
class OpenDDS::DCPS::DataWriterImpl_T< MessageType >