Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(449)

Side by Side Diff: runtime/observatory/lib/src/service/object.dart

Issue 1232193003: Provide stdout and stderr output in the Observatory debugger. (Closed) Base URL: git@github.com:dart-lang/sdk.git@master
Patch Set: before commit Created 5 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 679 matching lines...) Expand 10 before | Expand all | Expand 10 after
690 return invokeRpc('streamCancel', params); 690 return invokeRpc('streamCancel', params);
691 } 691 }
692 692
693 // A map from stream id to event stream state. 693 // A map from stream id to event stream state.
694 Map<String,_EventStreamState> _eventStreams = {}; 694 Map<String,_EventStreamState> _eventStreams = {};
695 695
696 // Well-known stream ids. 696 // Well-known stream ids.
697 static const kIsolateStream = 'Isolate'; 697 static const kIsolateStream = 'Isolate';
698 static const kDebugStream = 'Debug'; 698 static const kDebugStream = 'Debug';
699 static const kGCStream = 'GC'; 699 static const kGCStream = 'GC';
700 static const kStdoutStream = 'Stdout';
701 static const kStderrStream = 'Stderr';
700 static const _kGraphStream = '_Graph'; 702 static const _kGraphStream = '_Graph';
701 703
702 /// Returns a single-subscription Stream object for a VM event stream. 704 /// Returns a single-subscription Stream object for a VM event stream.
703 Future<Stream> getEventStream(String streamId) async { 705 Future<Stream> getEventStream(String streamId) async {
704 var eventStream = _eventStreams.putIfAbsent( 706 var eventStream = _eventStreams.putIfAbsent(
705 streamId, () => new _EventStreamState( 707 streamId, () => new _EventStreamState(
706 this, streamId, () => _eventStreams.remove(streamId))); 708 this, streamId, () => _eventStreams.remove(streamId)));
707 return eventStream.addStream(); 709 return eventStream.addStream();
708 } 710 }
709 711
(...skipping 908 matching lines...) Expand 10 before | Expand all | Expand 10 after
1618 1620
1619 @observable String kind; 1621 @observable String kind;
1620 @observable Breakpoint breakpoint; 1622 @observable Breakpoint breakpoint;
1621 @observable Frame topFrame; 1623 @observable Frame topFrame;
1622 @observable Instance exception; 1624 @observable Instance exception;
1623 @observable ServiceObject inspectee; 1625 @observable ServiceObject inspectee;
1624 @observable ByteData data; 1626 @observable ByteData data;
1625 @observable int count; 1627 @observable int count;
1626 @observable String reason; 1628 @observable String reason;
1627 @observable String exceptions; 1629 @observable String exceptions;
1630 @observable String bytesAsString;
1628 int chunkIndex, chunkCount, nodeCount; 1631 int chunkIndex, chunkCount, nodeCount;
1629 1632
1630 @observable bool get isPauseEvent { 1633 @observable bool get isPauseEvent {
1631 return (kind == kPauseStart || 1634 return (kind == kPauseStart ||
1632 kind == kPauseExit || 1635 kind == kPauseExit ||
1633 kind == kPauseBreakpoint || 1636 kind == kPauseBreakpoint ||
1634 kind == kPauseInterrupted || 1637 kind == kPauseInterrupted ||
1635 kind == kPauseException); 1638 kind == kPauseException);
1636 } 1639 }
1637 1640
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
1673 if (map['nodeCount'] != null) { 1676 if (map['nodeCount'] != null) {
1674 nodeCount = map['nodeCount']; 1677 nodeCount = map['nodeCount'];
1675 } 1678 }
1676 if (map['count'] != null) { 1679 if (map['count'] != null) {
1677 count = map['count']; 1680 count = map['count'];
1678 } 1681 }
1679 if (map['_debuggerSettings'] != null && 1682 if (map['_debuggerSettings'] != null &&
1680 map['_debuggerSettings']['_exceptions'] != null) { 1683 map['_debuggerSettings']['_exceptions'] != null) {
1681 exceptions = map['_debuggerSettings']['_exceptions']; 1684 exceptions = map['_debuggerSettings']['_exceptions'];
1682 } 1685 }
1686 if (map['bytes'] != null) {
1687 var bytes = decodeBase64(map['bytes']);
1688 bytesAsString = UTF8.decode(bytes);
1689 }
1683 } 1690 }
1684 1691
1685 String toString() { 1692 String toString() {
1686 if (data == null) { 1693 if (data == null) {
1687 return "ServiceEvent(owner='${owner.id}', kind='${kind}')"; 1694 return "ServiceEvent(owner='${owner.id}', kind='${kind}')";
1688 } else { 1695 } else {
1689 return "ServiceEvent(owner='${owner.id}', kind='${kind}', " 1696 return "ServiceEvent(owner='${owner.id}', kind='${kind}', "
1690 "data.lengthInBytes=${data.lengthInBytes})"; 1697 "data.lengthInBytes=${data.lengthInBytes})";
1691 } 1698 }
1692 } 1699 }
(...skipping 1879 matching lines...) Expand 10 before | Expand all | Expand 10 after
3572 var v = list[i]; 3579 var v = list[i];
3573 if ((v is ObservableMap) && _isServiceMap(v)) { 3580 if ((v is ObservableMap) && _isServiceMap(v)) {
3574 list[i] = owner.getFromMap(v); 3581 list[i] = owner.getFromMap(v);
3575 } else if (v is ObservableList) { 3582 } else if (v is ObservableList) {
3576 _upgradeObservableList(v, owner); 3583 _upgradeObservableList(v, owner);
3577 } else if (v is ObservableMap) { 3584 } else if (v is ObservableMap) {
3578 _upgradeObservableMap(v, owner); 3585 _upgradeObservableMap(v, owner);
3579 } 3586 }
3580 } 3587 }
3581 } 3588 }
OLDNEW
« no previous file with comments | « runtime/observatory/lib/src/elements/debugger.html ('k') | runtime/observatory/tests/service/capture_stdio_test.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698