Update::Manager Class Reference

#include <UpdateManager.h>

Collaboration diagram for Update::Manager:

[legend]List of all members.

Public Member Functions
	Manager ()
virtual	~Manager ()
virtual int	init (int argc, ACE_TCHAR *argv[])
	Shared object initializer.
virtual int	fini ()
	Shared object finalizer.
void	add (TAO_DDS_DCPSInfo_i *info)
void	add (Updater *updater)
void	remove ()
void	remove (const Updater *updater)
void	requestImage ()
	Force a clean shutdown.
void	pushImage (const DImage &image)
	Downstream request to push image.
template<class UType>
void	create (const UType &info)
template<class QosType>
void	update (const IdPath &id, const QosType &qos)
void	destroy (const IdPath &id, ItemType type, ActorType actor=DataWriter)
void	add (const DTopic &topic)
void	add (const DParticipant &participant)
void	add (const DActor &actor)
Private Types
typedef std::set< Updater * >	Updaters
Private Attributes
TAO_DDS_DCPSInfo_i *	info_
Updaters	updaters_

---

Detailed Description

Definition at line 30 of file UpdateManager.h.

---

Member Typedef Documentation

typedef std::set<Updater*> Update::Manager::Updaters [private]

Definition at line 78 of file UpdateManager.h.

---

Constructor & Destructor Documentation

Update::Manager::Manager

(

)

Definition at line 21 of file UpdateManager.cpp.

  : info_(0)
{
}

Update::Manager::~Manager

(

)

[virtual]

Definition at line 26 of file UpdateManager.cpp.

{
}

---

Member Function Documentation

void Update::Manager::add

(

const DActor &

actor

)

Definition at line 342 of file UpdateManager.cpp.

References Update::ActorStrt< PSQ, RWQ, C, T, CSP >::actorId, TAO_DDS_DCPSInfo_i::add_publication(), TAO_DDS_DCPSInfo_i::add_subscription(), Update::ActorStrt< PSQ, RWQ, C, T, CSP >::callback, Update::ActorStrt< PSQ, RWQ, C, T, CSP >::contentSubscriptionProfile, Update::DataReader, Update::DataWriter, Update::ActorStrt< PSQ, RWQ, C, T, CSP >::domainId, Update::ActorStrt< PSQ, RWQ, C, T, CSP >::drdwQos, Update::ContentSubscriptionInfo::exprParams, Update::ContentSubscriptionInfo::filterClassName, Update::ContentSubscriptionInfo::filterExpr, info_, Update::ActorStrt< PSQ, RWQ, C, T, CSP >::participantId, Update::ActorStrt< PSQ, RWQ, C, T, CSP >::pubsubQos, Update::ActorStrt< PSQ, RWQ, C, T, CSP >::topicId, Update::ActorStrt< PSQ, RWQ, C, T, CSP >::transportInterfaceInfo, and Update::ActorStrt< PSQ, RWQ, C, T, CSP >::type.

