OpenDDS::FaceTSS::Listener< Msg > Class Template Reference

#include <FaceTSS.h>

Inheritance diagram for OpenDDS::FaceTSS::Listener< Msg >:

Collaboration diagram for OpenDDS::FaceTSS::Listener< Msg >:

Public Types
typedef void(*	Callback) (FACE::TRANSACTION_ID_TYPE, Msg &, FACE::MESSAGE_TYPE_GUID, FACE::MESSAGE_SIZE_TYPE, const FACE::WAITSET_TYPE, FACE::RETURN_CODE_TYPE &)
Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::DataReaderListener >
typedef DDS::DataReaderListener ::_ptr_type	_ptr_type
typedef DDS::DataReaderListener ::_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 Member Functions
	Listener (Callback callback, FACE::CONNECTION_ID_TYPE connection_id)
void	add_callback (Callback callback)
Public Member Functions inherited from DDS::DataReaderListener
void	on_requested_deadline_missed (in DataReader reader, in RequestedDeadlineMissedStatus status)
void	on_requested_incompatible_qos (in DataReader reader, in RequestedIncompatibleQosStatus status)
void	on_sample_rejected (in DataReader reader, in SampleRejectedStatus status)
void	on_liveliness_changed (in DataReader reader, in LivelinessChangedStatus status)
void	on_data_available (in DataReader reader)
void	on_subscription_matched (in DataReader reader, in SubscriptionMatchedStatus status)
void	on_sample_lost (in DataReader reader, in SampleLostStatus status)
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_Core *	orb_core (void) const
IOP::IOR *	steal_ior (void)
const IOP::IOR &	ior (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

Private Types
typedef ACE_SYNCH_MUTEX	LockType
typedef ACE_Guard< LockType >	GuardType

Private Member Functions
void	on_requested_deadline_missed (DDS::DataReader_ptr, const DDS::RequestedDeadlineMissedStatus &)
void	on_requested_incompatible_qos (DDS::DataReader_ptr, const DDS::RequestedIncompatibleQosStatus &)
void	on_sample_rejected (DDS::DataReader_ptr, const DDS::SampleRejectedStatus &)
void	on_liveliness_changed (DDS::DataReader_ptr, const DDS::LivelinessChangedStatus &)
void	on_subscription_matched (DDS::DataReader_ptr, const DDS::SubscriptionMatchedStatus &)
void	on_sample_lost (DDS::DataReader_ptr, const DDS::SampleLostStatus &)
void	on_data_available (DDS::DataReader_ptr reader)
	OPENDDS_VECTOR (Callback) callbacks_

Private Attributes
LockType	callbacks_lock_
const FACE::CONNECTION_ID_TYPE	connection_id_

Additional Inherited Members
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::DataReaderListener >
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)
Protected Member Functions inherited from CORBA::LocalObject
	LocalObject (void)
Protected Member Functions inherited from CORBA::Object
	Object (int dummy=0)
TAO::Object_Proxy_Broker *	proxy_broker () const
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()
Protected Attributes inherited from CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long >	refcount_

Detailed Description

template<typename Msg>
class OpenDDS::FaceTSS::Listener< Msg >

Definition at line 275 of file FaceTSS.h.

Member Typedef Documentation

Callback

template<typename Msg>

typedef void(* OpenDDS::FaceTSS::Listener< Msg >::Callback) (FACE::TRANSACTION_ID_TYPE, Msg &, FACE::MESSAGE_TYPE_GUID, FACE::MESSAGE_SIZE_TYPE, const FACE::WAITSET_TYPE, FACE::RETURN_CODE_TYPE &)

Definition at line 277 of file FaceTSS.h.

GuardType

template<typename Msg>

typedef ACE_Guard<LockType> OpenDDS::FaceTSS::Listener< Msg >::GuardType

private

Definition at line 355 of file FaceTSS.h.

LockType

template<typename Msg>

typedef ACE_SYNCH_MUTEX OpenDDS::FaceTSS::Listener< Msg >::LockType

private

Definition at line 354 of file FaceTSS.h.

Constructor & Destructor Documentation

Listener()

template<typename Msg>

OpenDDS::FaceTSS::Listener< Msg >::Listener ( Callback  callback, FACE::CONNECTION_ID_TYPE  connection_id  )

inline

Definition at line 283 of file FaceTSS.h.

    : connection_id_(connection_id)
  {
    callbacks_.push_back(callback);
  }

Member Function Documentation

add_callback()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::add_callback ( Callback  callback )

inline

Definition at line 289 of file FaceTSS.h.

Referenced by OpenDDS::FaceTSS::register_callback().

                                       {
    GuardType guard(callbacks_lock_);
    callbacks_.push_back(callback);
  }

