OpenDDS::DCPS::ReceiveListenerSet Class Reference

#include <ReceiveListenerSet.h>

Inheritance diagram for OpenDDS::DCPS::ReceiveListenerSet:

Collaboration diagram for OpenDDS::DCPS::ReceiveListenerSet:

Public Types
enum	ConstrainReceiveSet { SET_EXCLUDED, SET_INCLUDED }

Public Member Functions
typedef	OPENDDS_MAP_CMP (GUID_t, TransportReceiveListener_wrch, GUID_tKeyLessThan) MapType
	ReceiveListenerSet ()
	ReceiveListenerSet (const ReceiveListenerSet &)
ReceiveListenerSet &	operator= (const ReceiveListenerSet &)
virtual	~ReceiveListenerSet ()
int	insert (GUID_t subscriber_id, const TransportReceiveListener_wrch &listener)
int	remove (GUID_t subscriber_id)
void	remove_all (const GUIDSeq &to_remove)
ssize_t	size () const
void	data_received (const ReceivedDataSample &sample, const RepoIdSet &incl_excl, ConstrainReceiveSet constrain)
void	data_received (const ReceivedDataSample &sample, const GUID_t &readerId)
MapType &	map ()
	Give access to the underlying map for iteration purposes. More...
const MapType &	map () const
bool	exist (const GUID_t &key, bool &last)
bool	exist (const GUID_t &local_id)
void	get_keys (ReaderIdSeq &ids)
void	clear ()
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

Private Types
typedef ACE_SYNCH_MUTEX	LockType
typedef ACE_Guard< LockType >	GuardType

Private Attributes
LockType	lock_
	This lock will protect the map. More...
MapType	map_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 27 of file ReceiveListenerSet.h.

Member Typedef Documentation

GuardType

typedef ACE_Guard<LockType> OpenDDS::DCPS::ReceiveListenerSet::GuardType

private

Definition at line 71 of file ReceiveListenerSet.h.

LockType

typedef ACE_SYNCH_MUTEX OpenDDS::DCPS::ReceiveListenerSet::LockType

private

Definition at line 70 of file ReceiveListenerSet.h.

Member Enumeration Documentation

ConstrainReceiveSet

enum OpenDDS::DCPS::ReceiveListenerSet::ConstrainReceiveSet

Enumerator
SET_EXCLUDED
SET_INCLUDED

Definition at line 31 of file ReceiveListenerSet.h.

                           {
    SET_EXCLUDED,
    SET_INCLUDED
  };

Constructor & Destructor Documentation

ReceiveListenerSet() [1/2]

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet::ReceiveListenerSet

(

)

Definition at line 20 of file ReceiveListenerSet.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

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

ReceiveListenerSet() [2/2]

ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet::ReceiveListenerSet

(

const ReceiveListenerSet &

rhs

)

Definition at line 26 of file ReceiveListenerSet.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

  : RcObject()
  , lock_()
  , map_()
{
  DBG_ENTRY_LVL("ReceiveListenerSet", "ReceiveListenerSet(rhs)", 6);
  *this = rhs;
}

~ReceiveListenerSet()

OpenDDS::DCPS::ReceiveListenerSet::~ReceiveListenerSet ( )

virtual

Definition at line 23 of file ReceiveListenerSet.cpp.

References DBG_ENTRY_LVL.

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

Member Function Documentation

clear()

void OpenDDS::DCPS::ReceiveListenerSet::clear

(

void

)

Definition at line 80 of file ReceiveListenerSet.cpp.

References lock_, and map_.

{
  GuardType guard(lock_);
  map_.clear();
}

data_received() [1/2]

void OpenDDS::DCPS::ReceiveListenerSet::data_received	(	const ReceivedDataSample &	sample,
		const RepoIdSet &	incl_excl,
		ConstrainReceiveSet	constrain
	)

Definition at line 87 of file ReceiveListenerSet.cpp.

References ACE_ERROR, OpenDDS::DCPS::TransportReceiveListener::data_received(), DBG_ENTRY_LVL, OpenDDS::DCPS::ReceivedDataSample::has_data(), LM_ERROR, lock_, map_, OpenDDS::DCPS::OPENDDS_VECTOR(), SET_EXCLUDED, and SET_INCLUDED.

