OpenDDS::RTPS::Sedp::Writer Class Reference

Inheritance diagram for OpenDDS::RTPS::Sedp::Writer:

Collaboration diagram for OpenDDS::RTPS::Sedp::Writer:

Public Member Functions
	Writer (const DCPS::GUID_t &pub_id, Sedp &sedp, ACE_INT64 seq_init=1)
virtual	~Writer ()
bool	assoc (const DCPS::AssociationData &subscription)
void	transport_assoc_done (int flags, const DCPS::GUID_t &remote)
void	data_delivered (const DCPS::DataSampleElement *)
void	data_dropped (const DCPS::DataSampleElement *, bool by_transport)
void	data_acked (const GUID_t &remote)
void	control_delivered (const DCPS::Message_Block_Ptr &sample)
void	control_dropped (const DCPS::Message_Block_Ptr &sample, bool dropped_by_transport)
void	notify_publication_disconnected (const DCPS::ReaderIdSeq &)
void	notify_publication_reconnected (const DCPS::ReaderIdSeq &)
void	notify_publication_lost (const DCPS::ReaderIdSeq &)
void	remove_associations (const DCPS::ReaderIdSeq &, bool)
void	replay_durable_data_for (const DCPS::GUID_t &remote_sub_id)
void	retrieve_inline_qos_data (InlineQosData &) const
const DCPS::SequenceNumber &	get_seq () const
DDS::ReturnCode_t	write_parameter_list (const ParameterList &plist, const DCPS::GUID_t &reader, DCPS::SequenceNumber &sequence)
void	end_historic_samples (const DCPS::GUID_t &reader)
void	request_ack (const DCPS::GUID_t &reader)
void	send_deferred_samples (const GUID_t &reader)
Public Member Functions inherited from OpenDDS::DCPS::TransportSendListener
virtual	~TransportSendListener ()
virtual SendControlStatus	send_control_customized (const DataLinkSet_rch &links, const DataSampleHeader &header, ACE_Message_Block *msg, void *extra)
virtual void	transport_discovery_change ()
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
long	ref_count () const
WeakObject *	_get_weak_object () const
Public Member Functions inherited from OpenDDS::RTPS::Sedp::Endpoint
	Endpoint (const DCPS::GUID_t &repo_id, Sedp &sedp)
virtual	~Endpoint ()
bool	check_transport_qos (const DCPS::TransportInst &)
DCPS::GUID_t	get_guid () const
DDS::DomainId_t	domain_id () const
CORBA::Long	get_priority_value (const DCPS::AssociationData &) const
void	set_crypto_handles (DDS::Security::ParticipantCryptoHandle p, DDS::Security::NativeCryptoHandle e=DDS::HANDLE_NIL)
DDS::Security::ParticipantCryptoHandle	get_crypto_handle () const
DDS::Security::NativeCryptoHandle	get_endpoint_crypto_handle () const
void	shutting_down ()
OPENDDS_STRING	get_instance_name (const DCPS::GUID_t &id) const
EntityId_t	counterpart_entity_id () const
GUID_t	make_counterpart_guid (const DCPS::GUID_t &remote_part) const
bool	associated_with_counterpart (const DCPS::GUID_t &remote_part) const
bool	pending_association_with_counterpart (const DCPS::GUID_t &remote_part) const
bool	associated_with_counterpart_if_not_pending (const DCPS::GUID_t &remote_part) const
RcHandle< DCPS::BitSubscriber >	get_builtin_subscriber_proxy () const
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

