OpenDDS  Snapshot(2023/04/28-20:55)
Public Member Functions | Public Attributes | List of all members
OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener Struct Reference

#include <Sedp.h>

Inheritance diagram for OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener:
Inheritance graph
[legend]
Collaboration diagram for OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener:
Collaboration graph
[legend]

Public Member Functions

 SubscriptionAgentInfoListener (Sedp &a_sedp)
 
void update_agent_info (const DCPS::GUID_t &a_local_guid, const ICE::AgentInfo &a_agent_info)
 
void remove_agent_info (const DCPS::GUID_t &a_local_guid)
 
- Public Member Functions inherited from OpenDDS::ICE::AgentInfoListener
virtual ~AgentInfoListener ()
 
- Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual ~RcObject ()
 
virtual void _add_ref ()
 
virtual void _remove_ref ()
 
long ref_count () const
 
WeakObject_get_weak_object () const
 

Public Attributes

Sedpsedp
 

Additional Inherited Members

- Protected Member Functions inherited from OpenDDS::DCPS::RcObject
 RcObject ()
 

Detailed Description

Definition at line 981 of file Sedp.h.

Constructor & Destructor Documentation

◆ SubscriptionAgentInfoListener()

OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::SubscriptionAgentInfoListener ( Sedp a_sedp)
inline

Member Function Documentation

◆ remove_agent_info()

void OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::remove_agent_info ( const DCPS::GUID_t a_local_guid)
virtual

Implements OpenDDS::ICE::AgentInfoListener.

Definition at line 5728 of file Sedp.cpp.

References ACE_GUARD, and ACE_Thread_Mutex::lock_.

5729 {
5731  LocalSubscriptionIter pos = sedp.local_subscriptions_.find(a_local_guid);
5732  if (pos != sedp.local_subscriptions_.end()) {
5733  pos->second.have_ice_agent_info = false;
5734  sedp.write_subscription_data(a_local_guid, pos->second);
5735  }
5736 }
ACE_Thread_Mutex & lock_
Definition: Sedp.h:1228
#define ACE_GUARD(MUTEX, OBJ, LOCK)
LocalSubscriptionMap local_subscriptions_
Definition: Sedp.h:1233
LocalSubscriptionMap::iterator LocalSubscriptionIter
Definition: Sedp.h:326
DDS::ReturnCode_t write_subscription_data(const DCPS::GUID_t &rid, LocalSubscription &sub, const DCPS::GUID_t &reader=GUID_UNKNOWN)
Definition: Sedp.cpp:4982

◆ update_agent_info()

void OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::update_agent_info ( const DCPS::GUID_t a_local_guid,
const ICE::AgentInfo a_agent_info 
)
virtual

Implements OpenDDS::ICE::AgentInfoListener.

Definition at line 5715 of file Sedp.cpp.

References ACE_GUARD, and ACE_Thread_Mutex::lock_.

5717 {
5719  LocalSubscriptionIter pos = sedp.local_subscriptions_.find(a_local_guid);
5720  if (pos != sedp.local_subscriptions_.end()) {
5721  pos->second.have_ice_agent_info = true;
5722  pos->second.ice_agent_info = a_agent_info;
5723  sedp.write_subscription_data(a_local_guid, pos->second);
5724  }
5725 }
ACE_Thread_Mutex & lock_
Definition: Sedp.h:1228
#define ACE_GUARD(MUTEX, OBJ, LOCK)
LocalSubscriptionMap local_subscriptions_
Definition: Sedp.h:1233
LocalSubscriptionMap::iterator LocalSubscriptionIter
Definition: Sedp.h:326
DDS::ReturnCode_t write_subscription_data(const DCPS::GUID_t &rid, LocalSubscription &sub, const DCPS::GUID_t &reader=GUID_UNKNOWN)
Definition: Sedp.cpp:4982

Member Data Documentation

◆ sedp

Sedp& OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::sedp

Definition at line 983 of file Sedp.h.


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