| Index: test/inspector/task-runner.cc
|
| diff --git a/test/inspector/task-runner.cc b/test/inspector/task-runner.cc
|
| deleted file mode 100644
|
| index 06675adf99a945cb50fea209edc7d7312f85952c..0000000000000000000000000000000000000000
|
| --- a/test/inspector/task-runner.cc
|
| +++ /dev/null
|
| @@ -1,137 +0,0 @@
|
| -// Copyright 2016 the V8 project authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "test/inspector/task-runner.h"
|
| -
|
| -namespace {
|
| -
|
| -const int kTaskRunnerIndex = 2;
|
| -
|
| -void ReportUncaughtException(v8::Isolate* isolate,
|
| - const v8::TryCatch& try_catch) {
|
| - CHECK(try_catch.HasCaught());
|
| - v8::HandleScope handle_scope(isolate);
|
| - std::string message = *v8::String::Utf8Value(try_catch.Message()->Get());
|
| - fprintf(stderr, "Unhandle exception: %s\n", message.data());
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -TaskRunner::TaskRunner(v8::ExtensionConfiguration* extensions,
|
| - v8::base::Semaphore* ready_semaphore)
|
| - : Thread(Options("Task Runner")),
|
| - extensions_(extensions),
|
| - ready_semaphore_(ready_semaphore),
|
| - isolate_(nullptr),
|
| - process_queue_semaphore_(0),
|
| - nested_loop_count_(0) {
|
| - Start();
|
| -}
|
| -
|
| -TaskRunner::~TaskRunner() { Join(); }
|
| -
|
| -void TaskRunner::InitializeContext() {
|
| - v8::Isolate::CreateParams params;
|
| - params.array_buffer_allocator =
|
| - v8::ArrayBuffer::Allocator::NewDefaultAllocator();
|
| - isolate_ = v8::Isolate::New(params);
|
| - isolate_->SetMicrotasksPolicy(v8::MicrotasksPolicy::kScoped);
|
| - v8::Isolate::Scope isolate_scope(isolate_);
|
| - v8::HandleScope handle_scope(isolate_);
|
| -
|
| - v8::Local<v8::ObjectTemplate> global_template =
|
| - v8::ObjectTemplate::New(isolate_);
|
| - v8::Local<v8::Context> context =
|
| - v8::Context::New(isolate_, extensions_, global_template);
|
| - context->SetAlignedPointerInEmbedderData(kTaskRunnerIndex, this);
|
| - context_.Reset(isolate_, context);
|
| -
|
| - if (ready_semaphore_) ready_semaphore_->Signal();
|
| -}
|
| -
|
| -void TaskRunner::Run() {
|
| - InitializeContext();
|
| - RunMessageLoop(false);
|
| -}
|
| -
|
| -void TaskRunner::RunMessageLoop(bool only_protocol) {
|
| - int loop_number = ++nested_loop_count_;
|
| - while (nested_loop_count_ == loop_number) {
|
| - TaskRunner::Task* task = GetNext(only_protocol);
|
| - v8::Isolate::Scope isolate_scope(isolate_);
|
| - v8::TryCatch try_catch(isolate_);
|
| - task->Run(isolate_, context_);
|
| - delete task;
|
| - if (try_catch.HasCaught()) {
|
| - ReportUncaughtException(isolate_, try_catch);
|
| - fflush(stdout);
|
| - fflush(stderr);
|
| - _exit(0);
|
| - }
|
| - }
|
| -}
|
| -
|
| -void TaskRunner::QuitMessageLoop() {
|
| - DCHECK(nested_loop_count_ > 0);
|
| - --nested_loop_count_;
|
| -}
|
| -
|
| -void TaskRunner::Append(Task* task) {
|
| - queue_.Enqueue(task);
|
| - process_queue_semaphore_.Signal();
|
| -}
|
| -
|
| -TaskRunner::Task* TaskRunner::GetNext(bool only_protocol) {
|
| - for (;;) {
|
| - if (only_protocol) {
|
| - Task* task = nullptr;
|
| - if (queue_.Dequeue(&task)) {
|
| - if (task->is_inspector_task()) return task;
|
| - deffered_queue_.Enqueue(task);
|
| - }
|
| - } else {
|
| - Task* task = nullptr;
|
| - if (deffered_queue_.Dequeue(&task)) return task;
|
| - if (queue_.Dequeue(&task)) return task;
|
| - }
|
| - process_queue_semaphore_.Wait();
|
| - }
|
| - UNREACHABLE();
|
| - return nullptr;
|
| -}
|
| -
|
| -TaskRunner* TaskRunner::FromContext(v8::Local<v8::Context> context) {
|
| - return static_cast<TaskRunner*>(
|
| - context->GetAlignedPointerFromEmbedderData(kTaskRunnerIndex));
|
| -}
|
| -
|
| -ExecuteStringTask::ExecuteStringTask(const v8_inspector::String16& expression)
|
| - : expression_(expression) {}
|
| -
|
| -void ExecuteStringTask::Run(v8::Isolate* isolate,
|
| - const v8::Global<v8::Context>& context) {
|
| - v8::MicrotasksScope microtasks_scope(isolate,
|
| - v8::MicrotasksScope::kRunMicrotasks);
|
| - v8::HandleScope handle_scope(isolate);
|
| - v8::Local<v8::Context> local_context = context.Get(isolate);
|
| - v8::Context::Scope context_scope(local_context);
|
| -
|
| - v8::ScriptOrigin origin(v8::String::Empty(isolate));
|
| - v8::Local<v8::String> source =
|
| - v8::String::NewFromTwoByte(isolate, expression_.characters16(),
|
| - v8::NewStringType::kNormal,
|
| - expression_.length())
|
| - .ToLocalChecked();
|
| -
|
| - v8::ScriptCompiler::Source scriptSource(source, origin);
|
| - v8::Local<v8::Script> script;
|
| - if (!v8::ScriptCompiler::Compile(local_context, &scriptSource)
|
| - .ToLocal(&script))
|
| - return;
|
| - v8::MaybeLocal<v8::Value> result;
|
| - result = script->Run(local_context);
|
| -}
|
| -
|
| -// main to make compiler happy before other patch will be landed.
|
| -int main(int argc, char* argv[]) { return 0; }
|
|
|