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 --steal-breakpoints | 4 // VMOptions=--error_on_bad_type --error_on_bad_override --steal-breakpoints |
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++; // Line 14. We set our breakpoint here. | 14 counter++; // Line 14. We set our breakpoint here. |
15 if (counter % 1000 == 0) { | 15 if (counter % 1000 == 0) { |
16 print('counter = $counter'); | 16 print('counter = $counter'); |
17 } | 17 } |
18 } | 18 } |
19 | 19 |
20 void startTimer() { | 20 void startTimer() { |
21 new Timer.periodic(const Duration(milliseconds: 10), periodicTask); | 21 new Timer.periodic(const Duration(milliseconds:10), periodicTask); |
22 } | 22 } |
23 | 23 |
24 var tests = [ | 24 var tests = [ |
| 25 |
25 // Add a breakpoint and wait for it to be reached. | 26 // Add a breakpoint and wait for it to be reached. |
26 (Isolate isolate) async { | 27 (Isolate isolate) async { |
27 await isolate.rootLibrary.load(); | 28 await isolate.rootLibrary.load(); |
28 | 29 |
29 // Set up a listener to wait for breakpoint events. | 30 // Set up a listener to wait for breakpoint events. |
30 Completer completer = new Completer(); | 31 Completer completer = new Completer(); |
31 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 32 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
32 var subscription; | 33 var subscription; |
33 subscription = stream.listen((ServiceEvent event) { | 34 subscription = stream.listen((ServiceEvent event) { |
34 if (event.kind == ServiceEvent.kPauseBreakpoint) { | 35 if (event.kind == ServiceEvent.kPauseBreakpoint) { |
35 print('Isolate paused at breakpoint'); | 36 print('Isolate paused at breakpoint'); |
36 subscription.cancel(); | 37 subscription.cancel(); |
37 completer.complete(); | 38 completer.complete(); |
38 } | 39 } |
39 }); | 40 }); |
40 | 41 |
41 // Add the breakpoint. | 42 // Add the breakpoint. |
42 var script = isolate.rootLibrary.scripts[0]; | 43 var script = isolate.rootLibrary.scripts[0]; |
43 var result = await isolate.addBreakpoint(script, 14); | 44 var result = await isolate.addBreakpoint(script, 14); |
44 expect(result is Breakpoint, isTrue); | 45 expect(result is Breakpoint, isTrue); |
45 | 46 |
46 await completer.future; // Wait for breakpoint event to fire. | 47 await completer.future; // Wait for breakpoint event to fire. |
47 }, | 48 }, |
48 | 49 |
49 // We are at the breakpoint on line 14. | 50 // We are at the breakpoint on line 14. |
50 (Isolate isolate) async { | 51 (Isolate isolate) async { |
51 ServiceMap stack = await isolate.getStack(); | 52 ServiceMap stack = await isolate.getStack(); |
52 expect(stack.type, equals('Stack')); | 53 expect(stack.type, equals('Stack')); |
53 expect(stack['frames'].length, greaterThanOrEqualTo(1)); | 54 expect(stack['frames'].length, greaterThanOrEqualTo(1)); |
54 | 55 |
55 Script script = stack['frames'][0].location.script; | 56 Script script = stack['frames'][0].location.script; |
56 await script.load(); | 57 await script.load(); |
57 expect(script.name, endsWith('steal_breakpoint_test.dart')); | 58 expect(script.name,endsWith('steal_breakpoint_test.dart')); |
58 expect( | 59 expect(script.tokenToLine(stack['frames'][0].location.tokenPos), equals(14)); |
59 script.tokenToLine(stack['frames'][0].location.tokenPos), equals(14)); | 60 }, |
60 }, | |
61 | 61 |
62 // Resume | 62 // Resume |
63 (Isolate isolate) async { | 63 (Isolate isolate) async { |
64 Completer completer = new Completer(); | 64 Completer completer = new Completer(); |
65 var stream = await isolate.vm.getEventStream(VM.kDebugStream); | 65 var stream = await isolate.vm.getEventStream(VM.kDebugStream); |
66 var subscription; | 66 var subscription; |
67 subscription = stream.listen((ServiceEvent event) { | 67 subscription = stream.listen((ServiceEvent event) { |
68 if (event.kind == ServiceEvent.kResume) { | 68 if (event.kind == ServiceEvent.kResume) { |
69 print('Isolate resumed'); | 69 print('Isolate resumed'); |
70 subscription.cancel(); | 70 subscription.cancel(); |
71 completer.complete(); | 71 completer.complete(); |
72 } | 72 } |
73 }); | 73 }); |
74 isolate.resume(); | 74 isolate.resume(); |
75 await completer.future; | 75 await completer.future; |
76 }, | 76 }, |
| 77 |
77 ]; | 78 ]; |
78 | 79 |
79 main(args) => runIsolateTests(args, tests, testeeBefore: startTimer); | 80 main(args) => runIsolateTests(args, tests, testeeBefore: startTimer); |
OLD | NEW |