OLD | NEW |
1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | 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 | 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. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #include "vm/kernel_isolate.h" | 5 #include "vm/kernel_isolate.h" |
6 | 6 |
7 #include "bin/dartutils.h" | 7 #include "bin/dartutils.h" |
8 #include "include/dart_native_api.h" | 8 #include "include/dart_native_api.h" |
9 #include "vm/compiler.h" | 9 #include "vm/compiler.h" |
10 #include "vm/dart_api_impl.h" | 10 #include "vm/dart_api_impl.h" |
(...skipping 28 matching lines...) Expand all Loading... |
39 false, | 39 false, |
40 "Show Kernel service isolate as normal isolate."); | 40 "Show Kernel service isolate as normal isolate."); |
41 | 41 |
42 const char* KernelIsolate::kName = DART_KERNEL_ISOLATE_NAME; | 42 const char* KernelIsolate::kName = DART_KERNEL_ISOLATE_NAME; |
43 Dart_IsolateCreateCallback KernelIsolate::create_callback_ = NULL; | 43 Dart_IsolateCreateCallback KernelIsolate::create_callback_ = NULL; |
44 Monitor* KernelIsolate::monitor_ = new Monitor(); | 44 Monitor* KernelIsolate::monitor_ = new Monitor(); |
45 Isolate* KernelIsolate::isolate_ = NULL; | 45 Isolate* KernelIsolate::isolate_ = NULL; |
46 bool KernelIsolate::initializing_ = true; | 46 bool KernelIsolate::initializing_ = true; |
47 Dart_Port KernelIsolate::kernel_port_ = ILLEGAL_PORT; | 47 Dart_Port KernelIsolate::kernel_port_ = ILLEGAL_PORT; |
48 | 48 |
49 | |
50 class RunKernelTask : public ThreadPool::Task { | 49 class RunKernelTask : public ThreadPool::Task { |
51 public: | 50 public: |
52 virtual void Run() { | 51 virtual void Run() { |
53 ASSERT(Isolate::Current() == NULL); | 52 ASSERT(Isolate::Current() == NULL); |
54 | 53 |
55 if (!FLAG_use_dart_frontend) { | 54 if (!FLAG_use_dart_frontend) { |
56 ASSERT(FLAG_use_dart_frontend); | 55 ASSERT(FLAG_use_dart_frontend); |
57 // In release builds, make this a no-op. In debug builds, the | 56 // In release builds, make this a no-op. In debug builds, the |
58 // assert shows that this is not supposed to happen. | 57 // assert shows that this is not supposed to happen. |
59 return; | 58 return; |
(...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
192 error.ToErrorCString()); | 191 error.ToErrorCString()); |
193 return false; | 192 return false; |
194 } | 193 } |
195 ASSERT(result.IsReceivePort()); | 194 ASSERT(result.IsReceivePort()); |
196 const ReceivePort& rp = ReceivePort::Cast(result); | 195 const ReceivePort& rp = ReceivePort::Cast(result); |
197 KernelIsolate::SetLoadPort(rp.Id()); | 196 KernelIsolate::SetLoadPort(rp.Id()); |
198 return true; | 197 return true; |
199 } | 198 } |
200 }; | 199 }; |
201 | 200 |
202 | |
203 void KernelIsolate::Run() { | 201 void KernelIsolate::Run() { |
204 if (!FLAG_use_dart_frontend) { | 202 if (!FLAG_use_dart_frontend) { |
205 return; | 203 return; |
206 } | 204 } |
207 // Grab the isolate create callback here to avoid race conditions with tests | 205 // Grab the isolate create callback here to avoid race conditions with tests |
208 // that change this after Dart_Initialize returns. | 206 // that change this after Dart_Initialize returns. |
209 create_callback_ = Isolate::CreateCallback(); | 207 create_callback_ = Isolate::CreateCallback(); |
210 Dart::thread_pool()->Run(new RunKernelTask()); | 208 Dart::thread_pool()->Run(new RunKernelTask()); |
211 } | 209 } |
212 | 210 |
213 | |
214 void KernelIsolate::InitCallback(Isolate* I) { | 211 void KernelIsolate::InitCallback(Isolate* I) { |
215 Thread* T = Thread::Current(); | 212 Thread* T = Thread::Current(); |
216 ASSERT(I == T->isolate()); | 213 ASSERT(I == T->isolate()); |
217 ASSERT(I != NULL); | 214 ASSERT(I != NULL); |
218 ASSERT(I->name() != NULL); | 215 ASSERT(I->name() != NULL); |
219 if (!FLAG_use_dart_frontend || | 216 if (!FLAG_use_dart_frontend || |
220 (strstr(I->name(), DART_KERNEL_ISOLATE_NAME) == NULL)) { | 217 (strstr(I->name(), DART_KERNEL_ISOLATE_NAME) == NULL)) { |
221 // Not kernel isolate. | 218 // Not kernel isolate. |
222 return; | 219 return; |
223 } | 220 } |
224 ASSERT(!Exists()); | 221 ASSERT(!Exists()); |
225 if (FLAG_trace_kernel) { | 222 if (FLAG_trace_kernel) { |
226 OS::Print(DART_KERNEL_ISOLATE_NAME ": InitCallback for %s.\n", I->name()); | 223 OS::Print(DART_KERNEL_ISOLATE_NAME ": InitCallback for %s.\n", I->name()); |
227 } | 224 } |
228 SetKernelIsolate(I); | 225 SetKernelIsolate(I); |
229 } | 226 } |
230 | 227 |
231 | |
232 bool KernelIsolate::IsKernelIsolate(const Isolate* isolate) { | 228 bool KernelIsolate::IsKernelIsolate(const Isolate* isolate) { |
233 MonitorLocker ml(monitor_); | 229 MonitorLocker ml(monitor_); |
234 return isolate == isolate_; | 230 return isolate == isolate_; |
235 } | 231 } |
236 | 232 |
237 | |
238 bool KernelIsolate::IsRunning() { | 233 bool KernelIsolate::IsRunning() { |
239 MonitorLocker ml(monitor_); | 234 MonitorLocker ml(monitor_); |
240 return (kernel_port_ != ILLEGAL_PORT) && (isolate_ != NULL); | 235 return (kernel_port_ != ILLEGAL_PORT) && (isolate_ != NULL); |
241 } | 236 } |
242 | 237 |
243 | |
244 bool KernelIsolate::Exists() { | 238 bool KernelIsolate::Exists() { |
245 MonitorLocker ml(monitor_); | 239 MonitorLocker ml(monitor_); |
246 return isolate_ != NULL; | 240 return isolate_ != NULL; |
247 } | 241 } |
248 | 242 |
249 | |
250 void KernelIsolate::SetKernelIsolate(Isolate* isolate) { | 243 void KernelIsolate::SetKernelIsolate(Isolate* isolate) { |
251 MonitorLocker ml(monitor_); | 244 MonitorLocker ml(monitor_); |
252 isolate_ = isolate; | 245 isolate_ = isolate; |
253 } | 246 } |
254 | 247 |
255 | |
256 void KernelIsolate::SetLoadPort(Dart_Port port) { | 248 void KernelIsolate::SetLoadPort(Dart_Port port) { |
257 MonitorLocker ml(monitor_); | 249 MonitorLocker ml(monitor_); |
258 kernel_port_ = port; | 250 kernel_port_ = port; |
259 } | 251 } |
260 | 252 |
261 | |
262 void KernelIsolate::FinishedInitializing() { | 253 void KernelIsolate::FinishedInitializing() { |
263 MonitorLocker ml(monitor_); | 254 MonitorLocker ml(monitor_); |
264 initializing_ = false; | 255 initializing_ = false; |
265 ml.NotifyAll(); | 256 ml.NotifyAll(); |
266 } | 257 } |
267 | 258 |
268 | |
269 Dart_Port KernelIsolate::WaitForKernelPort() { | 259 Dart_Port KernelIsolate::WaitForKernelPort() { |
270 if (!FLAG_use_dart_frontend) { | 260 if (!FLAG_use_dart_frontend) { |
271 return ILLEGAL_PORT; | 261 return ILLEGAL_PORT; |
272 } | 262 } |
273 MonitorLocker ml(monitor_); | 263 MonitorLocker ml(monitor_); |
274 while (initializing_ && (kernel_port_ == ILLEGAL_PORT)) { | 264 while (initializing_ && (kernel_port_ == ILLEGAL_PORT)) { |
275 ml.Wait(); | 265 ml.Wait(); |
276 } | 266 } |
277 return kernel_port_; | 267 return kernel_port_; |
278 } | 268 } |
279 | 269 |
280 | |
281 class KernelCompilationRequest : public ValueObject { | 270 class KernelCompilationRequest : public ValueObject { |
282 public: | 271 public: |
283 KernelCompilationRequest() | 272 KernelCompilationRequest() |
284 : monitor_(new Monitor()), | 273 : monitor_(new Monitor()), |
285 port_(Dart_NewNativePort("kernel-compilation-port", | 274 port_(Dart_NewNativePort("kernel-compilation-port", |
286 &HandleResponse, | 275 &HandleResponse, |
287 false)), | 276 false)), |
288 next_(NULL), | 277 next_(NULL), |
289 prev_(NULL) { | 278 prev_(NULL) { |
290 ASSERT(port_ != ILLEGAL_PORT); | 279 ASSERT(port_ != ILLEGAL_PORT); |
(...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
478 result.status = Dart_KernelCompilationStatus_Unknown; | 467 result.status = Dart_KernelCompilationStatus_Unknown; |
479 result.error = strdup("Error while initializing Kernel isolate"); | 468 result.error = strdup("Error while initializing Kernel isolate"); |
480 return result; | 469 return result; |
481 } | 470 } |
482 | 471 |
483 KernelCompilationRequest request; | 472 KernelCompilationRequest request; |
484 return request.SendAndWaitForResponse(kernel_port, script_uri, | 473 return request.SendAndWaitForResponse(kernel_port, script_uri, |
485 source_file_count, source_files); | 474 source_file_count, source_files); |
486 } | 475 } |
487 | 476 |
488 | |
489 #endif // DART_PRECOMPILED_RUNTIME | 477 #endif // DART_PRECOMPILED_RUNTIME |
490 | 478 |
491 } // namespace dart | 479 } // namespace dart |
OLD | NEW |