Add pause/resume for isolates in vmservice/observatory.

runtime/bin/dbg_connection.cc

 // Copyright (c) 2012, 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 "bin/dbg_connection.h"
 #include "bin/dbg_message.h"
 #include "bin/dartutils.h"
 #include "bin/log.h"
 #include "bin/socket.h"
 #include "bin/thread.h"
@@ skipping 279 matching lines @@
   }
   if (msgbuf_ != NULL) {
     delete msgbuf_;
     msgbuf_ = NULL;
   }
   // TODO(hausner): Need to tell the VM debugger object to remove all
   // breakpoints.
 }
 
 
+// The vm service relies on certain debugger functionality.
+void DebuggerConnectionHandler::InitForVmService() {
+  MonitorLocker ml(handler_lock_);
+  DbgMsgQueueList::Initialize();
+}
+
+
 int DebuggerConnectionHandler::StartHandler(const char* address,
                                             int port_number) {
   ASSERT(handler_lock_ != NULL);
   MonitorLocker ml(handler_lock_);
-  if (listener_fd_ != -1) {
+  if (IsListening()) {
     // The debugger connection handler was already started.
     return Socket::GetPort(listener_fd_);
   }
 
   // First setup breakpoint, exception and delayed breakpoint handlers.
   DbgMsgQueueList::Initialize();
 
   // Initialize the socket implementation.
   if (!Socket::Initialize()) {
     FATAL("Failed initializing socket implementation.");
@@ skipping 11 matching lines @@
   delete addresses;
   port_number = Socket::GetPort(listener_fd_);
   DebuggerConnectionImpl::StartHandler(port_number);
   return port_number;
 }
 
 
 void DebuggerConnectionHandler::WaitForConnection() {
   ASSERT(handler_lock_ != NULL);
   MonitorLocker ml(handler_lock_);
+  if (!IsListening()) {
+    // If we are only running the vm service, don't wait for
+    // connections.
+    return;
+  }
   while (!IsConnected()) {
     dart::Monitor::WaitResult res = ml.Wait();
     ASSERT(res == dart::Monitor::kNotified);
   }
 }
 
 
 void DebuggerConnectionHandler::SendMsg(int debug_fd, dart::TextBuffer* msg) {
   ASSERT(handler_lock_ != NULL);
   MonitorLocker ml(handler_lock_);
   SendMsgHelper(debug_fd, msg);
 }
 
 
 void DebuggerConnectionHandler::BroadcastMsg(dart::TextBuffer* msg) {
   ASSERT(handler_lock_ != NULL);
   MonitorLocker ml(handler_lock_);
+  if (!IsListening()) {
+    // If we are only running the vm service, don't try to broadcast
+    // to debugger clients.
+    return;
+  }
   // TODO(asiva): Once we support connection to multiple debuggers
   // we need to send the message to all of them.
   ASSERT(singleton_handler != NULL);
   SendMsgHelper(singleton_handler->debug_fd(), msg);
 }
 
 
 void DebuggerConnectionHandler::SendMsgHelper(int debug_fd,
                                               dart::TextBuffer* msg) {
   ASSERT(debug_fd >= 0);
@@ skipping 119 matching lines @@
 
 
 bool DebuggerConnectionHandler::IsConnected() {
   // TODO(asiva): Support multiple debugger connections.
   // Return true if a connection has been established.
   return singleton_handler != NULL;
 }
 
 }  // namespace bin
 }  // namespace dart