{
  if (info_ == NULL) {
    return;
  }

  // Demarshal QOS data
  TAO_InputCDR pubSubCdr(actor.pubsubQos.second.second
                         , actor.pubsubQos.second.first);

  TAO_InputCDR drdwCdr(actor.drdwQos.second.second
                       , actor.drdwQos.second.first);

  std::string callback(actor.callback.c_str());

  TAO_InputCDR transportCdr(actor.transportInterfaceInfo.second
                            , actor.transportInterfaceInfo.first);

  OpenDDS::DCPS::TransportLocatorSeq transport_info;
  transportCdr >> transport_info;

  if (actor.type == DataReader) {
    DDS::SubscriberQos sub_qos;
    DDS::DataReaderQos reader_qos;

    pubSubCdr >> sub_qos;
    drdwCdr >> reader_qos;

    Update::ContentSubscriptionInfo csi;
    csi.filterClassName = actor.contentSubscriptionProfile.filterClassName.c_str();
    csi.filterExpr = actor.contentSubscriptionProfile.filterExpr.c_str();
    TAO_InputCDR cspCdr(actor.contentSubscriptionProfile.exprParams.second,
                        actor.contentSubscriptionProfile.exprParams.first);
    cspCdr >> csi.exprParams;

    // Pass actor to InfoRepo.
    info_->add_subscription(actor.domainId, actor.participantId
                            , actor.topicId, actor.actorId
                            , callback.c_str(), reader_qos
                            , transport_info, sub_qos
                            , csi.filterClassName, csi.filterExpr, csi.exprParams);

  } else if (actor.type == DataWriter) {
    DDS::PublisherQos pub_qos;
    DDS::DataWriterQos writer_qos;

    pubSubCdr >> pub_qos;
    drdwCdr >> writer_qos;

    // Pass actor info to infoRepo.
    info_->add_publication(actor.domainId, actor.participantId
                           , actor.topicId, actor.actorId
                           , callback.c_str(), writer_qos
                           , transport_info, pub_qos);
  }
}

void Update::Manager::add

(

const DParticipant &

participant

)

Definition at line 322 of file UpdateManager.cpp.

References TAO_DDS_DCPSInfo_i::add_domain_participant(), Update::ParticipantStrt< QosSeq >::domainId, info_, Update::ParticipantStrt< QosSeq >::participantId, and Update::ParticipantStrt< QosSeq >::participantQos.

{
  if (info_ == NULL) {
    return;
  }

  // Demarshal QOS data
  TAO_InputCDR in_cdr(participant.participantQos.second.second
                      , participant.participantQos.second.first);

  DDS::DomainParticipantQos qos;
  in_cdr >> qos;

  // Pass participant info to infoRepo.
  info_->add_domain_participant(participant.domainId
                                , participant.participantId
                                , qos);
}

void Update::Manager::add

(

const DTopic &

topic

)

Definition at line 302 of file UpdateManager.cpp.

References TAO_DDS_DCPSInfo_i::add_topic(), Update::TopicStrt< Q, S >::dataType, Update::TopicStrt< Q, S >::domainId, info_, Update::TopicStrt< Q, S >::name, Update::TopicStrt< Q, S >::participantId, Update::TopicStrt< Q, S >::topicId, and Update::TopicStrt< Q, S >::topicQos.

{
  if (info_ == NULL) {
    return;
  }

  // Demarshal QOS data
  TAO_InputCDR in_cdr(topic.topicQos.second.second
                      , topic.topicQos.second.first);

  DDS::TopicQos qos;
  in_cdr >> qos;

  // Pass topic info to infoRepo.
  info_->add_topic(topic.topicId, topic.domainId
                   , topic.participantId, topic.name.c_str()
                   , topic.dataType.c_str(), qos);
}

void Update::Manager::add

(

Updater *

updater

)

Definition at line 37 of file UpdateManager.cpp.

References updaters_.

{
  // push new element to the back.
  updaters_.insert(updater);
}

void Update::Manager::add

(

TAO_DDS_DCPSInfo_i *

info

)

Definition at line 31 of file UpdateManager.cpp.

References info_.

Referenced by TAO_DDS_DCPSInfo_i::add(), Update::PersistenceUpdater::init(), and TAO_DDS_DCPSInfo_i::init_persistence().

{
  info_ = info;
}

template<class UType>

void Update::Manager::create

(

const UType &

info

)

Definition at line 12 of file UpdateManager_T.cpp.

References updaters_.

Referenced by TAO_DDS_DCPSInfo_i::add_domain_participant(), TAO_DDS_DCPSInfo_i::add_publication(), TAO_DDS_DCPSInfo_i::add_subscription(), TAO_DDS_DCPSInfo_i::assert_topic(), and DCPS_IR_Participant::takeOwnership().

{
  // Invoke add on each of the iterators.
  for (Updaters::iterator iter = updaters_.begin();
       iter != updaters_.end();
       iter++) {
    (*iter)->create(info);
  }
}

