Allow setting break-on-exceptions option over the service protocol.

runtime/observatory/lib/src/service/object.dart

 // Copyright (c) 2014, 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.
 
 part of service;
 
 /// An RpcException represents an exceptional event that happened
 /// while invoking an rpc.
 abstract class RpcException implements Exception {
   RpcException(this.message);
@@ skipping 113 matching lines @@
   bool get isPlainInstance => false;
 
   /// Has this object been fully loaded?
   bool get loaded => _loaded;
   bool _loaded = false;
   // TODO(turnidge): Make loaded observable and get rid of loading
   // from Isolate.
 
   /// Is this object cacheable?  That is, is it impossible for the [id]
   /// of this object to change?
-  bool get canCache => false;
+  bool _canCache;
+  bool get canCache => _canCache;
 
   /// Is this object immutable after it is [loaded]?
   bool get immutable => false;
 
   @observable String name;
   @observable String vmName;
 
   /// Creates an empty [ServiceObject].
   ServiceObject._empty(this._owner);
 
@@ skipping 152 matching lines @@
 
   /// Update [this] using [map] as a source. [map] can be a reference.
   void update(ObservableMap map) {
     assert(_isServiceMap(map));
 
     // Don't allow the type to change on an object update.
     var mapIsRef = _hasRef(map['type']);
     var mapType = _stripRef(map['type']);
     assert(_type == null || _type == mapType);
 
+    _canCache = map['fixedId'] == true;
     if (_id != null && _id != map['id']) {
       // It is only safe to change an id when the object isn't cacheable.
       assert(!canCache);
     }
     _id = map['id'];
 
     _type = mapType;
 
     // When the response specifies a specific vmType, use it.
     // Otherwise the vmType of the response is the same as the 'user'
@@ skipping 784 matching lines @@
     timers['compile'] = timerMap['time_compilation'];
     timers['gc'] = 0.0;  // TODO(turnidge): Export this from VM.
     timers['init'] = (timerMap['time_script_loading'] +
                       timerMap['time_creating_snapshot'] +
                       timerMap['time_isolate_initialization'] +
                       timerMap['time_bootstrap']);
     timers['dart'] = timerMap['time_dart_execution'];
 
     updateHeapsFromMap(map['_heaps']);
     _updateBreakpoints(map['breakpoints']);
+    exceptionsPauseInfo = map['_debuggerSettings']['_exceptions'];
 
     pauseEvent = map['pauseEvent'];
     _updateRunState();
     error = map['error'];
 
     libraries.clear();
     libraries.addAll(map['libraries']);
     libraries.sort(ServiceObject.LexicalSortName);
   }
 
   Future<TagProfile> updateTagProfile() {
     return isolate.invokeRpcNoUpgrade('_getTagProfile', {}).then(
       (ObservableMap map) {
         var seconds = new DateTime.now().millisecondsSinceEpoch / 1000.0;
         tagProfile._processTagProfile(seconds, map);
         return tagProfile;
       });
   }
 
   ObservableMap<int, Breakpoint> breakpoints = new ObservableMap();
+  String exceptionsPauseInfo;
 
   void _updateBreakpoints(List newBpts) {
     // Build a set of new breakpoints.
     var newBptSet = new Set();
     newBpts.forEach((bpt) => newBptSet.add(bpt.number));
 
     // Remove any old breakpoints which no longer exist.
     List toRemove = [];
     breakpoints.forEach((key, _) {
       if (!newBptSet.contains(key)) {
@@ skipping 22 matching lines @@
       case ServiceEvent.kInspect:
         // Handled elsewhere.
         break;
 
       case ServiceEvent.kBreakpointAdded:
         _addBreakpoint(event.breakpoint);
         break;
 
       case ServiceEvent.kIsolateUpdate:
       case ServiceEvent.kBreakpointResolved:
+      case ServiceEvent.kDebuggerSettingsUpdate:
         // Update occurs as side-effect of caching.
         break;
 
       case ServiceEvent.kBreakpointRemoved:
         _removeBreakpoint(event.breakpoint);
         break;
 
       case ServiceEvent.kPauseStart:
       case ServiceEvent.kPauseExit:
       case ServiceEvent.kPauseBreakpoint:
@@ skipping 75 matching lines @@
   }
 
   Future stepOut() {
     return invokeRpc('resume', {'step': 'Out'});
   }
 
   Future setName(String newName) {
     return invokeRpc('setName', {'name': newName});
   }
 
+  Future setExceptionPauseInfo(String exceptions) {
+    return invokeRpc('_setExceptionPauseInfo', {'exceptions': exceptions});
+  }
+
   Future<ServiceMap> getStack() {
     return invokeRpc('getStack', {});
   }
 
   Future<ServiceObject> _eval(ServiceObject target,
                               String expression) {
     Map params = {
       'targetId': target.id,
       'expression': expression,
     };
@@ skipping 170 matching lines @@
     name = 'DartError($message)';
     vmName = name;
   }
 
   String toString() => 'DartError($message)';
 }
 
 /// A [ServiceEvent] is an asynchronous event notification from the vm.
 class ServiceEvent extends ServiceObject {
   /// The possible 'kind' values.
-  static const kIsolateStart       = 'IsolateStart';
-  static const kIsolateExit        = 'IsolateExit';
-  static const kIsolateUpdate      = 'IsolateUpdate';
-  static const kPauseStart         = 'PauseStart';
-  static const kPauseExit          = 'PauseExit';
-  static const kPauseBreakpoint    = 'PauseBreakpoint';
-  static const kPauseInterrupted   = 'PauseInterrupted';
-  static const kPauseException     = 'PauseException';
-  static const kResume             = 'Resume';
-  static const kBreakpointAdded    = 'BreakpointAdded';
-  static const kBreakpointResolved = 'BreakpointResolved';
-  static const kBreakpointRemoved  = 'BreakpointRemoved';
-  static const kGraph              = '_Graph';
-  static const kGC                 = 'GC';
-  static const kInspect            = 'Inspect';
-  static const kConnectionClosed   = 'ConnectionClosed';
+  static const kIsolateStart           = 'IsolateStart';
+  static const kIsolateExit            = 'IsolateExit';
+  static const kIsolateUpdate          = 'IsolateUpdate';
+  static const kPauseStart             = 'PauseStart';
+  static const kPauseExit              = 'PauseExit';
+  static const kPauseBreakpoint        = 'PauseBreakpoint';
+  static const kPauseInterrupted       = 'PauseInterrupted';
+  static const kPauseException         = 'PauseException';
+  static const kResume                 = 'Resume';
+  static const kBreakpointAdded        = 'BreakpointAdded';
+  static const kBreakpointResolved     = 'BreakpointResolved';
+  static const kBreakpointRemoved      = 'BreakpointRemoved';
+  static const kGraph                  = '_Graph';
+  static const kGC                     = 'GC';
+  static const kInspect                = 'Inspect';
+  static const kDebuggerSettingsUpdate = '_DebuggerSettingsUpdate';
+  static const kConnectionClosed       = 'ConnectionClosed';
 
   ServiceEvent._empty(ServiceObjectOwner owner) : super._empty(owner);
 
   ServiceEvent.connectionClosed(this.reason) : super._empty(null) {
     kind = kConnectionClosed;
   }
 
   @observable String kind;
   @observable Breakpoint breakpoint;
   @observable Frame topFrame;
-  @observable ServiceMap exception;
+  @observable Instance exception;
   @observable ServiceObject inspectee;
   @observable ByteData data;
   @observable int count;
   @observable String reason;
+  @observable String exceptions;
   int chunkIndex, chunkCount, nodeCount;
 
   @observable bool get isPauseEvent {
     return (kind == kPauseStart ||
             kind == kPauseExit ||
             kind == kPauseBreakpoint ||
             kind == kPauseInterrupted ||
             kind == kPauseException);
   }
 
@@ skipping 31 matching lines @@
     }
     if (map['chunkCount'] != null) {
       chunkCount = map['chunkCount'];
     }
     if (map['nodeCount'] != null) {
       nodeCount = map['nodeCount'];
     }
     if (map['count'] != null) {
       count = map['count'];
     }
+    if (map['_debuggerSettings'] != null &&
+        map['_debuggerSettings']['_exceptions'] != null) {
+      exceptions = map['_debuggerSettings']['_exceptions'];
+    }
   }
 
   String toString() {
     if (data == null) {
       return "ServiceEvent(owner='${owner.id}', kind='${kind}')";
     } else {
       return "ServiceEvent(owner='${owner.id}', kind='${kind}', "
           "data.lengthInBytes=${data.lengthInBytes})";
     }
   }
@@ skipping 534 matching lines @@
   @observable Code unoptimizedCode;
   @observable bool isOptimizable;
   @observable bool isInlinable;
   @observable FunctionKind kind;
   @observable int deoptimizations;
   @observable String qualifiedName;
   @observable int usageCounter;
   @observable bool isDart;
   @observable ProfileFunction profile;
 
-  bool get canCache => true;
   bool get immutable => false;
 
   ServiceFunction._empty(ServiceObject owner) : super._empty(owner);
 
   void _update(ObservableMap map, bool mapIsRef) {
     name = map['name'];
     vmName = (map.containsKey('vmName') ? map['vmName'] : name);
 
     _upgradeCollection(map, isolate);
 
@@ skipping 232 matching lines @@
   Set<CallSite> callSites = new Set<CallSite>();
   final lines = new ObservableList<ScriptLine>();
   final _hits = new Map<int, int>();
   @observable String uri;
   @observable String kind;
   @observable int firstTokenPos;
   @observable int lastTokenPos;
   @observable int lineOffset;
   @observable int columnOffset;
   @observable Library library;
-  bool get canCache => true;
+
   bool get immutable => true;
 
   String _shortUri;
 
   Script._empty(ServiceObjectOwner owner) : super._empty(owner);
 
   ScriptLine getLine(int line) {
     assert(_loaded);
     assert(line >= 1);
     return lines[line - lineOffset - 1];
@@ skipping 480 matching lines @@
   @observable Script script;
   @observable bool isOptimized = false;
   @reflectable int startAddress = 0;
   @reflectable int endAddress = 0;
   @reflectable final instructions = new ObservableList<CodeInstruction>();
   @observable ProfileCode profile;
   final List<CodeInlineInterval> inlineIntervals =
       new List<CodeInlineInterval>();
   final ObservableList<ServiceFunction> inlinedFunctions =
       new ObservableList<ServiceFunction>();
-  bool get canCache => true;
+
   bool get immutable => true;
 
   Code._empty(ServiceObjectOwner owner) : super._empty(owner);
 
   void _updateDescriptors(Script script) {
     this.script = script;
     for (var instruction in instructions) {
       for (var descriptor in instruction.descriptors) {
         descriptor.processScript(script);
       }
@@ skipping 388 matching lines @@
   void _update(ObservableMap map, bool mapIsRef) {
     assert(!mapIsRef);
     _loaded = true;
     _upgradeCollection(map, owner);
     this.index = map['index'];
     this.function = map['function'];
     this.location = map['location'];
     this.code = map['code'];
     this.variables = map['vars'];
   }
+
+  String toString() => "Frame(${function.qualifiedName})";
 }
 
 
 class ServiceMessage extends ServiceObject {
   @observable int index;
   @observable String messageObjectId;
   @observable int size;
   @observable ServiceFunction handler;
   @observable SourceLocation location;
 
@@ skipping 52 matching lines @@
     var v = list[i];
     if ((v is ObservableMap) && _isServiceMap(v)) {
       list[i] = owner.getFromMap(v);
     } else if (v is ObservableList) {
       _upgradeObservableList(v, owner);
     } else if (v is ObservableMap) {
       _upgradeObservableMap(v, owner);
     }
   }
 }