OpenDDS::DCPS::ReceiveListenerSetMap Class Reference

#include <ReceiveListenerSetMap.h>

Public Member Functions
typedef	OPENDDS_MAP_CMP (GUID_t, ReceiveListenerSet_rch, GUID_tKeyLessThan) MapType
	ReceiveListenerSetMap ()
virtual	~ReceiveListenerSetMap ()
int	insert (GUID_t publisher_id, GUID_t subscriber_id, const TransportReceiveListener_wrch &receive_listener)
ReceiveListenerSet_rch	find (GUID_t publisher_id) const
int	remove (GUID_t publisher_id, GUID_t subscriber_id)
int	release_subscriber (GUID_t publisher_id, GUID_t subscriber_id)
ReceiveListenerSet_rch	remove_set (GUID_t publisher_id)
ssize_t	size () const
MapType &	map ()
	Give access to the underlying map for iteration purposes. More...
const MapType &	map () const
void	operator= (const ReceiveListenerSetMap &rh)
void	clear ()

Private Member Functions
ReceiveListenerSet_rch	find_or_create (GUID_t publisher_id)

Private Attributes
MapType	map_

Detailed Description

Definition at line 24 of file ReceiveListenerSetMap.h.

Constructor & Destructor Documentation

ReceiveListenerSetMap()

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSetMap::ReceiveListenerSetMap

(

)

Definition at line 14 of file ReceiveListenerSetMap.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","ReceiveListenerSetMap",6);
}

~ReceiveListenerSetMap()

OpenDDS::DCPS::ReceiveListenerSetMap::~ReceiveListenerSetMap ( )

virtual

Definition at line 17 of file ReceiveListenerSetMap.cpp.

References DBG_ENTRY_LVL, and insert().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","~ReceiveListenerSetMap",6);
}

Member Function Documentation

clear()

void OpenDDS::DCPS::ReceiveListenerSetMap::clear

(

void

)

Definition at line 182 of file ReceiveListenerSetMap.cpp.

References DBG_ENTRY_LVL, and map_.

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","clear",6);

  for (MapType::iterator itr = this->map_.begin();
       itr != this->map_.end();
       ++itr) {
    itr->second->clear();
  }

  this->map_.clear();
}

find()

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet_rch OpenDDS::DCPS::ReceiveListenerSetMap::find

(

GUID_t

publisher_id

)

const

Definition at line 20 of file ReceiveListenerSetMap.inl.

References ACE_INLINE, DBG_ENTRY_LVL, OpenDDS::DCPS::find(), and map_.

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","find",6);
  ReceiveListenerSet_rch listener_set;

  if (OpenDDS::DCPS::find(map_, publisher_id, listener_set) != 0) {
    return ReceiveListenerSet_rch();
  }
  return listener_set;
}

find_or_create()

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet_rch OpenDDS::DCPS::ReceiveListenerSetMap::find_or_create ( GUID_t  publisher_id )

private

Definition at line 32 of file ReceiveListenerSetMap.inl.

References ACE_INLINE, DBG_ENTRY_LVL, and map_.

Referenced by insert().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","find_or_create",6);

  ReceiveListenerSet_rch& listener_set = map_[publisher_id];
  if (!listener_set) {
    listener_set = make_rch<ReceiveListenerSet>();
  }
  return listener_set;
}

insert()

int OpenDDS::DCPS::ReceiveListenerSetMap::insert	(	GUID_t	publisher_id,
		GUID_t	subscriber_id,
		const TransportReceiveListener_wrch &	receive_listener
	)

Definition at line 24 of file ReceiveListenerSetMap.cpp.

References ACE_ERROR, ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), DBG_ENTRY_LVL, find_or_create(), OpenDDS::DCPS::RcHandle< T >::is_nil(), LM_ERROR, and remove_set().

Referenced by operator=(), and ~ReceiveListenerSetMap().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","insert",6);
  ReceiveListenerSet_rch listener_set (this->find_or_create(publisher_id));

  if (listener_set.is_nil()) {
    // find_or_create failure
    LogGuid pub_log(publisher_id);
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: ReceiveListenerSetMap::insert: ")
                      ACE_TEXT("failed to find_or_create entry for ")
                      ACE_TEXT("publisher %C.\n"),
                      pub_log.c_str()), -1);
  }

  int result = listener_set->insert(subscriber_id, receive_listener);

  if (result == 0 || result == 1) {
    return 0;
  }

  LogGuid sub_log(subscriber_id);
  LogGuid pub_log(publisher_id);
  ACE_ERROR((LM_ERROR,
             ACE_TEXT("(%P|%t) ERROR: ReceiveListenerSetMap::insert: ")
             ACE_TEXT("failed to insert subscriber %C for ")
             ACE_TEXT("publisher %C.\n"),
             sub_log.c_str(),
             pub_log.c_str()));

  // Deal with possibility that the listener_set just got
  // created - and just for us.  This is to make sure we don't leave any
  // empty ReceiveListenerSets in our map_.
  if (listener_set->size() == 0) {
    listener_set = this->remove_set(publisher_id);

    if (listener_set.is_nil()) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ReceiveListenerSetMap::insert: ")
                 ACE_TEXT("failed to remove (undo create) ReceiveListenerSet ")
                 ACE_TEXT("for publisher %C.\n"),
                 pub_log.c_str()));
    }
  }

  return -1;
}

map() [1/2]

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSetMap::MapType & OpenDDS::DCPS::ReceiveListenerSetMap::map

(

void

)

Give access to the underlying map for iteration purposes.

Definition at line 69 of file ReceiveListenerSetMap.inl.

References ACE_INLINE, DBG_ENTRY_LVL, and map_.

Referenced by operator=().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","map",6);
  return map_;
}

map() [2/2]

ACE_INLINE const OpenDDS::DCPS::ReceiveListenerSetMap::MapType & OpenDDS::DCPS::ReceiveListenerSetMap::map

(

void

)

const

Definition at line 76 of file ReceiveListenerSetMap.inl.

References DBG_ENTRY_LVL, and map_.

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","map",6);
  return map_;
}

OPENDDS_MAP_CMP()

typedef OpenDDS::DCPS::ReceiveListenerSetMap::OPENDDS_MAP_CMP	(	GUID_t	,
		ReceiveListenerSet_rch	,
		GUID_tKeyLessThan
	)

operator=()

void OpenDDS::DCPS::ReceiveListenerSetMap::operator=

(

const ReceiveListenerSetMap &

rh

)

Definition at line 162 of file ReceiveListenerSetMap.cpp.

References DBG_ENTRY_LVL, insert(), and map().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","operator=",6);
  const MapType& map = rh.map();

  for (MapType::const_iterator itr = map.begin();
       itr != map.end();
       ++itr) {
    ReceiveListenerSet_rch set = itr->second;
    ReceiveListenerSet::MapType& smap = set->map();

    for (ReceiveListenerSet::MapType::iterator sitr = smap.begin();
         sitr != smap.end();
         ++sitr) {
      this->insert(itr->first, sitr->first, sitr->second);
    }
  }
}

release_subscriber()

int OpenDDS::DCPS::ReceiveListenerSetMap::release_subscriber	(	GUID_t	publisher_id,
		GUID_t	subscriber_id
	)

