Update Namespace Reference

Classes
struct	ActorStrt
struct	ActorStrt< QosSeq, QosSeq, ACE_CString, BinSeq, ContentSubscriptionBin, BinSeq >
struct	ContentSubscriptionBin
struct	ContentSubscriptionInfo
struct	IdPath
struct	ImageData
class	Manager
struct	OwnershipData
struct	ParticipantStrt
struct	ParticipantStrt< QosSeq >
class	PersistenceUpdater
class	SeqGuard
struct	TopicStrt
struct	TopicStrt< QosSeq, ACE_CString >
class	Updater

Typedefs
typedef DDS::DomainId_t	DomainIdType
typedef OpenDDS::DCPS::GUID_t	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 &, DDS::OctetSeq &>	URActor
typedef struct ActorStrt< DDS::PublisherQos &, DDS::DataWriterQos &, std::string, OpenDDS::DCPS::TransportLocatorSeq &, ContentSubscriptionInfo &, DDS::OctetSeq &>	UWActor
typedef struct ActorStrt< QosSeq, QosSeq, std::string, BinSeq, ContentSubscriptionBin, BinSeq >	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

BinSeq

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

Definition at line 36 of file UpdateDataTypes.h.

DActor

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

Definition at line 183 of file UpdateDataTypes.h.

DImage

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

Definition at line 204 of file UpdateDataTypes.h.

DomainIdType

typedef DDS::DomainId_t Update::DomainIdType

Definition at line 34 of file UpdateDataTypes.h.

DParticipant

typedef struct ParticipantStrt< QosSeq > Update::DParticipant

Definition at line 106 of file UpdateDataTypes.h.

DTopic

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

Definition at line 86 of file UpdateDataTypes.h.

IdType

typedef OpenDDS::DCPS::GUID_t Update::IdType

Definition at line 35 of file UpdateDataTypes.h.

PartIdType

typedef long Update::PartIdType

Definition at line 38 of file UpdateDataTypes.h.

QosSeq

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

Definition at line 37 of file UpdateDataTypes.h.

UImage

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

Definition at line 203 of file UpdateDataTypes.h.

UParticipant

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

Definition at line 105 of file UpdateDataTypes.h.

URActor

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

Definition at line 169 of file UpdateDataTypes.h.

UTopic

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

Definition at line 85 of file UpdateDataTypes.h.

UWActor

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

Definition at line 176 of file UpdateDataTypes.h.

Enumeration Type Documentation

ActorType

enum Update::ActorType

Enumerator
DataReader
DataWriter

Definition at line 23 of file UpdateDataTypes.h.

{ DataReader, DataWriter };

ItemType

enum Update::ItemType

Enumerator
Topic
Participant
Actor

Definition at line 22 of file UpdateDataTypes.h.

{ Topic, Participant, Actor };

SpecificQos

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

createIndex()

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

Definition at line 231 of file PersistenceUpdater.cpp.

References ACE_ALLOCATOR_RETURN, ACE_ERROR, 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: ")
      ACE_TEXT("Initial allocation/Bind failed for %C.\n"),
      tag.c_str()));
  }

  return index;
}

index_cleanup()

template<typename I >

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

Definition at line 263 of file PersistenceUpdater.cpp.

References ACE_ERROR, 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: ")
        ACE_TEXT("Index unbind failed.\n")));
    }
  }
}