summaryrefslogtreecommitdiff
path: root/TAO/tests/LongUpcalls/AMI_Manager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/LongUpcalls/AMI_Manager.cpp')
-rw-r--r--TAO/tests/LongUpcalls/AMI_Manager.cpp209
1 files changed, 209 insertions, 0 deletions
diff --git a/TAO/tests/LongUpcalls/AMI_Manager.cpp b/TAO/tests/LongUpcalls/AMI_Manager.cpp
new file mode 100644
index 00000000000..01b2d58bb9e
--- /dev/null
+++ b/TAO/tests/LongUpcalls/AMI_Manager.cpp
@@ -0,0 +1,209 @@
+//
+// $Id$
+//
+
+#include "AMI_Manager.h"
+#include "ace/OS_NS_unistd.h"
+
+ACE_RCSID (LongUpcalls,
+ AMI_Manager,
+ "$Id$")
+
+static void
+validate_connection (Test::Controller_ptr controller
+ ACE_ENV_ARG_DECL)
+ ACE_THROW_SPEC (())
+{
+ ACE_TRY
+ {
+#if (TAO_HAS_CORBA_MESSAGING == 1)
+ CORBA::PolicyList_var unused;
+ controller->_validate_connection (unused
+ ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+#else
+ controller->_is_a ("Not_an_IDL_Type"
+ ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+#endif
+ }
+ ACE_CATCHANY
+ {
+ }
+ ACE_ENDTRY;
+}
+
+AMI_Manager::AMI_Manager (CORBA::ORB_ptr orb)
+ : orb_ (CORBA::ORB::_duplicate (orb))
+{
+}
+
+void
+AMI_Manager::start_workers (CORBA::Short worker_count,
+ CORBA::Long milliseconds,
+ Test::Controller_ptr controller
+ ACE_ENV_ARG_DECL)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ ACE_Thread_Manager thread_manager;
+
+ validate_connection(controller
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ // ACE_DEBUG ((LM_DEBUG, "Starting %d workers\n", worker_count));
+ Worker worker (&thread_manager,
+ controller, milliseconds,
+ this->orb_.in ());
+
+ worker.activate (THR_NEW_LWP | THR_JOINABLE, worker_count);
+
+ thread_manager.wait ();
+}
+
+void
+AMI_Manager::shutdown (ACE_ENV_SINGLE_ARG_DECL)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ this->orb_->shutdown (0 ACE_ENV_ARG_PARAMETER);
+}
+
+// ****************************************************************
+
+Worker::Worker (ACE_Thread_Manager *thr_mgr,
+ Test::Controller_ptr controller,
+ CORBA::Long milliseconds,
+ CORBA::ORB_ptr orb)
+ : ACE_Task_Base (thr_mgr)
+ , controller_ (Test::Controller::_duplicate (controller))
+ , milliseconds_ (milliseconds)
+ , orb_ (CORBA::ORB::_duplicate (orb))
+{
+}
+
+int
+Worker::svc (void)
+{
+ // ACE_DEBUG ((LM_DEBUG, "Worker starts\n"));
+ ACE_DECLARE_NEW_CORBA_ENV;
+ ACE_TRY
+ {
+ TAO_SYNCH_MUTEX mutex;
+ int pending_requests = 2;
+ Test::AMI_ControllerHandler_var handler;
+
+ {
+ Controller_Handler *handler_impl;
+ ACE_NEW_RETURN (handler_impl,
+ Controller_Handler (&mutex,
+ &pending_requests),
+ -1);
+
+ PortableServer::ServantBase_var auto_destroy (handler_impl);
+ handler = handler_impl->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+ }
+
+ validate_connection(this->controller_.in()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ this->controller_->sendc_worker_started (handler.in ()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ // ACE_DEBUG ((LM_DEBUG, "Worker start reported\n"));
+
+ ACE_Time_Value tv (0, 1000 * this->milliseconds_);
+ ACE_OS::sleep (tv);
+
+ this->controller_->sendc_worker_finished (handler.in ()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ // ACE_DEBUG ((LM_DEBUG, "Worker completion reported\n"));
+
+ for (;;)
+ {
+ ACE_Time_Value tv (0, 1000 * this->milliseconds_);
+ this->orb_->run (tv ACE_ENV_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+
+ ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, mutex, -1);
+ if (pending_requests == 0)
+ break;
+ }
+ }
+ ACE_CATCHANY
+ {
+ ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+ "Exception in svc() method\n");
+ }
+ ACE_ENDTRY;
+ return 0;
+}
+
+// ****************************************************************
+
+Controller_Handler::Controller_Handler (TAO_SYNCH_MUTEX *mutex,
+ int *pending_replies)
+ : mutex_ (mutex)
+ , pending_replies_ (pending_replies)
+{
+}
+
+void
+Controller_Handler::worker_started (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, *this->mutex_);
+ (*this->pending_replies_)--;
+}
+
+void
+Controller_Handler::worker_started_excep
+ (::Messaging::ExceptionHolder* h
+ ACE_ENV_ARG_DECL)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ ACE_TRY
+ {
+ h->raise_exception (ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+ }
+ ACE_CATCHANY
+ {
+ ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+ "Controller_Handler exception raised in"
+ " worker_started");
+ }
+ ACE_ENDTRY;
+}
+
+void
+Controller_Handler::worker_finished (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, *this->mutex_);
+ (*this->pending_replies_)--;
+}
+
+void
+Controller_Handler::worker_finished_excep
+ (::Messaging::ExceptionHolder *h
+ ACE_ENV_ARG_DECL)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ ACE_TRY
+ {
+ h->raise_exception (ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+ }
+ ACE_CATCHANY
+ {
+ ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+ "Controller_Handler exception raised in"
+ " worker_finished");
+ }
+ ACE_ENDTRY;
+}