blob: aa8ed0c686f21e33444bb0354fa60b49c2573a4f (
plain)
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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
// $Id$
#include "Topic.h"
#include "StatusCondition.h"
#include "InstanceHandle_t.h"
#include "InconsistentTopicStatus.h"
#include "ciao/Logger/Log_Macros.h"
namespace CIAO
{
namespace DDS4CCM
{
namespace RTI
{
// Implementation skeleton constructor
RTI_Topic_i::RTI_Topic_i (DDSTopic * top)
: impl_ (top)
{
}
// Implementation skeleton destructor
RTI_Topic_i::~RTI_Topic_i (void)
{
}
::DDS::ReturnCode_t
RTI_Topic_i::set_qos (const ::DDS::TopicQos & /*qos*/)
{
throw CORBA::NO_IMPLEMENT ();
}
::DDS::ReturnCode_t
RTI_Topic_i::get_qos (::DDS::TopicQos & /*qos*/)
{
throw CORBA::NO_IMPLEMENT ();
}
::DDS::ReturnCode_t
RTI_Topic_i::set_listener (::DDS::TopicListener_ptr /*a_listener*/,
::DDS::StatusMask /*mask*/)
{
//RTI_TopicListener_i* rti_impl_list = new RTI_TopicListener_i (a_listener);
//return this->impl_->set_listener (rti_impl_list, mask);
throw CORBA::NO_IMPLEMENT ();
}
::DDS::TopicListener_ptr
RTI_Topic_i::get_listener (void)
{
throw CORBA::NO_IMPLEMENT ();
}
::DDS::ReturnCode_t
RTI_Topic_i::get_inconsistent_topic_status (::DDS::InconsistentTopicStatus & a_status)
{
DDS_InconsistentTopicStatus ddsstatus;
ddsstatus <<= a_status;
return this->impl_->get_inconsistent_topic_status (ddsstatus);
}
::DDS::ReturnCode_t
RTI_Topic_i::enable (void)
{
return this->impl_->enable ();
}
::DDS::StatusCondition_ptr
RTI_Topic_i::get_statuscondition (void)
{
DDSStatusCondition* sc = this->impl_->get_statuscondition ();
::DDS::StatusCondition_var retval = new RTI_StatusCondition_i (sc);
return retval._retn ();
}
::DDS::StatusMask
RTI_Topic_i::get_status_changes (void)
{
return this->impl_->get_status_changes ();
}
::DDS::InstanceHandle_t
RTI_Topic_i::get_instance_handle (void)
{
::DDS_InstanceHandle_t const rtihandle = this->impl_->get_instance_handle ();
::DDS::InstanceHandle_t handle;
handle <<= rtihandle;
return handle;
}
char *
RTI_Topic_i::get_type_name (void)
{
return CORBA::string_dup (this->impl_->get_type_name ());
}
char *
RTI_Topic_i::get_name (void)
{
return CORBA::string_dup (this->impl_->get_name ());
}
::DDS::DomainParticipant_ptr
RTI_Topic_i::get_participant (void)
{
DDSDomainParticipant* p = this->impl_->get_participant ();
::DDS::DomainParticipant_var retval = new RTI_DomainParticipant_i (p);
return retval._retn ();
}
DDSTopic *
RTI_Topic_i::get_topic (void)
{
return impl_;
}
}
}
}
|
