#include "config.h"
#include "JITWorklist.h"
#if ENABLE(JIT)
#include "JIT.h"
#include "JSCInlines.h"
#include "VMInlines.h"
namespace JSC {
class JITWorklist::Plan : public ThreadSafeRefCounted<JITWorklist::Plan> {
public:
Plan(CodeBlock* codeBlock)
: m_codeBlock(codeBlock)
, m_jit(codeBlock->vm(), codeBlock)
{
m_jit.doMainThreadPreparationBeforeCompile();
}
void compileInThread()
{
m_jit.compileWithoutLinking(JITCompilationCanFail);
LockHolder locker(m_lock);
m_isFinishedCompiling = true;
}
void finalize()
{
CompilationResult result = m_jit.link();
switch (result) {
case CompilationFailed:
CODEBLOCK_LOG_EVENT(m_codeBlock, "delayJITCompile", ("compilation failed"));
if (Options::verboseOSR())
dataLogF(" JIT compilation failed.\n");
m_codeBlock->dontJITAnytimeSoon();
m_codeBlock->m_didFailJITCompilation = true;
return;
case CompilationSuccessful:
if (Options::verboseOSR())
dataLogF(" JIT compilation successful.\n");
m_codeBlock->ownerScriptExecutable()->installCode(m_codeBlock);
m_codeBlock->jitSoon();
return;
default:
RELEASE_ASSERT_NOT_REACHED();
return;
}
}
CodeBlock* codeBlock() { return m_codeBlock; }
VM* vm() { return m_codeBlock->vm(); }
bool isFinishedCompiling()
{
LockHolder locker(m_lock);
return m_isFinishedCompiling;
}
static void compileNow(CodeBlock* codeBlock)
{
Plan plan(codeBlock);
plan.compileInThread();
plan.finalize();
}
private:
CodeBlock* m_codeBlock;
JIT m_jit;
Lock m_lock;
bool m_isFinishedCompiling { false };
};
JITWorklist::JITWorklist()
{
createThread("JIT Worklist Worker Thread", [this] () { runThread(); });
}
JITWorklist::~JITWorklist()
{
UNREACHABLE_FOR_PLATFORM();
}
void JITWorklist::completeAllForVM(VM& vm)
{
DeferGC deferGC(vm.heap);
for (;;) {
Vector<RefPtr<Plan>, 32> myPlans;
{
LockHolder locker(m_lock);
for (;;) {
bool didFindUnfinishedPlan = false;
m_plans.removeAllMatching(
[&] (RefPtr<Plan>& plan) {
if (plan->vm() != &vm)
return false;
if (!plan->isFinishedCompiling()) {
didFindUnfinishedPlan = true;
return false;
}
myPlans.append(WTFMove(plan));
return true;
});
if (!myPlans.isEmpty())
break;
if (!didFindUnfinishedPlan)
return;
m_condition.wait(m_lock);
}
}
finalizePlans(myPlans);
}
}
void JITWorklist::poll(VM& vm)
{
DeferGC deferGC(vm.heap);
Plans myPlans;
{
LockHolder locker(m_lock);
m_plans.removeAllMatching(
[&] (RefPtr<Plan>& plan) {
if (plan->vm() != &vm)
return false;
if (!plan->isFinishedCompiling())
return false;
myPlans.append(WTFMove(plan));
return true;
});
}
finalizePlans(myPlans);
}
void JITWorklist::compileLater(CodeBlock* codeBlock)
{
DeferGC deferGC(codeBlock->vm()->heap);
RELEASE_ASSERT(codeBlock->jitType() == JITCode::InterpreterThunk);
if (codeBlock->m_didFailJITCompilation) {
codeBlock->dontJITAnytimeSoon();
return;
}
if (!Options::useConcurrentJIT()) {
Plan::compileNow(codeBlock);
return;
}
codeBlock->jitSoon();
{
LockHolder locker(m_lock);
if (m_planned.contains(codeBlock))
return;
if (m_numAvailableThreads) {
m_planned.add(codeBlock);
RefPtr<Plan> plan = adoptRef(new Plan(codeBlock));
m_plans.append(plan);
m_queue.append(plan);
m_condition.notifyAll();
return;
}
}
Plan::compileNow(codeBlock);
}
void JITWorklist::compileNow(CodeBlock* codeBlock)
{
DeferGC deferGC(codeBlock->vm()->heap);
if (codeBlock->jitType() != JITCode::InterpreterThunk)
return;
bool isPlanned;
{
LockHolder locker(m_lock);
isPlanned = m_planned.contains(codeBlock);
}
if (isPlanned) {
RELEASE_ASSERT(Options::useConcurrentJIT());
completeAllForVM(*codeBlock->vm());
}
if (codeBlock->jitType() != JITCode::InterpreterThunk)
return;
codeBlock->resetJITData();
JIT::compile(codeBlock->vm(), codeBlock, JITCompilationMustSucceed);
codeBlock->ownerScriptExecutable()->installCode(codeBlock);
}
void JITWorklist::runThread()
{
for (;;) {
Plans myPlans;
{
LockHolder locker(m_lock);
m_numAvailableThreads++;
while (m_queue.isEmpty())
m_condition.wait(m_lock);
m_numAvailableThreads--;
myPlans = WTFMove(m_queue);
}
RELEASE_ASSERT(!myPlans.isEmpty());
for (RefPtr<Plan>& plan : myPlans) {
plan->compileInThread();
plan = nullptr;
LockHolder locker(m_lock);
m_condition.notifyAll();
}
}
}
void JITWorklist::finalizePlans(Plans& myPlans)
{
for (RefPtr<Plan>& plan : myPlans) {
plan->finalize();
LockHolder locker(m_lock);
m_planned.remove(plan->codeBlock());
}
}
JITWorklist* JITWorklist::instance()
{
static JITWorklist* worklist;
static std::once_flag once;
std::call_once(
once,
[] {
worklist = new JITWorklist();
});
return worklist;
}
}
#endif // ENABLE(JIT)