Add support for asynchronous event notification to the observatory.

runtime/vm/debugger.h

 // 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.
 
 #ifndef VM_DEBUGGER_H_
 #define VM_DEBUGGER_H_
 
 #include "include/dart_debugger_api.h"
 
 #include "vm/object.h"
@@ skipping 257 matching lines @@
  public:
   enum EventType {
     kBreakpointReached = 1,
     kBreakpointResolved = 2,
     kExceptionThrown = 3,
     kIsolateCreated = 4,
     kIsolateShutdown = 5,
     kIsolateInterrupted = 6,
   };
 
-  explicit DebuggerEvent(EventType event_type)
-      : type_(event_type),
+  explicit DebuggerEvent(Isolate* isolate, EventType event_type)
+      : isolate_(isolate),
+        type_(event_type),
         top_frame_(NULL),
         breakpoint_(NULL),
-        exception_(NULL),
-        isolate_id_(0) {}
+        exception_(NULL) {}
+
+  Isolate* isolate() const { return isolate_; }
 
   EventType type() const { return type_; }
 
   ActivationFrame* top_frame() const {
     ASSERT(type_ == kBreakpointReached);
     return top_frame_;
   }
   void set_top_frame(ActivationFrame* frame) {
     ASSERT(type_ == kBreakpointReached);
     top_frame_ = frame;
@@ skipping 11 matching lines @@
   const Object* exception() const {
     ASSERT(type_ == kExceptionThrown);
     return exception_;
   }
   void set_exception(const Object* exception) {
     ASSERT(type_ == kExceptionThrown);
     exception_ = exception;
   }
 
   Dart_Port isolate_id() const {
-    ASSERT(type_ == kIsolateCreated ||
-           type_ == kIsolateShutdown ||
-           type_ == kIsolateInterrupted);
-    return isolate_id_;
-  }
-  void set_isolate_id(Dart_Port isolate_id) {
-    ASSERT(type_ == kIsolateCreated ||
-           type_ == kIsolateShutdown ||
-           type_ == kIsolateInterrupted);
-    isolate_id_ = isolate_id;
+    return isolate_->main_port();
   }
 
   void PrintJSON(JSONStream* js) const;
 
   static const char* EventTypeToCString(EventType type);
 
  private:
+  Isolate* isolate_;
   EventType type_;
   ActivationFrame* top_frame_;
   SourceBreakpoint* breakpoint_;
   const Object* exception_;
-  Dart_Port isolate_id_;
 };
 
 
 class Debugger {
  public:
-  typedef void EventHandler(DebuggerEvent *event);
+  typedef void EventHandler(DebuggerEvent* event);
 
   Debugger();
   ~Debugger();
 
   void Initialize(Isolate* isolate);
   void Shutdown();
 
   void NotifyCompilation(const Function& func);
 
   RawFunction* ResolveFunction(const Library& library,
@@ skipping 87 matching lines @@
   static bool IsDebuggable(const Function& func);
 
  private:
   enum ResumeAction {
     kContinue,
     kStepOver,
     kStepOut,
     kSingleStep
   };
 
+  static bool HasEventHandler();
+  static void InvokeEventHandler(DebuggerEvent* event);
+
   void FindCompiledFunctions(const Script& script,
                              intptr_t start_pos,
                              intptr_t end_pos,
                              GrowableObjectArray* function_list);
   RawFunction* FindBestFit(const Script& script, intptr_t token_pos);
   RawFunction* FindInnermostClosure(const Function& function,
                                     intptr_t token_pos);
   intptr_t ResolveBreakpointPos(const Function& func,
                                 intptr_t requested_token_pos,
                                 intptr_t last_token_pos);
@@ skipping 90 matching lines @@
 
   friend class Isolate;
   friend class SourceBreakpoint;
   DISALLOW_COPY_AND_ASSIGN(Debugger);
 };
 
 
 }  // namespace dart
 
 #endif  // VM_DEBUGGER_H_