Revert "Add Kernel Isolate"

runtime/vm/kernel_isolate.cc

Index: runtime/vm/kernel_isolate.cc
diff --git a/runtime/vm/kernel_isolate.cc b/runtime/vm/kernel_isolate.cc
deleted file mode 100644
index 6a94ac64b6fe5481e260cba4638211f68069b26d..0000000000000000000000000000000000000000
--- a/runtime/vm/kernel_isolate.cc
+++ /dev/null
@@ -1,252 +0,0 @@
-// Copyright (c) 2016, the Dart project authors.  Please see the AUTHORS file
-// for details. All rights reserved. Use of this source code is governed by a
-// BSD-style license that can be found in the LICENSE file.
-
-#include "vm/kernel_isolate.h"
-
-#include "vm/compiler.h"
-#include "vm/dart_api_impl.h"
-#include "vm/dart_entry.h"
-#include "vm/isolate.h"
-#include "vm/lockers.h"
-#include "vm/message.h"
-#include "vm/message_handler.h"
-#include "vm/native_entry.h"
-#include "vm/native_arguments.h"
-#include "vm/object.h"
-#include "vm/object_store.h"
-#include "vm/port.h"
-#include "vm/service.h"
-#include "vm/symbols.h"
-#include "vm/thread_pool.h"
-#include "vm/timeline.h"
-
-namespace dart {
-
-#if !defined(DART_PRECOMPILED_RUNTIME)
-
-#define Z (T->zone())
-
-DEFINE_FLAG(bool, trace_kernel, false, "Trace Kernel service requests.");
-
-
-const char* KernelIsolate::kName = "kernel-service";
-Dart_IsolateCreateCallback KernelIsolate::create_callback_ = NULL;
-Monitor* KernelIsolate::monitor_ = NULL;
-Isolate* KernelIsolate::isolate_ = NULL;
-bool KernelIsolate::initializing_ = true;
-Dart_Port KernelIsolate::kernel_port_ = ILLEGAL_PORT;
-
-
-class RunKernelTask : public ThreadPool::Task {
- public:
-  virtual void Run() {
-    ASSERT(Isolate::Current() == NULL);
-
-#ifndef PRODUCT
-    TimelineDurationScope tds(Timeline::GetVMStream(), "KernelIsolateStartup");
-#endif  // !PRODUCT
-    char* error = NULL;
-    Isolate* isolate = NULL;
-
-    Dart_IsolateCreateCallback create_callback =
-        KernelIsolate::create_callback();
-
-    if (create_callback == NULL) {
-      KernelIsolate::FinishedInitializing();
-      return;
-    }
-
-    Dart_IsolateFlags api_flags;
-    Isolate::FlagsInitialize(&api_flags);
-
-    isolate = reinterpret_cast<Isolate*>(create_callback(
-        KernelIsolate::kName, NULL, NULL, NULL, &api_flags, NULL, &error));
-    if (isolate == NULL) {
-      if (FLAG_trace_kernel) {
-        OS::PrintErr("kernel-service: Isolate creation error: %s\n", error);
-      }
-      KernelIsolate::SetKernelIsolate(NULL);
-      KernelIsolate::FinishedInitializing();
-      return;
-    }
-
-    bool init_success = false;
-    {
-      ASSERT(Isolate::Current() == NULL);
-      StartIsolateScope start_scope(isolate);
-      init_success = RunMain(isolate);
-    }
-    KernelIsolate::FinishedInitializing();
-
-    if (!init_success) {
-      ShutdownIsolate(reinterpret_cast<uword>(isolate));
-      return;
-    }
-
-    // isolate_ was set as side effect of create callback.
-    ASSERT(KernelIsolate::IsKernelIsolate(isolate));
-
-    isolate->message_handler()->Run(Dart::thread_pool(), NULL, ShutdownIsolate,
-                                    reinterpret_cast<uword>(isolate));
-  }
-
- protected:
-  static void ShutdownIsolate(uword parameter) {
-    if (FLAG_trace_kernel) {
-      OS::Print("kernel-service: ShutdownIsolate\n");
-    }
-    Isolate* I = reinterpret_cast<Isolate*>(parameter);
-    ASSERT(KernelIsolate::IsKernelIsolate(I));
-    KernelIsolate::SetKernelIsolate(NULL);
-    KernelIsolate::SetLoadPort(ILLEGAL_PORT);
-    I->WaitForOutstandingSpawns();
-    {
-      // Print the error if there is one.  This may execute dart code to
-      // print the exception object, so we need to use a StartIsolateScope.
-      ASSERT(Isolate::Current() == NULL);
-      StartIsolateScope start_scope(I);
-      Thread* T = Thread::Current();
-      ASSERT(I == T->isolate());
-      StackZone zone(T);
-      HandleScope handle_scope(T);
-      Error& error = Error::Handle(Z);
-      error = T->sticky_error();
-      if (!error.IsNull() && !error.IsUnwindError()) {
-        OS::PrintErr("kernel-service: Error: %s\n", error.ToErrorCString());
-      }
-      error = I->sticky_error();
-      if (!error.IsNull() && !error.IsUnwindError()) {
-        OS::PrintErr("kernel-service: Error: %s\n", error.ToErrorCString());
-      }
-      Dart::RunShutdownCallback();
-    }
-    // Shut the isolate down.
-    Dart::ShutdownIsolate(I);
-    if (FLAG_trace_kernel) {
-      OS::Print("kernel-service: Shutdown.\n");
-    }
-  }
-
-  bool RunMain(Isolate* I) {
-    Thread* T = Thread::Current();
-    ASSERT(I == T->isolate());
-    StackZone zone(T);
-    HANDLESCOPE(T);
-    // Invoke main which will return the port to which load requests are sent.
-    const Library& root_library =
-        Library::Handle(Z, I->object_store()->root_library());
-    if (root_library.IsNull()) {
-      if (FLAG_trace_kernel) {
-        OS::Print("kernel-service: Embedder did not install a script.");
-      }
-      // Kernel isolate is not supported by embedder.
-      return false;
-    }
-    ASSERT(!root_library.IsNull());
-    const String& entry_name = String::Handle(Z, String::New("main"));
-    ASSERT(!entry_name.IsNull());
-    const Function& entry = Function::Handle(
-        Z, root_library.LookupFunctionAllowPrivate(entry_name));
-    if (entry.IsNull()) {
-      // Kernel isolate is not supported by embedder.
-      if (FLAG_trace_kernel) {
-        OS::Print("kernel-service: Embedder did not provide a main function.");
-      }
-      return false;
-    }
-    ASSERT(!entry.IsNull());
-    const Object& result = Object::Handle(
-        Z, DartEntry::InvokeFunction(entry, Object::empty_array()));
-    ASSERT(!result.IsNull());
-    if (result.IsError()) {
-      // Kernel isolate did not initialize properly.
-      if (FLAG_trace_kernel) {
-        const Error& error = Error::Cast(result);
-        OS::Print("kernel-service: Calling main resulted in an error: %s",
-                  error.ToErrorCString());
-      }
-      return false;
-    }
-    ASSERT(result.IsReceivePort());
-    const ReceivePort& rp = ReceivePort::Cast(result);
-    KernelIsolate::SetLoadPort(rp.Id());
-    return true;
-  }
-};
-
-
-void KernelIsolate::Run() {
-  ASSERT(monitor_ == NULL);
-  monitor_ = new Monitor();
-  ASSERT(monitor_ != NULL);
-  // Grab the isolate create callback here to avoid race conditions with tests
-  // that change this after Dart_Initialize returns.
-  create_callback_ = Isolate::CreateCallback();
-  Dart::thread_pool()->Run(new RunKernelTask());
-}
-
-
-void KernelIsolate::InitCallback(Isolate* I) {
-  Thread* T = Thread::Current();
-  ASSERT(I == T->isolate());
-  ASSERT(I != NULL);
-  ASSERT(I->name() != NULL);
-  if (strstr(I->name(), "kernel-service") == NULL) {
-    // Not service isolate.
-    return;
-  }
-  ASSERT(!Exists());
-  if (FLAG_trace_kernel) {
-    OS::Print("kernel-service: InitCallback for %s.\n", I->name());
-  }
-  SetKernelIsolate(I);
-}
-
-
-bool KernelIsolate::IsKernelIsolate(const Isolate* isolate) {
-  MonitorLocker ml(monitor_);
-  return isolate == isolate_;
-}
-
-
-bool KernelIsolate::IsRunning() {
-  MonitorLocker ml(monitor_);
-  return (kernel_port_ != ILLEGAL_PORT) && (isolate_ != NULL);
-}
-
-
-bool KernelIsolate::Exists() {
-  MonitorLocker ml(monitor_);
-  return isolate_ != NULL;
-}
-
-
-void KernelIsolate::SetKernelIsolate(Isolate* isolate) {
-  MonitorLocker ml(monitor_);
-  isolate_ = isolate;
-}
-
-void KernelIsolate::SetLoadPort(Dart_Port port) {
-  MonitorLocker ml(monitor_);
-  kernel_port_ = port;
-}
-
-void KernelIsolate::FinishedInitializing() {
-  MonitorLocker ml(monitor_);
-  initializing_ = false;
-  ml.NotifyAll();
-}
-
-
-Dart_Port KernelIsolate::WaitForKernelPort() {
-  MonitorLocker ml(monitor_);
-  while (initializing_ && (kernel_port_ == ILLEGAL_PORT)) {
-    ml.Wait();
-  }
-  return kernel_port_;
-}
-
-#endif  // DART_PRECOMPILED_RUNTIME
-
-}  // namespace dart