OpenDDS: TransportReceiveStrategy

00001 /*
00002  *
00003  *
00004  * Distributed under the OpenDDS License.
00005  * See: http://www.opendds.org/license.html
00006  */
00007 
00008 #include "EntryExit.h"
00009 #include "TransportReassembly.h"
00010 
00011 template<typename TH, typename DSH>
00012 ACE_INLINE int
00013 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::start()
00014 {
00015   DBG_ENTRY_LVL("TransportReceiveStrategy","start",6);
00016   return this->start_i();
00017 }
00018 
00019 template<typename TH, typename DSH>
00020 ACE_INLINE void
00021 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::stop()
00022 {
00023   DBG_ENTRY_LVL("TransportReceiveStrategy","stop",6);
00024   this->stop_i();
00025 }
00026 
00027 template<typename TH, typename DSH>
00028 ACE_INLINE const TH&
00029 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::received_header() const
00030 {
00031   return this->receive_transport_header_;
00032 }
00033 
00034 template<typename TH, typename DSH>
00035 ACE_INLINE TH&
00036 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::received_header()
00037 {
00038   return this->receive_transport_header_;
00039 }
00040 
00041 template<typename TH, typename DSH>
00042 ACE_INLINE const DSH&
00043 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::received_sample_header() const
00044 {
00045   return this->data_sample_header_;
00046 }
00047 
00048 template<typename TH, typename DSH>
00049 ACE_INLINE DSH&
00050 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::received_sample_header()
00051 {
00052   return this->data_sample_header_;
00053 }
00054 
00055 template<typename TH, typename DSH>
00056 ACE_INLINE size_t
00057 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::successor_index(size_t index) const
00058 {
00059   return ++index % RECEIVE_BUFFERS;
00060 }
00061 
00062 template<typename TH, typename DSH>
00063 ACE_INLINE void
00064 OpenDDS::DCPS::TransportReceiveStrategy<TH, DSH>::relink(bool)
00065 {
00066   // The subclass needs implement this function for re-establishing
00067   // the link upon recv failure.
00068 }
TransportReceiveStrategy_T.inl
