- Add support to interrupt a running isolate

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/socket.h"
 #include "bin/thread.h"
 #include "bin/utils.h"
@@ skipping 149 matching lines @@
 }
 
 
 void DebuggerConnectionHandler::HandleUnknownMsg() {
   int msg_id = msgbuf_->MessageId();
   ASSERT(msg_id >= 0);
   SendError(debug_fd_, msg_id, "unknown debugger command");
 }
 
 
-typedef void (*CommandHandler)(DebuggerConnectionHandler* handler);
+typedef void (*CommandHandler)(DbgMessage* msg);
 
 struct JSONDebuggerCommand {
   const char* cmd_string;
   CommandHandler handler_function;
 };
 
 
 void DebuggerConnectionHandler::HandleMessages() {
   static JSONDebuggerCommand generic_debugger_commands[] = {
     { "interrupt", HandleInterruptCmd },
     { "isolates", HandleIsolatesListCmd },
-    { "quit", HandleQuitCmd },
     { NULL, NULL }
   };
 
   for (;;) {
     // Read a message.
     while (!msgbuf_->IsValidMessage() && msgbuf_->Alive()) {
       msgbuf_->ReadData();
     }
     if (!msgbuf_->Alive()) {
       return;
     }
 
     // Parse out the command portion from the message.
     dart::JSONReader r(msgbuf_->buf());
     bool found = r.Seek("command");
     if (r.Error()) {
       FATAL("Illegal JSON message received");
     }
     if (!found) {
       printf("'command' not found in JSON message: '%s'\n", msgbuf_->buf());
       msgbuf_->PopMessage();
     }
 
     // Check if this is a generic command (not isolate specific).
     int i = 0;
     bool is_handled = false;
     while (generic_debugger_commands[i].cmd_string != NULL) {
       if (r.IsStringLiteral(generic_debugger_commands[i].cmd_string)) {
-        (*generic_debugger_commands[i].handler_function)(this);
+        DbgMessage* msg = new DbgMessage(i,
+                                         msgbuf_->buf(),
+                                         r.EndOfObject(),
+                                         debug_fd_);
+        (*generic_debugger_commands[i].handler_function)(msg);
         is_handled = true;
         msgbuf_->PopMessage();
+        delete msg;
         break;
       }
       i++;
     }
     if (!is_handled) {
       // Check if this is an isolate specific command.
-      int32_t cmd_idx = DbgMessageQueue::LookupIsolateCommand(r.ValueChars(),
+      int32_t cmd_idx = DbgMsgQueueList::LookupIsolateCommand(r.ValueChars(),
                                                               r.ValueLen());
-      if (cmd_idx != DbgMessageQueue::kInvalidCommand) {
+      if (cmd_idx != DbgMsgQueueList::kInvalidCommand) {
         // Get debug message queue corresponding to isolate.
-        // TODO(asiva): Need to read the isolate id, map it to the appropriate
-        // isolate and pass it down to GetIsolateMessageQueue to get the
-        // appropriate debug message queue.
-        DbgMessageQueue* queue = DbgMessageQueue::GetIsolateMessageQueue(NULL);
+        // TODO(asiva): Once we have support for including the isolate id
+        // in the debug wire protocol we need to read the isolate id and
+        // pass it down to GetIsolateMsgQueue to get the appropriate debug
+        // message queue.
+        DbgMsgQueue* queue =
+            DbgMsgQueueList::GetIsolateMsgQueue(ILLEGAL_ISOLATE_ID);
         ASSERT(queue != NULL);
         queue->AddMessage(cmd_idx, msgbuf_->buf(), r.EndOfObject(), debug_fd_);
         msgbuf_->PopMessage();
         continue;
       }
 
       // This is an unrecognized command, report error and move on to next.
       printf("unrecognized command received: '%s'\n", msgbuf_->buf());
       HandleUnknownMsg();
       msgbuf_->PopMessage();
@@ skipping 25 matching lines @@
 
 
 void DebuggerConnectionHandler::StartHandler(const char* address,
                                              int port_number) {
   MonitorLocker ml(&handler_lock_);
   if (listener_fd_ != -1) {
     return;  // The debugger connection handler was already started.
   }
 
   // First setup breakpoint, exception and delayed breakpoint handlers.
-  DbgMessageQueue::Initialize();
+  DbgMsgQueueList::Initialize();
 
   // Now setup a listener socket and start a thread which will
   // listen, accept connections from debuggers, read and handle/dispatch
   // debugger commands received on these connections.
   ASSERT(listener_fd_ == -1);
   listener_fd_ = ServerSocket::CreateBindListen(address, port_number, 1);
   DebuggerConnectionImpl::StartHandler(port_number);
 }
 
 
@@ skipping 71 matching lines @@
   // corresponding to that fd and invoke HandleMessages on it.
   // For now we run that code here.
   DebuggerConnectionHandler* handler = GetDebuggerConnectionHandler(debug_fd);
   if (handler != NULL) {
     handler->HandleMessages();
     delete handler;
   }
 }
 
 
-void DebuggerConnectionHandler::HandleInterruptCmd(
-    DebuggerConnectionHandler* handler) {
-  int msg_id = handler->MessageId();
-  ASSERT(msg_id >= 0);
-  SendError(handler->debug_fd(), msg_id, "interrupt command unimplemented");
+void DebuggerConnectionHandler::HandleInterruptCmd(DbgMessage* in_msg) {
+  MessageParser msg_parser(in_msg->buffer(), in_msg->buffer_len());
+  int msg_id = msg_parser.MessageId();
+  Dart_IsolateId isolate_id =
+      static_cast<Dart_IsolateId>(msg_parser.GetIntParam("isolateId"));
+  if (isolate_id == ILLEGAL_ISOLATE_ID || Dart_GetIsolate(isolate_id) == NULL) {
+    in_msg->SendErrorReply(msg_id, "Invalid isolate specified");
+    return;
+  }
+  DbgMsgQueue* queue = DbgMsgQueueList::GetIsolateMsgQueue(isolate_id);
+  ASSERT(queue != NULL);
+  queue->InterruptIsolate();
+  dart::TextBuffer msg(64);
+  msg.Printf("{ \"id\": %d }", msg_id);
+  in_msg->SendReply(&msg);
 }
 
 
-void DebuggerConnectionHandler::HandleIsolatesListCmd(
-    DebuggerConnectionHandler* handler) {
-  int msg_id = handler->MessageId();
+void DebuggerConnectionHandler::HandleIsolatesListCmd(DbgMessage* in_msg) {
+  MessageParser msg_parser(in_msg->buffer(), in_msg->buffer_len());
+  int msg_id = msg_parser.MessageId();
   ASSERT(msg_id >= 0);
-  SendError(handler->debug_fd(), msg_id, "isolate list command unimplemented");
-}
-
-
-void DebuggerConnectionHandler::HandleQuitCmd(
-    DebuggerConnectionHandler* handler) {
-  int msg_id = handler->MessageId();
-  ASSERT(msg_id >= 0);
-  SendError(handler->debug_fd(), msg_id, "quit command unimplemented");
+  in_msg->SendErrorReply(msg_id, "isolate list command unimplemented");
 }
 
 
 void DebuggerConnectionHandler::AddNewDebuggerConnection(int debug_fd) {
   // TODO(asiva): Support multiple debugger connections, for now we just
   // create one handler, store it in a static variable and use it.
   ASSERT(singleton_handler == NULL);
   singleton_handler = new DebuggerConnectionHandler(debug_fd);
 }
 
@@ skipping 13 matching lines @@
   ASSERT(singleton_handler != NULL);
   return singleton_handler;
 }
 
 
 bool DebuggerConnectionHandler::IsConnected() {
   // TODO(asiva): Support multiple debugger connections.
   // Return true if a connection has been established.
   return singleton_handler != NULL;
 }