Initial Implementation of the vm-service protocol

src/vm/session.cc

 // Copyright (c) 2014, the Dartino 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.md file.
 
 #ifdef DARTINO_ENABLE_DEBUGGING
 
 #include "src/vm/session.h"
 
 #include "src/shared/bytecodes.h"
 #include "src/shared/connection.h"
@@ skipping 297 matching lines @@
   }
 
   Scheduler::ProcessInterruptionEvent HandleUncaughtException(
       Process* process) {
     if (IsDebuggingEnabled() || ObserveTermination(process)) {
       ProcessDebugInfo* debug_info = process->debug_info();
       if (debug_info->is_stepping()) {
         debug_info->ClearSteppingInterrupted();
       }
       WriteBuffer buffer;
+      buffer.WriteInt(debug_info->process_id());
+      session()->PushTopStackFrame(process->stack());
+      buffer.WriteInt64(
+          session()->FunctionMessage(Function::cast(session()->Top())));
+      // Drop function from session stack.
+      session()->Drop(1);
+      // Pop bytecode index from session stack and send it.
+      buffer.WriteInt64(session()->PopInteger());
       connection()->Send(Connection::kUncaughtException, buffer);
       // If observing termination, remain paused to allow access to the
       // termination state.
       return Scheduler::kRemainPaused;
     }
     return Scheduler::kExitWithUncaughtException;
   }
 
   Scheduler::ProcessInterruptionEvent HandleCompileTimeError(Process* process) {
     if (IsDebuggingEnabled() || ObserveTermination(process)) {
@@ skipping 511 matching lines @@
     case Connection::kMapLookup: {
       ASSERT(!IsScheduled() || IsPaused());
       int map_index = connection()->ReadInt();
       WriteBuffer buffer;
       buffer.WriteInt64(
           session()->MapLookupByObject(map_index, session()->Top()));
       connection()->Send(Connection::kObjectId, buffer);
       break;
     }
 
+    case Connection::kProcessGetProcessIds: {
+      int count = 0;
+      auto processes = program()->process_list();
+      for (auto process : *processes) {
+        USE(process);
+        ++count;
+      }
+      WriteBuffer buffer;
+      buffer.WriteInt(count);
+      for (auto process : *processes) {
+        process->EnsureDebuggerAttached();
+        buffer.WriteInt(process->debug_info()->process_id());
+      }
+      connection()->Send(Connection::kProcessGetProcessIdsResult, buffer);
+      break;
+    }
+
 #ifdef DARTINO_ENABLE_LIVE_CODING
     case Connection::kSetEntryPoint: {
       program()->set_entry(Function::cast(session()->Pop()));
       break;
     }
 
     case Connection::kCreateSnapshot: {
       ASSERT(!IsScheduled());
       bool writeToDisk = connection()->ReadBoolean();
       int length;
@@ skipping 501 matching lines @@
         stack->set_next(Smi::FromWord(0));
       }
       ASSERT(current == NULL);
       program()->ClearStackChain();
       WriteBuffer buffer;
       buffer.WriteInt(number_of_stacks);
       connection()->Send(Connection::kProcessNumberOfStacks, buffer);
       break;
     }
 
-    case Connection::kProcessGetProcessIds: {
-      int count = 0;
-      auto processes = program()->process_list();
-      for (auto process : *processes) {
-        USE(process);
-        ++count;
-      }
-      WriteBuffer buffer;
-      buffer.WriteInt(count);
-      for (auto process : *processes) {
-        process->EnsureDebuggerAttached();
-        buffer.WriteInt(process->debug_info()->process_id());
-      }
-      connection()->Send(Connection::kProcessGetProcessIdsResult, buffer);
-      break;
-    }
-
     default: {
       return ScheduledState::ProcessMessage(opcode);
     }
   }
   return this;
 }
 
 SessionState* TerminatedState::ProcessMessage(Connection::Opcode opcode) {
   if (opcode == Connection::kSessionEnd) {
     session()->SignalMainThread(Session::kSessionEnd);
@@ skipping 824 matching lines @@
   if (program()->was_loaded_from_snapshot()) {
     return program()->OffsetOf(HeapObject::cast(klass));
   } else {
     return MapLookupByObject(class_map_id_, klass);
   }
 }
 
 }  // namespace dartino
 
 #endif  // DARTINO_ENABLE_DEBUGGING