OpenDDS  Snapshot(2023/04/28-20:55)
DataSampleElement.inl
Go to the documentation of this file.
1 /*
2  *
3  *
4  * Distributed under the OpenDDS License.
5  * See: http://www.opendds.org/license.html
6  */
7 
8 #include <algorithm>
9 
11 
12 namespace OpenDDS {
13 namespace DCPS {
14 
15 
17 DataSampleElement*
19 {
20  return next_send_sample_;
21 }
22 
24 void
26 {
27  next_send_sample_ = next_send_sample;
28 }
29 
31 const DataSampleHeader&
33 {
34  return header_;
35 }
36 
40 {
41  return const_cast<DataSampleHeader&>(static_cast<const DataSampleElement &>(*this).get_header());
42 }
43 
44 
48 {
49  return sample_.get();
50 }
51 
55 {
56  return sample_.get();
57 }
58 
60 void
62 {
63  sample_.reset(sample.release());
64 }
65 
67 GUID_t
69 {
70  return publication_id_;
71 }
72 
76 {
77  return num_subs_;
78 }
79 
81 void
83 {
84  num_subs_ = num_subs;
85 }
86 
90 {
91  return subscription_ids_;
92 }
93 
97 {
98  return subscription_ids_[index];
99 }
100 
102 void
104 {
105  subscription_ids_[index] = id;
106 }
107 
111 {
112  return send_listener_;
113 }
114 
118 {
119  return send_listener_;
120 }
121 
122 
124 DataSampleElement::DataLinkIdTypeGUIDMap&
126 {
127  return filter_per_link_;
128 }
129 
131 void
133 {
134  filter_out_ = filter_out;
135 }
136 
138 void
140 {
142 }
143 
147 {
148  return transaction_id_;
149 }
150 
151 } // namespace DCPS
152 } // namespace OpenDDS
153 
void set_sample(Message_Block_Ptr sample)
const DataSampleHeader & get_header() const
TransportSendListener * get_send_listener() const
DataLinkIdTypeGUIDMap & get_filter_per_link()
void set_sub_id(CORBA::ULong index, OpenDDS::DCPS::GUID_t id)
void set_filter_out(GUIDSeq *filter_out)
GUIDSeq_var filter_out_
tracking for Content-Filtering data
OpenDDS::DCPS::GUID_t subscription_ids_[OpenDDS::DCPS::MAX_READERS_PER_ELEM]
DataSampleElement * get_next_send_sample() const
void set_transaction_id(ACE_UINT64 transaction_id)
TransportSendListener * send_listener_
DataSampleHeader header_
The OpenDDS DCPS header for this sample.
ACE_CDR::ULong ULong
OpenDDS::DCPS::GUID_t get_sub_id(CORBA::ULong index) const
GUID_t publication_id_
Publication Id used downstream.
DataSampleElement * next_send_sample_
Thread of data being unsent/sending/sent/released.
DataLinkIdTypeGUIDMap filter_per_link_
void set_num_subs(CORBA::ULong num_subs)
unsigned long long ACE_UINT64
sequence< GUID_t > GUIDSeq
Definition: DdsDcpsGuid.idl:62
#define OPENDDS_END_VERSIONED_NAMESPACE_DECL
#define ACE_INLINE
const OpenDDS::DCPS::GUID_t * get_sub_ids() const
void set_next_send_sample(DataSampleElement *next_send_sample)
The Internal API and Implementation of OpenDDS.
Definition: AddressCache.h:28