1 files changed, 147 insertions, 0 deletions
diff --git a/ACE/TAO/tests/Monitor/Marshal_Buffer/client.cpp b/ACE/TAO/tests/Monitor/Marshal_Buffer/client.cpp
new file mode 100644
index 00000000000..610ac702929
--- /dev/null
+++ b/ACE/TAO/tests/Monitor/Marshal_Buffer/client.cpp
@@ -0,0 +1,147 @@
+// $Id$
+
+#include "ace/OS_NS_unistd.h"
+#include "ace/OS_NS_stdio.h"
+#include "ace/Task.h"
+#include "ace/streams.h"
+#include "ace/CORBA_macros.h"
+
+#include "ace/Monitor_Control/Monitor_Control.h"
+
+#include "tao/Monitor/Monitor.h"
+
+#include "testC.h"
+
+#if defined (TAO_HAS_MONITOR_FRAMEWORK) && (TAO_HAS_MONITOR_FRAMEWORK == 1)
+
+using namespace ACE_VERSIONED_NAMESPACE_NAME::ACE::Monitor_Control;
+
+const ACE_TCHAR *ior_input_file = ACE_TEXT("file://test.ior");
+const ACE_TCHAR *monitor_output_file = ACE_TEXT("monitor.ior");
+
+/// Runs the ORB in a separate thread so we can listen
+/// for calls on our MC interface without blocking.
+class ORB_Runner : public ACE_Task_Base
+{
+private:
+  CORBA::ORB_ptr orb_;
+
+public:
+  ORB_Runner (CORBA::ORB_ptr orb)
+    : orb_ (orb)
+  {}
+
+  int svc (void)
+  {
+    this->orb_->run ();
+    return 0;
+  }
+};
+
+#endif /* TAO_HAS_MONITOR_FRAMEWORK==1 */
+
+int
+ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+#if defined (TAO_HAS_MONITOR_FRAMEWORK) && (TAO_HAS_MONITOR_FRAMEWORK == 1)
+
+  try
+    {
+      CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
+
+      Monitor_Base *bytes_sent_monitor =
+        create_os_monitor<BYTES_SENT_MONITOR> (0, ACE_Time_Value (1));
+      Monitor_Base *cpu_load_monitor =
+        create_os_monitor<CPU_LOAD_MONITOR> (0, ACE_Time_Value (1));
+      Monitor_Base *memory_usage_monitor =
+        create_os_monitor<MEMORY_USAGE_MONITOR> (0, ACE_Time_Value (1));
+      Monitor_Base *num_threads_monitor =
+        create_os_monitor<NUM_THREADS_MONITOR> (0, ACE_Time_Value (1));
+
+      START_PERIODIC_MONITORS;
+
+      /// Here we take on aspects of a server role, exposing the
+      /// Monitor interface of our ORB so the monitoring client
+      /// can access it remotely. No need to activate the POA
+      /// manager etc here - it is done in the Object_Loader code
+      /// in the Monitor lib.
+      CORBA::Object_var obj =
+        orb->resolve_initial_references ("Monitor");
+      Monitor::MC_var monitor = Monitor::MC::_narrow (obj.in ());
+
+      CORBA::String_var ior = orb->object_to_string (monitor.in ());
+
+      FILE *output_file = ACE_OS::fopen (monitor_output_file, "w");
+
+      if (output_file == 0)
+        {
+          ACE_ERROR_RETURN ((LM_ERROR,
+                             "Can't open output file for writing IOR: %s",
+                             monitor_output_file),
+                            1);
+        }
+
+      ACE_OS::fprintf (output_file,
+                       "%s",
+                       ior.in ());
+      ACE_OS::fclose (output_file);
+
+      /// Call orb->run() in a separate thread so the MC interface can
+      /// get remote calls.
+      ORB_Runner orb_runner (orb.in ());
+      orb_runner.activate ();
+
+      obj = orb->string_to_object (ior_input_file);
+
+      if (CORBA::is_nil (obj.in ()))
+        {
+          ACE_ERROR_RETURN ((LM_ERROR,
+                             "string_to_object failed.\n"),
+                            1);
+        }
+
+      test_var target = test::_narrow (obj.in ());
+
+      /// Let the monitor client query a time or two.
+      ACE_OS::sleep (2);
+
+      /// Create 1k, 2k and 3k strings to marshal, to force resizing of
+      /// the CDR stream buffer.
+      for (int i = 1; i < 4; ++i)
+        {
+          char *tmp = new char[1024 * i + 1];
+          ACE_OS::memset (tmp, 'a', 1024 * i);
+          tmp[1024 * i] = '\0';
+          CORBA::String_var result = target->test_op (tmp);
+          cout << "reply to client = " << ACE_OS::strlen (result.in ())
+               << " bytes" << endl;
+          delete [] tmp;
+
+          ACE_OS::sleep (2);
+        }
+
+      /// Make sure the monitor client is done before we destroy the ORB
+      /// and make the MC objref invalid.
+      ACE_OS::sleep (15);
+
+      STOP_PERIODIC_MONITORS;
+
+      bytes_sent_monitor->remove_ref ();
+      cpu_load_monitor->remove_ref ();
+      memory_usage_monitor->remove_ref ();
+      num_threads_monitor->remove_ref ();
+
+      orb->destroy ();
+    }
+  catch (const CORBA::Exception &ex)
+    {
+      ex._tao_print_exception ("Client: exception caught:");
+      return 1;
+    }
+#else /* ACE_HAS_MONITOR_FRAMEWORK==1 */
+  ACE_UNUSED_ARG (argc);
+  ACE_UNUSED_ARG (argv);
+#endif /* TAO_HAS_MONITOR_FRAMEWORK==1 */
+
+  return 0;
+}