Update Namespace Reference

Classes
struct	TopicStrt< QosSeq, ACE_CString >
struct	ParticipantStrt< QosSeq >
struct	ActorStrt< QosSeq, QosSeq, ACE_CString, BinSeq, ContentSubscriptionBin >
class	PersistenceUpdater
struct	IdPath
struct	OwnershipData
struct	TopicStrt
struct	ParticipantStrt
struct	ContentSubscriptionInfo
struct	ContentSubscriptionBin
struct	ActorStrt
struct	ImageData
class	SeqGuard
class	Manager
class	Updater
Typedefs
typedef DDS::DomainId_t	DomainIdType
typedef OpenDDS::DCPS::RepoId	IdType
typedef std::pair< size_t, char * >	BinSeq
typedef std::pair< SpecificQos, BinSeq >	QosSeq
typedef long	PartIdType
typedef struct TopicStrt < DDS::TopicQos &, std::string >	UTopic
typedef struct TopicStrt < QosSeq, std::string >	DTopic
typedef struct ParticipantStrt < DDS::DomainParticipantQos & >	UParticipant
typedef struct ParticipantStrt < QosSeq >	DParticipant
typedef struct ActorStrt < DDS::SubscriberQos &, DDS::DataReaderQos &, std::string, OpenDDS::DCPS::TransportLocatorSeq &, ContentSubscriptionInfo & >	URActor
typedef struct ActorStrt < DDS::PublisherQos &, DDS::DataWriterQos &, std::string, OpenDDS::DCPS::TransportLocatorSeq &, ContentSubscriptionInfo & >	UWActor
typedef struct ActorStrt < QosSeq, QosSeq, std::string, BinSeq, ContentSubscriptionBin >	DActor
typedef struct ImageData < UTopic *, UParticipant *, URActor *, UWActor * >	UImage
typedef struct ImageData < DTopic, DParticipant, DActor, DActor >	DImage
Enumerations
enum	ItemType { Topic, Participant, Actor }
enum	ActorType { DataReader, DataWriter }
enum	SpecificQos {   NoQos, ParticipantQos, TopicQos, DataWriterQos,   PublisherQos, DataReaderQos, SubscriberQos }
Functions
void *	createIndex (const std::string &tag, PersistenceUpdater::ALLOCATOR &allocator, size_t size, bool &exists)
template<typename I >
void	index_cleanup (I *index, PersistenceUpdater::ALLOCATOR *allocator)

---

Typedef Documentation

typedef std::pair<size_t, char*> Update::BinSeq

Definition at line 36 of file UpdateDataTypes.h.

typedef struct ActorStrt< QosSeq, QosSeq, std::string,BinSeq, ContentSubscriptionBin > Update::DActor

Definition at line 175 of file UpdateDataTypes.h.

typedef struct ImageData< DTopic,DParticipant,DActor,DActor > Update::DImage

Definition at line 195 of file UpdateDataTypes.h.

typedef DDS::DomainId_t Update::DomainIdType

Definition at line 34 of file UpdateDataTypes.h.

typedef struct ParticipantStrt< QosSeq > Update::DParticipant

Definition at line 106 of file UpdateDataTypes.h.

typedef struct TopicStrt< QosSeq, std::string > Update::DTopic

Definition at line 86 of file UpdateDataTypes.h.

typedef OpenDDS::DCPS::RepoId Update::IdType

Definition at line 35 of file UpdateDataTypes.h.

typedef long Update::PartIdType

Definition at line 38 of file UpdateDataTypes.h.

typedef std::pair<SpecificQos, BinSeq> Update::QosSeq

Definition at line 37 of file UpdateDataTypes.h.

typedef struct ImageData< UTopic *, UParticipant *, URActor *, UWActor * > Update::UImage

Definition at line 194 of file UpdateDataTypes.h.

typedef struct ParticipantStrt< DDS::DomainParticipantQos & > Update::UParticipant

Definition at line 105 of file UpdateDataTypes.h.

typedef struct ActorStrt< DDS::SubscriberQos &,DDS::DataReaderQos &,std::string,OpenDDS::DCPS::TransportLocatorSeq &,ContentSubscriptionInfo & > Update::URActor

Definition at line 163 of file UpdateDataTypes.h.

typedef struct TopicStrt< DDS::TopicQos &, std::string > Update::UTopic

Definition at line 85 of file UpdateDataTypes.h.

typedef struct ActorStrt< DDS::PublisherQos &,DDS::DataWriterQos &,std::string,OpenDDS::DCPS::TransportLocatorSeq &,ContentSubscriptionInfo & > Update::UWActor

Definition at line 169 of file UpdateDataTypes.h.

---

Enumeration Type Documentation

enum Update::ActorType

Enumerator:

DataReader
DataWriter

Definition at line 23 of file UpdateDataTypes.h.

{ DataReader, DataWriter };

enum Update::ItemType

Enumerator:

Topic
Participant
Actor

Definition at line 22 of file UpdateDataTypes.h.

{ Topic, Participant, Actor };

enum Update::SpecificQos

Enumerator:

NoQos
ParticipantQos
TopicQos
DataWriterQos
PublisherQos
DataReaderQos
SubscriberQos

Definition at line 24 of file UpdateDataTypes.h.

                 {
  NoQos,
  ParticipantQos,
  TopicQos,
  DataWriterQos,
  PublisherQos,
  DataReaderQos,
  SubscriberQos
};

---

Function Documentation

void* Update::createIndex	(	const std::string &	tag,
		PersistenceUpdater::ALLOCATOR &	allocator,
		size_t	size,
		bool &	exists
	)

Definition at line 228 of file PersistenceUpdater.cpp.

References ACE_TEXT(), ACE_Allocator_Adapter< class >::bind(), ACE_Allocator_Adapter< class >::find(), ACE_Allocator_Adapter< class >::free(), LM_ERROR, and ACE_Allocator_Adapter< class >::malloc().

Referenced by Update::PersistenceUpdater::init().

{
  void* index = 0;

  // This is the easy case since if we find hash table in the
  // memory-mapped file we know it's already initialized.
  if (allocator.find(tag.c_str(), index) == 0) {
    exists = true;
    return index;

  } else {
    ACE_ALLOCATOR_RETURN(index, allocator.malloc(size), 0);

    if (allocator.bind(tag.c_str(), index) == -1) {
      allocator.free(index);
      index = 0;
    }
  }

  if (!index) {
    ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: PersistenceUpdater::init "
      "Initial allocation/Bind failed for %C.\n"), tag.c_str()));
  }

  return index;
}

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename I >

void Update::index_cleanup	(	I *	index,
		PersistenceUpdater::ALLOCATOR *	allocator
	)			[inline]

Definition at line 258 of file PersistenceUpdater.cpp.

References ACE_TEXT(), and LM_ERROR.

Referenced by Update::PersistenceUpdater::init().

{
  for (typename I::ITERATOR iter = index->begin()
                                   ; iter != index->end();) {
    typename I::ITERATOR current_iter = iter;
    iter++;

    if (index->unbind((*current_iter).ext_id_, allocator) != 0) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: PersistenceUpdater::init:"
        "Index unbind failed.\n")));
    }
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: