Line data    Source code

       1             : /*
       2             :  *
       3             :  *
       4             :  * Distributed under the OpenDDS License.
       5             :  * See: http://www.opendds.org/license.html
       6             :  */
       7             : 
       8             : OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
       9             : 
      10             : namespace OpenDDS {
      11             : namespace DCPS {
      12             : 
      13             : ACE_INLINE size_t
      14           0 : TransportSendBuffer::capacity() const
      15             : {
      16           0 :   return this->capacity_;
      17             : }
      18             : 
      19             : ACE_INLINE void
      20           0 : TransportSendBuffer::bind(TransportSendStrategy* strategy)
      21             : {
      22           0 :   this->strategy_ = strategy;
      23           0 : }
      24             : 
      25             : 
      26             : // class SingleSendBuffer
      27             : 
      28             : ACE_INLINE size_t
      29             : SingleSendBuffer::n_chunks() const
      30             : {
      31             :   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, this->n_chunks_);
      32             :   return this->n_chunks_;
      33             : }
      34             : 
      35             : ACE_INLINE void
      36             : SingleSendBuffer::pre_insert(SequenceNumber sequence)
      37             : {
      38             :   ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
      39             :   pre_seq_.insert(sequence);
      40             : }
      41             : 
      42             : 
      43             : } // namespace DCPS
      44             : } // namespace OpenDDS
      45             : 
      46             : OPENDDS_END_VERSIONED_NAMESPACE_DECL