OpenDDS  Snapshot(2023/04/28-20:55)
Public Member Functions | Protected Attributes | List of all members
OpenDDS::DCPS::ReadConditionImpl Class Reference

#include <ReadConditionImpl.h>

Inheritance diagram for OpenDDS::DCPS::ReadConditionImpl:
Inheritance graph
[legend]
Collaboration diagram for OpenDDS::DCPS::ReadConditionImpl:
Collaboration graph
[legend]

Public Member Functions

 ReadConditionImpl (DataReaderImpl *dr, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
 
virtual ~ReadConditionImpl ()
 
CORBA::Boolean get_trigger_value ()
 
DDS::SampleStateMask get_sample_state_mask ()
 
DDS::ViewStateMask get_view_state_mask ()
 
DDS::InstanceStateMask get_instance_state_mask ()
 
DDS::DataReader_ptr get_datareader ()
 
- Public Member Functions inherited from OpenDDS::DCPS::LocalObjectBase
virtual void _add_ref ()
 
virtual void _remove_ref ()
 
virtual CORBA::ULong _refcount_value () const
 
- Public Member Functions inherited from CORBA::LocalObject
virtual ~LocalObject (void)
 
virtual CORBA::Boolean _non_existent (void)
 
virtual char * _repository_id (void)
 
virtual CORBA::InterfaceDef_ptr _get_interface (void)
 
virtual CORBA::Object_ptr _get_component (void)
 
virtual void _create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::Request_ptr &request, CORBA::Flags req_flags)
 
virtual void _create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::ExceptionList_ptr exclist, CORBA::ContextList_ptr ctxtlist, CORBA::Request_ptr &request, CORBA::Flags req_flags)
 
virtual CORBA::Request_ptr _request (const char *operation)
 
CORBA::Policy_ptr _get_policy (CORBA::PolicyType type)
 
CORBA::Policy_ptr _get_cached_policy (TAO_Cached_Policy_Type type)
 
CORBA::Object_ptr _set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)
 
CORBA::PolicyList_get_policy_overrides (const CORBA::PolicyTypeSeq &types)
 
CORBA::Boolean _validate_connection (CORBA::PolicyList_out inconsistent_policies)
 
virtual CORBA::ULong _hash (CORBA::ULong maximum)
 
virtual CORBA::Boolean _is_equivalent (CORBA::Object_ptr other_obj)
 
virtual CORBA::ORB_ptr _get_orb (void)
 
virtual TAO::ObjectKey_key (void)
 
- Public Member Functions inherited from CORBA::Object
virtual ~Object (void)
 
virtual TAO_Abstract_ServantBase_servant (void) const
 
virtual CORBA::Boolean _is_collocated (void) const
 
virtual CORBA::Boolean _is_local (void) const
 
 Object (TAO_Stub *p, CORBA::Boolean collocated=false, TAO_Abstract_ServantBase *servant=0, TAO_ORB_Core *orb_core=0)
 
 Object (IOP::IOR *ior, TAO_ORB_Core *orb_core)
 
virtual TAO_Stub_stubobj (void) const
 
virtual TAO_Stub_stubobj (void)
 
virtual void _proxy_broker (TAO::Object_Proxy_Broker *proxy_broker)
 
virtual CORBA::Boolean marshal (TAO_OutputCDR &cdr)
 
CORBA::Boolean is_evaluated (void) const
 
TAO_ORB_Coreorb_core (void) const
 
IOP::IORsteal_ior (void)
 
const IOP::IORior (void) const
 
virtual bool can_convert_to_ior (void) const
 
virtual char * convert_to_ior (bool use_omg_ior_format, const char *ior_prefix) const
 
void _decr_refcount (void)
 
virtual CORBA::Boolean _is_a (const char *logical_type_id)
 
virtual const char * _interface_repository_id (void) const
 
CORBA::Policy_ptr _get_policy (CORBA::PolicyType type)
 
CORBA::Policy_ptr _get_cached_policy (TAO_Cached_Policy_Type type)
 
CORBA::Object_ptr _set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)
 
CORBA::PolicyList_get_policy_overrides (const CORBA::PolicyTypeSeq &types)
 
CORBA::Boolean _validate_connection (CORBA::PolicyList_out inconsistent_policies)
 
- Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual ~RcObject ()
 
long ref_count () const
 
WeakObject_get_weak_object () const
 
- Public Member Functions inherited from OpenDDS::DCPS::ConditionImpl
DDS::ReturnCode_t attach_to_ws (DDS::WaitSet_ptr ws)
 
DDS::ReturnCode_t detach_from_ws (DDS::WaitSet_ptr ws)
 
void signal_all ()
 

Protected Attributes

DataReaderImplparent_
 
DDS::SampleStateMask sample_states_
 
DDS::ViewStateMask view_states_
 
DDS::InstanceStateMask instance_states_
 
- Protected Attributes inherited from CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long > refcount_
 
- Protected Attributes inherited from OpenDDS::DCPS::ConditionImpl
WaitSetSet waitsets_
 
ACE_Recursive_Thread_Mutex lock_
 

Additional Inherited Members

- Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::ReadCondition >
typedef DDS::ReadCondition ::_ptr_type _ptr_type
 
typedef DDS::ReadCondition ::_var_type _var_type
 
- Public Types inherited from CORBA::LocalObject
typedef LocalObject_ptr _ptr_type
 
typedef LocalObject_var _var_type
 
typedef LocalObject_out _out_type
 
- Public Types inherited from CORBA::Object
typedef Object_ptr _ptr_type
 
typedef Object_var _var_type
 
typedef Object_out _out_type
 
- Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::Condition >
typedef DDS::Condition ::_ptr_type _ptr_type
 
typedef DDS::Condition ::_var_type _var_type
 
- Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::ReadCondition >
static _ptr_type _narrow (CORBA::Object_ptr obj)
 
- Static Public Member Functions inherited from CORBA::LocalObject
static LocalObject_ptr _duplicate (LocalObject_ptr obj)
 
static LocalObject_ptr _nil (void)
 
static LocalObject_ptr _narrow (CORBA::Object_ptr obj)
 
- Static Public Member Functions inherited from CORBA::Object
static CORBA::Boolean marshal (const Object_ptr x, TAO_OutputCDR &cdr)
 
static void _tao_any_destructor (void *)
 
static CORBA::Boolean is_nil_i (CORBA::Object_ptr obj)
 
static void tao_object_initialize (Object *)
 
static CORBA::Object_ptr _duplicate (CORBA::Object_ptr obj)
 
static CORBA::Object_ptr _nil (void)
 
static CORBA::Object_ptr _narrow (CORBA::Object_ptr obj)
 
- Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::Condition >
static _ptr_type _narrow (CORBA::Object_ptr obj)
 
- Protected Member Functions inherited from CORBA::LocalObject
 LocalObject (void)
 
- Protected Member Functions inherited from CORBA::Object
 Object (int dummy=0)
 
TAO::Object_Proxy_Brokerproxy_broker () const
 
- Protected Member Functions inherited from OpenDDS::DCPS::RcObject
 RcObject ()
 
- Protected Member Functions inherited from OpenDDS::DCPS::ConditionImpl
 ConditionImpl ()
 
virtual ~ConditionImpl ()
 
typedef OPENDDS_SET (OpenDDS::DCPS::WeakRcHandle< DDS::WaitSet >) WaitSetSet
 

Detailed Description

Definition at line 25 of file ReadConditionImpl.h.

Constructor & Destructor Documentation

◆ ReadConditionImpl()

OpenDDS::DCPS::ReadConditionImpl::ReadConditionImpl ( DataReaderImpl dr,
DDS::SampleStateMask  sample_states,
DDS::ViewStateMask  view_states,
DDS::InstanceStateMask  instance_states 
)
inline

Definition at line 29 of file ReadConditionImpl.h.

31  : parent_(dr)
local interface<%TYPE%> inout ::DDS::SampleInfoSeq in long in ::DDS::SampleStateMask sample_states
Definition: IDLTemplate.txt:72
local interface<%TYPE%> inout ::DDS::SampleInfoSeq in long in ::DDS::SampleStateMask in ::DDS::ViewStateMask in ::DDS::InstanceStateMask instance_states
Definition: IDLTemplate.txt:72
local interface<%TYPE%> inout ::DDS::SampleInfoSeq in long in ::DDS::SampleStateMask in ::DDS::ViewStateMask view_states
Definition: IDLTemplate.txt:72
DDS::SampleStateMask sample_states_
DDS::InstanceStateMask instance_states_

◆ ~ReadConditionImpl()

virtual OpenDDS::DCPS::ReadConditionImpl::~ReadConditionImpl ( )
inlinevirtual

Member Function Documentation

◆ get_datareader()

DDS::DataReader_ptr OpenDDS::DCPS::ReadConditionImpl::get_datareader ( )

Implements DDS::ReadCondition.

Definition at line 38 of file ReadConditionImpl.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL, and parent_.

Referenced by ~ReadConditionImpl().

39 {
40  return DDS::DataReader::_duplicate(parent_);
41 }

◆ get_instance_state_mask()

DDS::InstanceStateMask OpenDDS::DCPS::ReadConditionImpl::get_instance_state_mask ( )

Implements DDS::ReadCondition.

Definition at line 33 of file ReadConditionImpl.cpp.

References instance_states_.

Referenced by ~ReadConditionImpl().

34 {
35  return instance_states_;
36 }
DDS::InstanceStateMask instance_states_

◆ get_sample_state_mask()

DDS::SampleStateMask OpenDDS::DCPS::ReadConditionImpl::get_sample_state_mask ( )

Implements DDS::ReadCondition.

Definition at line 23 of file ReadConditionImpl.cpp.

References sample_states_.

Referenced by ~ReadConditionImpl().

24 {
25  return sample_states_;
26 }
DDS::SampleStateMask sample_states_

◆ get_trigger_value()

CORBA::Boolean OpenDDS::DCPS::ReadConditionImpl::get_trigger_value ( )

Implements DDS::Condition.

Definition at line 17 of file ReadConditionImpl.cpp.

References OpenDDS::DCPS::DataReaderImpl::contains_sample(), instance_states_, parent_, sample_states_, and view_states_.

Referenced by OpenDDS::DCPS::QueryConditionImpl::get_trigger_value(), and ~ReadConditionImpl().

18 {
21 }
bool contains_sample(DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
DDS::SampleStateMask sample_states_
DDS::InstanceStateMask instance_states_

◆ get_view_state_mask()

DDS::ViewStateMask OpenDDS::DCPS::ReadConditionImpl::get_view_state_mask ( )

Implements DDS::ReadCondition.

Definition at line 28 of file ReadConditionImpl.cpp.

References view_states_.

Referenced by ~ReadConditionImpl().

29 {
30  return view_states_;
31 }

Member Data Documentation

◆ instance_states_

DDS::InstanceStateMask OpenDDS::DCPS::ReadConditionImpl::instance_states_
protected

◆ parent_

DataReaderImpl* OpenDDS::DCPS::ReadConditionImpl::parent_
protected

◆ sample_states_

DDS::SampleStateMask OpenDDS::DCPS::ReadConditionImpl::sample_states_
protected

◆ view_states_

DDS::ViewStateMask OpenDDS::DCPS::ReadConditionImpl::view_states_
protected

The documentation for this class was generated from the following files: