OpenDDS::DCPS::ReceiveListenerSetMap Class Reference

#include <ReceiveListenerSetMap.h>

List of all members.

Public Member Functions
typedef	OPENDDS_MAP_CMP (RepoId, ReceiveListenerSet_rch, GUID_tKeyLessThan) MapType
	ReceiveListenerSetMap ()
virtual	~ReceiveListenerSetMap ()
int	insert (RepoId publisher_id, RepoId subscriber_id, TransportReceiveListener *receive_listener)
ReceiveListenerSet *	find (RepoId publisher_id) const
int	remove (RepoId publisher_id, RepoId subscriber_id)
int	release_subscriber (RepoId publisher_id, RepoId subscriber_id)
ReceiveListenerSet *	remove_set (RepoId publisher_id)
ssize_t	size () const
MapType &	map ()
	Give access to the underlying map for iteration purposes.
const MapType &	map () const
void	operator= (const ReceiveListenerSetMap &rh)
void	clear ()
Private Member Functions
ReceiveListenerSet *	find_or_create (RepoId publisher_id)
Private Attributes
MapType	map_

---

Detailed Description

Definition at line 24 of file ReceiveListenerSetMap.h.

---

Constructor & Destructor Documentation

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSetMap::ReceiveListenerSetMap

(

)

Definition at line 14 of file ReceiveListenerSetMap.inl.

References DBG_ENTRY_LVL.

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

OpenDDS::DCPS::ReceiveListenerSetMap::~ReceiveListenerSetMap

(

)

[virtual]

Definition at line 17 of file ReceiveListenerSetMap.cpp.

References DBG_ENTRY_LVL.

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

---

Member Function Documentation

void OpenDDS::DCPS::ReceiveListenerSetMap::clear

(

)

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();
}

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet * OpenDDS::DCPS::ReceiveListenerSetMap::find

(

RepoId

publisher_id

)

const

Definition at line 20 of file ReceiveListenerSetMap.inl.

References OpenDDS::DCPS::RcHandle< T >::_retn(), 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 0;
  }

  return listener_set._retn();
}

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet * OpenDDS::DCPS::ReceiveListenerSetMap::find_or_create

(

RepoId

publisher_id

)

[private]

Definition at line 33 of file ReceiveListenerSetMap.inl.

References OpenDDS::DCPS::RcHandle< T >::_retn(), OpenDDS::DCPS::bind(), DBG_ENTRY_LVL, OpenDDS::DCPS::find(), and map_.

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

  if (OpenDDS::DCPS::find(map_, publisher_id, listener_set) != 0) {
    // It wasn't found.  Create one and insert it.
    listener_set = new ReceiveListenerSet();

    if (OpenDDS::DCPS::bind(map_, publisher_id, listener_set) != 0) {
      ACE_ERROR((LM_ERROR,
                 "(%P|%t) ERROR: Unable to insert ReceiveListenerSet into the "
                 "ReceiveListenerSetMap for publisher_id %C.\n",
                 LogGuid(publisher_id).c_str()));
      // Return a 'nil' ReceiveListenerSet*
      return 0;
    }
  }

  return listener_set._retn();
}

int OpenDDS::DCPS::ReceiveListenerSetMap::insert	(	RepoId	publisher_id,
		RepoId	subscriber_id,
		TransportReceiveListener *	receive_listener
	)

Definition at line 24 of file ReceiveListenerSetMap.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::RcHandle< T >::is_nil(), and OPENDDS_STRING.

{
  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
    GuidConverter converter(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"),
                      OPENDDS_STRING(converter).c_str()), -1);
  }

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

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

  GuidConverter sub_converter(subscriber_id);
  GuidConverter pub_converter(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"),
             OPENDDS_STRING(sub_converter).c_str(),
             OPENDDS_STRING(pub_converter).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"),
                 OPENDDS_STRING(pub_converter).c_str()));
    }
  }

  return -1;
}

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

(

)

const

Definition at line 88 of file ReceiveListenerSetMap.inl.

References DBG_ENTRY_LVL, and map_.

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

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

(

)

Give access to the underlying map for iteration purposes.

Definition at line 81 of file ReceiveListenerSetMap.inl.

References DBG_ENTRY_LVL, and map_.

Referenced by operator=().

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

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

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

(

const ReceiveListenerSetMap &

rh

)

Definition at line 162 of file ReceiveListenerSetMap.cpp.

References DBG_ENTRY_LVL, 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);
    }
  }
}

int OpenDDS::DCPS::ReceiveListenerSetMap::release_subscriber	(	RepoId	publisher_id,
		RepoId	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 DBG_ENTRY_LVL, OpenDDS::DCPS::find(), map_, OPENDDS_STRING, 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) {
    GuidConverter converter(publisher_id);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: ReciveListenerSetMap::release_subscriber: ")
               ACE_TEXT("publisher %C not found in map_.\n"),
               OPENDDS_STRING(converter).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) {
      GuidConverter converter(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"),
                 OPENDDS_STRING(converter).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;
}

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

Definition at line 75 of file ReceiveListenerSetMap.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::find(), map_, OPENDDS_STRING, 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) {
      GuidConverter converter(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"),
                        OPENDDS_STRING(converter).c_str()), -1);
    }
  }

  return 0;
}

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet * OpenDDS::DCPS::ReceiveListenerSetMap::remove_set

(

RepoId

publisher_id

)

Definition at line 56 of file ReceiveListenerSetMap.inl.

References OpenDDS::DCPS::RcHandle< T >::_retn(), DBG_ENTRY_LVL, map_, OpenDDS::DCPS::unbind(), and VDBG.

{
  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 0;
  }

  return listener_set._retn();
}

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

(

)

const

Definition at line 74 of file ReceiveListenerSetMap.inl.

References DBG_ENTRY_LVL, and map_.

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

---

Member Data Documentation

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

---