blob: 290e5f6f09019f6a61d83d596a17dfd50d91c22b [file] [log] [blame]
/*
* 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 "Utilities.h"
#include <wtf/RunLoop.h>
#include <wtf/Threading.h>
namespace TestWebKitAPI {
static bool testFinished;
static int count = 100;
TEST(WTF_RunLoop, Deadlock)
{
RunLoop::initializeMainRunLoop();
struct DispatchFromDestructorTester {
~DispatchFromDestructorTester() {
RunLoop::main().dispatch([] {
if (!(--count))
testFinished = true;
});
}
};
for (int i = 0; i < count; ++i) {
auto capture = std::make_shared<DispatchFromDestructorTester>();
RunLoop::main().dispatch([capture] { });
}
Util::run(&testFinished);
}
class DerivedOneShotTimer : public RunLoop::Timer<DerivedOneShotTimer> {
public:
DerivedOneShotTimer(bool& testFinished)
: RunLoop::Timer<DerivedOneShotTimer>(RunLoop::current(), this, &DerivedOneShotTimer::fired)
, m_testFinished(testFinished)
{
}
void fired()
{
m_testFinished = true;
stop();
}
private:
bool& m_testFinished;
};
TEST(WTF_RunLoop, OneShotTimer)
{
RunLoop::initializeMainRunLoop();
bool testFinished = false;
DerivedOneShotTimer timer(testFinished);
timer.startOneShot(100_ms);
Util::run(&testFinished);
}
class DerivedRepeatingTimer : public RunLoop::Timer<DerivedRepeatingTimer> {
public:
DerivedRepeatingTimer(bool& testFinished)
: RunLoop::Timer<DerivedRepeatingTimer>(RunLoop::current(), this, &DerivedRepeatingTimer::fired)
, m_testFinished(testFinished)
{
}
void fired()
{
if (++m_count == 10) {
m_testFinished = true;
stop();
}
}
private:
unsigned m_count { 0 };
bool& m_testFinished;
};
TEST(WTF_RunLoop, RepeatingTimer)
{
RunLoop::initializeMainRunLoop();
bool testFinished = false;
DerivedRepeatingTimer timer(testFinished);
timer.startRepeating(10_ms);
Util::run(&testFinished);
ASSERT_FALSE(timer.isActive());
}
TEST(WTF_RunLoop, ManyTimes)
{
class Counter {
public:
void run()
{
if (++m_count == 100000) {
RunLoop::current().stop();
return;
}
RunLoop::current().dispatch([this] {
run();
});
}
private:
unsigned m_count { 0 };
};
Thread::create("RunLoopManyTimes", [] {
Counter counter;
RunLoop::current().dispatch([&counter] {
counter.run();
});
RunLoop::run();
})->waitForCompletion();
}
} // namespace TestWebKitAPI