1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
// $Id$
#include "dds4ccm/impl/ndds/Utils.h"
#include "ciao/Logger/Log_Macros.h"
// Implementation skeleton constructor
template <typename NDDS_TYPE, typename RAWLISTENER, typename PORTSTATUSLISTENER>
CIAO::DDS4CCM::RTI::DataReaderListener_T<NDDS_TYPE, RAWLISTENER, PORTSTATUSLISTENER>::DataReaderListener_T (
typename RAWLISTENER::_ptr_type listen, typename PORTSTATUSLISTENER::_ptr_type psl, ACE_Atomic_Op <TAO_SYNCH_MUTEX, bool> &enabled)
: listener_ (RAWLISTENER::_duplicate (listen)),
portlistener_ (PORTSTATUSLISTENER::_duplicate (psl)),
enable_ (enabled)
{
CIAO_TRACE ("CIAO::DDS4CCM::RTI::DataReaderListener_T::DataReaderListener_T");
}
// Implementation skeleton destructor
template <typename NDDS_TYPE, typename RAWLISTENER, typename PORTSTATUSLISTENER>
CIAO::DDS4CCM::RTI::DataReaderListener_T<NDDS_TYPE, RAWLISTENER, PORTSTATUSLISTENER>::~DataReaderListener_T (void)
{
CIAO_TRACE ("CIAO::DDS4CCM::RTI::DataReaderListener_T::~DataReaderListener_T");
}
template <typename NDDS_TYPE, typename RAWLISTENER, typename PORTSTATUSLISTENER>
void
CIAO::DDS4CCM::RTI::DataReaderListener_T<NDDS_TYPE, RAWLISTENER, PORTSTATUSLISTENER>::on_data_available( ::DDS::DataReader *rdr)
{
printf ("*** on data available\n");
if (!this->enable_.value ())
return;
::CIAO::DDS4CCM::RTI::RTI_DataReader_i* rd = dynamic_cast < ::CIAO::DDS4CCM::RTI::RTI_DataReader_i*>(rdr);
typename NDDS_TYPE::data_reader * reader = dynamic_cast< typename NDDS_TYPE::data_reader * > ((rd->get_datareader ()));
if (!reader) {
/* In this specific case, this will never fail */
ACE_ERROR ((LM_ERROR, ACE_TEXT ("Stock_InfoDataReader::narrow failed.\n")));
return;
}
/* Loop until there are messages available in the queue */
for(;;) {
typename NDDS_TYPE::value_type instance;
::DDS_SampleInfo sampleinfo;
::DDS::ReturnCode_t const result = reader->take_next_sample(instance,
sampleinfo);
if (result == DDS_RETCODE_NO_DATA) {
printf ("no more samples\n");
/* No more samples */
break;
} else if (result != DDS_RETCODE_OK) {
ACE_ERROR ((LM_ERROR, ACE_TEXT ("Unable to take data from data reader, error %d.\n"), result));
return;
}
if (sampleinfo.valid_data) {
printf ("got valid data\n");
::CCM_DDS::ReadInfo empty;
listener_->on_data (instance, empty);
}
}
}
template <typename NDDS_TYPE, typename RAWLISTENER, typename PORTSTATUSLISTENER>
void
CIAO::DDS4CCM::RTI::DataReaderListener_T<NDDS_TYPE, RAWLISTENER, PORTSTATUSLISTENER>::on_requested_deadline_missed (::DDS::DataReader_ptr the_reader,
const ::DDS::RequestedDeadlineMissedStatus & status)
{
this->portlistener_->on_requested_deadline_missed (the_reader, status);
}
template <typename NDDS_TYPE, typename RAWLISTENER, typename PORTSTATUSLISTENER>
void
CIAO::DDS4CCM::RTI::DataReaderListener_T<NDDS_TYPE, RAWLISTENER, PORTSTATUSLISTENER>::on_sample_lost (::DDS::DataReader_ptr the_reader,
const ::DDS::SampleLostStatus & status)
{
this->portlistener_->on_sample_lost (the_reader, status);
}
|
