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
118
119
120
121
122
123
124
125
126
|
#include "I2C_Shapes_Common.h"
#include "ace/Env_Value_T.h"
#include "connectors/dds4ccm/impl/ndds/DomainParticipant.h"
#include "connectors/dds4ccm/impl/logger/Log_Macros.h"
#define TOPIC_NAME "Square"
I2C_Shapes_Common::I2C_Shapes_Common (void)
: factory_ (0)
{
ACE_Env_Value<int> trace (ACE_TEXT("DDS4CCM_TRACE_ENABLE"), 0);
if (trace)
{
DDS4CCM_ENABLE_TRACE ();
}
else
{
DDS4CCM_DISABLE_TRACE ();
}
}
I2C_Shapes_Common::~I2C_Shapes_Common (void)
{
delete this->factory_;
}
int
I2C_Shapes_Common::get_domain_id (void)
{
int domain_id = 0;
ACE_Env_Value<int> id (ACE_TEXT("DDS4CCM_DEFAULT_DOMAIN_ID"), domain_id);
return id;
}
void
I2C_Shapes_Common::initialize (void)
{
this->participant_ = this->participant_factory_.create_participant_with_profile (
this->get_domain_id (),
QOS_PROFILE,
::DDS::DomainParticipantListener::_nil (),
0);
::CIAO::NDDS::DDS_DomainParticipant_i *part =
dynamic_cast< CIAO::NDDS::DDS_DomainParticipant_i * > (this->participant_.in ());
if (!part)
{
DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO
"I2C_Shapes_Common::initialize - Unable to cast the "
"DomainParticipant proxy to its internal representation.\n"));
throw ::CORBA::INTERNAL ();
}
ACE_NEW_THROW_EX (this->factory_,
dds_type_factory (),
::CORBA::NO_MEMORY ());
const char* typesupport_name = ShapeType_DDS_Traits::type_support::get_type_name ();
if (! ::CIAO::NDDS::DDS_TypeSupport_i::register_type (this->participant_,
typesupport_name,
this->factory_))
{
DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO
"I2C_Shapes_Common::initialize - Unable to register type factory\n"));
throw ::CORBA::INTERNAL ();
}
::DDS::ReturnCode_t retcode = ShapeType_DDS_Traits::type_support::register_type (
part->get_rti_entity (),
typesupport_name);
if (retcode != ::DDS::RETCODE_OK)
{
DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO
"I2C_Shapes_Common::initialize - Unable to register type\n"));
throw ::CORBA::INTERNAL ();
}
this->topic_ = this->participant_->create_topic_with_profile (TOPIC_NAME,
typesupport_name,
QOS_PROFILE,
::DDS::TopicListener::_nil (),
0);
if (::CORBA::is_nil (this->topic_.in ()))
{
ACE_ERROR ((LM_ERROR, "I2C_Shapes_Common::initialize - "
"Topic seems to be nil\n"));
throw ::CORBA::INTERNAL ();
}
}
::DDS::Topic_ptr
I2C_Shapes_Common::get_topic (void)
{
return ::DDS::Topic::_duplicate (this->topic_.in ());
}
::DDS::Publisher_ptr
I2C_Shapes_Common::create_publisher (void)
{
if (::CORBA::is_nil (participant_.in ()))
{
initialize();
}
::DDS::Publisher_var publisher = participant_->create_publisher_with_profile (
QOS_PROFILE,
::DDS::PublisherListener::_nil (),
0);
return publisher._retn ();
}
::DDS::Subscriber_ptr
I2C_Shapes_Common::create_subscriber (void)
{
if (::CORBA::is_nil (participant_.in ()))
{
initialize();
}
::DDS::Subscriber_var subscriber = participant_->create_subscriber_with_profile (
QOS_PROFILE,
::DDS::SubscriberListener::_nil (),
0);
return subscriber._retn ();
}
|