Protected Member Functions
typedef	OPENDDS_MAP (DCPS::SequenceNumber, DCPS::DataSampleElement *) PerReaderDeferredSamples
typedef	OPENDDS_MAP (GUID_t, PerReaderDeferredSamples) DeferredSamples
void	send_sample (DCPS::Message_Block_Ptr payload, size_t size, const DCPS::GUID_t &reader, DCPS::SequenceNumber &sequence, bool historic=false)
void	send_sample_i (DCPS::DataSampleElement *el)
void	set_header_fields (DCPS::DataSampleHeader &dsh, size_t size, const DCPS::GUID_t &reader, DCPS::SequenceNumber &sequence, bool historic_sample=false, DCPS::MessageId id=DCPS::SAMPLE_DATA)
void	write_control_msg (DCPS::Message_Block_Ptr payload, size_t size, DCPS::MessageId id, DCPS::SequenceNumber seq=DCPS::SequenceNumber())
virtual bool	deferrable () const
Protected Member Functions inherited from OpenDDS::DCPS::TransportSendListener
	TransportSendListener ()
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()
Protected Member Functions inherited from OpenDDS::DCPS::TransportClient
void	cdr_encapsulation (bool encap)

Protected Attributes
DeferredSamples	deferred_samples_
DCPS::SequenceNumber	seq_
Protected Attributes inherited from OpenDDS::RTPS::Sedp::Endpoint
DCPS::GUID_t	repo_id_
Sedp &	sedp_
AtomicBool	shutting_down_
DDS::Security::ParticipantCryptoHandle	participant_crypto_handle_
DDS::Security::NativeCryptoHandle	endpoint_crypto_handle_

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::TransportClient
enum	{ ASSOC_OK = 1, ASSOC_ACTIVE = 2 }

Detailed Description

Definition at line 432 of file Sedp.h.

Constructor & Destructor Documentation

Writer()

OpenDDS::RTPS::Sedp::Writer::Writer	(	const DCPS::GUID_t &	pub_id,
		Sedp &	sedp,
		ACE_INT64	seq_init = 1
	)

Definition at line 3180 of file Sedp.cpp.

  : Endpoint(pub_id, sedp), seq_(seq_init)
{
}

~Writer()

OpenDDS::RTPS::Sedp::Writer::~Writer ( )

virtual

Definition at line 3185 of file Sedp.cpp.

{
}

Member Function Documentation

assoc()

bool OpenDDS::RTPS::Sedp::Writer::assoc

(

const DCPS::AssociationData &

subscription

)

Definition at line 3190 of file Sedp.cpp.

References OpenDDS::DCPS::TransportClient::associate().

{
  return associate(subscription, true);
}

control_delivered()

void OpenDDS::RTPS::Sedp::Writer::control_delivered ( const DCPS::Message_Block_Ptr &  sample )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 3231 of file Sedp.cpp.

{
}

control_dropped()

void OpenDDS::RTPS::Sedp::Writer::control_dropped ( const DCPS::Message_Block_Ptr &  sample, bool  dropped_by_transport  )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 3236 of file Sedp.cpp.

{
}

data_acked()

void OpenDDS::RTPS::Sedp::Writer::data_acked ( const GUID_t &  remote )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 3225 of file Sedp.cpp.

References OpenDDS::RTPS::Sedp::data_acked_i(), OpenDDS::RTPS::Sedp::Endpoint::get_guid(), and OpenDDS::RTPS::Sedp::Endpoint::sedp_.

{
  sedp_.data_acked_i(get_guid(), remote);
}

data_delivered()

void OpenDDS::RTPS::Sedp::Writer::data_delivered ( const DCPS::DataSampleElement *  dsle )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 3213 of file Sedp.cpp.

{
  delete dsle;
}

data_dropped()

void OpenDDS::RTPS::Sedp::Writer::data_dropped ( const DCPS::DataSampleElement *  dsle, bool  by_transport  )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 3219 of file Sedp.cpp.

{
  delete dsle;
}

deferrable()

virtual bool OpenDDS::RTPS::Sedp::Writer::deferrable ( ) const

inlineprotectedvirtual

Reimplemented in OpenDDS::RTPS::Sedp::TypeLookupReplyWriter, and OpenDDS::RTPS::Sedp::TypeLookupRequestWriter.

Definition at line 500 of file Sedp.h.

Referenced by send_sample().

    {
      return false;
    }

end_historic_samples()

void OpenDDS::RTPS::Sedp::Writer::end_historic_samples