void Update::Manager::destroy	(	const IdPath &	id,
		ItemType	type,
		ActorType	actor = DataWriter
	)

Definition at line 291 of file UpdateManager.cpp.

References updaters_.

Referenced by DCPS_IR_Participant::remove_all_dependents(), TAO_DDS_DCPSInfo_i::remove_domain_participant(), TAO_DDS_DCPSInfo_i::remove_publication(), TAO_DDS_DCPSInfo_i::remove_subscription(), and TAO_DDS_DCPSInfo_i::remove_topic().

{
  // Invoke remove on each of the iterators.
  for (Updaters::iterator iter = updaters_.begin();
       iter != updaters_.end();
       iter++) {
    (*iter)->destroy(id, type, actor);
  }
}

int Update::Manager::fini

(

)

[virtual]

Shared object finalizer.

Definition at line 71 of file UpdateManager.cpp.

{
  return 0;
}

int Update::Manager::init	(	int	argc,
		ACE_TCHAR *	argv[]
	)			[virtual]

Shared object initializer.

Definition at line 65 of file UpdateManager.cpp.

{
  return 0;
}

void Update::Manager::pushImage

(

const DImage &

image

)

Downstream request to push image.

Definition at line 111 of file UpdateManager.cpp.

References Update::ImageData< T, P, A, W >::actors, Update::DataReader, Update::DataWriter, Update::ContentSubscriptionInfo::exprParams, Update::ContentSubscriptionInfo::filterClassName, Update::ContentSubscriptionInfo::filterExpr, info_, Update::ImageData< T, P, A, W >::participants, TAO_DDS_DCPSInfo_i::receive_image(), Update::SeqGuard< T >::seq(), Update::ImageData< T, P, A, W >::topics, and Update::ImageData< T, P, A, W >::wActors.

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

