OpenDDS  Snapshot(2023/04/28-20:55)
QueueRemoveVisitor.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 
12 namespace OpenDDS {
13 namespace DCPS {
14 
18  bool remove_all)
19  : mc_(mc)
20  , status_(REMOVE_NOT_FOUND)
21  , removed_bytes_(0)
22  , remove_all_(remove_all)
23 {
24  DBG_ENTRY_LVL("QueueRemoveVisitor", "QueueRemoveVisitor", 6);
25 }
26 
29 {
30  DBG_ENTRY_LVL("QueueRemoveVisitor", "status", 6);
31  return this->status_;
32 }
33 
34 ACE_INLINE int
36 {
37  DBG_ENTRY_LVL("QueueRemoveVisitor", "removed_bytes", 6);
38  return static_cast<int>(this->removed_bytes_);
39 }
40 
41 }
42 }
43 
RemoveResult
used by DataLink::remove_sample(), TransportSendStrategy, *RemoveVisitor
RemoveResult status_
Holds the status of our visit.
#define DBG_ENTRY_LVL(CNAME, MNAME, DBG_LVL)
Definition: EntryExit.h:68
#define OPENDDS_END_VERSIONED_NAMESPACE_DECL
#define ACE_INLINE
The Internal API and Implementation of OpenDDS.
Definition: AddressCache.h:28
QueueRemoveVisitor(const TransportQueueElement::MatchCriteria &mc, bool remove_all=false)