(

const DCPS::GUID_t &

reader

)

Definition at line 3513 of file Sedp.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_Message_Block::cont(), OpenDDS::DCPS::END_HISTORIC_SAMPLES, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), OpenDDS::DCPS::DataSampleHeader::get_max_serialized_size(), LM_ERROR, ACE_Message_Block::MB_DATA, OpenDDS::DCPS::move(), OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), ACE_Message_Block::wr_ptr(), and write_control_msg().

{
  DCPS::Message_Block_Ptr mb(
    new ACE_Message_Block(
      DCPS::DataSampleHeader::get_max_serialized_size(),
      ACE_Message_Block::MB_DATA,
      new ACE_Message_Block(
        reinterpret_cast<const char*>(&reader),
        sizeof(reader))));
  if (mb.get()) {
    mb->cont()->wr_ptr(sizeof(reader));
    // 'mb' would contain the DSHeader, but we skip it. mb.cont() has the data
    write_control_msg(move(mb), sizeof(reader), DCPS::END_HISTORIC_SAMPLES,
                      DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN());
  } else {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: Sedp::Writer::end_historic_samples")
               ACE_TEXT(" - Failed to allocate message block message\n")));
  }
}

get_seq()

const DCPS::SequenceNumber& OpenDDS::RTPS::Sedp::Writer::get_seq ( ) const

inline

Definition at line 460 of file Sedp.h.

References OpenDDS::RTPS::Sedp::OPENDDS_MAP().

    {
      return seq_;
    }

notify_publication_disconnected()

void OpenDDS::RTPS::Sedp::Writer::notify_publication_disconnected ( const DCPS::ReaderIdSeq &  )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 453 of file Sedp.h.

{}

notify_publication_lost()

void OpenDDS::RTPS::Sedp::Writer::notify_publication_lost ( const DCPS::ReaderIdSeq &  )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 455 of file Sedp.h.

{}

notify_publication_reconnected()

void OpenDDS::RTPS::Sedp::Writer::notify_publication_reconnected ( const DCPS::ReaderIdSeq &  )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 454 of file Sedp.h.

{}

OPENDDS_MAP() [1/2]

typedef OpenDDS::RTPS::Sedp::Writer::OPENDDS_MAP ( DCPS::SequenceNumber  , DCPS::DataSampleElement *    )

protected

OPENDDS_MAP() [2/2]

typedef OpenDDS::RTPS::Sedp::Writer::OPENDDS_MAP ( GUID_t  , PerReaderDeferredSamples    )

protected

remove_associations()

void OpenDDS::RTPS::Sedp::Writer::remove_associations ( const DCPS::ReaderIdSeq &  , bool    )

inlinevirtual

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 456 of file Sedp.h.

References OpenDDS::RTPS::Sedp::replay_durable_data_for().

{}

replay_durable_data_for()

void OpenDDS::RTPS::Sedp::Writer::replay_durable_data_for ( const DCPS::GUID_t &  remote_sub_id )

virtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 3241 of file Sedp.cpp.

References OpenDDS::RTPS::Sedp::replay_durable_data_for(), and OpenDDS::RTPS::Sedp::Endpoint::sedp_.

{
  // Ideally, we would have the data cached and ready for replay but we do not.
  sedp_.replay_durable_data_for(remote_sub_id);
}

request_ack()

void OpenDDS::RTPS::Sedp::Writer::request_ack

(

const DCPS::GUID_t &

reader

)

Definition at line 3535 of file Sedp.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_Message_Block::cont(), OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), OpenDDS::DCPS::DataSampleHeader::get_max_serialized_size(), LM_ERROR, ACE_Message_Block::MB_DATA, OpenDDS::DCPS::move(), OpenDDS::DCPS::REQUEST_ACK, OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), ACE_Message_Block::wr_ptr(), and write_control_msg().

