UpdateDataTypes.h

Go to the documentation of this file.

/*
 *
 *
 * Distributed under the OpenDDS License.
 * See: http://www.opendds.org/license.html
 */

#ifndef UPDATE_DATA_TYPES
#define UPDATE_DATA_TYPES

#include "dds/DdsDcpsInfoUtilsC.h"
#include "dds/DdsDcpsInfrastructureC.h"

#include <vector>
#include <string>
#include <map>

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL

namespace Update {

enum ItemType  { Topic, Participant, Actor };
enum ActorType { DataReader, DataWriter };
enum SpecificQos {
  NoQos,
  ParticipantQos,
  TopicQos,
  DataWriterQos,
  PublisherQos,
  DataReaderQos,
  SubscriberQos
};

typedef DDS::DomainId_t DomainIdType;
typedef OpenDDS::DCPS::GUID_t           IdType; // Federation scope identifier type.
typedef std::pair <size_t, char*>       BinSeq;
typedef std::pair <SpecificQos, BinSeq> QosSeq;
typedef long PartIdType;

struct IdPath {
  DomainIdType domain;
  IdType       participant;
  IdType       id;

  IdPath(DomainIdType d, IdType p, IdType i)
  : domain(d),
      participant(p),
      id(i) { }
};

struct OwnershipData {
  DomainIdType domain;
  IdType       participant;
  long         owner;

  OwnershipData(DomainIdType d, IdType p, long o)
  : domain(d),
      participant(p),
      owner(o) { }
};

template <typename Q, typename S>
struct TopicStrt {
  DomainIdType domainId;
  IdType       topicId;
  IdType       participantId;
  S            name;
  S            dataType;
  Q            topicQos;

  TopicStrt(
    DomainIdType dom,
    IdType       to,
    IdType       pa,
    const char*  na,
    const char*  da,
    Q            tQos) :
      domainId(dom),
      topicId(to),
      participantId(pa),
      name(na),
      dataType(da),
      topicQos(tQos) { };
};
typedef struct TopicStrt<DDS::TopicQos&, std::string> UTopic;
typedef struct TopicStrt<QosSeq, std::string>         DTopic;

template <typename Q>
struct ParticipantStrt {
  DomainIdType domainId;
  long         owner;
  IdType       participantId;
  Q            participantQos;

  ParticipantStrt(
    DomainIdType dom,
    long         own,
    IdType       part,
    Q            pQos):
      domainId(dom),
      owner(own),
      participantId(part),
      participantQos(pQos) { };
};
typedef struct ParticipantStrt<DDS::DomainParticipantQos&> UParticipant;
typedef struct ParticipantStrt<QosSeq>                     DParticipant;

struct ContentSubscriptionInfo {
  CORBA::String_var filterClassName;
  CORBA::String_var filterExpr;
  DDS::StringSeq exprParams;

  ContentSubscriptionInfo() {}
  ContentSubscriptionInfo(const char* fcn, const char* fx, const DDS::StringSeq& ep)
    : filterClassName(fcn), filterExpr(fx), exprParams(ep) {}
};

// like std::pair but with names instead of "first" and "second", since the
// exprParams attribute is itself a std::pair and naming is too confusing with
// nested pairs.
struct ContentSubscriptionBin {
  ACE_CString filterClassName;
  ACE_CString filterExpr;
  BinSeq exprParams;
};

template <typename PSQ, typename RWQ, typename C, typename T, typename CSP, typename STI>
struct ActorStrt {
  DomainIdType domainId;
  IdType       actorId;
  IdType       topicId;
  IdType       participantId;
  ActorType    type;
  C            callback;
  PSQ          pubsubQos;
  RWQ          drdwQos;
  T            transportInterfaceInfo;
  ACE_CDR::ULong transportContext;
  CSP          contentSubscriptionProfile;
  STI          serializedTypeInfo;

  ActorStrt(
    DomainIdType dom,
    IdType       act,
    IdType       top,
    IdType       part,
    ActorType    typ,
    const char*  call,
    PSQ          pub,
    RWQ          drdw,
    T            trans,
    ACE_CDR::ULong tContext,
    CSP          csProf,
    STI          sti)
    : domainId(dom),
      actorId(act),
      topicId(top),
      participantId(part),
      type(typ),
      callback(call),
      pubsubQos(pub),
      drdwQos(drdw),
      transportInterfaceInfo(trans),
      transportContext(tContext),
      contentSubscriptionProfile(csProf),
      serializedTypeInfo(sti)
    { };
};
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;

template <typename T, typename P, typename A, typename W>
struct ImageData {
  typedef std::vector<T> TopicSeq;
  typedef std::vector<P> ParticipantSeq;
  typedef std::vector<A> ReaderSeq;
  typedef std::vector<W> WriterSeq;

  unsigned long  sequenceNumber;
  TopicSeq       topics;
  ParticipantSeq participants;
  ReaderSeq      actors;
  WriterSeq      wActors;

  /// What the last participant id is/was
  PartIdType lastPartId;
};
typedef struct ImageData<UTopic*, UParticipant*, URActor*, UWActor*> UImage;
typedef struct ImageData<DTopic,  DParticipant,  DActor,   DActor>   DImage;

} // namespace Update

OPENDDS_END_VERSIONED_NAMESPACE_DECL

#endif /* UPDATE_DATA_TYPES */