OpenDDS
Snapshot(2023/04/28-20:55)
dds
DCPS
transport
framework
TransportControlElement.cpp
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 "
DCPS/DdsDcps_pch.h
"
//Only the _pch include should start with DCPS/
9
#include "
TransportControlElement.h
"
10
#include "
EntryExit.h
"
11
12
#if !defined (__ACE_INLINE__)
13
#include "
TransportControlElement.inl
"
14
#endif
/* __ACE_INLINE__ */
15
16
OpenDDS::DCPS::TransportControlElement::TransportControlElement
(
Message_Block_Ptr
msg_block,
17
const
GUID_t
& publication_id)
18
:
TransportQueueElement
(1)
19
, msg_( msg_block.
release
())
20
, publication_id_(publication_id)
21
{
22
DBG_ENTRY_LVL
(
"TransportControlElement"
,
"TransportControlElement"
, 6);
23
}
24
25
OpenDDS::DCPS::TransportControlElement::~TransportControlElement
()
26
{
27
DBG_ENTRY_LVL
(
"TransportControlElement"
,
"~TransportControlElement"
, 6);
28
}
29
30
void
31
OpenDDS::DCPS::TransportControlElement::release_element
(
32
bool
/* dropped_by_transport */
33
)
34
{
35
delete
this
;
36
}
OpenDDS::DCPS::TransportControlElement::release_element
virtual void release_element(bool dropped_by_transport)
Invoked when the counter reaches 0.
Definition:
TransportControlElement.cpp:31
OpenDDS::DCPS::TransportControlElement::TransportControlElement
TransportControlElement(Message_Block_Ptr msg_block, const GUID_t &publication_id=GUID_UNKNOWN)
Definition:
TransportControlElement.cpp:16
EntryExit.h
release
void release(T x)
OpenDDS::DCPS::unique_ptr< ACE_Message_Block, Message_Block_Deleter >
TransportControlElement.h
TransportControlElement.inl
OpenDDS::DCPS::TransportControlElement::~TransportControlElement
virtual ~TransportControlElement()
Definition:
TransportControlElement.cpp:25
OpenDDS::DCPS::GUID_t
Definition:
DdsDcpsGuid.idl:57
DBG_ENTRY_LVL
#define DBG_ENTRY_LVL(CNAME, MNAME, DBG_LVL)
Definition:
EntryExit.h:68
DdsDcps_pch.h
OpenDDS::DCPS::TransportQueueElement
Base wrapper class around a data/control sample to be sent.
Definition:
TransportQueueElement.h:53
Generated by
1.8.13