OpenDDS  Snapshot(2023/04/28-20:55)
TransportControlElement.inl
Go to the documentation of this file.
1 /*
2  *
3  *
4  * Distributed under the OpenDDS License.
5  * See: http://www.opendds.org/license.html
6  */
7 
8 #include "EntryExit.h"
9 
11 bool
13 {
14  DBG_ENTRY_LVL("TransportControlElement", "requires_exclusive_packet", 6);
15  return true;
16 }
17 
19 void
21 {
22  DBG_ENTRY_LVL("TransportControlElement", "data_delivered", 6);
23 }
24 
28 {
29  return publication_id_;
30 }
31 
35 {
36  return msg_->duplicate();
37 }
38 
40 const ACE_Message_Block*
42 {
43  return msg_.get();
44 }
45 
47 const ACE_Message_Block*
49 {
50  return msg_->cont();
51 }
52 
54 bool
56 {
57  return true;
58 }
virtual GUID_t publication_id() const
Accessor for the publication id that sent the sample.
virtual bool owned_by_transport()
Is the sample created by the transport?
virtual bool requires_exclusive_packet() const
Does the sample require an exclusive transport packet?
virtual const ACE_Message_Block * msg() const
The marshalled sample (sample header + sample data)
virtual ACE_Message_Block * duplicate_msg() const
A reference-incremented duplicate of the marshalled sample (sample header + sample data) ...
ACE_Message_Block * cont(void) const
virtual ACE_Message_Block * duplicate(void) const
virtual const ACE_Message_Block * msg_payload() const
The marshalled payload only (sample data)
#define DBG_ENTRY_LVL(CNAME, MNAME, DBG_LVL)
Definition: EntryExit.h:68
Message_Block_Ptr msg_
The control message.
#define ACE_INLINE