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

Inheritance diagram for OpenDDS::RTPS::Sedp::Writer:
Inheritance graph
[legend]
Collaboration diagram for OpenDDS::RTPS::Sedp::Writer:
Collaboration graph
[legend]

List of all members.

Public Member Functions

 Writer (const DCPS::RepoId &pub_id, Sedp &sedp)
virtual ~Writer ()
bool assoc (const DCPS::AssociationData &subscription)
void data_delivered (const DCPS::DataSampleElement *)
void data_dropped (const DCPS::DataSampleElement *, bool by_transport)
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 retrieve_inline_qos_data (InlineQosData &) const
void send_sample (const ACE_Message_Block &data, size_t size, const DCPS::RepoId &reader, DCPS::SequenceNumber &sequence, bool historic=false)
DDS::ReturnCode_t write_parameter_list (const ParameterList &plist, const DCPS::RepoId &reader, DCPS::SequenceNumber &sequence)
DDS::ReturnCode_t write_participant_message (const ParticipantMessageData &pmd, const DCPS::RepoId &reader, DCPS::SequenceNumber &sequence)
DDS::ReturnCode_t write_stateless_message (const DDS::Security::ParticipantStatelessMessage &msg, const DCPS::RepoId &reader, DCPS::SequenceNumber &sequence)
DDS::ReturnCode_t write_volatile_message_secure (const DDS::Security::ParticipantVolatileMessageSecure &msg, const DCPS::RepoId &reader, DCPS::SequenceNumber &sequence)
DDS::ReturnCode_t write_dcps_participant_secure (const Security::SPDPdiscoveredParticipantData &msg, const DCPS::RepoId &reader, DCPS::SequenceNumber &sequence)
DDS::ReturnCode_t write_unregister_dispose (const DCPS::RepoId &rid, CORBA::UShort pid=PID_ENDPOINT_GUID)
void end_historic_samples (const DCPS::RepoId &reader)

Private Member Functions

void write_control_msg (DCPS::Message_Block_Ptr payload, size_t size, DCPS::MessageId id, DCPS::SequenceNumber seq=DCPS::SequenceNumber())
void set_header_fields (DCPS::DataSampleHeader &dsh, size_t size, const DCPS::RepoId &reader, DCPS::SequenceNumber &sequence, bool historic_sample=false, DCPS::MessageId id=DCPS::SAMPLE_DATA)

Private Attributes

Header header_
DCPS::SequenceNumber seq_

Detailed Description

Definition at line 270 of file Sedp.h.

Constructor & Destructor Documentation

OpenDDS::RTPS::Sedp::Writer::Writer ( const DCPS::RepoId &  pub_id,
Sedp &  sedp 
)
OpenDDS::RTPS::Sedp::Writer::~Writer (  )  [virtual]

Definition at line 2518 of file Sedp.cpp.

02519 {
02520 }

Member Function Documentation

bool OpenDDS::RTPS::Sedp::Writer::assoc ( const DCPS::AssociationData &  subscription  ) 

Definition at line 2523 of file Sedp.cpp.

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

Referenced by OpenDDS::RTPS::Sedp::Task::svc_i().

02524 {
02525   return associate(subscription, true);
02526 }

Here is the call graph for this function:

Here is the caller graph for this function:

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

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 2541 of file Sedp.cpp.

02542 {
02543 }

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 2546 of file Sedp.cpp.

02547 {
02548 }

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

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 2529 of file Sedp.cpp.

02530 {
02531   delete dsle;
02532 }

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

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 2535 of file Sedp.cpp.

02536 {
02537   delete dsle;
02538 }

void OpenDDS::RTPS::Sedp::Writer::end_historic_samples ( const DCPS::RepoId &  reader  ) 
void OpenDDS::RTPS::Sedp::Writer::notify_publication_disconnected ( const DCPS::ReaderIdSeq &   )  [inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 287 of file Sedp.h.

00287 {}

void OpenDDS::RTPS::Sedp::Writer::notify_publication_lost ( const DCPS::ReaderIdSeq &   )  [inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 289 of file Sedp.h.

00289 {}

void OpenDDS::RTPS::Sedp::Writer::notify_publication_reconnected ( const DCPS::ReaderIdSeq &   )  [inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 288 of file Sedp.h.

00288 {}

void OpenDDS::RTPS::Sedp::Writer::remove_associations ( const DCPS::ReaderIdSeq &  ,
bool   
) [inline, virtual]

Implements OpenDDS::DCPS::TransportSendListener.

Definition at line 290 of file Sedp.h.

00290 {}

void OpenDDS::RTPS::Sedp::Writer::retrieve_inline_qos_data ( InlineQosData &   )  const [inline, virtual]

Reimplemented from OpenDDS::DCPS::TransportSendListener.

Definition at line 291 of file Sedp.h.

00291 {}

void OpenDDS::RTPS::Sedp::Writer::send_sample ( const ACE_Message_Block &  data,
size_t  size,
const DCPS::RepoId &  reader,
DCPS::SequenceNumber &  sequence,
bool  historic = false 
)
void OpenDDS::RTPS::Sedp::Writer::set_header_fields ( DCPS::DataSampleHeader &  dsh,
size_t  size,
const DCPS::RepoId &  reader,
DCPS::SequenceNumber &  sequence,
bool  historic_sample = false,
DCPS::MessageId  id = DCPS::SAMPLE_DATA 
) [private]

Referenced by write_control_msg().

Here is the caller graph for this function:

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

Definition at line 2818 of file Sedp.cpp.

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

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

Here is the call graph for this function:

DDS::ReturnCode_t OpenDDS::RTPS::Sedp::Writer::write_dcps_participant_secure ( const Security::SPDPdiscoveredParticipantData &  msg,
const DCPS::RepoId &  reader,
DCPS::SequenceNumber &  sequence 
)
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::Writer::write_parameter_list ( const ParameterList &  plist,
const DCPS::RepoId &  reader,
DCPS::SequenceNumber &  sequence 
)
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::Writer::write_participant_message ( const ParticipantMessageData &  pmd,
const DCPS::RepoId &  reader,
DCPS::SequenceNumber &  sequence 
)

Referenced by OpenDDS::RTPS::Sedp::signal_liveliness_unsecure().

Here is the caller graph for this function:

DDS::ReturnCode_t OpenDDS::RTPS::Sedp::Writer::write_stateless_message ( const DDS::Security::ParticipantStatelessMessage &  msg,
const DCPS::RepoId &  reader,
DCPS::SequenceNumber &  sequence 
)
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::Writer::write_unregister_dispose ( const DCPS::RepoId &  rid,
CORBA::UShort  pid = PID_ENDPOINT_GUID 
)
DDS::ReturnCode_t OpenDDS::RTPS::Sedp::Writer::write_volatile_message_secure ( const DDS::Security::ParticipantVolatileMessageSecure &  msg,
const DCPS::RepoId &  reader,
DCPS::SequenceNumber &  sequence 
)

Member Data Documentation

Header OpenDDS::RTPS::Sedp::Writer::header_ [private]

Definition at line 324 of file Sedp.h.

DCPS::SequenceNumber OpenDDS::RTPS::Sedp::Writer::seq_ [private]

Definition at line 325 of file Sedp.h.

The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines
Generated on 10 Aug 2018 for OpenDDS by  doxygen 1.6.1