INTEGRATION: CWS configrefactor01 (1.1.2); FILE ADDED

2007/10/12 17:19:52 mmeeks 1.1.2.3: Issue number: i#82311#
Submitted by: mmeeks
final review ...
2007/10/12 16:56:50 mmeeks 1.1.2.2: Issue number: i#82311#
Submitted by: mmeeks
Split out bootstrapping piece, add cross-platform /tmp/ directory creation,
Fix cross-thread locking issues during notification, remove some printfs.
2007/10/11 16:14:07 mmeeks 1.1.2.1: Issue number: i#82311#
Submitted by: mmeeks
Add threaded unit tests, fix locking issues in apitreeimplobj.cxx
Add UnoApiLockClearable, and UnoApiLockReleaser (prolly needed for the next tests)

1 files changed, 270 insertions, 0 deletions

diff --git a/configmgr/qa/unit/threading.cxx b/configmgr/qa/unit/threading.cxx
new file mode 100644
index 000000000000..1ccafc5df341
--- /dev/null
+++ b/configmgr/qa/unit/threading.cxx
@@ -0,0 +1,270 @@
+/*************************************************************************
+ *
+ *  OpenOffice.org - a multi-platform office productivity suite
+ *
+ *  $RCSfile: threading.cxx,v $
+ *
+ *  $Revision: 1.2 $
+ *
+ *  last change: $Author: ihi $ $Date: 2007-11-23 13:58:51 $
+ *
+ *  The Contents of this file are made available subject to
+ *  the terms of GNU Lesser General Public License Version 2.1.
+ *
+ *
+ *    GNU Lesser General Public License Version 2.1
+ *    =============================================
+ *    Copyright 2007 by Sun Microsystems, Inc.
+ *    901 San Antonio Road, Palo Alto, CA 94303, USA
+ *
+ *    This library is free software; you can redistribute it and/or
+ *    modify it under the terms of the GNU Lesser General Public
+ *    License version 2.1, as published by the Free Software Foundation.
+ *
+ *    This library is distributed in the hope that it will be useful,
+ *    but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ *    Lesser General Public License for more details.
+ *
+ *    You should have received a copy of the GNU Lesser General Public
+ *    License along with this library; if not, write to the Free Software
+ *    Foundation, Inc., 59 Temple Place, Suite 330, Boston,
+ *    MA  02111-1307  USA
+ *
+ ************************************************************************/
+
+#include "common.hxx"
+#include <osl/thread.hxx>
+#include <osl/conditn.hxx>
+#include <cppuhelper/implbase1.hxx>
+#include "com/sun/star/beans/XPropertyChangeListener.hpp"
+
+class KeyTester : public osl::Thread
+{
+    osl::Condition *m_pCond;
+  protected:
+    rtl::OString    m_aPath;
+    rtl::OString    m_aKey;
+    Test           *m_pTest;
+  public:
+    KeyTester (osl::Condition *pCond, Test *pTest,
+               const char *pPath, const char *pKey)
+        : m_pCond (pCond)
+        , m_aPath (pPath)
+        , m_aKey (pKey)
+        , m_pTest (pTest)
+    {
+    }
+    virtual ~KeyTester ()
+    {
+    }
+    virtual void run ()
+    {
+        testIteration();
+        while (!m_pCond->check())
+            testIteration();
+    }
+    virtual void testIteration()
+    {
+        css::uno::Any a = m_pTest->getKey (m_aPath, m_aKey);
+        CPPUNIT_ASSERT_MESSAGE ("no value", a.hasValue());
+    }
+};
+
+class KeyReader : public KeyTester
+{
+public:
+    KeyReader (osl::Condition *pCond, Test *pTest,
+               const char *pPath, const char *pKey)
+        : KeyTester (pCond, pTest, pPath, pKey)
+    {
+        // to ensure we have the right vtable when we hit 'run'
+        create();
+    }
+};
+
+class KeyWriter : public KeyTester
+{
+    int curOpt;
+  public:
+    KeyWriter (osl::Condition *pCond, Test *pTest,
+               const char *pPath, const char *pKey)
+        : KeyTester (pCond, pTest, pPath, pKey)
+        , curOpt(0)
+    {
+        m_pTest->normalizePathKey (m_aPath, m_aKey);
+        create();
+    }
+    virtual void testIteration ()
+    {
+        try {
+            static const char *options[] = { "fish", "chips", "kippers", "bloaters" };
+//            fprintf (stderr, "set key %d\n",
+//                     (int) osl_getThreadIdentifier(NULL));
+            m_pTest->setKey (m_aPath, rtl::OUString::createFromAscii (m_aKey),
+                             css::uno::makeAny (rtl::OUString::createFromAscii(options[(curOpt++ & 3)])));
+        } CATCH_FAIL ("setting keys")
+    }
+};
+
+void Test::threadTests()
+{
+    osl::Condition stop;
+    stop.reset();
+
+    struct {
+        const char *pPath;
+        const char *pKey;
+    } keyList[] = {
+        { "/org.openoffice.Setup", "Test/AString" },
+        { "/org.openoffice.Setup", "Test/AString" },
+        { "/org.openoffice.UI.GenericCommands", "UserInterface/Commands/dotuno:WebHtml/Label" },
+        { "/org.openoffice.UI.GenericCommands", "UserInterface/Commands/dotuno:NewPresentation/Label" },
+        { "/org.openoffice.UI.GenericCommands", "UserInterface/Commands/dotuno:RecentFileList/Label" },
+
+        { "/org.openoffice.Setup", "L10N/ooLocale" },
+        { "/org.openoffice.Setup", "Test/ABoolean" }
+    };
+    const int numReaders = sizeof (keyList) / sizeof (keyList[0]);
+    const int numWriters = (sizeof (keyList) / sizeof (keyList[0])) - 2;
+    KeyReader *pReaders[numReaders];
+    KeyWriter *pWriters[numReaders];
+
+    int i;
+    try {
+        for (i = 0; i < numReaders; i++) {
+            css::uno::Any a = getKey (keyList[i].pPath, keyList[i].pKey);
+            CPPUNIT_ASSERT_MESSAGE ("check key", a.hasValue());
+        }
+
+        // a few readers
+        for (i = 0; i < numReaders; i++)
+            pReaders[i] = new KeyReader (&stop, this, keyList[i].pPath,
+                                         keyList[i].pKey);
+        // a few writers
+        for (i = 0; i < numWriters; i++)
+            pWriters[i] = new KeyWriter (&stop, this, keyList[i].pPath,
+                                         keyList[i].pKey);
+
+        // Threads are running ...
+        const int numIters = 5;
+        for (int j = 0; j < numIters; j++) {
+            for (i = 0; i < numReaders; i++)
+            {
+                try {
+                    rtl::OString aPath (keyList[i].pPath);
+                    rtl::OString aKey (keyList[i].pKey);
+                    normalizePathKey (aPath, aKey);
+                    resetKey (aPath, rtl::OUString::createFromAscii (aKey));
+                    osl::Thread::yield();
+                } CATCH_FAIL ("resetting keys");
+            }
+        }
+        stop.set();
+
+        for (i = 0; i < numReaders; i++) {
+            pReaders[i]->join();
+            delete pReaders[i];
+        }
+        for (i = 0; i < numWriters; i++) {
+            pWriters[i]->join();
+            delete pWriters[i];
+        }
+
+    } CATCH_FAIL ("checking keys exist")
+}
+
+typedef ::cppu::WeakImplHelper1< css::beans::XPropertyChangeListener > ListenerBase;
+
+class RecursiveListener : public ListenerBase
+{
+public:
+    sal_Int32 m_nRecurse;
+    css::uno::Reference< css::beans::XPropertySet > mxPropSet;
+  protected:
+    Test *m_pTest;
+    rtl::OString m_pPath;
+    rtl::OString m_pKey;
+  public:
+    RecursiveListener (Test *pTest, int nCount,
+                       const char *pPath, const char *pKey)
+        : ListenerBase()
+        , m_nRecurse (nCount)
+        , m_pTest (pTest)
+        , m_pPath (pPath)
+        , m_pKey (pKey)
+    {
+        mxPropSet = css::uno::Reference< css::beans::XPropertySet > (
+            pTest->createView (pPath, true), css::uno::UNO_QUERY_THROW );
+
+        CPPUNIT_ASSERT_MESSAGE ("is prop set", mxPropSet.is());
+        mxPropSet->addPropertyChangeListener (rtl::OUString::createFromAscii (m_pKey),
+                                              css::uno::Reference<css::beans::XPropertyChangeListener>(this));
+    }
+    virtual ~RecursiveListener()
+    {
+        disposeComponent (mxPropSet);
+    }
+
+    virtual void SAL_CALL acquire() throw() { ListenerBase::acquire(); }
+    virtual void SAL_CALL release() throw() { ListenerBase::acquire(); }
+    // XPropertyChangeListener
+    virtual void SAL_CALL propertyChange( const ::css::beans::PropertyChangeEvent& ) throw (::css::uno::RuntimeException)
+    {
+        if (m_nRecurse-- > 0)
+            runTest();
+    }
+    // XEventListener
+    virtual void SAL_CALL disposing( const ::css::lang::EventObject& ) throw (::css::uno::RuntimeException)
+    {
+    }
+    virtual void runTest()
+    {
+        m_pTest->setKey (m_pPath, rtl::OUString::createFromAscii (m_pKey),
+                         css::uno::makeAny(
+                             rtl::OUString::valueOf (m_nRecurse) ) );
+    }
+};
+
+class CrossThreadListener : public RecursiveListener
+{
+  public:
+    CrossThreadListener (Test *pTest, int nCount,
+                         const char *pPath, const char *pKey)
+        : RecursiveListener (pTest, nCount, pPath, pKey)
+    {
+    }
+    virtual ~CrossThreadListener()
+    {
+    }
+    virtual void runTest()
+    {
+        osl::Condition stopAfterOne;
+        stopAfterOne.set();
+        KeyWriter aWriter (&stopAfterOne, m_pTest, m_pPath, m_pKey);
+        aWriter.join();
+
+        rtl::OString aPath (m_pPath), aKey (m_pKey);
+        m_pTest->normalizePathKey (aPath, aKey);
+        m_pTest->resetKey (aPath, rtl::OUString::createFromAscii (aKey));
+    }
+};
+
+void Test::recursiveTests()
+{
+    RecursiveListener *pList = new RecursiveListener(this, 100,
+                                                     "/org.openoffice.UI.GenericCommands/UserInterface/Commands/dotuno:WebHtml",
+                                                     "Label");
+    css::uno::Reference< css::beans::XPropertyChangeListener > xListener(pList);
+    pList->runTest();
+}
+
+void Test::eventTests()
+{
+    CrossThreadListener *pList = new CrossThreadListener(this, 10,
+                                                         "/org.openoffice.UI.GenericCommands/UserInterface/Commands/dotuno:WebHtml",
+                                                         "Label");
+    css::uno::Reference< css::beans::XPropertyChangeListener > xListener(pList);
+    pList->runTest();
+}
+