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; } |