{
  DBG_ENTRY_LVL("ReceiveListenerSet", "data_received", 6);
  OPENDDS_VECTOR(TransportReceiveListener_wrch) handles;
  {
    GuardType guard(lock_);
    handles.reserve(map_.size());
    for (MapType::iterator itr = map_.begin(); itr != map_.end(); ++itr) {
      if (constrain == ReceiveListenerSet::SET_EXCLUDED) {
        if (itr->second && incl_excl.count(itr->first) == 0) {
          handles.push_back(itr->second);
        }
      } else if (constrain == ReceiveListenerSet::SET_INCLUDED) { //SET_INCLUDED
        if (itr->second && incl_excl.count(itr->first) != 0) {
          handles.push_back(itr->second);
        }
      } else {
        ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: ReceiveListenerSet::data_received - NOTHING\n"));
      }
    }
  }

  for (size_t i = 0; i < handles.size(); ++i) {
    TransportReceiveListener_rch listener = handles[i].lock();
    if (!listener)
      continue;
    if (i < handles.size() - 1 && sample.has_data()) {
      // demarshal (in data_received()) updates the rd_ptr() of any of
      // the message blocks in the chain, so give it a duplicated chain.
      ReceivedDataSample rds(sample);
      listener->data_received(rds);
    } else {
      listener->data_received(sample);
    }
  }
}

data_received() [2/2]

void OpenDDS::DCPS::ReceiveListenerSet::data_received	(	const ReceivedDataSample &	sample,
		const GUID_t &	readerId
	)

Definition at line 127 of file ReceiveListenerSet.cpp.

References OpenDDS::DCPS::TransportReceiveListener::data_received(), DBG_ENTRY_LVL, OpenDDS::DCPS::WeakRcHandle< T >::lock(), lock_, map_, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

{
  DBG_ENTRY_LVL("ReceiveListenerSet", "data_received(sample, readerId)", 6);
  TransportReceiveListener_wrch h;
  {
    GuardType guard(lock_);
    MapType::iterator itr = map_.find(readerId);
    if (itr != map_.end() && itr->second) {
      h = itr->second;
    }
  }
  TransportReceiveListener_rch listener = h.lock();
  if (listener)
    listener->data_received(sample);
}

exist() [1/2]

bool OpenDDS::DCPS::ReceiveListenerSet::exist	(	const GUID_t &	key,
		bool &	last
	)

Check if the key is in the map and if it's the only left entry in the map.

Definition at line 29 of file ReceiveListenerSet.cpp.

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

{
  GuardType guard(lock_);

  last = true;

  TransportReceiveListener_wrch listener;

  if (find(map_, local_id, listener) == -1) {
    LogGuid logger(local_id);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ReceiveListenerSet::exist: ")
               ACE_TEXT("could not find local %C.\n"),
               logger.c_str()));

    return false;
  }

  if (!listener) {
    LogGuid logger(local_id);
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ReceiveListenerSet::exist: ")
               ACE_TEXT("listener for local %C is nil.\n"),
               logger.c_str()));

    return false;
  }

  last = map_.size() == 1;
  return true;
}

exist() [2/2]

bool OpenDDS::DCPS::ReceiveListenerSet::exist

(

const GUID_t &

local_id

)

Definition at line 73 of file ReceiveListenerSet.cpp.

References lock_, and map_.

{
  GuardType guard(lock_);
  return map_.count(local_id) > 0;
}

get_keys()

void OpenDDS::DCPS::ReceiveListenerSet::get_keys

(

ReaderIdSeq &

ids

)

Definition at line 62 of file ReceiveListenerSet.cpp.

References lock_, map_, and OpenDDS::DCPS::push_back().

{
  GuardType guard(lock_);

  for (MapType::iterator iter = map_.begin();
       iter != map_.end(); ++ iter) {
    push_back(ids, iter->first);
  }
}

insert()

ACE_INLINE int OpenDDS::DCPS::ReceiveListenerSet::insert	(	GUID_t	subscriber_id,
		const TransportReceiveListener_wrch &	listener
	)

Definition at line 48 of file ReceiveListenerSet.inl.

References ACE_INLINE, DBG_ENTRY_LVL, lock_, and map_.

