publisher.cpp

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <sstream>
#include <vector>
#include "ccpp_dds_dcps.h"
#include "opensplice_dds_broker/check_status.h"
#include "opensplice_dds_broker/ccpp_GSDFPacket.h"
#include "opensplice_dds_broker/example_main.h"
#include "opensplice_dds_broker/publisher.h"

using namespace DDS;

namespace opensplice_dds_broker{
    
    Publisher::Publisher(const std::string& topic_name)
    {
        domain = 0;
        topic_name_ = topic_name.data();
        GSDFPacketTypeName = NULL;
        
        //Create a DomainParticipantFactory and a DomainParticipant, using Default QoS settings
        dpf = DomainParticipantFactory::get_instance ();
        checkHandle(dpf.in(), "DDS::DomainParticipantFactory::get_instance");
        participant = dpf->create_participant(domain, PARTICIPANT_QOS_DEFAULT, NULL, STATUS_MASK_NONE);
        checkHandle(participant.in(), "DDS::DomainParticipantFactory::create_participant");

        //Register the required datatype
        GSDFPacketTS = new GSDFPacketTypeSupport();
        checkHandle(GSDFPacketTS.in(), "new GSDFPacketTypeSupport");
        GSDFPacketTypeName = GSDFPacketTS->get_type_name();
        status = GSDFPacketTS->register_type(
            participant.in(),
            GSDFPacketTypeName);
        checkStatus(status, "micros_swarm_framework::GSDFPacketTypeSupport::register_type");

        //Set the ReliabilityQosPolicy to BEST_EFFORT_RELIABILITY
        status = participant->get_default_topic_qos(topic_qos);
        checkStatus(status, "DDS::DomainParticipant::get_default_topic_qos");
        topic_qos.reliability.kind = BEST_EFFORT_RELIABILITY_QOS;
        //topic_qos.reliability.kind = RELIABLE_RELIABILITY_QOS;
        topic_qos.durability_service.history_kind = KEEP_LAST_HISTORY_QOS;
        //topic_qos.durability_service.history_depth = 4000;

        //Make the tailored QoS the new default
        status = participant->set_default_topic_qos(topic_qos);
        checkStatus(status, "DDS::DomainParticipant::set_default_topic_qos");

        //Use the changed policy when defining the GSDFPacket topic
        GSDFPacketTopic = participant->create_topic(
            topic_name_,
            GSDFPacketTypeName,
            topic_qos,
            NULL,
            STATUS_MASK_NONE);
        checkHandle(GSDFPacketTopic.in(), "DDS::DomainParticipant::create_topic (GSDFPacket)");

        //Adapt the default PublisherQos to write into the "micros_swarm_framework_default_partion" Partition
        status = participant->get_default_publisher_qos (pub_qos);
        checkStatus(status, "DDS::DomainParticipant::get_default_publisher_qos");
        pub_qos.partition.name.length(1);
        pub_qos.partition.name[0] = "micros_swarm_framework_partion";

        //Create a Publisher for the application
        publisher_ = participant->create_publisher(pub_qos, NULL, STATUS_MASK_NONE);
        checkHandle(publisher_.in(), "DDS::DomainParticipant::create_publisher");
        
        status = publisher_->get_default_datawriter_qos(dw_qos);
        dw_qos.destination_order.kind = BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS;
        dw_qos.history.kind = KEEP_ALL_HISTORY_QOS;
        //dw_qos.history.kind = KEEP_LAST_HISTORY_QOS;
        //dw_qos.durability.kind = TRANSIENT_LOCAL_DURABILITY_QOS;
        dw_qos.durability.kind = VOLATILE_DURABILITY_QOS;

        //Create a DataWriter for the GSDFPacket Topic (using the appropriate QoS)
        parentWriter = publisher_->create_datawriter(
            GSDFPacketTopic.in(),
            dw_qos,
            NULL,
            STATUS_MASK_NONE);
        checkHandle(parentWriter, "DDS::Publisher::create_datawriter (GSDFPacket)");

        //Narrow the abstract parent into its typed representative
        GSDFPacketDW = GSDFPacketDataWriter::_narrow(parentWriter);
        checkHandle(GSDFPacketDW.in(), "micros_swarm_framework::GSDFPacketDataWriter::_narrow");
    }
    
    void Publisher::publish(const GSDFPacket& packet)
    {
        status = GSDFPacketDW->write(packet, DDS::HANDLE_NIL);
        checkStatus(status, "micros_swarm_framework::GSDFPacketDataWriter::write");
    }
    
    Publisher::~Publisher()
    {
        //Remove the DataWriters 
        status = publisher_->delete_datawriter(GSDFPacketDW.in() );
        checkStatus(status, "DDS::Publisher::delete_datawriter (GSDFPacketDW)");

        //Remove the Publisher
        status = participant->delete_publisher(publisher_.in() );
        checkStatus(status, "DDS::DomainParticipant::delete_publisher");

        status = participant->delete_topic( GSDFPacketTopic.in() );
        checkStatus(status, "DDS::DomainParticipant::delete_topic (GSDFPacketTopic)");

        //Remove the type-names
        string_free(GSDFPacketTypeName);

        //Remove the DomainParticipant
        status = dpf->delete_participant( participant.in() );
        checkStatus(status, "DDS::DomainParticipantFactory::delete_participant");

        //cout << "Completed publisher" << endl;
    }
};