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
|
// $Id$
#include "Common/I2C_Shapes_Common.h"
#include "connectors/dds4ccm/impl/ndds/DataWriter_T.h"
#include "ace/OS_NS_unistd.h"
#define MAX_X_Y 250
typedef ::I2C_Shapes::DataWriter TypedDataWriter;
void
write (TypedDataWriter::_ptr_type shapes_dw)
{
if (shapes_dw)
{
ShapeType square;
square.color = "GREEN";
square.x = ACE_OS::rand () % MAX_X_Y;
square.y = ACE_OS::rand () % MAX_X_Y;
square.shapesize = 25;
bool x_increasing = true;
bool y_increasing = true;
for (::CORBA::ULong i = 0; i < 1000; ++i)
{
if (x_increasing)
{
++square.x;
x_increasing = square.x + 1 <= MAX_X_Y;
}
else
{
--square.x;
x_increasing = square.x - 1 < 0;
}
if (y_increasing)
{
++square.y;
y_increasing = square.y + 1 <= MAX_X_Y;
}
else
{
--square.y;
y_increasing = square.y - 1 < 0;
}
::DDS::ReturnCode_t retcode = shapes_dw->write (square, ::DDS::HANDLE_NIL);
if (retcode == ::DDS::RETCODE_OK)
{
ACE_DEBUG ((LM_DEBUG, "Updated square - "
"x: <%u> - y: <%u>\n",
square.x, square.y));
}
ACE_Time_Value tv (0, 500000);
ACE_OS::sleep (tv);
}
ACE_DEBUG ((LM_DEBUG, "write - Ready. Written 1000 samples.\n"));
}
else
{
ACE_ERROR ((LM_ERROR, "write - ERROR: DataWriter seems to be nil\n"));
}
}
int ACE_TMAIN (int , ACE_TCHAR *[])
{
int main_result = 0;
I2C_Shapes_Common common;
try
{
::DDS::Publisher_var publisher = common.create_publisher ();
if (::CORBA::is_nil (publisher.in ()))
{
ACE_ERROR ((LM_ERROR, "ACE_TMAIN - Publisher seems to be nil\n"));
throw ::CORBA::INTERNAL ();
}
::DDS::Topic_var topic = common.get_topic ();
::DDS::DataWriter_var dw = publisher->create_datawriter_with_profile (
topic.in (),
QOS_PROFILE,
::DDS::DataWriterListener::_nil (),
0);
TypedDataWriter::_var_type shapes_dw = TypedDataWriter::_narrow (dw.in ());
if (shapes_dw->enable () != DDS_RETCODE_OK)
{
ACE_ERROR ((LM_ERROR, "ACE_TMAIN - Unable to enable the datawriter.\n"));
throw ::CORBA::INTERNAL ();
}
write (shapes_dw);
}
catch (::CORBA::Exception &e)
{
e._tao_print_exception ("ACE_TMAIN SENDER");
}
catch (...)
{
ACE_ERROR ((LM_ERROR, "ACE_TMAIN SENDER - "
"Error: unexpected exception caught\n"));
}
return main_result;
}
|
