| OLD | NEW |
|---|
| (Empty) |
| 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | |
| 2 // for details. All rights reserved. Use of this source code is governed by a | |
| 3 // BSD-style license that can be found in the LICENSE file. | |
| 4 | |
| 5 #include "vm/kernel_isolate.h" | |
| 6 | |
| 7 #include "vm/compiler.h" | |
| 8 #include "vm/dart_api_impl.h" | |
| 9 #include "vm/dart_entry.h" | |
| 10 #include "vm/isolate.h" | |
| 11 #include "vm/lockers.h" | |
| 12 #include "vm/message.h" | |
| 13 #include "vm/message_handler.h" | |
| 14 #include "vm/native_entry.h" | |
| 15 #include "vm/native_arguments.h" | |
| 16 #include "vm/object.h" | |
| 17 #include "vm/object_store.h" | |
| 18 #include "vm/port.h" | |
| 19 #include "vm/service.h" | |
| 20 #include "vm/symbols.h" | |
| 21 #include "vm/thread_pool.h" | |
| 22 #include "vm/timeline.h" | |
| 23 | |
| 24 namespace dart { | |
| 25 | |
| 26 #if !defined(DART_PRECOMPILED_RUNTIME) | |
| 27 | |
| 28 #define Z (T->zone()) | |
| 29 | |
| 30 DEFINE_FLAG(bool, trace_kernel, false, "Trace Kernel service requests."); | |
| 31 | |
| 32 | |
| 33 const char* KernelIsolate::kName = "kernel-service"; | |
| 34 Dart_IsolateCreateCallback KernelIsolate::create_callback_ = NULL; | |
| 35 Monitor* KernelIsolate::monitor_ = NULL; | |
| 36 Isolate* KernelIsolate::isolate_ = NULL; | |
| 37 bool KernelIsolate::initializing_ = true; | |
| 38 Dart_Port KernelIsolate::kernel_port_ = ILLEGAL_PORT; | |
| 39 | |
| 40 | |
| 41 class RunKernelTask : public ThreadPool::Task { | |
| 42 public: | |
| 43 virtual void Run() { | |
| 44 ASSERT(Isolate::Current() == NULL); | |
| 45 | |
| 46 #ifndef PRODUCT | |
| 47 TimelineDurationScope tds(Timeline::GetVMStream(), "KernelIsolateStartup"); | |
| 48 #endif // !PRODUCT | |
| 49 char* error = NULL; | |
| 50 Isolate* isolate = NULL; | |
| 51 | |
| 52 Dart_IsolateCreateCallback create_callback = | |
| 53 KernelIsolate::create_callback(); | |
| 54 | |
| 55 if (create_callback == NULL) { | |
| 56 KernelIsolate::FinishedInitializing(); | |
| 57 return; | |
| 58 } | |
| 59 | |
| 60 Dart_IsolateFlags api_flags; | |
| 61 Isolate::FlagsInitialize(&api_flags); | |
| 62 | |
| 63 isolate = reinterpret_cast<Isolate*>(create_callback( | |
| 64 KernelIsolate::kName, NULL, NULL, NULL, &api_flags, NULL, &error)); | |
| 65 if (isolate == NULL) { | |
| 66 if (FLAG_trace_kernel) { | |
| 67 OS::PrintErr("kernel-service: Isolate creation error: %s\n", error); | |
| 68 } | |
| 69 KernelIsolate::SetKernelIsolate(NULL); | |
| 70 KernelIsolate::FinishedInitializing(); | |
| 71 return; | |
| 72 } | |
| 73 | |
| 74 bool init_success = false; | |
| 75 { | |
| 76 ASSERT(Isolate::Current() == NULL); | |
| 77 StartIsolateScope start_scope(isolate); | |
| 78 init_success = RunMain(isolate); | |
| 79 } | |
| 80 KernelIsolate::FinishedInitializing(); | |
| 81 | |
| 82 if (!init_success) { | |
| 83 ShutdownIsolate(reinterpret_cast<uword>(isolate)); | |
| 84 return; | |
| 85 } | |
| 86 | |
| 87 // isolate_ was set as side effect of create callback. | |
| 88 ASSERT(KernelIsolate::IsKernelIsolate(isolate)); | |
| 89 | |
| 90 isolate->message_handler()->Run(Dart::thread_pool(), NULL, ShutdownIsolate, | |
| 91 reinterpret_cast<uword>(isolate)); | |
| 92 } | |
| 93 | |
| 94 protected: | |
| 95 static void ShutdownIsolate(uword parameter) { | |
| 96 if (FLAG_trace_kernel) { | |
| 97 OS::Print("kernel-service: ShutdownIsolate\n"); | |
| 98 } | |
| 99 Isolate* I = reinterpret_cast<Isolate*>(parameter); | |
| 100 ASSERT(KernelIsolate::IsKernelIsolate(I)); | |
| 101 KernelIsolate::SetKernelIsolate(NULL); | |
| 102 KernelIsolate::SetLoadPort(ILLEGAL_PORT); | |
| 103 I->WaitForOutstandingSpawns(); | |
| 104 { | |
| 105 // Print the error if there is one. This may execute dart code to | |
| 106 // print the exception object, so we need to use a StartIsolateScope. | |
| 107 ASSERT(Isolate::Current() == NULL); | |
| 108 StartIsolateScope start_scope(I); | |
| 109 Thread* T = Thread::Current(); | |
| 110 ASSERT(I == T->isolate()); | |
| 111 StackZone zone(T); | |
| 112 HandleScope handle_scope(T); | |
| 113 Error& error = Error::Handle(Z); | |
| 114 error = T->sticky_error(); | |
| 115 if (!error.IsNull() && !error.IsUnwindError()) { | |
| 116 OS::PrintErr("kernel-service: Error: %s\n", error.ToErrorCString()); | |
| 117 } | |
| 118 error = I->sticky_error(); | |
| 119 if (!error.IsNull() && !error.IsUnwindError()) { | |
| 120 OS::PrintErr("kernel-service: Error: %s\n", error.ToErrorCString()); | |
| 121 } | |
| 122 Dart::RunShutdownCallback(); | |
| 123 } | |
| 124 // Shut the isolate down. | |
| 125 Dart::ShutdownIsolate(I); | |
| 126 if (FLAG_trace_kernel) { | |
| 127 OS::Print("kernel-service: Shutdown.\n"); | |
| 128 } | |
| 129 } | |
| 130 | |
| 131 bool RunMain(Isolate* I) { | |
| 132 Thread* T = Thread::Current(); | |
| 133 ASSERT(I == T->isolate()); | |
| 134 StackZone zone(T); | |
| 135 HANDLESCOPE(T); | |
| 136 // Invoke main which will return the port to which load requests are sent. | |
| 137 const Library& root_library = | |
| 138 Library::Handle(Z, I->object_store()->root_library()); | |
| 139 if (root_library.IsNull()) { | |
| 140 if (FLAG_trace_kernel) { | |
| 141 OS::Print("kernel-service: Embedder did not install a script."); | |
| 142 } | |
| 143 // Kernel isolate is not supported by embedder. | |
| 144 return false; | |
| 145 } | |
| 146 ASSERT(!root_library.IsNull()); | |
| 147 const String& entry_name = String::Handle(Z, String::New("main")); | |
| 148 ASSERT(!entry_name.IsNull()); | |
| 149 const Function& entry = Function::Handle( | |
| 150 Z, root_library.LookupFunctionAllowPrivate(entry_name)); | |
| 151 if (entry.IsNull()) { | |
| 152 // Kernel isolate is not supported by embedder. | |
| 153 if (FLAG_trace_kernel) { | |
| 154 OS::Print("kernel-service: Embedder did not provide a main function."); | |
| 155 } | |
| 156 return false; | |
| 157 } | |
| 158 ASSERT(!entry.IsNull()); | |
| 159 const Object& result = Object::Handle( | |
| 160 Z, DartEntry::InvokeFunction(entry, Object::empty_array())); | |
| 161 ASSERT(!result.IsNull()); | |
| 162 if (result.IsError()) { | |
| 163 // Kernel isolate did not initialize properly. | |
| 164 if (FLAG_trace_kernel) { | |
| 165 const Error& error = Error::Cast(result); | |
| 166 OS::Print("kernel-service: Calling main resulted in an error: %s", | |
| 167 error.ToErrorCString()); | |
| 168 } | |
| 169 return false; | |
| 170 } | |
| 171 ASSERT(result.IsReceivePort()); | |
| 172 const ReceivePort& rp = ReceivePort::Cast(result); | |
| 173 KernelIsolate::SetLoadPort(rp.Id()); | |
| 174 return true; | |
| 175 } | |
| 176 }; | |
| 177 | |
| 178 | |
| 179 void KernelIsolate::Run() { | |
| 180 ASSERT(monitor_ == NULL); | |
| 181 monitor_ = new Monitor(); | |
| 182 ASSERT(monitor_ != NULL); | |
| 183 // Grab the isolate create callback here to avoid race conditions with tests | |
| 184 // that change this after Dart_Initialize returns. | |
| 185 create_callback_ = Isolate::CreateCallback(); | |
| 186 Dart::thread_pool()->Run(new RunKernelTask()); | |
| 187 } | |
| 188 | |
| 189 | |
| 190 void KernelIsolate::InitCallback(Isolate* I) { | |
| 191 Thread* T = Thread::Current(); | |
| 192 ASSERT(I == T->isolate()); | |
| 193 ASSERT(I != NULL); | |
| 194 ASSERT(I->name() != NULL); | |
| 195 if (strstr(I->name(), "kernel-service") == NULL) { | |
| 196 // Not service isolate. | |
| 197 return; | |
| 198 } | |
| 199 ASSERT(!Exists()); | |
| 200 if (FLAG_trace_kernel) { | |
| 201 OS::Print("kernel-service: InitCallback for %s.\n", I->name()); | |
| 202 } | |
| 203 SetKernelIsolate(I); | |
| 204 } | |
| 205 | |
| 206 | |
| 207 bool KernelIsolate::IsKernelIsolate(const Isolate* isolate) { | |
| 208 MonitorLocker ml(monitor_); | |
| 209 return isolate == isolate_; | |
| 210 } | |
| 211 | |
| 212 | |
| 213 bool KernelIsolate::IsRunning() { | |
| 214 MonitorLocker ml(monitor_); | |
| 215 return (kernel_port_ != ILLEGAL_PORT) && (isolate_ != NULL); | |
| 216 } | |
| 217 | |
| 218 | |
| 219 bool KernelIsolate::Exists() { | |
| 220 MonitorLocker ml(monitor_); | |
| 221 return isolate_ != NULL; | |
| 222 } | |
| 223 | |
| 224 | |
| 225 void KernelIsolate::SetKernelIsolate(Isolate* isolate) { | |
| 226 MonitorLocker ml(monitor_); | |
| 227 isolate_ = isolate; | |
| 228 } | |
| 229 | |
| 230 void KernelIsolate::SetLoadPort(Dart_Port port) { | |
| 231 MonitorLocker ml(monitor_); | |
| 232 kernel_port_ = port; | |
| 233 } | |
| 234 | |
| 235 void KernelIsolate::FinishedInitializing() { | |
| 236 MonitorLocker ml(monitor_); | |
| 237 initializing_ = false; | |
| 238 ml.NotifyAll(); | |
| 239 } | |
| 240 | |
| 241 | |
| 242 Dart_Port KernelIsolate::WaitForKernelPort() { | |
| 243 MonitorLocker ml(monitor_); | |
| 244 while (initializing_ && (kernel_port_ == ILLEGAL_PORT)) { | |
| 245 ml.Wait(); | |
| 246 } | |
| 247 return kernel_port_; | |
| 248 } | |
| 249 | |
| 250 #endif // DART_PRECOMPILED_RUNTIME | |
| 251 | |
| 252 } // namespace dart | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 2554953004:
Revert "Add Kernel Isolate" (Closed)
