[inspector] added reconnect method for tests

test/inspector/inspector-impl.cc

 // 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/inspector-impl.h"
 
 #include "include/v8.h"
 
 #include "src/vector.h"
 
@@ skipping 90 matching lines @@
     v8::Local<v8::Context> context = global_context.Get(isolate);
     client_->connect(context);
     if (ready_semaphore_) ready_semaphore_->Signal();
   }
 
  private:
   InspectorClientImpl* client_;
   v8::base::Semaphore* ready_semaphore_;
 };
 
+class DisconnectTask : public TaskRunner::Task {
+ public:
+  explicit DisconnectTask(InspectorClientImpl* client) : client_(client) {}
+  virtual ~DisconnectTask() = default;
+
+  bool is_inspector_task() final { return true; }
+
+  void Run(v8::Isolate* isolate,
+           const v8::Global<v8::Context>& global_context) {
+    client_->disconnect();
+  }
+
+ private:
+  InspectorClientImpl* client_;
+};
+
 InspectorClientImpl::InspectorClientImpl(TaskRunner* task_runner,
                                          FrontendChannel* frontend_channel,
                                          v8::base::Semaphore* ready_semaphore)
     : isolate_(nullptr),
       task_runner_(task_runner),
       frontend_channel_(frontend_channel) {
   task_runner_->Append(new ConnectTask(this, ready_semaphore));
 }
 
 InspectorClientImpl::~InspectorClientImpl() {}
 
 void InspectorClientImpl::connect(v8::Local<v8::Context> context) {
   isolate_ = context->GetIsolate();
   isolate_->AddMessageListener(MessageHandler);
   channel_.reset(new ChannelImpl(frontend_channel_));
 
   inspector_ = v8_inspector::V8Inspector::create(isolate_, this);
-  session_ = inspector_->connect(1, channel_.get(), v8_inspector::StringView());
+  v8_inspector::StringView state =
+      state_ ? state_->string() : v8_inspector::StringView();
+  session_ = inspector_->connect(1, channel_.get(), state);
 
   context->SetAlignedPointerInEmbedderData(kInspectorClientIndex, this);
   inspector_->contextCreated(
       v8_inspector::V8ContextInfo(context, 1, v8_inspector::StringView()));
   context_.Reset(isolate_, context);
 }
 
+void InspectorClientImpl::scheduleReconnect(
+    v8::base::Semaphore* ready_semaphore) {
+  task_runner_->Append(new DisconnectTask(this));
+  task_runner_->Append(new ConnectTask(this, ready_semaphore));
+}
+
+void InspectorClientImpl::disconnect() {
+  state_ = session_->stateJSON();
+  session_.reset();
+}
+
 v8::Local<v8::Context> InspectorClientImpl::ensureDefaultContextInGroup(int) {
   CHECK(isolate_);
   return context_.Get(isolate_);
 }
 
 void InspectorClientImpl::setCurrentTimeMSForTest(double time) {
   current_time_ = time;
   current_time_set_for_test_ = true;
 }
 
@@ skipping 54 matching lines @@
       isolate, SendMessageToBackendExtension::SendMessageToBackend);
 }
 
 void SendMessageToBackendExtension::SendMessageToBackend(
     const v8::FunctionCallbackInfo<v8::Value>& args) {
   CHECK(backend_task_runner_);
   CHECK(args.Length() == 1 && args[0]->IsString());
   v8::Local<v8::String> message = args[0].As<v8::String>();
   backend_task_runner_->Append(new SendMessageToBackendTask(ToVector(message)));
 }