00001 /* 00002 * 00003 * 00004 * Distributed under the OpenDDS License. 00005 * See: http://www.opendds.org/license.html 00006 */ 00007 00008 #ifndef OPENDDS_RTPSCUSTOMIZEDELEMENT_H 00009 #define OPENDDS_RTPSCUSTOMIZEDELEMENT_H 00010 00011 #include "Rtps_Udp_Export.h" 00012 00013 #include "dds/DCPS/transport/framework/TransportCustomizedElement.h" 00014 00015 #include "dds/DCPS/Dynamic_Cached_Allocator_With_Overflow_T.h" 00016 00017 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 00018 00019 namespace OpenDDS { 00020 namespace DCPS { 00021 00022 class OpenDDS_Rtps_Udp_Export RtpsCustomizedElement 00023 : public TransportCustomizedElement { 00024 00025 public: 00026 00027 RtpsCustomizedElement(TransportQueueElement* orig, 00028 Message_Block_Ptr msg); 00029 00030 SequenceNumber sequence() const; 00031 SequenceNumber last_fragment() const; 00032 00033 private: 00034 00035 virtual ~RtpsCustomizedElement(); 00036 00037 ElementPair fragment(size_t size); 00038 const ACE_Message_Block* msg_payload() const; 00039 00040 SequenceNumber seq_, last_frag_; 00041 }; 00042 00043 typedef Dynamic_Cached_Allocator_With_Overflow<ACE_Thread_Mutex> 00044 RtpsCustomizedElementAllocator; 00045 00046 00047 } // namespace DCPS 00048 } // namespace OpenDDS 00049 00050 OPENDDS_END_VERSIONED_NAMESPACE_DECL 00051 00052 #if defined (__ACE_INLINE__) 00053 #include "RtpsCustomizedElement.inl" 00054 #endif /* __ACE_INLINE__ */ 00055 00056 #endif /* OPENDDS_RTPSCUSTOMIZEDELEMENT_H */
1.6.1
