GSDFPacket_listener.cpp

Go to the documentation of this file.

#include "opensplice_dds_comm/GSDFPacket_listener.h"
#include "opensplice_dds_comm/check_status.h"
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>
#include <boost/serialization/string.hpp> 
#include <boost/serialization/vector.hpp>
#include <sstream>
#include <fstream>

using namespace DDS;

namespace opensplice_dds_comm{

    void GSDFPacketListener::on_data_available(DDS::DataReader_ptr reader)
      THROW_ORB_EXCEPTIONS
    {
        DDS::ReturnCode_t status;
        GSDFPacketSeq packetSeq;
        SampleInfoSeq infoSeq;
        
        GSDFPacketDataReader_var GSDFPacketDR_ = GSDFPacketDataReader::_narrow(reader);

        status = GSDFPacketDR_->take(packetSeq, infoSeq, LENGTH_UNLIMITED,
        ANY_SAMPLE_STATE, ANY_VIEW_STATE, ANY_INSTANCE_STATE);
        checkStatus(status, "GSDFPacketDataReader::read");

        for (CORBA::ULong i = 0; i < packetSeq.length(); i++)
        {
            try{
                callBack_(packetSeq[i]);
            }catch(const std::bad_alloc&){
                return;
            }
        }
        status = GSDFPacketDR_->return_loan(packetSeq, infoSeq);
        checkStatus(status, "GSDFPacketDataReader::return_loan");
    };

    void GSDFPacketListener::on_requested_deadline_missed(DDS::DataReader_ptr
      reader, const DDS::RequestedDeadlineMissedStatus &status)THROW_ORB_EXCEPTIONS
    {
        printf("\n=== [GSDFPacketListener::on_requested_deadline_missed] : triggered\n");
        printf("\n=== [GSDFPacketListener::on_requested_deadline_missed] : stopping\n");
    };

    void GSDFPacketListener::on_requested_incompatible_qos(DDS::DataReader_ptr
      reader, const DDS::RequestedIncompatibleQosStatus &status)
      THROW_ORB_EXCEPTIONS
    {
        printf("\n=== [GSDFPacketListener::on_requested_incompatible_qos] : triggered\n");
    };

    void GSDFPacketListener::on_sample_rejected(DDS::DataReader_ptr reader, const
      DDS::SampleRejectedStatus &status)THROW_ORB_EXCEPTIONS
    {
        printf("\n=== [GSDFPacketListener::on_sample_rejected] : triggered\n");
    };

    void GSDFPacketListener::on_liveliness_changed(DDS::DataReader_ptr reader,
      const DDS::LivelinessChangedStatus &status)THROW_ORB_EXCEPTIONS
    {
        printf("\n=== [GSDFPacketListener::on_liveliness_changed] : triggered\n");
    };

    void GSDFPacketListener::on_subscription_matched(DDS::DataReader_ptr reader,
      const DDS::SubscriptionMatchedStatus &status)THROW_ORB_EXCEPTIONS
    {
        printf("\n=== [GSDFPacketListener::on_subscription_matched] : triggered\n");
    };

    void GSDFPacketListener::on_sample_lost(DDS::DataReader_ptr reader, const DDS
      ::SampleLostStatus &status)THROW_ORB_EXCEPTIONS
    {
        printf("\n=== [GSDFPacketListener::on_sample_lost] : triggered\n");
    };
};