[inspector] added inspector protocol test runner

test/inspector-protocol/task-queue.cc

Index: test/inspector-protocol/task-queue.cc
diff --git a/test/inspector-protocol/task-queue.cc b/test/inspector-protocol/task-queue.cc
new file mode 100644
index 0000000000000000000000000000000000000000..3b546c823b4600952f8e48724e38d96beb709a09
--- /dev/null
+++ b/test/inspector-protocol/task-queue.cc
@@ -0,0 +1,51 @@
+// 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-protocol/task-queue.h"
+
+#include "test/inspector-protocol/task.h"
+
+namespace {
+const int kTaskQueueIndex = 2;
+}
+
+namespace v8_inspector {
+
+TaskQueue::TaskQueue() : process_queue_semaphore_(0) {}
+
+TaskQueue::~TaskQueue() {}
+
+void TaskQueue::Append(Task* task) {
+  queue_.Enqueue(task);
+  process_queue_semaphore_.Signal();
+}
+
+Task* TaskQueue::GetNext(bool only_protocol) {
+  for (;;) {
+    if (only_protocol) {
+      for (;;) {
+        Task* task = nullptr;
+        if (!queue_.Dequeue(&task)) break;
+        if (task->is_protocol_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();
+  }
+}
+
+void TaskQueue::SetContext(v8::Local<v8::Context> context) {
+  context->SetAlignedPointerInEmbedderData(kTaskQueueIndex, this);
+}
+
+TaskQueue* TaskQueue::FromContext(v8::Local<v8::Context> context) {
+  return static_cast<TaskQueue*>(
+      context->GetAlignedPointerFromEmbedderData(kTaskQueueIndex));
+}
+
+}  //  v8_inspector