- Allow an isolate to be started in paused state.

runtime/vm/isolate.cc

 // Copyright (c) 2013, 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/isolate.h"
 
 #include "include/dart_api.h"
 #include "platform/assert.h"
 #include "platform/json.h"
 #include "vm/code_observers.h"
@@ skipping 941 matching lines @@
     // debugging.  Remove this once the vmservice becomes the standard
     // way to debug.
     if (FLAG_break_at_isolate_spawn) {
       isolate->debugger()->OneTimeBreakAtEntry(func);
     }
 
     const Array& capabilities = Array::Handle(Array::New(2));
     Capability& capability = Capability::Handle();
     capability = Capability::New(isolate->pause_capability());
     capabilities.SetAt(0, capability);
+    // Check whether this isolate should be started in paused state.
+    if (state->paused()) {
+      bool added = isolate->AddResumeCapability(capability);
+      ASSERT(added);  // There should be no pending resume capabilities.
+      isolate->message_handler()->increment_paused();
+    }
     capability = Capability::New(isolate->terminate_capability());
     capabilities.SetAt(1, capability);
 
     // Instead of directly invoking the entry point we call '_startIsolate' with
     // the entry point as argument.
     // Since this function ("RunIsolate") is used for both Isolate.spawn and
     // Isolate.spawnUri we also send a boolean flag as argument so that the
     // "_startIsolate" function can act corresponding to how the isolate was
     // created.
     const Array& args = Array::Handle(Array::New(7));
@@ skipping 557 matching lines @@
   const Object& obj = Object::Handle(isolate, reader.ReadObject());
   ASSERT(!obj.IsError());
   Instance& instance = Instance::Handle(isolate);
   instance ^= obj.raw();  // Can't use Instance::Cast because may be null.
   return instance.raw();
 }
 
 
 IsolateSpawnState::IsolateSpawnState(Dart_Port parent_port,
                                      const Function& func,
-                                     const Instance& message)
+                                     const Instance& message,
+                                     bool paused)
     : isolate_(NULL),
       parent_port_(parent_port),
       script_url_(NULL),
       package_root_(NULL),
       library_url_(NULL),
       class_name_(NULL),
       function_name_(NULL),
       exception_callback_name_(NULL),
       serialized_args_(NULL),
       serialized_args_len_(0),
       serialized_message_(NULL),
-      serialized_message_len_(0) {
+      serialized_message_len_(0),
+      paused_(paused) {
   script_url_ = NULL;
   const Class& cls = Class::Handle(func.Owner());
   const Library& lib = Library::Handle(cls.library());
   const String& lib_url = String::Handle(lib.url());
   library_url_ = strdup(lib_url.ToCString());
 
   const String& func_name = String::Handle(func.name());
   function_name_ = strdup(func_name.ToCString());
   if (!cls.IsTopLevel()) {
     const String& class_name = String::Handle(cls.Name());
     class_name_ = strdup(class_name.ToCString());
   }
   exception_callback_name_ = strdup("_unhandledExceptionCallback");
   SerializeObject(message, &serialized_message_, &serialized_message_len_);
 }
 
 
 IsolateSpawnState::IsolateSpawnState(Dart_Port parent_port,
                                      const char* script_url,
                                      const char* package_root,
                                      const Instance& args,
-                                     const Instance& message)
+                                     const Instance& message,
+                                     bool paused)
     : isolate_(NULL),
       parent_port_(parent_port),
       package_root_(NULL),
       library_url_(NULL),
       class_name_(NULL),
       function_name_(NULL),
       exception_callback_name_(NULL),
       serialized_args_(NULL),
       serialized_args_len_(0),
       serialized_message_(NULL),
-      serialized_message_len_(0) {
+      serialized_message_len_(0),
+      paused_(paused) {
   script_url_ = strdup(script_url);
   if (package_root != NULL) {
     package_root_ = strdup(package_root);
   }
   library_url_ = NULL;
   function_name_ = strdup("main");
   exception_callback_name_ = strdup("_unhandledExceptionCallback");
   SerializeObject(args, &serialized_args_, &serialized_args_len_);
   SerializeObject(message, &serialized_message_, &serialized_message_len_);
 }
@@ skipping 74 matching lines @@
                            serialized_message_, serialized_message_len_);
 }
 
 
 void IsolateSpawnState::Cleanup() {
   SwitchIsolateScope switch_scope(I);
   Dart::ShutdownIsolate();
 }
 
 }  // namespace dart