| 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 // VMOptions=--error_on_bad_type --error_on_bad_override | 4 // VMOptions=--error_on_bad_type --error_on_bad_override |
| 5 | 5 |
| 6 import 'package:observatory/service_io.dart'; | 6 import 'package:observatory/service_io.dart'; |
| 7 import 'package:unittest/unittest.dart'; | 7 import 'package:unittest/unittest.dart'; |
| 8 import 'test_helper.dart'; | 8 import 'test_helper.dart'; |
| 9 import 'dart:async'; | 9 import 'dart:async'; |
| 10 | 10 |
| 11 int counter = 0; | 11 int counter = 0; |
| 12 | 12 |
| 13 void periodicTask(_) { | 13 void periodicTask(_) { |
| 14 counter++; | 14 counter++; |
| 15 counter++; // Line 15. We set our breakpoint here. | 15 counter++; // Line 15. We set our breakpoint here. |
| 16 counter++; | 16 counter++; |
| 17 if (counter % 300 == 0) { | 17 if (counter % 300 == 0) { |
| 18 print('counter = $counter'); | 18 print('counter = $counter'); |
| 19 } | 19 } |
| 20 } | 20 } |
| 21 | 21 |
| 22 void startTimer() { | 22 void startTimer() { |
| 23 new Timer.periodic(const Duration(milliseconds:10), periodicTask); | 23 new Timer.periodic(const Duration(milliseconds: 10), periodicTask); |
| 24 } | 24 } |
| 25 | 25 |
| 26 var tests = [ | 26 var tests = [ |
| 27 | |
| 28 // Pause | 27 // Pause |
| 29 (Isolate isolate) async { | 28 (Isolate isolate) async { |
| 30 Completer completer = new Completer(); | 29 Completer completer = new Completer(); |
| 31 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 30 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
| 32 var subscription; | 31 var subscription; |
| 33 subscription = stream.listen((ServiceEvent event) { | 32 subscription = stream.listen((ServiceEvent event) { |
| 34 if (event.kind == ServiceEvent.kPauseInterrupted) { | 33 if (event.kind == ServiceEvent.kPauseInterrupted) { |
| 35 subscription.cancel(); | 34 subscription.cancel(); |
| 36 completer.complete(); | 35 completer.complete(); |
| 37 } | 36 } |
| 38 }); | 37 }); |
| 39 isolate.pause(); | 38 isolate.pause(); |
| 40 await completer.future; | 39 await completer.future; |
| 41 }, | 40 }, |
| 42 | 41 |
| 43 // Resume | 42 // Resume |
| 44 (Isolate isolate) async { | 43 (Isolate isolate) async { |
| 45 Completer completer = new Completer(); | 44 Completer completer = new Completer(); |
| 46 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 45 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
| 47 var subscription; | 46 var subscription; |
| 48 subscription = stream.listen((ServiceEvent event) { | 47 subscription = stream.listen((ServiceEvent event) { |
| 49 if (event.kind == ServiceEvent.kResume) { | 48 if (event.kind == ServiceEvent.kResume) { |
| 50 subscription.cancel(); | 49 subscription.cancel(); |
| 51 completer.complete(); | 50 completer.complete(); |
| 52 } | 51 } |
| 53 }); | 52 }); |
| 54 isolate.resume(); | 53 isolate.resume(); |
| 55 await completer.future; | 54 await completer.future; |
| 56 }, | 55 }, |
| 57 | 56 |
| 58 // Add breakpoint | 57 // Add breakpoint |
| 59 (Isolate isolate) async { | 58 (Isolate isolate) async { |
| 60 await isolate.rootLibrary.load(); | 59 await isolate.rootLibrary.load(); |
| 61 | 60 |
| 62 // Set up a listener to wait for breakpoint events. | 61 // Set up a listener to wait for breakpoint events. |
| 63 Completer completer = new Completer(); | 62 Completer completer = new Completer(); |
| 64 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 63 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
| 65 var subscription; | 64 var subscription; |
| 66 subscription = stream.listen((ServiceEvent event) { | 65 subscription = stream.listen((ServiceEvent event) { |
| 67 if (event.kind == ServiceEvent.kPauseBreakpoint) { | 66 if (event.kind == ServiceEvent.kPauseBreakpoint) { |
| 68 print('Breakpoint reached'); | 67 print('Breakpoint reached'); |
| 69 subscription.cancel(); | 68 subscription.cancel(); |
| 70 completer.complete(); | 69 completer.complete(); |
| 71 } | 70 } |
| 72 }); | 71 }); |
| 73 | 72 |
| 74 var script = isolate.rootLibrary.scripts[0]; | 73 var script = isolate.rootLibrary.scripts[0]; |
| 75 await script.load(); | 74 await script.load(); |
| 76 | 75 |
| 77 // Add the breakpoint. | 76 // Add the breakpoint. |
| 78 var result = await isolate.addBreakpoint(script, 15); | 77 var result = await isolate.addBreakpoint(script, 15); |
| 79 expect(result is Breakpoint, isTrue); | 78 expect(result is Breakpoint, isTrue); |
| 80 Breakpoint bpt = result; | 79 Breakpoint bpt = result; |
| 81 expect(bpt.type, equals('Breakpoint')); | 80 expect(bpt.type, equals('Breakpoint')); |
| 82 expect(bpt.location.script.id, equals(script.id)); | 81 expect(bpt.location.script.id, equals(script.id)); |
| 83 expect(bpt.location.script.tokenToLine(bpt.location.tokenPos), equals(15)); | 82 expect(bpt.location.script.tokenToLine(bpt.location.tokenPos), equals(15)); |
| 84 expect(isolate.breakpoints.length, equals(1)); | 83 expect(isolate.breakpoints.length, equals(1)); |
| 85 | 84 |
| 86 await completer.future; // Wait for breakpoint events. | 85 await completer.future; // Wait for breakpoint events. |
| 87 }, | 86 }, |
| 88 | 87 |
| 89 // We are at the breakpoint on line 15. | 88 // We are at the breakpoint on line 15. |
| 90 (Isolate isolate) async { | 89 (Isolate isolate) async { |
| 91 ServiceMap stack = await isolate.getStack(); | 90 ServiceMap stack = await isolate.getStack(); |
| 92 expect(stack.type, equals('Stack')); | 91 expect(stack.type, equals('Stack')); |
| 93 expect(stack['frames'].length, greaterThanOrEqualTo(1)); | 92 expect(stack['frames'].length, greaterThanOrEqualTo(1)); |
| 94 | 93 |
| 95 Script script = stack['frames'][0].location.script; | 94 Script script = stack['frames'][0].location.script; |
| 96 expect(script.name,endsWith('debugging_test.dart')); | 95 expect(script.name, endsWith('debugging_test.dart')); |
| 97 expect(script.tokenToLine(stack['frames'][0].location.tokenPos), equals(15)); | 96 expect( |
| 98 }, | 97 script.tokenToLine(stack['frames'][0].location.tokenPos), equals(15)); |
| 98 }, |
| 99 | 99 |
| 100 // Stepping | 100 // Stepping |
| 101 (Isolate isolate) async { | 101 (Isolate isolate) async { |
| 102 // Set up a listener to wait for breakpoint events. | 102 // Set up a listener to wait for breakpoint events. |
| 103 Completer completer = new Completer(); | 103 Completer completer = new Completer(); |
| 104 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 104 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
| 105 var subscription; | 105 var subscription; |
| 106 subscription = stream.listen((ServiceEvent event) { | 106 subscription = stream.listen((ServiceEvent event) { |
| 107 if (event.kind == ServiceEvent.kPauseBreakpoint) { | 107 if (event.kind == ServiceEvent.kPauseBreakpoint) { |
| 108 print('Breakpoint reached'); | 108 print('Breakpoint reached'); |
| 109 subscription.cancel(); | 109 subscription.cancel(); |
| 110 completer.complete(); | 110 completer.complete(); |
| 111 } | 111 } |
| 112 }); | 112 }); |
| 113 | 113 |
| 114 await isolate.stepOver(); | 114 await isolate.stepOver(); |
| 115 await completer.future; // Wait for breakpoint events. | 115 await completer.future; // Wait for breakpoint events. |
| 116 }, | 116 }, |
| 117 | 117 |
| 118 // We are now at line 16. | 118 // We are now at line 16. |
| 119 (Isolate isolate) async { | 119 (Isolate isolate) async { |
| 120 ServiceMap stack = await isolate.getStack(); | 120 ServiceMap stack = await isolate.getStack(); |
| 121 expect(stack.type, equals('Stack')); | 121 expect(stack.type, equals('Stack')); |
| 122 expect(stack['frames'].length, greaterThanOrEqualTo(1)); | 122 expect(stack['frames'].length, greaterThanOrEqualTo(1)); |
| 123 | 123 |
| 124 Script script = stack['frames'][0].location.script; | 124 Script script = stack['frames'][0].location.script; |
| 125 expect(script.name,endsWith('debugging_test.dart')); | 125 expect(script.name, endsWith('debugging_test.dart')); |
| 126 expect(script.tokenToLine(stack['frames'][0].location.tokenPos), equals(16)); | 126 expect( |
| 127 }, | 127 script.tokenToLine(stack['frames'][0].location.tokenPos), equals(16)); |
| 128 }, |
| 128 | 129 |
| 129 // Remove breakpoint | 130 // Remove breakpoint |
| 130 (Isolate isolate) async { | 131 (Isolate isolate) async { |
| 131 // Set up a listener to wait for breakpoint events. | 132 // Set up a listener to wait for breakpoint events. |
| 132 Completer completer = new Completer(); | 133 Completer completer = new Completer(); |
| 133 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 134 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
| 134 var subscription; | 135 var subscription; |
| 135 subscription = stream.listen((ServiceEvent event) { | 136 subscription = stream.listen((ServiceEvent event) { |
| 136 if (event.kind == ServiceEvent.kBreakpointRemoved) { | 137 if (event.kind == ServiceEvent.kBreakpointRemoved) { |
| 137 print('Breakpoint removed'); | 138 print('Breakpoint removed'); |
| 138 expect(isolate.breakpoints.length, equals(0)); | 139 expect(isolate.breakpoints.length, equals(0)); |
| 139 subscription.cancel(); | 140 subscription.cancel(); |
| 140 completer.complete(); | 141 completer.complete(); |
| 141 } | 142 } |
| 142 }); | 143 }); |
| 143 | 144 |
| 144 expect(isolate.breakpoints.length, equals(1)); | 145 expect(isolate.breakpoints.length, equals(1)); |
| 145 var bpt = isolate.breakpoints.values.first; | 146 var bpt = isolate.breakpoints.values.first; |
| 146 await isolate.removeBreakpoint(bpt); | 147 await isolate.removeBreakpoint(bpt); |
| 147 await completer.future; | 148 await completer.future; |
| 148 }, | 149 }, |
| 149 | 150 |
| 150 // Resume | 151 // Resume |
| 151 (Isolate isolate) async { | 152 (Isolate isolate) async { |
| 152 Completer completer = new Completer(); | 153 Completer completer = new Completer(); |
| 153 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 154 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
| 154 var subscription; | 155 var subscription; |
| 155 subscription = stream.listen((ServiceEvent event) { | 156 subscription = stream.listen((ServiceEvent event) { |
| 156 if (event.kind == ServiceEvent.kResume) { | 157 if (event.kind == ServiceEvent.kResume) { |
| 157 subscription.cancel(); | 158 subscription.cancel(); |
| 158 completer.complete(); | 159 completer.complete(); |
| 159 } | 160 } |
| 160 }); | 161 }); |
| 161 isolate.resume(); | 162 isolate.resume(); |
| 162 await completer.future; | 163 await completer.future; |
| 163 }, | 164 }, |
| 164 | 165 |
| 165 // Add breakpoint at function entry | 166 // Add breakpoint at function entry |
| 166 (Isolate isolate) async { | 167 (Isolate isolate) async { |
| 167 // Set up a listener to wait for breakpoint events. | 168 // Set up a listener to wait for breakpoint events. |
| 168 Completer completer = new Completer(); | 169 Completer completer = new Completer(); |
| 169 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 170 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
| 170 var subscription; | 171 var subscription; |
| 171 subscription = stream.listen((ServiceEvent event) { | 172 subscription = stream.listen((ServiceEvent event) { |
| 172 if (event.kind == ServiceEvent.kPauseBreakpoint) { | 173 if (event.kind == ServiceEvent.kPauseBreakpoint) { |
| 173 print('Breakpoint reached'); | 174 print('Breakpoint reached'); |
| 174 subscription.cancel(); | 175 subscription.cancel(); |
| 175 completer.complete(); | 176 completer.complete(); |
| 176 } | 177 } |
| 177 }); | 178 }); |
| 178 | 179 |
| 179 // Find a specific function. | 180 // Find a specific function. |
| 180 ServiceFunction function = isolate.rootLibrary.functions.firstWhere( | 181 ServiceFunction function = isolate.rootLibrary.functions |
| 181 (f) => f.name == 'periodicTask'); | 182 .firstWhere((f) => f.name == 'periodicTask'); |
| 182 expect(function, isNotNull); | 183 expect(function, isNotNull); |
| 183 | 184 |
| 184 // Add the breakpoint at function entry | 185 // Add the breakpoint at function entry |
| 185 var result = await isolate.addBreakpointAtEntry(function); | 186 var result = await isolate.addBreakpointAtEntry(function); |
| 186 expect(result is Breakpoint, isTrue); | 187 expect(result is Breakpoint, isTrue); |
| 187 Breakpoint bpt = result; | 188 Breakpoint bpt = result; |
| 188 expect(bpt.type, equals('Breakpoint')); | 189 expect(bpt.type, equals('Breakpoint')); |
| 189 expect(bpt.location.script.name, equals('debugging_test.dart')); | 190 expect(bpt.location.script.name, equals('debugging_test.dart')); |
| 190 expect(bpt.location.script.tokenToLine(bpt.location.tokenPos), equals(13)); | 191 expect(bpt.location.script.tokenToLine(bpt.location.tokenPos), equals(13)); |
| 191 expect(isolate.breakpoints.length, equals(1)); | 192 expect(isolate.breakpoints.length, equals(1)); |
| 192 | 193 |
| 193 await completer.future; // Wait for breakpoint events. | 194 await completer.future; // Wait for breakpoint events. |
| 194 }, | 195 }, |
| 195 | 196 |
| 196 // We are now at line 13. | 197 // We are now at line 13. |
| 197 (Isolate isolate) async { | 198 (Isolate isolate) async { |
| 198 ServiceMap stack = await isolate.getStack(); | 199 ServiceMap stack = await isolate.getStack(); |
| 199 expect(stack.type, equals('Stack')); | 200 expect(stack.type, equals('Stack')); |
| 200 expect(stack['frames'].length, greaterThanOrEqualTo(1)); | 201 expect(stack['frames'].length, greaterThanOrEqualTo(1)); |
| 201 | 202 |
| 202 Script script = stack['frames'][0].location.script; | 203 Script script = stack['frames'][0].location.script; |
| 203 expect(script.name,endsWith('debugging_test.dart')); | 204 expect(script.name, endsWith('debugging_test.dart')); |
| 204 expect(script.tokenToLine(stack['frames'][0].location.tokenPos), equals(13)); | 205 expect( |
| 205 }, | 206 script.tokenToLine(stack['frames'][0].location.tokenPos), equals(13)); |
| 206 | 207 }, |
| 207 ]; | 208 ]; |
| 208 | 209 |
| 209 main(args) => runIsolateTests(args, tests, testeeBefore: startTimer); | 210 main(args) => runIsolateTests(args, tests, testeeBefore: startTimer); |
| OLD | NEW |