{
  DBG_ENTRY_LVL("ReceiveListenerSet", "insert", 6);
  GuardType guard(lock_);

  std::pair<MapType::iterator,bool> r = map_.insert(std::make_pair(subscriber_id,listener));
  if (!r.second) {
    // subscriber_id is already in the map
    if (!r.first->second) {
      // subscriber_id is in the map with a null listener, update it.
      r.first->second = listener;
    }
    return 1; // 1 ==> key already existed in map
  }
  return 0;
}

map() [1/2]

ACE_INLINE ReceiveListenerSet::MapType & OpenDDS::DCPS::ReceiveListenerSet::map

(

void

)

Give access to the underlying map for iteration purposes.

Definition at line 102 of file ReceiveListenerSet.inl.

References ACE_INLINE, and map_.

{
  return map_;
}

map() [2/2]

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

(

void

)

const

Definition at line 108 of file ReceiveListenerSet.inl.

References map_, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

{
  return map_;
}

OPENDDS_MAP_CMP()

typedef OpenDDS::DCPS::ReceiveListenerSet::OPENDDS_MAP_CMP	(	GUID_t	,
		TransportReceiveListener_wrch	,
		GUID_tKeyLessThan
	)

operator=()

ACE_INLINE ReceiveListenerSet & OpenDDS::DCPS::ReceiveListenerSet::operator=

(

const ReceiveListenerSet &

rhs

)

Definition at line 36 of file ReceiveListenerSet.inl.

References ACE_INLINE, DBG_ENTRY_LVL, lock_, and map_.

{
  DBG_ENTRY_LVL("ReceiveListenerSet", "operator=", 6);
  if (&rhs != this) {
    GuardType guard_lt(&lock_ < &rhs.lock_ ? lock_ : rhs.lock_);
    GuardType guard_gt(&lock_ < &rhs.lock_ ? rhs.lock_ : lock_);
    map_ = rhs.map_;
  }
  return *this;
}

remove()

ACE_INLINE int OpenDDS::DCPS::ReceiveListenerSet::remove

(

GUID_t

subscriber_id

)

Definition at line 67 of file ReceiveListenerSet.inl.

References ACE_ERROR_RETURN, ACE_INLINE, DBG_ENTRY_LVL, LM_ERROR, lock_, map_, and OpenDDS::DCPS::unbind().

{
  DBG_ENTRY_LVL("ReceiveListenerSet", "remove", 6);
  GuardType guard(lock_);

  if (unbind(map_, subscriber_id) != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      "(%P|%t) ERROR: subscriber_id (%C) not found in map_.\n",
                      LogGuid(subscriber_id).c_str()),
                     -1);
  }

  return 0;
}

remove_all()

ACE_INLINE void OpenDDS::DCPS::ReceiveListenerSet::remove_all

(

const GUIDSeq &

to_remove

)

Definition at line 83 of file ReceiveListenerSet.inl.

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

Referenced by OpenDDS::DCPS::DataLink::data_received_i().

{
  DBG_ENTRY_LVL("ReceiveListenerSet", "remove_all", 6);
  GuardType guard(lock_);
  const CORBA::ULong len = to_remove.length();
  for (CORBA::ULong i(0); i < len; ++i) {
    unbind(map_, to_remove[i]);
  }
}

size()

ACE_INLINE ssize_t OpenDDS::DCPS::ReceiveListenerSet::size

(

void

)

const

Definition at line 94 of file ReceiveListenerSet.inl.

References ACE_INLINE, DBG_ENTRY_LVL, lock_, and map_.

{
  DBG_ENTRY_LVL("ReceiveListenerSet", "size", 6);
  GuardType guard(lock_);
  return map_.size();
}

Member Data Documentation

lock_

LockType OpenDDS::DCPS::ReceiveListenerSet::lock_

mutableprivate

This lock will protect the map.

Definition at line 74 of file ReceiveListenerSet.h.

Referenced by clear(), data_received(), exist(), get_keys(), insert(), operator=(), remove(), remove_all(), and size().

map_

MapType OpenDDS::DCPS::ReceiveListenerSet::map_

private

Definition at line 76 of file ReceiveListenerSet.h.

Referenced by clear(), data_received(), exist(), get_keys(), insert(), map(), operator=(), remove(), remove_all(), and size().

---

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

• ReceiveListenerSet.h
• ReceiveListenerSet.cpp
• ReceiveListenerSet.inl