{
  DCPS::Message_Block_Ptr mb(
    new ACE_Message_Block(
      DCPS::DataSampleHeader::get_max_serialized_size(),
      ACE_Message_Block::MB_DATA,
      new ACE_Message_Block(
        reinterpret_cast<const char*>(&reader),
        sizeof(reader))));
  if (mb.get()) {
    mb->cont()->wr_ptr(sizeof(reader));
    // 'mb' would contain the DSHeader, but we skip it. mb.cont() has the data
    write_control_msg(move(mb), sizeof(reader), DCPS::REQUEST_ACK,
                      DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN());
  } else {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: Sedp::Writer::request_ack")
               ACE_TEXT(" - Failed to allocate message block message\n")));
  }
}

retrieve_inline_qos_data()

void OpenDDS::RTPS::Sedp::Writer::retrieve_inline_qos_data ( InlineQosData &  ) const

inlinevirtual

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 458 of file Sedp.h.

{}

send_deferred_samples()

void OpenDDS::RTPS::Sedp::Writer::send_deferred_samples

(

const GUID_t &

reader

)

Definition at line 3283 of file Sedp.cpp.

References ACE_DEBUG, OpenDDS::DCPS::DCPS_debug_level, deferred_samples_, LM_DEBUG, and send_sample_i().

{
  DeferredSamples::iterator samples_for_reader = deferred_samples_.find(reader);
  if (samples_for_reader != deferred_samples_.end()) {
    if (DCPS::DCPS_debug_level >= 8) {
      ACE_DEBUG((LM_DEBUG, "(%P|%t) Sedp::Writer::send_deferred_samples to %C\n",
        DCPS::LogGuid(reader).c_str()));
    }
    for (PerReaderDeferredSamples::iterator i = samples_for_reader->second.begin();
        i != samples_for_reader->second.end(); ++i) {
      send_sample_i(i->second);
    }
    deferred_samples_.erase(samples_for_reader);
  }
}

send_sample()

void OpenDDS::RTPS::Sedp::Writer::send_sample ( DCPS::Message_Block_Ptr  payload, size_t  size, const DCPS::GUID_t &  reader, DCPS::SequenceNumber &  sequence, bool  historic = false  )

protected

Definition at line 3247 of file Sedp.cpp.

References ACE_DEBUG, OpenDDS::RTPS::Sedp::Endpoint::associated_with_counterpart(), OpenDDS::DCPS::DCPS_debug_level, deferrable(), deferred_samples_, OpenDDS::DCPS::DataSampleElement::get_header(), OpenDDS::DCPS::DataSampleElement::get_sample(), OpenDDS::DCPS::GUID_UNKNOWN, LM_DEBUG, OpenDDS::DCPS::move(), OpenDDS::RTPS::Sedp::Endpoint::repo_id_, send_sample_i(), set_header_fields(), OpenDDS::DCPS::DataSampleElement::set_num_subs(), OpenDDS::DCPS::DataSampleElement::set_sample(), and OpenDDS::DCPS::DataSampleElement::set_sub_id().

Referenced by OpenDDS::RTPS::Sedp::TypeLookupReplyWriter::send_type_lookup_reply(), OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request(), write_parameter_list(), OpenDDS::RTPS::Sedp::LivelinessWriter::write_participant_message(), OpenDDS::RTPS::Sedp::SecurityWriter::write_stateless_message(), and OpenDDS::RTPS::Sedp::SecurityWriter::write_volatile_message_secure().

{
  if (DCPS::DCPS_debug_level >= 8) {
    ACE_DEBUG((LM_DEBUG, "(%P|%t) Sedp::Writer::send_sample from %C to %C\n",
      DCPS::LogGuid(repo_id_).c_str(),
      DCPS::LogGuid(reader).c_str()));
  }
  DCPS::DataSampleElement* el = new DCPS::DataSampleElement(repo_id_, this, DCPS::PublicationInstance_rch());
  set_header_fields(el->get_header(), size, reader, sequence, historic);

  el->set_sample(DCPS::move(payload));
  *el->get_sample() << el->get_header();

  if (reader != GUID_UNKNOWN) {
    el->set_sub_id(0, reader);
    el->set_num_subs(1);

    if (deferrable() && !associated_with_counterpart(reader)) {
      if (DCPS::DCPS_debug_level >= 8) {
        ACE_DEBUG((LM_DEBUG, "(%P|%t) Sedp::Writer::send_sample: "
          "counterpart isn't associated, deferring\n"));
      }
      DeferredSamples::iterator samples_for_reader = deferred_samples_.insert(
        std::make_pair(reader, PerReaderDeferredSamples())).first;
      samples_for_reader->second.insert(std::make_pair(sequence, el));
      return;
    }
  }

  send_sample_i(el);
}

