1 files changed, 58 insertions, 0 deletions
diff --git a/trunk/TAO/examples/RTCORBA/Activity/Job_i.cpp b/trunk/TAO/examples/RTCORBA/Activity/Job_i.cpp
new file mode 100644
index 00000000000..637ea2cd7f6
--- /dev/null
+++ b/trunk/TAO/examples/RTCORBA/Activity/Job_i.cpp
@@ -0,0 +1,58 @@
+//$Id$
+#include "Job_i.h"
+
+#include "tao/debug.h"
+
+#include "Activity.h"
+
+Job_i::Job_i ()
+{
+}
+
+const ACE_CString&
+Job_i::name (void)
+{
+  return job_name_;
+}
+
+const ACE_CString&
+Job_i::poa (void)
+{
+  return POA_name_;
+}
+
+int
+Job_i::init (ACE_Arg_Shifter& arg_shifter)
+{
+  job_name_ = arg_shifter.get_current (); // Read the name of the Job
+  arg_shifter.consume_arg ();
+
+  POA_name_ = arg_shifter.get_current (); // Read the name of the POA
+  arg_shifter.consume_arg ();
+
+  return 0;
+}
+
+void
+Job_i::work (CORBA::ULong work ACE_ENV_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  static CORBA::ULong prime_number = 9619;
+
+  if (TAO_debug_level > 0)
+    ACE_DEBUG ((LM_DEBUG,
+                "test_i::method: %hd units of work\n",
+                work));
+
+  for (; work != 0; work--)
+    ACE::is_prime (prime_number,
+                   2,
+                   prime_number / 2);
+}
+
+void
+Job_i::shutdown (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  ACTIVITY::instance()->job_ended (this);
+}