Adding upstream version 1:7.0.4.upstream/1%7.0.4upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 182 insertions, 0 deletions

diff --git a/sal/qa/rtl/doublelock/rtl_doublelocking.cxx b/sal/qa/rtl/doublelock/rtl_doublelocking.cxx
new file mode 100644
index 000000000..ef639423d
--- /dev/null
+++ b/sal/qa/rtl/doublelock/rtl_doublelocking.cxx
@@ -0,0 +1,182 @@
+/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+/*
+ * This file is part of the LibreOffice project.
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ *
+ * This file incorporates work covered by the following license notice:
+ *
+ *   Licensed to the Apache Software Foundation (ASF) under one or more
+ *   contributor license agreements. See the NOTICE file distributed
+ *   with this work for additional information regarding copyright
+ *   ownership. The ASF licenses this file to you under the Apache
+ *   License, Version 2.0 (the "License"); you may not use this file
+ *   except in compliance with the License. You may obtain a copy of
+ *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
+ */
+
+#include <sal/config.h>
+
+#include <iostream>
+
+#include <sal/types.h>
+
+#include <osl/thread.hxx>
+
+#include <rtl/instance.hxx>
+#include <rtl/ustring.hxx>
+
+#include <cppunit/TestFixture.h>
+#include <cppunit/extensions/HelperMacros.h>
+#include <cppunit/plugin/TestPlugIn.h>
+
+#ifdef _WIN32
+#if !defined WIN32_LEAN_AND_MEAN
+# define WIN32_LEAN_AND_MEAN
+#endif
+#include <windows.h>
+#else
+#include <unistd.h>
+#include <time.h>
+#endif
+
+#define CONST_TEST_STRING "gregorian"
+
+namespace {
+struct Gregorian : public rtl::StaticWithInit<OUString, Gregorian> {
+    OUString operator () () {
+        return CONST_TEST_STRING;
+    }
+};
+
+/** Simple thread for testing Thread-create.
+ * Just add 1 of value 0, and after running, result is 1.
+ */
+class OGetThread : public osl::Thread
+{
+    osl::Mutex m_mutex;
+    sal_Int32 m_nOK;
+    sal_Int32 m_nFails;
+
+    OUString m_sConstStr;
+public:
+    OGetThread()
+            :m_nOK(0),
+             m_nFails(0),
+             m_sConstStr(CONST_TEST_STRING)
+        {
+        }
+
+    sal_Int32 getOK() { osl::MutexGuard g(m_mutex); return m_nOK; }
+    sal_Int32 getFails() {osl::MutexGuard g(m_mutex); return m_nFails;}
+
+protected:
+
+    /** guarded value which initialized 0
+
+        @see ThreadSafeValue
+    */
+    void SAL_CALL run() override
+        {
+            for (int i = 0; i != 5; ++i)
+            {
+                OUString aStr = Gregorian::get();
+                if (aStr == m_sConstStr)
+                {
+                    osl::MutexGuard g(m_mutex);
+                    m_nOK++;
+                }
+                else
+                {
+                    osl::MutexGuard g(m_mutex);
+                    m_nFails++;
+                }
+            }
+        }
+
+public:
+
+    virtual ~OGetThread() override
+        {
+            if (isRunning())
+            {
+                printf("error: not terminated.\n");
+            }
+        }
+};
+
+}
+
+namespace rtl_DoubleLocking
+{
+
+/** Test of the osl::Thread::create method
+ */
+
+    class getValue : public CppUnit::TestFixture
+    {
+    public:
+
+        void getValue_001()
+            {
+                OUString aStr = Gregorian::get();
+
+                CPPUNIT_ASSERT_MESSAGE(
+                    "Gregorian::get() failed, wrong value expected.",
+                    !aStr.isEmpty()
+                    );
+            }
+
+        /** check 2 threads.
+
+            ALGORITHM:
+            Here the function should show, that 2 different threads,
+            which only increase a value, should run at the same time with same prio.
+            The test fails, if the difference between the two values is more than 5%
+            but IMHO this isn't a failure, it's only a feature of the OS.
+        */
+
+        void getValue_002()
+            {
+                // initial 5 threads with different priorities
+                OGetThread* pThread = new OGetThread();
+                OGetThread* p2Thread = new OGetThread();
+
+                //Create them and start running at the same time
+                pThread->create();
+                p2Thread->create();
+
+                pThread->join();
+                p2Thread->join();
+
+                sal_Int32 nValueOK = pThread->getOK();
+
+                sal_Int32 nValueOK2 = p2Thread->getOK();
+
+                std::cout << "Value in Thread #1 is " << nValueOK << "\n";
+                std::cout << "Value in Thread #2 is " << nValueOK2 << "\n";
+                sal_Int32 nValueFails = pThread->getFails();
+
+                sal_Int32 nValueFails2 = p2Thread->getFails();
+
+                delete pThread;
+                delete p2Thread;
+
+                CPPUNIT_ASSERT_EQUAL(sal_Int32(5), nValueOK);
+                CPPUNIT_ASSERT_EQUAL(sal_Int32(5), nValueOK2);
+                CPPUNIT_ASSERT_EQUAL(sal_Int32(0), nValueFails);
+                CPPUNIT_ASSERT_EQUAL(sal_Int32(0), nValueFails2);
+            }
+
+        CPPUNIT_TEST_SUITE(getValue);
+        CPPUNIT_TEST(getValue_001);
+        CPPUNIT_TEST(getValue_002);
+        CPPUNIT_TEST_SUITE_END();
+    }; // class create
+
+    CPPUNIT_TEST_SUITE_REGISTRATION(rtl_DoubleLocking::getValue);
+} // namespace rtl_DoubleLocking
+
+/* vim:set shiftwidth=4 softtabstop=4 expandtab: */