00001 /* 00002 * 00003 * 00004 * Distributed under the OpenDDS License. 00005 * See: http://www.opendds.org/license.html 00006 */ 00007 00008 #include <algorithm> 00009 00010 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 00011 00012 namespace OpenDDS { 00013 namespace DCPS { 00014 00015 00016 ACE_INLINE 00017 DataSampleElement* 00018 DataSampleElement::get_next_send_sample() const 00019 { 00020 return next_send_sample_; 00021 } 00022 00023 ACE_INLINE 00024 void 00025 DataSampleElement::set_next_send_sample(DataSampleElement* next_send_sample) 00026 { 00027 this->next_send_sample_ = next_send_sample; 00028 } 00029 00030 ACE_INLINE 00031 const DataSampleHeader& 00032 DataSampleElement::get_header() const 00033 { 00034 return header_; 00035 } 00036 00037 ACE_INLINE 00038 DataSampleHeader& 00039 DataSampleElement::get_header() 00040 { 00041 return const_cast<DataSampleHeader&>(static_cast<const DataSampleElement &>(*this).get_header()); 00042 } 00043 00044 00045 ACE_INLINE 00046 DataSample* 00047 DataSampleElement::get_sample() const 00048 { 00049 return sample_.get(); 00050 } 00051 00052 ACE_INLINE 00053 DataSample* 00054 DataSampleElement::get_sample() 00055 { 00056 return sample_.get(); 00057 } 00058 00059 ACE_INLINE 00060 void 00061 DataSampleElement::set_sample(Message_Block_Ptr sample) 00062 { 00063 this->sample_.reset(sample.release()); 00064 } 00065 00066 ACE_INLINE 00067 PublicationId 00068 DataSampleElement::get_pub_id() const 00069 { 00070 return publication_id_; 00071 } 00072 00073 ACE_INLINE 00074 CORBA::ULong 00075 DataSampleElement::get_num_subs() const 00076 { 00077 return num_subs_; 00078 } 00079 00080 ACE_INLINE 00081 void 00082 DataSampleElement::set_num_subs(int num_subs) 00083 { 00084 this->num_subs_ = num_subs; 00085 } 00086 00087 ACE_INLINE 00088 const OpenDDS::DCPS::RepoId* 00089 DataSampleElement::get_sub_ids() const 00090 { 00091 return subscription_ids_; 00092 } 00093 00094 ACE_INLINE 00095 OpenDDS::DCPS::RepoId 00096 DataSampleElement::get_sub_id(int index) const 00097 { 00098 return subscription_ids_[index]; 00099 } 00100 00101 ACE_INLINE 00102 void 00103 DataSampleElement::set_sub_id(int index, OpenDDS::DCPS::RepoId id) 00104 { 00105 this->subscription_ids_[index] = id; 00106 } 00107 00108 ACE_INLINE 00109 TransportSendListener* 00110 DataSampleElement::get_send_listener() const 00111 { 00112 return send_listener_; 00113 } 00114 00115 ACE_INLINE 00116 TransportSendListener* 00117 DataSampleElement::get_send_listener() 00118 { 00119 return send_listener_; 00120 } 00121 00122 00123 ACE_INLINE 00124 DataSampleElement::DataLinkIdTypeGUIDMap& 00125 DataSampleElement::get_filter_per_link() 00126 { 00127 return filter_per_link_; 00128 } 00129 00130 ACE_INLINE 00131 void 00132 DataSampleElement::set_filter_out(GUIDSeq *filter_out) 00133 { 00134 filter_out_ = filter_out; 00135 } 00136 00137 ACE_INLINE 00138 void 00139 DataSampleElement::set_transaction_id(ACE_UINT64 transaction_id) 00140 { 00141 transaction_id_ = transaction_id; 00142 } 00143 00144 ACE_INLINE 00145 ACE_UINT64 00146 DataSampleElement::transaction_id() const 00147 { 00148 return transaction_id_; 00149 } 00150 00151 } // namespace DCPS 00152 } // namespace OpenDDS 00153 00154 OPENDDS_END_VERSIONED_NAMESPACE_DECL
1.6.1