{
  if (info_ == NULL) {
    return;
  }

  // image to be propagated.
  UImage u_image;

  /***************************
  // The downstream image needs to be converted to a
  // format compatible with the upstream layers (Dimage -> UImage)
  // The Uimage cotains a lot of refrences to the complex data
  // types. These are collecetd in several buckets (see below) and
  // passed by reference. Usage of a custom guard class 'SeqGuard'
  // automates memory cleanup.
  ***************************/

  // Participant buckets
  SeqGuard<DDS::DomainParticipantQos> part_qos_guard;
  SeqGuard<DDS::DomainParticipantQos>::Seq& part_qos = part_qos_guard.seq();

  SeqGuard<UParticipant> part_guard;
  SeqGuard<UParticipant>::Seq& parts = part_guard.seq();

  for (DImage::ParticipantSeq::const_iterator iter = image.participants.begin();
       iter != image.participants.end(); iter++) {
    const DParticipant& part = *iter;

    TAO_InputCDR in_cdr(part.participantQos.second.second
                        , part.participantQos.second.first);

    DDS::DomainParticipantQos* qos;
    ACE_NEW_NORETURN(qos, DDS::DomainParticipantQos);
    in_cdr >> *qos;
    part_qos.push_back(qos);

    UParticipant* u_part;
    ACE_NEW_NORETURN(u_part, UParticipant(part.domainId
                                          , part.owner
                                          , part.participantId
                                          , *qos));
    parts.push_back(u_part);

    // push newly created UParticipant into UImage Participant bucket
    u_image.participants.push_back(u_part);
  }

  // Topic buckets
  SeqGuard<DDS::TopicQos> topics_qos_guard;
  SeqGuard<DDS::TopicQos>::Seq& topics_qos = topics_qos_guard.seq();

  SeqGuard<UTopic> topics_guard;
  SeqGuard<UTopic>::Seq& topics = topics_guard.seq();

  for (DImage::TopicSeq::const_iterator iter = image.topics.begin();
       iter != image.topics.end(); iter++) {
    const DTopic& topic = *iter;

    TAO_InputCDR in_cdr(topic.topicQos.second.second
                        , topic.topicQos.second.first);

    DDS::TopicQos* qos;
    ACE_NEW_NORETURN(qos, DDS::TopicQos);
    in_cdr >> *qos;
    topics_qos.push_back(qos);

    UTopic* u_topic;
    ACE_NEW_NORETURN(u_topic
                     , UTopic(topic.domainId, topic.topicId
                              , topic.participantId
                              , topic.name.c_str()
                              , topic.dataType.c_str(), *qos));
    topics.push_back(u_topic);

    // Push newly created UTopic into UImage Topic bucket
    u_image.topics.push_back(u_topic);
  }

  // Actor buckets
  SeqGuard<DDS::PublisherQos> pub_qos_guard;
  SeqGuard<DDS::PublisherQos>::Seq& pub_qos_seq = pub_qos_guard.seq();
  SeqGuard<DDS::DataWriterQos> dw_qos_guard;
  SeqGuard<DDS::DataWriterQos>::Seq& dw_qos_seq = dw_qos_guard.seq();

  SeqGuard<DDS::SubscriberQos> sub_qos_guard;
  SeqGuard<DDS::SubscriberQos>::Seq& sub_qos_seq = sub_qos_guard.seq();
  SeqGuard<DDS::DataReaderQos> dr_qos_guard;
  SeqGuard<DDS::DataReaderQos>::Seq& dr_qos_seq = dr_qos_guard.seq();

  SeqGuard<OpenDDS::DCPS::TransportLocatorSeq> trans_guard;
  SeqGuard<OpenDDS::DCPS::TransportLocatorSeq>::Seq& transports = trans_guard.seq();

  SeqGuard<URActor> reader_guard;
  SeqGuard<URActor>::Seq& readers = reader_guard.seq();
  SeqGuard<UWActor> writer_guard;
  SeqGuard<UWActor>::Seq& writers = writer_guard.seq();

  for (DImage::ReaderSeq::const_iterator iter = image.actors.begin();
       iter != image.actors.end(); iter++) {
    const DActor& actor = *iter;

    TAO_InputCDR in_cdr(actor.transportInterfaceInfo.second
                        , actor.transportInterfaceInfo.first);
    OpenDDS::DCPS::TransportLocatorSeq* trans;
    ACE_NEW_NORETURN(trans, OpenDDS::DCPS::TransportLocatorSeq);
    transports.push_back(trans);
    in_cdr >> *trans;

    DDS::PublisherQos* pub_qos = 0;
    DDS::DataWriterQos* writer_qos = 0;
    DDS::SubscriberQos* sub_qos = 0;
    DDS::DataReaderQos* reader_qos = 0;

    if (actor.type == DataReader) {
      TAO_InputCDR sub_cdr(actor.pubsubQos.second.second
                           , actor.pubsubQos.second.first);
      ACE_NEW_NORETURN(sub_qos, DDS::SubscriberQos);
      sub_qos_seq.push_back(sub_qos);
      sub_cdr >> *sub_qos;

      TAO_InputCDR read_cdr(actor.drdwQos.second.second
                            , actor.drdwQos.second.first);
      ACE_NEW_NORETURN(reader_qos, DDS::DataReaderQos);
      dr_qos_seq.push_back(reader_qos);
      read_cdr >> *reader_qos;

      ContentSubscriptionInfo* csi = 0;
      ACE_NEW_NORETURN(csi, ContentSubscriptionInfo);
      csi->filterClassName = actor.contentSubscriptionProfile.filterClassName.c_str();
      csi->filterExpr = actor.contentSubscriptionProfile.filterExpr.c_str();
      TAO_InputCDR csp_cdr(actor.contentSubscriptionProfile.exprParams.second,
                           actor.contentSubscriptionProfile.exprParams.first);
      csp_cdr >> csi->exprParams;

      URActor* reader;
      ACE_NEW_NORETURN(reader
                       , URActor(actor.domainId, actor.actorId
                                 , actor.topicId, actor.participantId
                                 , actor.type, actor.callback.c_str()
                                 , *sub_qos, *reader_qos
                                 , *trans, *csi));
      readers.push_back(reader);
      u_image.actors.push_back(reader);

    } else if (actor.type == DataWriter) {
      TAO_InputCDR pub_cdr(actor.pubsubQos.second.second
                           , actor.pubsubQos.second.first);
      ACE_NEW_NORETURN(pub_qos, DDS::PublisherQos);
      pub_qos_seq.push_back(pub_qos);
      pub_cdr >> *pub_qos;

      TAO_InputCDR write_cdr(actor.drdwQos.second.second
                             , actor.drdwQos.second.first);
      ACE_NEW_NORETURN(writer_qos, DDS::DataWriterQos);
      dw_qos_seq.push_back(writer_qos);
      write_cdr >> *writer_qos;

      ContentSubscriptionInfo csi; //writers have no info

      UWActor* writer;
      ACE_NEW_NORETURN(writer
                       , UWActor(actor.domainId, actor.actorId
                                 , actor.topicId, actor.participantId
                                 , actor.type, actor.callback.c_str()
                                 , *pub_qos, *writer_qos
                                 , *trans, csi));
      writers.push_back(writer);
      u_image.wActors.push_back(writer);

    } else {
      ACE_ERROR((LM_ERROR, "Update::Manager::pushImage> unknown "
                 "actor type.\n"));
    }
  }

  info_->receive_image(u_image);
}

