summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/examples/IDL2CPPWrapper/Shapes/Sender/I2C_Shapes_Sender.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/connectors/dds4ccm/examples/IDL2CPPWrapper/Shapes/Sender/I2C_Shapes_Sender.cpp')
-rw-r--r--CIAO/connectors/dds4ccm/examples/IDL2CPPWrapper/Shapes/Sender/I2C_Shapes_Sender.cpp102
1 files changed, 0 insertions, 102 deletions
diff --git a/CIAO/connectors/dds4ccm/examples/IDL2CPPWrapper/Shapes/Sender/I2C_Shapes_Sender.cpp b/CIAO/connectors/dds4ccm/examples/IDL2CPPWrapper/Shapes/Sender/I2C_Shapes_Sender.cpp
deleted file mode 100644
index 9db989a3b61..00000000000
--- a/CIAO/connectors/dds4ccm/examples/IDL2CPPWrapper/Shapes/Sender/I2C_Shapes_Sender.cpp
+++ /dev/null
@@ -1,102 +0,0 @@
-#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;
-}
-