diff options
Diffstat (limited to 'modules/CIAO/connectors/ami4ccm/tests/DelReplyH/Sender/DelReplyH_Sender_exec.cpp')
| -rw-r--r-- | modules/CIAO/connectors/ami4ccm/tests/DelReplyH/Sender/DelReplyH_Sender_exec.cpp | 206 |
1 files changed, 206 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/ami4ccm/tests/DelReplyH/Sender/DelReplyH_Sender_exec.cpp b/modules/CIAO/connectors/ami4ccm/tests/DelReplyH/Sender/DelReplyH_Sender_exec.cpp new file mode 100644 index 00000000000..4709cb60ff5 --- /dev/null +++ b/modules/CIAO/connectors/ami4ccm/tests/DelReplyH/Sender/DelReplyH_Sender_exec.cpp @@ -0,0 +1,206 @@ +// -*- C++ -*- +// $Id$ + +#include "DelReplyH_Sender_exec.h" +#include "ace/OS_NS_unistd.h" + +namespace CIAO_DelReplyH_Sender_Impl +{ + Atomic_UShort nr_callbacks = 0; + Atomic_UShort nr_exceptions = 0; + + //============================================================ + // Facet Executor Implementation Class: MyFoo_callback_exec_i + //============================================================ + MyFoo_callback_exec_i::MyFoo_callback_exec_i (void) + { + ACE_DEBUG ((LM_DEBUG,"CONSTRUCTOR replyhandle\n")); + ++nr_callbacks; + } + + MyFoo_callback_exec_i::~MyFoo_callback_exec_i (void) + { + ACE_DEBUG ((LM_DEBUG,"DESTRUCTOR replyhandle\n")); + --nr_callbacks; + } + + void + MyFoo_callback_exec_i::_add_ref (void) + { + ACE_DEBUG ((LM_DEBUG,"add_ref replyhandle\n")); + ::CORBA::Object::_add_ref (); + } + + void + MyFoo_callback_exec_i::_remove_ref (void) + { + ACE_DEBUG ((LM_DEBUG,"remove_ref replyhandle\n")); + ::CORBA::Object::_remove_ref (); + } + + //============================================================ + // Operations from ::CCM_AMI::MyFoo_callback + //============================================================ + + // FOO methods + void + MyFoo_callback_exec_i::foo ( + ::CORBA::Long /*ami_return_val*/, + const char * answer) + { + ACE_DEBUG ((LM_DEBUG, "OK: ASYNCH foo() returns answer: %C.\n", + answer)); + } + + void + MyFoo_callback_exec_i::foo_excep ( + ::CCM_AMI::ExceptionHolder * /*excep_holder*/) + { + ++nr_exceptions; + } + + //============================================================ + // Worker thread for asynchronous invocations for MyFoo + //============================================================ + asynch_foo_generator::asynch_foo_generator ( + ::DelReplyH::AMI4CCM_MyFoo_ptr my_foo_ami) + : my_foo_ami_ (::DelReplyH::AMI4CCM_MyFoo::_duplicate (my_foo_ami)) + { + } + + int asynch_foo_generator::svc () + { + ACE_OS::sleep (3); + if (CORBA::is_nil (my_foo_ami_)) + { + ACE_ERROR ((LM_ERROR, "ERROR Sender (ASYNCH) :\tfoo_ami is NIL !\n")); + return 1; + } + else + { + //Invoke Asynchronous calls + //test with replyhandler. + ::DelReplyH::CCM_AMI4CCM_MyFooReplyHandler_var cb = + new MyFoo_callback_exec_i (); + my_foo_ami_->sendc_foo(cb.in(), + "Do something asynchronous"); + + } + //Invoke Asynchronous calls to test exception handling + ::DelReplyH::CCM_AMI4CCM_MyFooReplyHandler_var cb2 = + new MyFoo_callback_exec_i (); + my_foo_ami_->sendc_foo (cb2.in (), ""); + + return 0; + } + + //============================================================ + // Worker thread for synchronous invocations for MyFoo + //============================================================ + synch_foo_generator::synch_foo_generator (::DelReplyH::MyFoo_ptr my_foo_ami) + : my_foo_ami_ (::DelReplyH::MyFoo::_duplicate (my_foo_ami)) + { + } + + int synch_foo_generator::svc () + { + ACE_OS::sleep (3); + //run some synch calls + try + { + char *answer = 0; + my_foo_ami_->foo("synchroon call", answer); + ACE_DEBUG ((LM_DEBUG, "OK: SYNCH foo returns <%C>.\n", + answer)); + } + catch (const DelReplyH::InternalError& ) + { + ACE_ERROR ((LM_ERROR, "ERROR: SYNCH foo(): " + "Unexpected return.\n")); + } + return 0; + } + + //============================================================ + // Component Executor Implementation Class: Sender_exec_i + //============================================================ + Sender_exec_i::Sender_exec_i (void) + : global_foo_callback_ (0) + { + } + + Sender_exec_i::~Sender_exec_i (void) + { + } + + void + Sender_exec_i::set_session_context ( + ::Components::SessionContext_ptr ctx) + { + this->context_ = ::DelReplyH::CCM_Sender_Context::_narrow (ctx); + if ( ::CORBA::is_nil (this->context_.in ())) + { + throw ::CORBA::INTERNAL (); + } + } + + void + Sender_exec_i::configuration_complete (void) + { + } + + void + Sender_exec_i::ccm_activate (void) + { + ::DelReplyH::AMI4CCM_MyFoo_var asynch_foo = + this->context_->get_connection_sendc_run_my_foo(); + asynch_foo_generator* asynch_foo_gen = + new asynch_foo_generator (asynch_foo); + asynch_foo_gen->activate (THR_NEW_LWP | THR_JOINABLE, 1); + + ::DelReplyH::MyFoo_var synch_foo = + this->context_->get_connection_run_my_foo (); + synch_foo_generator* synch_foo_gen = + new synch_foo_generator (synch_foo); + synch_foo_gen->activate (THR_NEW_LWP | THR_JOINABLE, 1); + } + + void + Sender_exec_i::ccm_passivate (void) + { + } + + void + Sender_exec_i::ccm_remove (void) + { + if (nr_callbacks.value() != 0) + { + ACE_ERROR ((LM_ERROR, "ERROR: Not all ReplyHandlers were " + "deleted, %d left.\n", nr_callbacks.value ())); + } + if (nr_exceptions.value() != 1) + { + ACE_ERROR ((LM_ERROR, "ERROR: Wrong number of exceptions received. " + "Expected : 1, Received = %u.\n",nr_exceptions.value())); + } + if ((nr_callbacks.value() == 0) && (nr_exceptions.value() == 1)) + { + ACE_DEBUG ((LM_DEBUG, + "OK: All constructed ReplyHandlers were deleted.\n")); + } + } + + extern "C" ::Components::EnterpriseComponent_ptr + create_DelReplyH_AMI_Sender_Impl (void) + { + ::Components::EnterpriseComponent_ptr retval = + ::Components::EnterpriseComponent::_nil (); + + ACE_NEW_RETURN ( + retval, + Sender_exec_i, + ::Components::EnterpriseComponent::_nil ()); + + return retval; + } +} |