Process service events as microtasks.

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;
 
 /// Helper function for canceling a Future<StreamSubscription>.
 Future cancelFutureSubscription(
     Future<StreamSubscription> subscriptionFuture) async {
   if (subscriptionFuture != null) {
@@ skipping 1265 matching lines @@
     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'];
-    if (vm.verbose) {
-      print('VM-VERBOSE: $name reloaded. pause event= $pauseEvent');
-    }
+    var newPauseEvent = map['pauseEvent'];
+    assert((pauseEvent == null) ||
+           (newPauseEvent == null) ||
+           !newPauseEvent.timestamp.isBefore(pauseEvent.timestamp));
+    pauseEvent = newPauseEvent;
     _updateRunState();
     error = map['error'];
 
     libraries.clear();
     libraries.addAll(map['libraries']);
     libraries.sort(ServiceObject.LexicalSortName);
     if (savedStartTime == null) {
       vm._buildIsolateList();
     }
   }
@@ skipping 31 matching lines @@
   void _addBreakpoint(Breakpoint bpt) {
     breakpoints[bpt.number] = bpt;
   }
 
   void _removeBreakpoint(Breakpoint bpt) {
     breakpoints.remove(bpt.number);
     bpt.remove();
   }
 
   void _onEvent(ServiceEvent event) {
-    if (vm.verbose) {
-      print('VM-VERBOSE: $name _onEvent $event');
-    }
     switch(event.kind) {
       case ServiceEvent.kIsolateStart:
       case ServiceEvent.kIsolateRunnable:
       case ServiceEvent.kIsolateExit:
       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:
       case ServiceEvent.kPauseInterrupted:
       case ServiceEvent.kPauseException:
       case ServiceEvent.kResume:
+        assert((pauseEvent == null) ||
+               !event.timestamp.isBefore(pauseEvent.timestamp));
         pauseEvent = event;
-        print('VM-VERBOSE: $name pause event $pauseEvent');
         _updateRunState();
         break;
 
       case ServiceEvent.kGraph:
         _loadHeapSnapshot(event);
         break;
 
       case ServiceEvent.kGC:
         // Ignore GC events for now.
         break;
@@ skipping 443 matching lines @@
     if (map['logRecord'] != null) {
       logRecord = map['logRecord'];
       logRecord['time'] =
           new DateTime.fromMillisecondsSinceEpoch(logRecord['time'].toInt());
       logRecord['level'] = _findLogLevel(logRecord['level']);
     }
   }
 
   String toString() {
     if (data == null) {
-      return "ServiceEvent(owner='${owner.id}', kind='${kind}')";
+      return "ServiceEvent(owner='${owner.id}', kind='${kind}', "
+          "time=${timestamp})";
     } else {
       return "ServiceEvent(owner='${owner.id}', kind='${kind}', "
-          "data.lengthInBytes=${data.lengthInBytes})";
+          "data.lengthInBytes=${data.lengthInBytes}, time=${timestamp})";
     }
   }
 }
 
 class Breakpoint extends ServiceObject {
   Breakpoint._empty(ServiceObjectOwner owner) : super._empty(owner);
 
   // TODO(turnidge): Add state to track if a breakpoint has been
   // removed from the program.  Remove from the cache when deleted.
   bool get canCache => true;
@@ skipping 1959 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);
     }
   }
 }