| OLD | NEW |
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, 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 import 'package:observatory/service_io.dart'; | 5 import 'package:observatory/service_io.dart'; |
| 6 import 'package:unittest/unittest.dart'; | 6 import 'package:unittest/unittest.dart'; |
| 7 import 'test_helper.dart'; | 7 import 'test_helper.dart'; |
| 8 import 'dart:async'; | 8 import 'dart:async'; |
| 9 | 9 |
| 10 void testFunction() { | 10 void testFunction() { |
| (...skipping 28 matching lines...) Expand all Loading... |
| 39 | 39 |
| 40 // Add breakpoint | 40 // Add breakpoint |
| 41 (Isolate isolate) { | 41 (Isolate isolate) { |
| 42 return isolate.rootLib.load().then((_) { | 42 return isolate.rootLib.load().then((_) { |
| 43 // Set up a listener to wait for breakpoint events. | 43 // Set up a listener to wait for breakpoint events. |
| 44 Completer completer = new Completer(); | 44 Completer completer = new Completer(); |
| 45 List events = []; | 45 List events = []; |
| 46 isolate.vm.events.stream.listen((ServiceEvent event) { | 46 isolate.vm.events.stream.listen((ServiceEvent event) { |
| 47 if (event.eventType.startsWith('Breakpoint')) { | 47 if (event.eventType.startsWith('Breakpoint')) { |
| 48 events.add(event); | 48 events.add(event); |
| 49 } | 49 if (events.length == 2) { |
| 50 if (events.length == 2) { | 50 expect(events[0].eventType, equals('BreakpointResolved')); |
| 51 expect(events[0].eventType, equals('BreakpointResolved')); | 51 expect(events[1].eventType, equals('BreakpointReached')); |
| 52 expect(events[1].eventType, equals('BreakpointReached')); | 52 print('Breakpoint reached'); |
| 53 print('Breakpoint reached'); | 53 completer.complete(); |
| 54 completer.complete(); | 54 } |
| 55 } | 55 } |
| 56 }); | 56 }); |
| 57 | 57 |
| 58 // Add the breakpoint. | 58 // Add the breakpoint. |
| 59 var script = isolate.rootLib.scripts[0]; | 59 var script = isolate.rootLib.scripts[0]; |
| 60 return isolate.addBreakpoint(script, 14).then((ServiceObject bpt) { | 60 return isolate.addBreakpoint(script, 14).then((ServiceObject bpt) { |
| 61 expect(bpt is ServiceMap, isTrue); | 61 expect(bpt is ServiceMap, isTrue); |
| 62 ServiceMap m = bpt; | 62 ServiceMap m = bpt; |
| 63 expect(m.type, equals('Breakpoint')); | 63 expect(m.type, equals('Breakpoint')); |
| 64 expect(m['location']['script'].id, equals(script.id)); | 64 expect(m['location']['script'].id, equals(script.id)); |
| 65 expect(m['location']['tokenPos'], equals(51)); | 65 expect(m['location']['tokenPos'], equals(51)); |
| 66 expect(isolate.breakpoints.type, equals('BreakpointList')); | 66 expect(isolate.breakpoints.length, equals(1)); |
| 67 expect(isolate.breakpoints['breakpoints'].length, equals(1)); | |
| 68 return completer.future; // Wait for breakpoint events. | 67 return completer.future; // Wait for breakpoint events. |
| 69 }); | 68 }); |
| 70 }); | 69 }); |
| 71 }, | 70 }, |
| 72 | 71 |
| 73 // Get the stack trace | 72 // Get the stack trace |
| 74 (Isolate isolate) { | 73 (Isolate isolate) { |
| 75 return isolate.getStack().then((ServiceMap stack) { | 74 return isolate.getStack().then((ServiceMap stack) { |
| 76 expect(stack.type, equals('Stack')); | 75 expect(stack.type, equals('Stack')); |
| 77 expect(stack['frames'].length, greaterThanOrEqualTo(1)); | 76 expect(stack['frames'].length, greaterThanOrEqualTo(1)); |
| 78 expect(stack['frames'][0]['function'].name, equals('testFunction')); | 77 expect(stack['frames'][0]['function'].name, equals('testFunction')); |
| 79 }); | 78 }); |
| 80 }, | 79 }, |
| 81 | 80 |
| 82 // Stepping | 81 // Stepping |
| 83 (Isolate isolate) { | 82 (Isolate isolate) { |
| 84 // Set up a listener to wait for breakpoint events. | 83 // Set up a listener to wait for breakpoint events. |
| 85 Completer completer = new Completer(); | 84 Completer completer = new Completer(); |
| 86 List events = []; | 85 List events = []; |
| 87 isolate.vm.events.stream.listen((ServiceEvent event) { | 86 isolate.vm.events.stream.listen((ServiceEvent event) { |
| 88 if (event.eventType.startsWith('Breakpoint')) { | 87 if (event.eventType.startsWith('Breakpoint')) { |
| 89 expect(event.eventType, equals('BreakpointReached')); | 88 expect(event.eventType, equals('BreakpointReached')); |
| 89 print('Breakpoint reached'); |
| 90 completer.complete(); |
| 90 } | 91 } |
| 91 print('Breakpoint reached'); | |
| 92 completer.complete(); | |
| 93 }); | 92 }); |
| 94 | 93 |
| 95 return isolate.stepInto().then((isolate) { | 94 return isolate.stepInto().then((isolate) { |
| 96 return completer.future; // Wait for breakpoint events. | 95 return completer.future; // Wait for breakpoint events. |
| 97 }); | 96 }); |
| 98 }, | 97 }, |
| 99 | 98 |
| 100 // Get the stack trace again. We are in 'print'. | 99 // Get the stack trace again. We are in 'print'. |
| 101 (Isolate isolate) { | 100 (Isolate isolate) { |
| 102 return isolate.getStack().then((ServiceMap stack) { | 101 return isolate.getStack().then((ServiceMap stack) { |
| 103 expect(stack.type, equals('Stack')); | 102 expect(stack.type, equals('Stack')); |
| 104 expect(stack['frames'].length, greaterThanOrEqualTo(2)); | 103 expect(stack['frames'].length, greaterThanOrEqualTo(2)); |
| 105 expect(stack['frames'][0]['function'].name, equals('print')); | 104 expect(stack['frames'][0]['function'].name, equals('print')); |
| 106 }); | 105 }); |
| 107 }, | 106 }, |
| 108 | 107 |
| 109 // Remove breakpoint | 108 // Remove breakpoint |
| 110 (Isolate isolate) { | 109 (Isolate isolate) { |
| 111 expect(isolate.breakpoints['breakpoints'].length, equals(1)); | 110 expect(isolate.breakpoints.length, equals(1)); |
| 112 var bpt = isolate.breakpoints['breakpoints'][0]; | 111 var bpt = isolate.breakpoints[0]; |
| 113 return isolate.removeBreakpoint(bpt).then((_) { | 112 return isolate.removeBreakpoint(bpt).then((_) { |
| 114 expect(isolate.breakpoints['breakpoints'].length, equals(0)); | 113 expect(isolate.breakpoints.length, equals(0)); |
| 115 }); | 114 }); |
| 116 }, | 115 }, |
| 117 | 116 |
| 118 ]; | 117 ]; |
| 119 | 118 |
| 120 main(args) => runIsolateTests(args, tests, testeeConcurrent: testFunction); | 119 main(args) => runIsolateTests(args, tests, testeeConcurrent: testFunction); |
| OLD | NEW |