webkitgtk-2.4.11webkitgtk-2.4.11

1 files changed, 0 insertions, 257 deletions

diff --git a/Tools/TestWebKitAPI/Tests/WTF/Condition.cpp b/Tools/TestWebKitAPI/Tests/WTF/Condition.cpp
deleted file mode 100644
index c450d8953..000000000
--- a/Tools/TestWebKitAPI/Tests/WTF/Condition.cpp
+++ /dev/null
@@ -1,257 +0,0 @@
-/*
- * Copyright (C) 2015 Apple Inc. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- * 1. Redistributions of source code must retain the above copyright
- *    notice, this list of conditions and the following disclaimer.
- * 2. Redistributions in binary form must reproduce the above copyright
- *    notice, this list of conditions and the following disclaimer in the
- *    documentation and/or other materials provided with the distribution.
- *
- * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
- * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
- * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
- * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
- * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
- * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
- * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
- * THE POSSIBILITY OF SUCH DAMAGE.
- */
-
-#include "config.h"
-#include <mutex>
-#include <thread>
-#include <wtf/Condition.h>
-#include <wtf/DataLog.h>
-#include <wtf/Deque.h>
-#include <wtf/Lock.h>
-#include <wtf/StringPrintStream.h>
-#include <wtf/Threading.h>
-#include <wtf/Vector.h>
-
-using namespace WTF;
-
-namespace TestWebKitAPI {
-
-namespace {
-
-const bool verbose = false;
-
-enum NotifyStyle {
-    AlwaysNotifyOne,
-    TacticallyNotifyAll
-};
-
-template<typename Functor>
-void wait(Condition& condition, std::unique_lock<Lock>& locker, const Functor& predicate, std::chrono::microseconds timeout)
-{
-    if (timeout == std::chrono::microseconds::max())
-        condition.wait(locker, predicate);
-    else {
-        // This tests timeouts in the sense that it verifies that we can call wait() again after a
-        // timeout happened. That's a non-trivial piece of functionality since upon timeout the
-        // ParkingLot has to remove us from the queue.
-        while (!predicate())
-            condition.waitFor(locker, timeout, predicate);
-    }
-}
-
-void notify(NotifyStyle notifyStyle, Condition& condition, bool shouldNotify)
-{
-    switch (notifyStyle) {
-    case AlwaysNotifyOne:
-        condition.notifyOne();
-        break;
-    case TacticallyNotifyAll:
-        if (shouldNotify)
-            condition.notifyAll();
-        break;
-    }
-}
-
-void runTest(
-    unsigned numProducers,
-    unsigned numConsumers,
-    unsigned maxQueueSize,
-    unsigned numMessagesPerProducer,
-    NotifyStyle notifyStyle,
-    std::chrono::microseconds timeout = std::chrono::microseconds::max(),
-    std::chrono::microseconds delay = std::chrono::microseconds::zero())
-{
-    Deque<unsigned> queue;
-    bool shouldContinue = true;
-    Lock lock;
-    Condition emptyCondition;
-    Condition fullCondition;
-
-    Vector<ThreadIdentifier> consumerThreads;
-    Vector<ThreadIdentifier> producerThreads;
-
-    Vector<unsigned> received;
-    Lock receivedLock;
-    
-    for (unsigned i = numConsumers; i--;) {
-        ThreadIdentifier threadIdentifier = createThread(
-            "Consumer thread",
-            [&] () {
-                for (;;) {
-                    unsigned result;
-                    unsigned shouldNotify = false;
-                    {
-                        std::unique_lock<Lock> locker(lock);
-                        wait(
-                            emptyCondition, locker, 
-                            [&] () {
-                                if (verbose)
-                                    dataLog(toString(currentThread(), ": Checking consumption predicate with shouldContinue = ", shouldContinue, ", queue.size() == ", queue.size(), "\n"));
-                                return !shouldContinue || !queue.isEmpty();
-                            },
-                            timeout);
-                        if (!shouldContinue && queue.isEmpty())
-                            return;
-                        shouldNotify = queue.size() == maxQueueSize;
-                        result = queue.takeFirst();
-                    }
-                    notify(notifyStyle, fullCondition, shouldNotify);
-
-                    {
-                        std::lock_guard<Lock> locker(receivedLock);
-                        received.append(result);
-                    }
-                }
-            });
-        consumerThreads.append(threadIdentifier);
-    }
-
-    std::this_thread::sleep_for(delay);
-
-    for (unsigned i = numProducers; i--;) {
-        ThreadIdentifier threadIdentifier = createThread(
-            "Producer Thread",
-            [&] () {
-                for (unsigned i = 0; i < numMessagesPerProducer; ++i) {
-                    bool shouldNotify = false;
-                    {
-                        std::unique_lock<Lock> locker(lock);
-                        wait(
-                            fullCondition, locker,
-                            [&] () {
-                                if (verbose)
-                                    dataLog(toString(currentThread(), ": Checking production predicate with shouldContinue = ", shouldContinue, ", queue.size() == ", queue.size(), "\n"));
-                                return queue.size() < maxQueueSize;
-                            },
-                            timeout);
-                        shouldNotify = queue.isEmpty();
-                        queue.append(i);
-                    }
-                    notify(notifyStyle, emptyCondition, shouldNotify);
-                }
-            });
-        producerThreads.append(threadIdentifier);
-    }
-
-    for (ThreadIdentifier threadIdentifier : producerThreads)
-        waitForThreadCompletion(threadIdentifier);
-
-    {
-        std::lock_guard<Lock> locker(lock);
-        shouldContinue = false;
-    }
-    emptyCondition.notifyAll();
-
-    for (ThreadIdentifier threadIdentifier : consumerThreads)
-        waitForThreadCompletion(threadIdentifier);
-
-    EXPECT_EQ(numProducers * numMessagesPerProducer, received.size());
-    std::sort(received.begin(), received.end());
-    for (unsigned messageIndex = 0; messageIndex < numMessagesPerProducer; ++messageIndex) {
-        for (unsigned producerIndex = 0; producerIndex < numProducers; ++producerIndex)
-            EXPECT_EQ(messageIndex, received[messageIndex * numProducers + producerIndex]);
-    }
-}
-
-} // anonymous namespace
-
-TEST(WTF_Condition, OneProducerOneConsumerOneSlot)
-{
-    runTest(1, 1, 1, 100000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, OneProducerOneConsumerOneSlotTimeout)
-{
-    runTest(
-        1, 1, 1, 100000, TacticallyNotifyAll,
-        std::chrono::microseconds(10000),
-        std::chrono::microseconds(1000000));
-}
-
-TEST(WTF_Condition, OneProducerOneConsumerHundredSlots)
-{
-    runTest(1, 1, 100, 1000000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, TenProducersOneConsumerOneSlot)
-{
-    runTest(10, 1, 1, 10000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, TenProducersOneConsumerHundredSlotsNotifyAll)
-{
-    runTest(10, 1, 100, 10000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, TenProducersOneConsumerHundredSlotsNotifyOne)
-{
-    runTest(10, 1, 100, 10000, AlwaysNotifyOne);
-}
-
-TEST(WTF_Condition, OneProducerTenConsumersOneSlot)
-{
-    runTest(1, 10, 1, 10000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, OneProducerTenConsumersHundredSlotsNotifyAll)
-{
-    runTest(1, 10, 100, 100000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, OneProducerTenConsumersHundredSlotsNotifyOne)
-{
-    runTest(1, 10, 100, 100000, AlwaysNotifyOne);
-}
-
-TEST(WTF_Condition, TenProducersTenConsumersOneSlot)
-{
-    runTest(10, 10, 1, 50000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, TenProducersTenConsumersHundredSlotsNotifyAll)
-{
-    runTest(10, 10, 100, 50000, TacticallyNotifyAll);
-}
-
-TEST(WTF_Condition, TenProducersTenConsumersHundredSlotsNotifyOne)
-{
-    runTest(10, 10, 100, 50000, AlwaysNotifyOne);
-}
-
-TEST(WTF_Condition, TimeoutTimesOut)
-{
-    Lock lock;
-    Condition condition;
-
-    lock.lock();
-    bool result = condition.waitFor(
-        lock, std::chrono::microseconds(10000), [] () -> bool { return false; });
-    lock.unlock();
-
-    EXPECT_FALSE(result);
-}
-
-} // namespace TestWebKitAPI
-