Wed Mar 8 11:19:37 UTC 2006 Don Sharp <Donald.Sharp@prismtech.com>

5 files changed, 405 insertions, 0 deletions

diff --git a/TAO/orbsvcs/tests/Bug_2377_Regression/Bug_2377_Regression.mpc b/TAO/orbsvcs/tests/Bug_2377_Regression/Bug_2377_Regression.mpc
new file mode 100644
index 00000000000..6616beb3c5d
--- /dev/null
+++ b/TAO/orbsvcs/tests/Bug_2377_Regression/Bug_2377_Regression.mpc
@@ -0,0 +1,9 @@
+// -*- MPC -*-
+// $Id$
+
+project(*Test) : orbsvcsexe, taoidldefaults, portablegroup, portableserver {
+  exename = uipmc_test
+  Source_Files {
+    Hello.cpp
+  }
+}
diff --git a/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp b/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp
new file mode 100644
index 00000000000..8c9fc67c0ed
--- /dev/null
+++ b/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.cpp
@@ -0,0 +1,350 @@
+//
+// $Id$
+//
+
+#include "HelloS.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 "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)
+{
+#ifdef ACE_WIN32
+    ::Sleep(millisec);
+#else
+    struct timespec tv;
+    tv.tv_sec = millisec / 1000;
+    tv.tv_nsec = (millisec % 1000) * 1000000;
+    struct timespec tv_not_elapsed;
+    int status_nanosleep;
+    while ((status_nanosleep = nanosleep(&tv, &tv_not_elapsed)) < 0
+           && (errno == EINTR))
+    {
+        tv = tv_not_elapsed;
+    }
+#endif /* ACE_WIN32 */
+};
+
+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")));
+        }
+        std::string 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);
+
+        // 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
+    {
+        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;
+}
diff --git a/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.idl b/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.idl
new file mode 100644
index 00000000000..f6b6d7eb0b7
--- /dev/null
+++ b/TAO/orbsvcs/tests/Bug_2377_Regression/Hello.idl
@@ -0,0 +1,9 @@
+// $Id$
+module Test {
+
+    interface Hello {
+        oneway void say_hello(in short count);
+    };
+
+
+};
diff --git a/TAO/orbsvcs/tests/Bug_2377_Regression/run_test.pl b/TAO/orbsvcs/tests/Bug_2377_Regression/run_test.pl
new file mode 100755
index 00000000000..322eeff3e7e
--- /dev/null
+++ b/TAO/orbsvcs/tests/Bug_2377_Regression/run_test.pl
@@ -0,0 +1,32 @@
+eval '(exit $?0)' && eval 'exec perl -S $0 ${1+"$@"}'
+    & eval 'exec perl -S $0 $argv:q'
+    if 0;
+
+# $Id$
+# -*- perl -*-
+
+use lib '../../../../bin';
+use PerlACE::Run_Test;
+
+$dum_core = PerlACE::LocalFile ("core");
+$status = 0;
+unlink $dum_core;
+
+$HELLO = new PerlACE::Process ("uipmc_test", "");
+
+$prog = $HELLO->SpawnWaitKill (20);
+
+if ($prog != 0) {
+    print STDERR "ERROR: uipmc_test returned $prog\n";
+    $status = 1;
+}
+
+if (-e $dum_core) {
+    print STDERR "ERROR: uipmc_test core dumped\n";
+    $status = 1;
+}
+
+unlink $dum_core;
+
+exit $status;
+
diff --git a/TAO/orbsvcs/tests/Bug_2377_Regression/svc.conf b/TAO/orbsvcs/tests/Bug_2377_Regression/svc.conf
new file mode 100644
index 00000000000..1510ade0e8f
--- /dev/null
+++ b/TAO/orbsvcs/tests/Bug_2377_Regression/svc.conf
@@ -0,0 +1,5 @@
+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"