void Update::Manager::remove

(

const Updater *

updater

)

Definition at line 51 of file UpdateManager.cpp.

References updaters_.

{
  // check if the Updaters is part of the list.
  Updaters::iterator iter = updaters_.find(const_cast<Updater*>(updater));

  if (iter == updaters_.end()) {
    return;
  }

  // remove the element
  updaters_.erase(iter);
}

void Update::Manager::remove

(

)

Definition at line 44 of file UpdateManager.cpp.

References info_.

{
  // Clean the refrence to the InfoRepo.
  info_ = 0;
}

void Update::Manager::requestImage

(

)

Force a clean shutdown.

Upstream request for a fresh image Currently handled synchronously via 'pushImage' TBD: Replace with an asynchronous model.

Definition at line 77 of file UpdateManager.cpp.

References updaters_.

Referenced by TAO_DDS_DCPSInfo_i::init_persistence().

{
  for (Updaters::iterator iter = updaters_.begin();
       iter != updaters_.end();
       iter++) {
    (*iter)->requestImage();
  }
}

template<class QosType>

void Update::Manager::update	(	const IdPath &	id,
		const QosType &	qos
	)

Definition at line 24 of file UpdateManager_T.cpp.

References updaters_.

Referenced by TAO_DDS_DCPSInfo_i::update_domain_participant_qos(), TAO_DDS_DCPSInfo_i::update_publication_qos(), TAO_DDS_DCPSInfo_i::update_subscription_params(), TAO_DDS_DCPSInfo_i::update_subscription_qos(), and TAO_DDS_DCPSInfo_i::update_topic_qos().

{
  // Invoke update on each of the iterators.
  for (Updaters::iterator iter = updaters_.begin();
       iter != updaters_.end();
       iter++) {
    (*iter)->update(id, qos);
  }
}

---

Member Data Documentation

TAO_DDS_DCPSInfo_i* Update::Manager::info_ [private]

Definition at line 83 of file UpdateManager.h.

Referenced by add(), pushImage(), and remove().

Updaters Update::Manager::updaters_ [private]

Definition at line 84 of file UpdateManager.h.

Referenced by add(), create(), destroy(), remove(), requestImage(), and update().

---

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

• UpdateManager.h
• UpdateManager.cpp
• UpdateManager_T.cpp

---