OLD | NEW |
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 part of service; | 5 part of service; |
6 | 6 |
7 /// Helper function for canceling a Future<StreamSubscription>. | 7 /// Helper function for canceling a Future<StreamSubscription>. |
8 Future cancelFutureSubscription( | 8 Future cancelFutureSubscription( |
9 Future<StreamSubscription> subscriptionFuture) async { | 9 Future<StreamSubscription> subscriptionFuture) async { |
10 if (subscriptionFuture != null) { | 10 if (subscriptionFuture != null) { |
(...skipping 749 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
760 return; | 760 return; |
761 } | 761 } |
762 // Note that upgrading the collection creates any isolates in the | 762 // Note that upgrading the collection creates any isolates in the |
763 // isolate list which are new. | 763 // isolate list which are new. |
764 _upgradeCollection(map, vm); | 764 _upgradeCollection(map, vm); |
765 | 765 |
766 _loaded = true; | 766 _loaded = true; |
767 version = map['version']; | 767 version = map['version']; |
768 targetCPU = map['targetCPU']; | 768 targetCPU = map['targetCPU']; |
769 architectureBits = map['architectureBits']; | 769 architectureBits = map['architectureBits']; |
770 var startTimeMillis = map['startTime']; | 770 var startTimeMillis = map['startTime'].toInt(); |
771 startTime = new DateTime.fromMillisecondsSinceEpoch(startTimeMillis); | 771 startTime = new DateTime.fromMillisecondsSinceEpoch(startTimeMillis); |
772 refreshTime = new DateTime.now(); | 772 refreshTime = new DateTime.now(); |
773 notifyPropertyChange(#upTime, 0, 1); | 773 notifyPropertyChange(#upTime, 0, 1); |
774 pid = map['pid']; | 774 pid = map['pid']; |
775 assertsEnabled = map['_assertsEnabled']; | 775 assertsEnabled = map['_assertsEnabled']; |
776 typeChecksEnabled = map['_typeChecksEnabled']; | 776 typeChecksEnabled = map['_typeChecksEnabled']; |
777 _removeDeadIsolates(map['isolates']); | 777 _removeDeadIsolates(map['isolates']); |
778 } | 778 } |
779 | 779 |
780 // Reload all isolates. | 780 // Reload all isolates. |
(...skipping 450 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1231 } | 1231 } |
1232 _loaded = true; | 1232 _loaded = true; |
1233 loading = false; | 1233 loading = false; |
1234 | 1234 |
1235 _upgradeCollection(map, isolate); | 1235 _upgradeCollection(map, isolate); |
1236 rootLibrary = map['rootLib']; | 1236 rootLibrary = map['rootLib']; |
1237 if (map['entry'] != null) { | 1237 if (map['entry'] != null) { |
1238 entry = map['entry']; | 1238 entry = map['entry']; |
1239 } | 1239 } |
1240 var savedStartTime = startTime; | 1240 var savedStartTime = startTime; |
1241 var startTimeInMillis = map['startTime']; | 1241 var startTimeInMillis = map['startTime'].toInt(); |
1242 startTime = new DateTime.fromMillisecondsSinceEpoch(startTimeInMillis); | 1242 startTime = new DateTime.fromMillisecondsSinceEpoch(startTimeInMillis); |
1243 notifyPropertyChange(#upTime, 0, 1); | 1243 notifyPropertyChange(#upTime, 0, 1); |
1244 var countersMap = map['_tagCounters']; | 1244 var countersMap = map['_tagCounters']; |
1245 if (countersMap != null) { | 1245 if (countersMap != null) { |
1246 var names = countersMap['names']; | 1246 var names = countersMap['names']; |
1247 var counts = countersMap['counters']; | 1247 var counts = countersMap['counters']; |
1248 assert(names.length == counts.length); | 1248 assert(names.length == counts.length); |
1249 var sum = 0; | 1249 var sum = 0; |
1250 for (var i = 0; i < counts.length; i++) { | 1250 for (var i = 0; i < counts.length; i++) { |
1251 sum += counts[i]; | 1251 sum += counts[i]; |
(...skipping 474 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1726 static const kConnectionClosed = 'ConnectionClosed'; | 1726 static const kConnectionClosed = 'ConnectionClosed'; |
1727 static const kLogging = '_Logging'; | 1727 static const kLogging = '_Logging'; |
1728 | 1728 |
1729 ServiceEvent._empty(ServiceObjectOwner owner) : super._empty(owner); | 1729 ServiceEvent._empty(ServiceObjectOwner owner) : super._empty(owner); |
1730 | 1730 |
1731 ServiceEvent.connectionClosed(this.reason) : super._empty(null) { | 1731 ServiceEvent.connectionClosed(this.reason) : super._empty(null) { |
1732 kind = kConnectionClosed; | 1732 kind = kConnectionClosed; |
1733 } | 1733 } |
1734 | 1734 |
1735 @observable String kind; | 1735 @observable String kind; |
| 1736 @observable DateTime timestamp; |
1736 @observable Breakpoint breakpoint; | 1737 @observable Breakpoint breakpoint; |
1737 @observable Frame topFrame; | 1738 @observable Frame topFrame; |
1738 @observable Instance exception; | 1739 @observable Instance exception; |
1739 @observable Instance asyncContinuation; | 1740 @observable Instance asyncContinuation; |
1740 @observable bool atAsyncJump; | 1741 @observable bool atAsyncJump; |
1741 @observable ServiceObject inspectee; | 1742 @observable ServiceObject inspectee; |
1742 @observable ByteData data; | 1743 @observable ByteData data; |
1743 @observable int count; | 1744 @observable int count; |
1744 @observable String reason; | 1745 @observable String reason; |
1745 @observable String exceptions; | 1746 @observable String exceptions; |
1746 @observable String bytesAsString; | 1747 @observable String bytesAsString; |
1747 @observable Map logRecord; | 1748 @observable Map logRecord; |
| 1749 |
1748 int chunkIndex, chunkCount, nodeCount; | 1750 int chunkIndex, chunkCount, nodeCount; |
1749 | 1751 |
1750 @observable bool get isPauseEvent { | 1752 @observable bool get isPauseEvent { |
1751 return (kind == kPauseStart || | 1753 return (kind == kPauseStart || |
1752 kind == kPauseExit || | 1754 kind == kPauseExit || |
1753 kind == kPauseBreakpoint || | 1755 kind == kPauseBreakpoint || |
1754 kind == kPauseInterrupted || | 1756 kind == kPauseInterrupted || |
1755 kind == kPauseException); | 1757 kind == kPauseException); |
1756 } | 1758 } |
1757 | 1759 |
1758 void _update(ObservableMap map, bool mapIsRef) { | 1760 void _update(ObservableMap map, bool mapIsRef) { |
1759 _loaded = true; | 1761 _loaded = true; |
1760 _upgradeCollection(map, owner); | 1762 _upgradeCollection(map, owner); |
1761 assert(map['isolate'] == null || owner == map['isolate']); | 1763 assert(map['isolate'] == null || owner == map['isolate']); |
| 1764 timestamp = |
| 1765 new DateTime.fromMillisecondsSinceEpoch(map['timestamp'].toInt()); |
1762 kind = map['kind']; | 1766 kind = map['kind']; |
1763 notifyPropertyChange(#isPauseEvent, 0, 1); | 1767 notifyPropertyChange(#isPauseEvent, 0, 1); |
1764 name = 'ServiceEvent $kind'; | 1768 name = 'ServiceEvent $kind'; |
1765 vmName = name; | 1769 vmName = name; |
1766 if (map['breakpoint'] != null) { | 1770 if (map['breakpoint'] != null) { |
1767 breakpoint = map['breakpoint']; | 1771 breakpoint = map['breakpoint']; |
1768 } | 1772 } |
1769 // TODO(turnidge): Expose the full list of breakpoints. For now | 1773 // TODO(turnidge): Expose the full list of breakpoints. For now |
1770 // we just pretend like there is only one active breakpoint. | 1774 // we just pretend like there is only one active breakpoint. |
1771 if (map['pauseBreakpoints'] != null) { | 1775 if (map['pauseBreakpoints'] != null) { |
(...skipping 2024 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3796 var v = list[i]; | 3800 var v = list[i]; |
3797 if ((v is ObservableMap) && _isServiceMap(v)) { | 3801 if ((v is ObservableMap) && _isServiceMap(v)) { |
3798 list[i] = owner.getFromMap(v); | 3802 list[i] = owner.getFromMap(v); |
3799 } else if (v is ObservableList) { | 3803 } else if (v is ObservableList) { |
3800 _upgradeObservableList(v, owner); | 3804 _upgradeObservableList(v, owner); |
3801 } else if (v is ObservableMap) { | 3805 } else if (v is ObservableMap) { |
3802 _upgradeObservableMap(v, owner); | 3806 _upgradeObservableMap(v, owner); |
3803 } | 3807 } |
3804 } | 3808 } |
3805 } | 3809 } |
OLD | NEW |