diff options
Diffstat (limited to 'trunk/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp')
| -rw-r--r-- | trunk/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp | 340 |
1 files changed, 340 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp b/trunk/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp new file mode 100644 index 00000000000..03cb59b88e1 --- /dev/null +++ b/trunk/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp @@ -0,0 +1,340 @@ +// +// $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; +} |