LoaderRunLoopCF.cpp [plain text]
#include "config.h"
#include "LoaderRunLoopCF.h"
#if USE(CFNETWORK)
#include <CoreFoundation/CoreFoundation.h>
#include <condition_variable>
#include <limits>
#include <wtf/AutodrainedPool.h>
#include <wtf/MainThread.h>
#include <wtf/NeverDestroyed.h>
#include <wtf/Threading.h>
namespace WebCore {
static CFRunLoopRef loaderRunLoopObject = 0;
static std::mutex& loaderRunLoopMutex()
{
static NeverDestroyed<std::mutex> mutex;
return mutex;
}
static std::condition_variable& loaderRunLoopConditionVariable()
{
static NeverDestroyed<std::condition_variable> conditionVariable;
return conditionVariable;
}
static void emptyPerform(void*)
{
}
static void runLoaderThread(void*)
{
{
std::lock_guard<std::mutex> lock(loaderRunLoopMutex());
loaderRunLoopObject = CFRunLoopGetCurrent();
CFRunLoopSourceContext ctxt = {0, (void*)1 , 0, 0, 0, 0, 0, 0, 0, emptyPerform};
CFRunLoopSourceRef bogusSource = CFRunLoopSourceCreate(0, 0, &ctxt);
CFRunLoopAddSource(loaderRunLoopObject, bogusSource, kCFRunLoopDefaultMode);
loaderRunLoopConditionVariable().notify_one();
}
SInt32 result;
do {
AutodrainedPool pool;
result = CFRunLoopRunInMode(kCFRunLoopDefaultMode, std::numeric_limits<double>::max(), true);
} while (result != kCFRunLoopRunStopped && result != kCFRunLoopRunFinished);
}
CFRunLoopRef loaderRunLoop()
{
ASSERT(isMainThread());
std::unique_lock<std::mutex> lock(loaderRunLoopMutex());
if (!loaderRunLoopObject) {
createThread(runLoaderThread, 0, "WebCore: CFNetwork Loader");
loaderRunLoopConditionVariable().wait(lock, [] { return loaderRunLoopObject; });
}
return loaderRunLoopObject;
}
}
#endif // USE(CFNETWORK)