send_sample_i()

void OpenDDS::RTPS::Sedp::Writer::send_sample_i ( DCPS::DataSampleElement *  el )

protected

Definition at line 3299 of file Sedp.cpp.

References OpenDDS::DCPS::SendStateDataSampleList::enqueue_tail(), and OpenDDS::DCPS::TransportClient::send().

Referenced by send_deferred_samples(), and send_sample().

{
  DCPS::SendStateDataSampleList list;
  list.enqueue_tail(el);

  send(list);
}

set_header_fields()

void OpenDDS::RTPS::Sedp::Writer::set_header_fields ( DCPS::DataSampleHeader &  dsh, size_t  size, const DCPS::GUID_t &  reader, DCPS::SequenceNumber &  sequence, bool  historic_sample = false, DCPS::MessageId  id = DCPS::SAMPLE_DATA  )

protected

Definition at line 3569 of file Sedp.cpp.

References ACE_CDR_BYTE_ORDER, OpenDDS::DCPS::DataSampleHeader::byte_order_, OpenDDS::DCPS::END_HISTORIC_SAMPLES, OpenDDS::DCPS::GUID_UNKNOWN, OpenDDS::DCPS::DataSampleHeader::historic_sample_, OpenDDS::DCPS::DataSampleHeader::message_id_, OpenDDS::DCPS::DataSampleHeader::message_length_, OpenDDS::DCPS::DataSampleHeader::publication_id_, OpenDDS::RTPS::Sedp::Endpoint::repo_id_, OpenDDS::DCPS::REQUEST_ACK, seq_, OpenDDS::DCPS::DataSampleHeader::sequence_, OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), OpenDDS::DCPS::DataSampleHeader::source_timestamp_nanosec_, and OpenDDS::DCPS::DataSampleHeader::source_timestamp_sec_.

Referenced by send_sample(), and write_control_msg().

{
  dsh.message_id_ = id;
  dsh.byte_order_ = ACE_CDR_BYTE_ORDER;
  dsh.message_length_ = static_cast<ACE_UINT32>(size);
  dsh.publication_id_ = repo_id_;

  if (id != DCPS::END_HISTORIC_SAMPLES && id != DCPS::REQUEST_ACK &&
      (reader == GUID_UNKNOWN ||
       sequence == DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN())) {
    sequence = seq_++;
  }

  if (historic_sample && reader != GUID_UNKNOWN) {
    // retransmit with same seq# for durability
    dsh.historic_sample_ = true;
  }

  dsh.sequence_ = sequence;

  const SystemTimePoint now = SystemTimePoint::now();
  dsh.source_timestamp_sec_ = static_cast<ACE_INT32>(now.value().sec());
  dsh.source_timestamp_nanosec_ = static_cast<ACE_UINT32>(now.value().usec() * 1000);
}

transport_assoc_done()

void OpenDDS::RTPS::Sedp::Writer::transport_assoc_done ( int  flags, const DCPS::GUID_t &  remote  )

virtual

Reimplemented from OpenDDS::DCPS::TransportClient.

Definition at line 3195 of file Sedp.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::TransportClient::ASSOC_OK, OpenDDS::RTPS::Sedp::association_complete_i(), LM_ERROR, OpenDDS::RTPS::Sedp::Endpoint::repo_id_, OpenDDS::RTPS::Sedp::Endpoint::sedp_, and OpenDDS::RTPS::Sedp::Endpoint::shutting_down_.

