#include <ReceiveListenerSet.h>
Inheritance diagram for OpenDDS::DCPS::ReceiveListenerSet:


Public Types | |
| typedef std::map< RepoId, TransportReceiveListener *, GUID_tKeyLessThan > | MapType |
Public Member Functions | |
| ReceiveListenerSet () | |
| virtual | ~ReceiveListenerSet () |
| int | insert (RepoId subscriber_id, TransportReceiveListener *listener) |
| int | remove (RepoId subscriber_id) |
| ssize_t | size () const |
| void | data_received (const ReceivedDataSample &sample) |
| MapType & | map () |
| Give access to the underlying map for iteration purposes. | |
| const MapType & | map () const |
| bool | exist (const RepoId &key, bool &last) |
| void | get_keys (ReaderIdSeq &ids) |
| bool | exist (const RepoId &local_id) |
| void | clear () |
Private Types | |
| typedef ACE_SYNCH_MUTEX | LockType |
| typedef ACE_Guard< LockType > | GuardType |
Private Attributes | |
| LockType | lock_ |
| This lock will protect the map. | |
| MapType | map_ |
typedef ACE_Guard<LockType> OpenDDS::DCPS::ReceiveListenerSet::GuardType [private] |
typedef ACE_SYNCH_MUTEX OpenDDS::DCPS::ReceiveListenerSet::LockType [private] |
| typedef std::map<RepoId, TransportReceiveListener*, GUID_tKeyLessThan> OpenDDS::DCPS::ReceiveListenerSet::MapType |
| ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet::ReceiveListenerSet | ( | ) |
| OpenDDS::DCPS::ReceiveListenerSet::~ReceiveListenerSet | ( | ) | [virtual] |
| void OpenDDS::DCPS::ReceiveListenerSet::clear | ( | ) |
| ACE_INLINE void OpenDDS::DCPS::ReceiveListenerSet::data_received | ( | const ReceivedDataSample & | sample | ) |
| bool OpenDDS::DCPS::ReceiveListenerSet::exist | ( | const RepoId & | local_id | ) |
| bool OpenDDS::DCPS::ReceiveListenerSet::exist | ( | const RepoId & | key, | |
| bool & | last | |||
| ) |
Check if the key is in the map and if it's the only left entry in the map.
| void OpenDDS::DCPS::ReceiveListenerSet::get_keys | ( | ReaderIdSeq & | ids | ) |
| ACE_INLINE int OpenDDS::DCPS::ReceiveListenerSet::insert | ( | RepoId | subscriber_id, | |
| TransportReceiveListener * | listener | |||
| ) |
| ACE_INLINE const OpenDDS::DCPS::ReceiveListenerSet::MapType & OpenDDS::DCPS::ReceiveListenerSet::map | ( | ) | const |
| ACE_INLINE OpenDDS::DCPS::ReceiveListenerSet::MapType & OpenDDS::DCPS::ReceiveListenerSet::map | ( | ) |
Give access to the underlying map for iteration purposes.
| ACE_INLINE int OpenDDS::DCPS::ReceiveListenerSet::remove | ( | RepoId | subscriber_id | ) |
| ACE_INLINE ssize_t OpenDDS::DCPS::ReceiveListenerSet::size | ( | ) | const |
LockType OpenDDS::DCPS::ReceiveListenerSet::lock_ [mutable, private] |
This lock will protect the map.
1.4.7