summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/tests/HomeTest/HomeComp/controller.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/HomeTest/HomeComp/controller.cpp')
-rw-r--r--CIAO/connectors/dds4ccm/tests/HomeTest/HomeComp/controller.cpp105
1 files changed, 105 insertions, 0 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/HomeTest/HomeComp/controller.cpp b/CIAO/connectors/dds4ccm/tests/HomeTest/HomeComp/controller.cpp
new file mode 100644
index 00000000000..a20e49201e4
--- /dev/null
+++ b/CIAO/connectors/dds4ccm/tests/HomeTest/HomeComp/controller.cpp
@@ -0,0 +1,105 @@
+// $Id$
+
+//==============================================================
+/**
+ * @file controller.cpp
+ *
+ * This is a controller tat interact with the Home-component implementation.
+ * This test uses the explicit factory
+ * operation in the home interface to create a connector component
+ * instance, run it for a while, and destroy the component instance.
+ */
+//==============================================================
+
+#include "HomeT_HomeCC.h"
+#include "ace/streams.h"
+#include "ace/OS_NS_unistd.h"
+#include "ace/Get_Opt.h"
+
+const ACE_TCHAR *home_comp_ior_ = 0;
+
+int
+parse_args (int argc, ACE_TCHAR *argv[])
+{
+ ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:of"));
+ int c;
+
+ while ((c = get_opts ()) != -1)
+ {
+ switch (c)
+ {
+ case 'o':
+ break;
+ case 'f':
+ break;
+ case 'k':
+ home_comp_ior_ = get_opts.opt_arg ();
+ break;
+ case '?': // display help for use of the server.
+ default:
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "usage: %s\n"
+ "-k <HomeComponent IOR> (default is file://HomeC.ior)\n"
+ "\n",
+ argv [0]),
+ -1);
+ break;
+ }
+ }
+
+ if (home_comp_ior_ == 0)
+ {
+ home_comp_ior_ = ACE_TEXT("file://HomeC.ior");
+ }
+
+ return 0;
+}
+
+
+int
+ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+ try
+ {
+ // Initialize orb
+ CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
+
+ if (parse_args (argc, argv) != 0)
+ {
+ return -1;
+ }
+
+ // Resolve Home interface
+ CORBA::Object_var obj
+ = orb->string_to_object (home_comp_ior_);
+
+ ConnHome_var home
+ = ConnHome::_narrow (obj.in ());
+ if (CORBA::is_nil (home.in ()))
+ ACE_ERROR_RETURN ((LM_ERROR, "Unable to acquire ConnHome objref\n"), -1);
+
+ // starting Connector component
+ printf("starting Connector component home->new_ConnComp ()\n");
+
+ home->new_ConnComp ();
+
+ printf("started Connector component home->new_ConnComp ()\n");
+
+ // Place to plug in the rate
+
+ ACE_OS::sleep (5);
+
+ // home->remove_component ();
+
+ orb->destroy ();
+ }
+ catch (const CORBA::Exception& ex)
+ {
+ ex._tao_print_exception ("Who is the culprit\n");
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "Uncaught CORBA exception\n"),
+ 1);
+ }
+
+ return 0;
+}