{
  if (!(flags & ASSOC_OK)) {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) Sedp::Writer::transport_assoc_done: ")
               ACE_TEXT("ERROR: transport layer failed to associate %C\n"),
               DCPS::LogGuid(remote).c_str()));
    return;
  }

  if (shutting_down_) {
    return;
  }

  sedp_.association_complete_i(repo_id_, remote);
}

write_control_msg()

void OpenDDS::RTPS::Sedp::Writer::write_control_msg ( DCPS::Message_Block_Ptr  payload, size_t  size, DCPS::MessageId  id, DCPS::SequenceNumber  seq = DCPS::SequenceNumber()  )

protected

Definition at line 3557 of file Sedp.cpp.

References OpenDDS::DCPS::GUID_UNKNOWN, header, OpenDDS::DCPS::move(), OpenDDS::DCPS::TransportClient::send_control(), and set_header_fields().

Referenced by end_historic_samples(), request_ack(), and OpenDDS::RTPS::Sedp::DiscoveryWriter::write_unregister_dispose().

{
  DCPS::DataSampleHeader header;
  Writer::set_header_fields(header, size, GUID_UNKNOWN, seq, false, id);
  // no need to serialize header since rtps_udp transport ignores it
  send_control(header, DCPS::move(payload));
}

write_parameter_list()

DDS::ReturnCode_t OpenDDS::RTPS::Sedp::Writer::write_parameter_list	(	const ParameterList &	plist,
		const DCPS::GUID_t &	reader,
		DCPS::SequenceNumber &	sequence
	)

Definition at line 3308 of file Sedp.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_Message_Block::cont(), OpenDDS::DCPS::DataSampleHeader::get_max_serialized_size(), OpenDDS::DCPS::GUID_UNKNOWN, LM_ERROR, ACE_Message_Block::MB_DATA, OpenDDS::DCPS::move(), OpenDDS::DCPS::MUTABLE, OpenDDS::DCPS::primitive_serialized_size_ulong(), DDS::RETCODE_ERROR, DDS::RETCODE_OK, send_sample(), and OpenDDS::DCPS::serialized_size().

Referenced by OpenDDS::RTPS::Sedp::DiscoveryWriter::write_dcps_participant_secure().

{
  DDS::ReturnCode_t result = DDS::RETCODE_OK;

  // Determine message length
  size_t size = 0;
  DCPS::primitive_serialized_size_ulong(sedp_encoding, size);
  DCPS::serialized_size(sedp_encoding, size, plist);

  // Build and send RTPS message
  DCPS::Message_Block_Ptr payload(
    new ACE_Message_Block(
      DCPS::DataSampleHeader::get_max_serialized_size(),
      ACE_Message_Block::MB_DATA,
      new ACE_Message_Block(size)));

  if (!payload) {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: Sedp::Writer::write_parameter_list")
               ACE_TEXT(" - Failed to allocate message block message\n")));
    return DDS::RETCODE_ERROR;
  }

  Serializer serializer(payload->cont(), sedp_encoding);
  DCPS::EncapsulationHeader encap;
  if (encap.from_encoding(sedp_encoding, DCPS::MUTABLE) &&
      serializer << encap && serializer << plist) {
    send_sample(move(payload), size, reader, sequence, reader != GUID_UNKNOWN);
  } else {
    result = DDS::RETCODE_ERROR;
  }

  return result;
}

Member Data Documentation

deferred_samples_

DeferredSamples OpenDDS::RTPS::Sedp::Writer::deferred_samples_

protected

Definition at line 478 of file Sedp.h.

Referenced by send_deferred_samples(), and send_sample().

seq_

DCPS::SequenceNumber OpenDDS::RTPS::Sedp::Writer::seq_

protected

Definition at line 505 of file Sedp.h.

Referenced by OpenDDS::RTPS::Sedp::TypeLookupReplyWriter::send_type_lookup_reply(), OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request(), and set_header_fields().

---

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

• Sedp.h
• Sedp.cpp