on_data_available()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::on_data_available ( DDS::DataReader_ptr  reader )

inlineprivate

Definition at line 312 of file FaceTSS.h.

References ACE_DEBUG, ACE_ERROR, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::FaceTSS::Entities::instance(), LM_DEBUG, LM_ERROR, OpenDDS::FaceTSS::populate_header_received(), OpenDDS::FaceTSS::Entities::receivers_, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_OK, OpenDDS::FaceTSS::update_status(), and DDS::SampleInfo::valid_data.

  {
    typedef typename DCPS::DDSTraits<Msg>::DataReaderType DataReader;
    const typename DataReader::_var_type typedReader =
      DataReader::_narrow(reader);
    if (!typedReader) {
      update_status(connection_id_, DDS::RETCODE_BAD_PARAMETER);
      return;
    }

    FACE::MESSAGE_TYPE_GUID& msg_id = Entities::instance()->connections_[connection_id_].platform_view_guid;
    Msg sample;
    DDS::SampleInfo sinfo;
    while (typedReader->take_next_sample(sample, sinfo) == DDS::RETCODE_OK) {
      if (sinfo.valid_data) {
        DDS::Subscriber_var subscriber = typedReader->get_subscriber();
        DDS::DomainParticipant_var participant = subscriber->get_participant();
        FACE::RETURN_CODE_TYPE ret_code;
        populate_header_received(connection_id_, participant, sinfo, ret_code);
        if (ret_code != FACE::RC_NO_ERROR) {
          update_status(connection_id_, ret_code);
          return;
        }

        FACE::TRANSACTION_ID_TYPE transaction_id = ++Entities::instance()->receivers_[connection_id_]->last_msg_tid;
        update_status(connection_id_, DDS::RETCODE_OK);
        FACE::RETURN_CODE_TYPE retcode;
        GuardType guard(callbacks_lock_);
        if (OpenDDS::DCPS::DCPS_debug_level > 3) {
          ACE_DEBUG((LM_DEBUG, "Listener::on_data_available - invoking %d callbacks\n", callbacks_.size()));
        }
        for (size_t i = 0; i < callbacks_.size(); ++i) {
          retcode = FACE::RC_NO_ERROR;
          callbacks_.at(i)(transaction_id /*Transaction_ID*/, sample, msg_id, sizeof(Msg), 0 /*WAITSET_TYPE*/, retcode);
          if (retcode != FACE::RC_NO_ERROR) {
            ACE_ERROR((LM_ERROR, "ERROR: Listener::on_data_available - callback %d returned retcode: %d\n", i, retcode));
          }
        }
      }
    }
  }

on_liveliness_changed()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::on_liveliness_changed ( DDS::DataReader_ptr  , const DDS::LivelinessChangedStatus &    )

inlineprivate

Definition at line 304 of file FaceTSS.h.

                                       {}

on_requested_deadline_missed()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::on_requested_deadline_missed ( DDS::DataReader_ptr  , const DDS::RequestedDeadlineMissedStatus &    )

inlineprivate

Definition at line 295 of file FaceTSS.h.

                                             {}

on_requested_incompatible_qos()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::on_requested_incompatible_qos ( DDS::DataReader_ptr  , const DDS::RequestedIncompatibleQosStatus &    )

inlineprivate

Definition at line 298 of file FaceTSS.h.

                                              {}

on_sample_lost()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::on_sample_lost ( DDS::DataReader_ptr  , const DDS::SampleLostStatus &    )

inlineprivate

Definition at line 310 of file FaceTSS.h.

{}

on_sample_rejected()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::on_sample_rejected ( DDS::DataReader_ptr  , const DDS::SampleRejectedStatus &    )

inlineprivate

Definition at line 301 of file FaceTSS.h.

                                    {}

on_subscription_matched()

template<typename Msg>

void OpenDDS::FaceTSS::Listener< Msg >::on_subscription_matched ( DDS::DataReader_ptr  , const DDS::SubscriptionMatchedStatus &    )

inlineprivate

Definition at line 307 of file FaceTSS.h.

                                         {}

OPENDDS_VECTOR()

template<typename Msg>

OpenDDS::FaceTSS::Listener< Msg >::OPENDDS_VECTOR ( Callback  )

private

Member Data Documentation

callbacks_lock_

template<typename Msg>

LockType OpenDDS::FaceTSS::Listener< Msg >::callbacks_lock_

private

Definition at line 356 of file FaceTSS.h.

connection_id_

template<typename Msg>

const FACE::CONNECTION_ID_TYPE OpenDDS::FaceTSS::Listener< Msg >::connection_id_

private

Definition at line 358 of file FaceTSS.h.

---

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

• FaceTSS.h