This method is called when the (remote) subscriber is being released. This method will return a 0 if the subscriber_id is successfully disassociated with the publisher_id and there are still other subscribers associated with the publisher_id. This method will return 1 if, after the disassociation, the publisher_id is no longer associated with any subscribers (which also means it's element was removed from our map_).

Definition at line 119 of file ReceiveListenerSetMap.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), DBG_ENTRY_LVL, OpenDDS::DCPS::find(), LM_ERROR, map_, and OpenDDS::DCPS::unbind().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","release_subscriber",6);
  ReceiveListenerSet_rch listener_set;

  if (OpenDDS::DCPS::find(map_, publisher_id, listener_set) != 0) {
    LogGuid pub_log(publisher_id);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: ReciveListenerSetMap::release_subscriber: ")
               ACE_TEXT("publisher %C not found in map_.\n"),
               pub_log.c_str()));
    // Return 1 to indicate that the publisher_id is no longer associated
    // with any subscribers at all.
    return 1;
  }

  int result = listener_set->remove(subscriber_id);

  // Ignore the result
  ACE_UNUSED_ARG(result);

  if (listener_set->size() == 0) {
    if (unbind(map_, publisher_id) != 0) {
      LogGuid pub_log(publisher_id);
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ReceiveListenerSetMap::release_subscriber: ")
                 ACE_TEXT("failed to remove empty ReceiveListenerSet for ")
                 ACE_TEXT("publisher %C.\n"),
                 pub_log.c_str()));
    }

    // We always return 1 if we know the publisher_id is no longer
    // associated with any ReceiveListeners.
    return 1;
  }

  // There are still ReceiveListeners associated with the publisher_id.
  // We return a 0 in this case.
  return 0;
}

remove()

int OpenDDS::DCPS::ReceiveListenerSetMap::remove	(	GUID_t	publisher_id,
		GUID_t	subscriber_id
	)

Definition at line 75 of file ReceiveListenerSetMap.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), DBG_ENTRY_LVL, OpenDDS::DCPS::find(), LM_ERROR, map_, and OpenDDS::DCPS::unbind().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","remove",6);
  ReceiveListenerSet_rch listener_set;

  if (OpenDDS::DCPS::find(map_, publisher_id, listener_set) != 0) {
    return 0;
  }

  int result = listener_set->remove(subscriber_id);

  // Ignore the result
  ACE_UNUSED_ARG(result);

  if (listener_set->size() == 0) {
    if (unbind(map_, publisher_id) != 0) {
      LogGuid pub_log(publisher_id);
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: ReceiveListenerSetMap::remove: ")
                        ACE_TEXT("failed to remove empty ReceiveListenerSet for ")
                        ACE_TEXT("publisher %C.\n"),
                        pub_log.c_str()), -1);
    }
  }

  return 0;
}

remove_set()

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet_rch OpenDDS::DCPS::ReceiveListenerSetMap::remove_set

(

GUID_t

publisher_id

)

Definition at line 44 of file ReceiveListenerSetMap.inl.

References ACE_INLINE, DBG_ENTRY_LVL, LM_DEBUG, map_, OpenDDS::DCPS::unbind(), and VDBG.

Referenced by insert().

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","remove_set",6);
  ReceiveListenerSet_rch listener_set;

  if (unbind(map_, publisher_id, listener_set) != 0) {
    VDBG((LM_DEBUG,
          "(%P|%t) Unable to remove ReceiveListenerSet from the "
          "ReceiveListenerSetMap for id %d.\n",
          LogGuid(publisher_id).c_str()));
    // Return a 'nil' ReceiveListenerSet*
    return ReceiveListenerSet_rch();
  }

  return listener_set;
}

size()

ACE_INLINE ssize_t OpenDDS::DCPS::ReceiveListenerSetMap::size

(

void

)

const

Definition at line 62 of file ReceiveListenerSetMap.inl.

References ACE_INLINE, DBG_ENTRY_LVL, and map_.

{
  DBG_ENTRY_LVL("ReceiveListenerSetMap","size",6);
  return map_.size();
}

Member Data Documentation

map_

MapType OpenDDS::DCPS::ReceiveListenerSetMap::map_

private

Definition at line 65 of file ReceiveListenerSetMap.h.

Referenced by clear(), find(), find_or_create(), map(), release_subscriber(), remove(), remove_set(), and size().

---

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

• ReceiveListenerSetMap.h
• ReceiveListenerSetMap.cpp
• ReceiveListenerSetMap.inl