Line data    Source code

       1             : /*
       2             :  *
       3             :  *
       4             :  * Distributed under the OpenDDS License.
       5             :  * See: http://www.opendds.org/license.html
       6             :  */
       7             : 
       8             : #include <algorithm>
       9             : 
      10             : OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
      11             : 
      12             : namespace OpenDDS {
      13             : namespace DCPS {
      14             : 
      15             : 
      16             : ACE_INLINE
      17             : DataSampleElement*
      18           0 : DataSampleElement::get_next_send_sample() const
      19             : {
      20           0 :   return next_send_sample_;
      21             : }
      22             : 
      23             : ACE_INLINE
      24             : void
      25             : DataSampleElement::set_next_send_sample(DataSampleElement* next_send_sample)
      26             : {
      27             :   next_send_sample_ = next_send_sample;
      28             : }
      29             : 
      30             : ACE_INLINE
      31             : const DataSampleHeader&
      32           0 : DataSampleElement::get_header() const
      33             : {
      34           0 :   return header_;
      35             : }
      36             : 
      37             : ACE_INLINE
      38             : DataSampleHeader&
      39           0 : DataSampleElement::get_header()
      40             : {
      41           0 :   return const_cast<DataSampleHeader&>(static_cast<const DataSampleElement &>(*this).get_header());
      42             : }
      43             : 
      44             : 
      45             : ACE_INLINE
      46             : DataSample*
      47           6 : DataSampleElement::get_sample() const
      48             : {
      49           6 :   return sample_.get();
      50             : }
      51             : 
      52             : ACE_INLINE
      53             : DataSample*
      54          11 : DataSampleElement::get_sample()
      55             : {
      56          11 :   return sample_.get();
      57             : }
      58             : 
      59             : ACE_INLINE
      60             : void
      61           2 : DataSampleElement::set_sample(Message_Block_Ptr sample)
      62             : {
      63           2 :   sample_.reset(sample.release());
      64           2 : }
      65             : 
      66             : ACE_INLINE
      67             : GUID_t
      68           2 : DataSampleElement::get_pub_id() const
      69             : {
      70           2 :   return publication_id_;
      71             : }
      72             : 
      73             : ACE_INLINE
      74             : CORBA::ULong
      75           0 : DataSampleElement::get_num_subs() const
      76             : {
      77           0 :   return num_subs_;
      78             : }
      79             : 
      80             : ACE_INLINE
      81             : void
      82           0 : DataSampleElement::set_num_subs(CORBA::ULong num_subs)
      83             : {
      84           0 :   num_subs_ = num_subs;
      85           0 : }
      86             : 
      87             : ACE_INLINE
      88             : const OpenDDS::DCPS::GUID_t*
      89           0 : DataSampleElement::get_sub_ids() const
      90             : {
      91           0 :   return subscription_ids_;
      92             : }
      93             : 
      94             : ACE_INLINE
      95             : OpenDDS::DCPS::GUID_t
      96           0 : DataSampleElement::get_sub_id(CORBA::ULong index) const
      97             : {
      98           0 :   return subscription_ids_[index];
      99             : }
     100             : 
     101             : ACE_INLINE
     102             : void
     103           0 : DataSampleElement::set_sub_id(CORBA::ULong index, OpenDDS::DCPS::GUID_t id)
     104             : {
     105           0 :   subscription_ids_[index] = id;
     106           0 : }
     107             : 
     108             : ACE_INLINE
     109             : TransportSendListener*
     110           2 : DataSampleElement::get_send_listener() const
     111             : {
     112           2 :   return send_listener_;
     113             : }
     114             : 
     115             : ACE_INLINE
     116             : TransportSendListener*
     117           0 : DataSampleElement::get_send_listener()
     118             : {
     119           0 :   return send_listener_;
     120             : }
     121             : 
     122             : 
     123             : ACE_INLINE
     124             : DataSampleElement::DataLinkIdTypeGUIDMap&
     125           0 : DataSampleElement::get_filter_per_link()
     126             : {
     127           0 :   return filter_per_link_;
     128             : }
     129             : 
     130             : ACE_INLINE
     131             : void
     132           0 : DataSampleElement::set_filter_out(GUIDSeq *filter_out)
     133             : {
     134           0 :   filter_out_ = filter_out;
     135           0 : }
     136             : 
     137             : ACE_INLINE
     138             : void
     139           0 : DataSampleElement::set_transaction_id(ACE_UINT64 transaction_id)
     140             : {
     141           0 :   transaction_id_ = transaction_id;
     142           0 : }
     143             : 
     144             : ACE_INLINE
     145             : ACE_UINT64
     146           0 : DataSampleElement::transaction_id() const
     147             : {
     148           0 :   return transaction_id_;
     149             : }
     150             : 
     151             : } // namespace DCPS
     152             : } // namespace OpenDDS
     153             : 
     154             : OPENDDS_END_VERSIONED_NAMESPACE_DECL