diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp')
| -rw-r--r-- | TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp | 340 |
1 files changed, 0 insertions, 340 deletions
diff --git a/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp b/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp deleted file mode 100644 index 03cb59b88e1..00000000000 --- a/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp +++ /dev/null @@ -1,340 +0,0 @@ -// -// $Id$ -// - -#include "HelloS.h" - -#include "ace/SString.h" -#include "ace/Log_Msg.h" -#include "ace/Task.h" -#include "ace/Mutex.h" -#include "ace/streams.h" -#include "ace/OS_NS_time.h" -#include "ace/OS_NS_unistd.h" -#include "tao/debug.h" -#include "tao/corba.h" -#include "orbsvcs/PortableGroup/MIOP.h" -#include "orbsvcs/PortableGroup/GOA.h" - -#define CLIENT_SLEEP_TIME 100 /* in milliseconds */ -#define NB_HELLO_CLIENT_THREAD 8 -#define NB_HELLO_CALLS 100 - -void -sleep(int millisec) -{ - ACE_Time_Value tv(millisec / 1000, (millisec % 1000) * 1000); - - ACE_OS::sleep ((const ACE_Time_Value &) tv); -} - -class MessageLog -{ - private: - bool *sent; - bool *recv; - int extent; - - public: - MessageLog(int num) - { - extent = num + 1; - sent = new bool[extent]; - recv = new bool[extent]; - - int i; - - for (i = 0; i < extent; i++) - { - sent[i] = false; - recv[i] = false; - } - } - - void - register_message_send(int message_num) - { - sent[message_num] = true; - } - - void - register_message_recv(int message_num) - { - recv[message_num] = true; - } - - bool - lost_messages() - { - bool lm = false; - int i; - - for (i = 0; i < extent; i++) - { - if (sent[i] && !recv[i]) - { - // message lost - lm = true; - break; - } - } - return lm; - } - - void - report_lost_messages(const ACE_TCHAR *int_format_string) - { - int i; - - for (i = 0; i < extent; i++) - { - if (sent[i] && !recv[i]) - { - ACE_DEBUG ((LM_DEBUG, - int_format_string, - i)); - } - } - } -}; - -namespace Test -{ - class Hello_impl - : public virtual POA_Test::Hello - { - private: - MessageLog *logger; - public: - Hello_impl(MessageLog *log) - : logger(log) - { - } - - void say_hello(CORBA::Short count) throw(CORBA::SystemException) - { - logger->register_message_recv(count); - if (TAO_debug_level == 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("R"))); - } - } - }; -} - -class OrbRunThread -: public ACE_Task_Base -{ - public: - OrbRunThread(CORBA::ORB_ptr orb) - : m_orb(CORBA::ORB::_duplicate(orb)) - { - } - virtual int svc() - { - m_orb->run(); - return 1; - } - private: - CORBA::ORB_var m_orb; -}; - -class HelloClientThread -: public ACE_Task_Base -{ - public: - HelloClientThread(Test::Hello_ptr hello, MessageLog *log) - : m_hello(Test::Hello::_duplicate(hello)), - logger(log), - m_count(0) - { - } - virtual int svc() - { - while (m_count < NB_HELLO_CALLS) - { - ACE_TRY_NEW_ENV - { - int count; - { - // get your message number here - ACE_Guard < ACE_Mutex > guard(m_mutex); - count = m_count++; - if (TAO_debug_level == 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("s"))); - } - } - { - // send your message number here -#ifdef SEQUENCED_SAY_HELLO_REQUIRED - ACE_Guard < ACE_Mutex > guard(m_mutex); -#endif /* SEQUENCED_SAY_HELLO_REQUIRED */ - logger->register_message_send(count); - m_hello->say_hello(count); - } - sleep(CLIENT_SLEEP_TIME); - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, - ACE_TEXT ("Exception thrown during say_hello()\n")); - } - ACE_ENDTRY; - } - return 1; - } - private: - Test::Hello_var m_hello; - MessageLog *logger; - int m_count; - ACE_Mutex m_mutex; -}; - -int -main(int argc, char *argv[]) -{ - MessageLog *logger = 0; - CORBA::ORB_var orb = CORBA::ORB::_nil(); - int exit_code = 0; - - OrbRunThread *orbThread = 0; - Test::Hello_impl * hello_i = 0; - - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("<<< %s Started - \"s\" = message sent \"R\" = message received >>>\n"), argv[0])); - - ACE_TRY_NEW_ENV - { - /*** in svc.conf -dynamic UIPMC_Factory Service_Object * TAO_PortableGroup:_make_TAO_UIPMC_Protocol_Factory() "" -static Resource_Factory "-ORBProtocolFactory IIOP_Factory -ORBProtocolFactory UIPMC_Factory" -dynamic PortableGroup_Loader Service_Object * TAO_PortableGroup:_make_TAO_PortableGroup_Loader() "" -static Server_Strategy_Factory "-ORBConcurrency reactive -ORBPOALock thread -ORBAllowReactivationOfSystemids 1" -static Client_Strategy_Factory "-ORBProfileLock thread -ORBClientConnectionHandler MT" - ***/ - - // Initialize the ORB - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT (" - ORB_init\n"))); - } - orb = CORBA::ORB_init(argc, argv); - - // Get the root POA - CORBA::Object_var obj_root = - orb->resolve_initial_references("RootPOA"); - PortableGroup::GOA_var rootPOA = - PortableGroup::GOA::_narrow(obj_root.in()); - - // Activate the POA manager - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT (" - POA manager activation\n"))); - } - PortableServer::POAManager_var poaManager = rootPOA->the_POAManager(); - - poaManager->activate(); - - // create Message Log - logger = new MessageLog(NB_HELLO_CALLS); - - // create Hello servant - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT (" - create Hello servant\n"))); - } - hello_i = new Test::Hello_impl(logger); - - // activate Hello Object - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT (" - activate Hello object\n"))); - } - PortableServer::ObjectId_var obj_id = - rootPOA->activate_object(hello_i); - - // create MIOP reference - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT (" - create MIOP reference\n"))); - } - ACE_CString multicast_addr("corbaloc:miop:1.0@1.0-cdmwftdomain-1/225.1.1.8:5555"); - CORBA::Object_var miop_ref = - orb->string_to_object(multicast_addr.c_str()); - - // associate MIOP reference with Hello object - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT (" - associate MIOP reference with Hello object\n"))); - } - rootPOA->associate_reference_with_id(miop_ref.in(), obj_id.in ()); - - // create Hello reference - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT (" - create Hello reference\n"))); - } - Test::Hello_var hello = Test::Hello::_unchecked_narrow(miop_ref.in()); - - // start ORB run() in a thread - orbThread = new OrbRunThread(orb.in()); - orbThread->activate(THR_NEW_LWP, 1); - - // create client threads - HelloClientThread *helloThread = new HelloClientThread(hello.in(), - logger); - - // start client threads - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("--------------------------------------------------\n"))); - helloThread->activate(THR_NEW_LWP, NB_HELLO_CLIENT_THREAD); - helloThread->wait(); - delete helloThread; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, - ACE_TEXT ("Exception thrown during main()\n")); - exit_code = 1; - } - ACE_ENDTRY; - - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("\n--------------------------------------------------\n"))); - if (logger->lost_messages()) - { - logger->report_lost_messages(ACE_TEXT ("LOST ==> say_hello() %d\n")); - exit_code = 1; - } - else if (exit_code == 0) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("<<< %s - no lost messages >>>\n"), argv[0])); - } - - delete logger; - - if (orbThread != 0) - { - orb->shutdown(true); - orbThread->wait(); - delete orbThread; - delete hello_i; - } - if (!CORBA::is_nil(orb.in())) - { - ACE_TRY_NEW_ENV - { - orb->destroy(); - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, - ACE_TEXT ("Exception thrown during orb check\n")); - exit_code = 1; - } - ACE_ENDTRY; - } - exit(exit_code); - return 0; -} |