Add Observatory to sky dart_controller

mojo/dart/embedder/dart_debugger.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
-#include <vector>
-
+#include "mojo/dart/embedder/dart_debugger.h"
 #include "dart/runtime/include/dart_api.h"
 #include "dart/runtime/include/dart_debugger_api.h"
 #include "dart/runtime/include/dart_native_api.h"
-#include "mojo/dart/embedder/dart_debugger.h"
+
 
 namespace mojo {
 namespace dart {
 
 void DartDebuggerIsolate::MessageLoop() {
   MonitorLocker ml(&monitor_);
   // Request notification on isolate messages.  This allows us to
   // respond to vm service messages while at breakpoint.
   Dart_SetMessageNotifyCallback(DartDebugger::NotifyIsolate);
   while (true) {
@@ skipping 17 matching lines @@
                                       intptr_t bp_id,
                                       const Dart_CodeLocation& location) {
   // Nothing to do here. Service event is dispatched to let Observatory know
   // that a breakpoint was resolved.
 }
 
 void DartDebugger::PausedEventHandler(Dart_IsolateId isolate_id,
                                       intptr_t bp_id,
                                       const Dart_CodeLocation& loc) {
   Dart_EnterScope();
-  DartDebuggerIsolate* debugger_isolate =
-      FindIsolateById(isolate_id);
-  CHECK(debugger_isolate != nullptr);
-  debugger_isolate->MessageLoop();
+  intptr_t isolate_index = FindIsolateIndexById(isolate_id);
+  CHECK(isolate_index != -1);
+  (*isolates_)[isolate_index]->MessageLoop();
   Dart_ExitScope();
 }
 
 void DartDebugger::ExceptionThrownHandler(Dart_IsolateId isolate_id,
                                           Dart_Handle exception,
                                           Dart_StackTrace stack_trace) {
   Dart_EnterScope();
-  DartDebuggerIsolate* debugger_isolate =
-      FindIsolateById(isolate_id);
-  CHECK(debugger_isolate != nullptr);
-  debugger_isolate->MessageLoop();
+  intptr_t isolate_index = FindIsolateIndexById(isolate_id);
+  CHECK(isolate_index != -1);
+  (*isolates_)[isolate_index]->MessageLoop();
   Dart_ExitScope();
 }
 
 void DartDebugger::IsolateEventHandler(Dart_IsolateId isolate_id,
                                        Dart_IsolateEvent kind) {
   Dart_EnterScope();
   if (kind == Dart_IsolateEvent::kCreated) {
     AddIsolate(isolate_id);
   } else {
-    DartDebuggerIsolate* debugger_isolate =
-        FindIsolateById(isolate_id);
-    CHECK(debugger_isolate != nullptr);
+    intptr_t isolate_index = FindIsolateIndexById(isolate_id);
+    CHECK(isolate_index != -1);
     if (kind == Dart_IsolateEvent::kInterrupted) {
-      debugger_isolate->MessageLoop();
+      (*isolates_)[isolate_index]->MessageLoop();
     } else {
       CHECK(kind == Dart_IsolateEvent::kShutdown);
       RemoveIsolate(isolate_id);
     }
   }
   Dart_ExitScope();
 }
 
 void DartDebugger::NotifyIsolate(Dart_Isolate isolate) {
   base::AutoLock al(*lock_);
   Dart_IsolateId isolate_id = Dart_GetIsolateId(isolate);
-  DartDebuggerIsolate* debugger_isolate =
-      FindIsolateByIdLocked(isolate_id);
-  if (debugger_isolate != nullptr) {
-    debugger_isolate->Notify();
+  intptr_t isolate_index = FindIsolateIndexByIdLocked(isolate_id);
+  if (isolate_index >= 0) {
+    (*isolates_)[isolate_index]->Notify();
   }
 }
 
 void DartDebugger::InitDebugger() {
   Dart_SetIsolateEventHandler(IsolateEventHandler);
   Dart_SetPausedEventHandler(PausedEventHandler);
   Dart_SetBreakpointResolvedHandler(BptResolvedHandler);
   Dart_SetExceptionThrownHandler(ExceptionThrownHandler);
   lock_ = new base::Lock();
+  isolates_ = new std::vector<std::unique_ptr<DartDebuggerIsolate>>();
 }
 
-DartDebuggerIsolate* DartDebugger::FindIsolateById(Dart_IsolateId id) {
+intptr_t DartDebugger::FindIsolateIndexById(Dart_IsolateId id) {
   base::AutoLock al(*lock_);
-  return FindIsolateByIdLocked(id);
+  return FindIsolateIndexByIdLocked(id);
 }
 
-DartDebuggerIsolate* DartDebugger::FindIsolateByIdLocked(
+intptr_t DartDebugger::FindIsolateIndexByIdLocked(
       Dart_IsolateId id) {
   lock_->AssertAcquired();
-  for (size_t i = 0; i < isolates_.size(); i++) {
-    DartDebuggerIsolate* isolate = isolates_[i];
-    if (id == isolate->id()) {
-      return isolate;
+  for (size_t i = 0; i < isolates_->size(); i++) {
+    if ((*isolates_)[i]->id() == id) {
+      return i;
     }
   }
-  return nullptr;
+  return -1;
 }
 
-DartDebuggerIsolate* DartDebugger::AddIsolate(Dart_IsolateId id) {
+void DartDebugger::AddIsolate(Dart_IsolateId id) {
   base::AutoLock al(*lock_);
-  CHECK(FindIsolateByIdLocked(id) == nullptr);
-  DartDebuggerIsolate* debugger_isolate =
-      new DartDebuggerIsolate(id);
-  isolates_.push_back(debugger_isolate);
-  return debugger_isolate;
+  CHECK(FindIsolateIndexByIdLocked(id) == -1);
+  std::unique_ptr<DartDebuggerIsolate> debugger_isolate =
+      std::unique_ptr<DartDebuggerIsolate>(new DartDebuggerIsolate(id));
+  isolates_->push_back(std::move(debugger_isolate));
 }
 
 void DartDebugger::RemoveIsolate(Dart_IsolateId id) {
   base::AutoLock al(*lock_);
-  for (size_t i = 0; i < isolates_.size(); i++) {
-    DartDebuggerIsolate* isolate = isolates_[i];
-    if (id == isolate->id()) {
-      isolates_.erase(isolates_.begin() + i);
+  for (size_t i = 0; i < isolates_->size(); i++) {
+    if (id == (*isolates_)[i]->id()) {
+      isolates_->erase(isolates_->begin() + i);
       return;
     }
   }
   NOTREACHED();
 }
 
 base::Lock* DartDebugger::lock_ = nullptr;
-std::vector<DartDebuggerIsolate*> DartDebugger::isolates_;
+std::vector<std::unique_ptr<DartDebuggerIsolate>>* DartDebugger::isolates_ =
+    nullptr;
 
-}  // namespace apps
+}  // namespace dart
 }  // namespace mojo