TDomainParticipant.hpp

Go to the documentation of this file.

#ifndef OMG_TDDS_DOMAIN_DOMAIN_PARTICIPANT_HPP_
#define OMG_TDDS_DOMAIN_DOMAIN_PARTICIPANT_HPP_

/* Copyright 2010, Object Management Group, Inc.
 * Copyright 2010, PrismTech, Corp.
 * Copyright 2010, Real-Time Innovations, Inc.
 * All rights reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include <string>

#include <dds/core/detail/conformance.hpp>
#include <dds/core/types.hpp>
#include <dds/core/Time.hpp>
#include <dds/core/TEntity.hpp>
#include <dds/core/cond/StatusCondition.hpp>
#include <dds/domain/qos/DomainParticipantQos.hpp>

#include <dds/topic/qos/TopicQos.hpp>

#include <dds/pub/qos/PublisherQos.hpp>
#include <dds/sub/qos/SubscriberQos.hpp>


namespace dds { namespace domain {

  template <typename DELEGATE>
  class TDomainParticipant;

  class DomainParticipantListener;
} }

template <typename DELEGATE>
class dds::domain::TDomainParticipant : public ::dds::core::TEntity<DELEGATE> {
public:
  typedef dds::domain::DomainParticipantListener Listener;

public:
  TDomainParticipant(uint32_t did)
  : ::dds::core::TEntity<DELEGATE>(new DELEGATE(did));

  TDomainParticipant(uint32_t                                          id,
      const dds::domain::qos::DomainParticipantQos&     qos,
      dds::domain::DomainParticipantListener*           listener = NULL,
      const dds::core::status::StatusMask&              mask = dds::core::status::StatusMask::all());

public:
  OMG_DDS_BASIC_REF_TYPE(TDomainParticipant, ::dds::core::TEntity, DELEGATE)

public:
  ~TDomainParticipant();

public:

  void listener(Listener* the_listener,
      const ::dds::core::status::StatusMask& event_mask);

  Listener* listener() const;


  const dds::domain::qos::DomainParticipantQos&
  qos() const;
  void qos(const dds::domain::qos::DomainParticipantQos& the_qos);

  uint32_t domain_id() const;


  void
  assert_liveliness();


  bool
  contains_entity(const ::dds::core::InstanceHandle& handle);

  dds::core::Time
  current_time();

public:
  // --- DomainParticipant QoS Defaults --- //
  static dds::domain::qos::DomainParticipantQos default_participant_qos();
  static void default_participant_qos(const ::dds::domain::qos::DomainParticipantQos& qos);

  // --- Publisher QoS Defaults --- //
  dds::pub::qos::PublisherQos default_publisher_qos() const;
  TDomainParticipant& default_publisher_qos(const ::dds::pub::qos::PublisherQos& qos);

  // --- Subscriber QoS Defaults --- //
  dds::sub::qos::SubscriberQos default_subscriber_qos() const;
  TDomainParticipant& default_subscriber_qos(const ::dds::sub::qos::SubscriberQos& qos);

  // --- Topic QoS Defaults --- //
  dds::topic::qos::TopicQos default_topic_qos() const;
  TDomainParticipant& default_topic_qos(const dds::topic::qos::TopicQos& qos);

  //=============================================================================
};


#endif /* OMG_TDDS_DOMAIN_DOMAIN_PARTICIPANT_HPP_ */