//?-*-?C++?-*-
//
//?$Id:?DataReaderListener.cpp?2311?2009-07-30?02:19:02Z?dai_y?$

#include?“DataReaderListener.h“
#include?“ShapeDemoTypeSupportC.h“
#include?“ShapeDemoTypeSupportImpl.h“
#include?
#include?

using?namespace?ShapeDemo;

//?Implementation?skeleton?constructor
DataReaderListenerImpl::DataReaderListenerImpl（）
{
	m_pShape.xpos?=?m_pShape.ypos?=?0;
}

//?Implementation?skeleton?destructor
DataReaderListenerImpl::~DataReaderListenerImpl?（）
{
}

void?DataReaderListenerImpl::on_data_available（DDS::DataReader_ptr?reader）
??throw?（CORBA::SystemException）
{
??try?{
????ShapeDataReader_var?message_dr?=?ShapeDataReader::_narrow（reader）;
????if?（CORBA::is_nil?（message_dr.in?（）））?{
??????//cerr?<??????return?;
????}

????DDS::SampleInfo?si?;
????DDS::ReturnCode_t?status?=?message_dr->take_next_sample（m_pShape?si）?;

????if?（status?==?DDS::RETCODE_OK）?{
????}?else?if?（status?==?DDS::RETCODE_NO_DATA）?{
??????//cerr?<????}?else?{
??????//cerr?<????}
??}?catch?（CORBA::Exception&?e）?{
????//cerr?<????return?;
??}
}

void?DataReaderListenerImpl::on_requested_deadline_missed?（
????DDS::DataReader_ptr
????const?DDS::RequestedDeadlineMissedStatus?&）
??throw?（CORBA::SystemException）
{
??//cerr?<}

void?DataReaderListenerImpl::on_requested_incompatible_qos?（
????DDS::DataReader_ptr
????const?DDS::RequestedIncompatibleQosStatus?&）
??throw?（CORBA::SystemException）
{
??//cerr?<}

void?DataReaderListenerImpl::on_liveliness_changed?（
????DDS::DataReader_ptr
????const?DDS::LivelinessChangedStatus?&）
??throw?（CORBA::SystemException）
{
??//cerr?<}

void?DataReaderListenerImpl::on_subscription_matched?（
????DDS::DataReader_ptr
????const?DDS::SubscriptionMatchedStatus?&）
??throw?（CORBA::SystemException）
{
??//cerr?<ription_matched“?<}

void?DataReaderListenerImpl::on_sample_rejected（
????DDS::DataReader_ptr
????const?DDS::SampleRejectedStatus&）
??throw?（CORBA::SystemException）
{
??//cerr?<}

void?DataReaderListenerImpl::on_sample_lost（
??DDS::DataReader_ptr
??const?DDS::SampleLostStatus&）
??throw?（CORBA::SystemException）
{
??//cerr?<}

void?DataReaderListenerImpl::on_subscription_disconnected?（
??DDS::DataReader_ptr
??const?::OpenDDS::DCPS::SubscriptionDisconnectedStatus?&）
??throw?（CORBA::SystemException）
{
??//cerr?<ription_disconnected“?<