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 | 9 |
10 genRepeater(value) { | 10 genRepeater(value) { |
(...skipping 29 matching lines...) Expand all Loading... |
40 r2(); | 40 r2(); |
41 r3(); | 41 r3(); |
42 } | 42 } |
43 | 43 |
44 void testeeDoNamed() { | 44 void testeeDoNamed() { |
45 r1_named(y: 'Not a closure', x: 'Not a closure'); | 45 r1_named(y: 'Not a closure', x: 'Not a closure'); |
46 r2_named(y: 'Not a closure', x: 'Not a closure'); | 46 r2_named(y: 'Not a closure', x: 'Not a closure'); |
47 r3_named(y: 'Not a closure', x: 'Not a closure'); | 47 r3_named(y: 'Not a closure', x: 'Not a closure'); |
48 } | 48 } |
49 | 49 |
| 50 var tests = [ |
| 51 (Isolate isolate) async { |
| 52 var rootLib = await isolate.rootLibrary.load(); |
50 | 53 |
51 var tests = [ | 54 var breaksHit = 0; |
52 (Isolate isolate) async { | |
53 var rootLib = await isolate.rootLibrary.load(); | |
54 | 55 |
55 var breaksHit = 0; | 56 var subscriptionFuture = |
| 57 isolate.vm.listenEventStream(VM.kDebugStream, (ServiceEvent event) { |
| 58 if (event.kind == ServiceEvent.kPauseBreakpoint) { |
| 59 print("Hit breakpoint ${event.breakpoint}"); |
| 60 breaksHit++; |
| 61 isolate.resume(); |
| 62 } |
| 63 }); |
56 | 64 |
57 var subscriptionFuture = isolate.vm.listenEventStream( | 65 valueOfField(String name) async { |
58 VM.kDebugStream, (ServiceEvent event) { | 66 var field = rootLib.variables.singleWhere((v) => v.name == name); |
59 if (event.kind == ServiceEvent.kPauseBreakpoint) { | 67 await field.load(); |
60 print("Hit breakpoint ${event.breakpoint}"); | 68 return field.staticValue; |
61 breaksHit++; | 69 } |
62 isolate.resume(); | |
63 } | |
64 }); | |
65 | 70 |
66 valueOfField(String name) async { | 71 var r1Ref = await valueOfField('r1'); |
67 var field = rootLib.variables.singleWhere((v) => v.name == name); | |
68 await field.load(); | |
69 return field.staticValue; | |
70 | 72 |
71 } | 73 var bpt1 = await isolate.addBreakOnActivation(r1Ref); |
72 var r1Ref = await valueOfField('r1'); | 74 print("Added breakpoint $bpt1"); |
| 75 expect(bpt1 is Breakpoint, isTrue); |
| 76 expect(breaksHit, equals(0)); |
| 77 await r1Ref.reload(); |
| 78 expect(r1Ref.activationBreakpoint, equals(bpt1)); |
| 79 print("testeeDo()"); |
| 80 var res = await rootLib.evaluate("testeeDo()"); |
| 81 expect(res is Instance, isTrue); // Not error. |
| 82 expect(breaksHit, equals(1)); |
73 | 83 |
74 var bpt1 = await isolate.addBreakOnActivation(r1Ref); | 84 await isolate.removeBreakpoint(bpt1); |
75 print("Added breakpoint $bpt1"); | 85 print("Removed breakpoint $bpt1"); |
76 expect(bpt1 is Breakpoint, isTrue); | 86 print("testeeDo()"); |
77 expect(breaksHit, equals(0)); | 87 await r1Ref.reload(); |
78 await r1Ref.reload(); | 88 expect(r1Ref.activationBreakpoint, equals(null)); |
79 expect(r1Ref.activationBreakpoint, equals(bpt1)); | 89 res = await rootLib.evaluate("testeeDo()"); |
80 print("testeeDo()"); | 90 expect(res is Instance, isTrue); // Not error. |
81 var res = await rootLib.evaluate("testeeDo()"); | 91 expect(breaksHit, equals(1)); |
82 expect(res is Instance, isTrue); // Not error. | |
83 expect(breaksHit, equals(1)); | |
84 | 92 |
85 await isolate.removeBreakpoint(bpt1); | 93 await cancelFutureSubscription(subscriptionFuture); |
86 print("Removed breakpoint $bpt1"); | 94 }, |
87 print("testeeDo()"); | 95 (Isolate isolate) async { |
88 await r1Ref.reload(); | 96 var rootLib = await isolate.rootLibrary.load(); |
89 expect(r1Ref.activationBreakpoint, equals(null)); | |
90 res = await rootLib.evaluate("testeeDo()"); | |
91 expect(res is Instance, isTrue); // Not error. | |
92 expect(breaksHit, equals(1)); | |
93 | 97 |
94 await cancelFutureSubscription(subscriptionFuture); | 98 var breaksHit = 0; |
95 }, | |
96 | 99 |
97 (Isolate isolate) async { | 100 var subscriptionFuture = |
98 var rootLib = await isolate.rootLibrary.load(); | 101 isolate.vm.listenEventStream(VM.kDebugStream, (ServiceEvent event) { |
| 102 if (event.kind == ServiceEvent.kPauseBreakpoint) { |
| 103 print("Hit breakpoint ${event.breakpoint}"); |
| 104 breaksHit++; |
| 105 isolate.resume(); |
| 106 } |
| 107 }); |
99 | 108 |
100 var breaksHit = 0; | 109 valueOfField(String name) async { |
| 110 var field = rootLib.variables.singleWhere((v) => v.name == name); |
| 111 await field.load(); |
| 112 return field.staticValue; |
| 113 } |
101 | 114 |
102 var subscriptionFuture = isolate.vm.listenEventStream( | 115 var r1Ref = await valueOfField('r1_named'); |
103 VM.kDebugStream, (ServiceEvent event) { | |
104 if (event.kind == ServiceEvent.kPauseBreakpoint) { | |
105 print("Hit breakpoint ${event.breakpoint}"); | |
106 breaksHit++; | |
107 isolate.resume(); | |
108 } | |
109 }); | |
110 | 116 |
111 valueOfField(String name) async { | 117 var bpt1 = await isolate.addBreakOnActivation(r1Ref); |
112 var field = rootLib.variables.singleWhere((v) => v.name == name); | 118 print("Added breakpoint $bpt1"); |
113 await field.load(); | 119 expect(bpt1 is Breakpoint, isTrue); |
114 return field.staticValue; | 120 expect(breaksHit, equals(0)); |
115 } | 121 await r1Ref.reload(); |
116 var r1Ref = await valueOfField('r1_named'); | 122 expect(r1Ref.activationBreakpoint, equals(bpt1)); |
| 123 print("testeeDoNamed()"); |
| 124 var res = await rootLib.evaluate("testeeDoNamed()"); |
| 125 expect(res is Instance, isTrue); // Not error. |
| 126 expect(breaksHit, equals(1)); |
117 | 127 |
118 var bpt1 = await isolate.addBreakOnActivation(r1Ref); | 128 await isolate.removeBreakpoint(bpt1); |
119 print("Added breakpoint $bpt1"); | 129 print("Removed breakpoint $bpt1"); |
120 expect(bpt1 is Breakpoint, isTrue); | 130 await r1Ref.reload(); |
121 expect(breaksHit, equals(0)); | 131 expect(r1Ref.activationBreakpoint, equals(null)); |
122 await r1Ref.reload(); | 132 print("testeeDoNamed()"); |
123 expect(r1Ref.activationBreakpoint, equals(bpt1)); | 133 res = await rootLib.evaluate("testeeDoNamed()"); |
124 print("testeeDoNamed()"); | 134 expect(res is Instance, isTrue); // Not error. |
125 var res = await rootLib.evaluate("testeeDoNamed()"); | 135 expect(breaksHit, equals(1)); |
126 expect(res is Instance, isTrue); // Not error. | |
127 expect(breaksHit, equals(1)); | |
128 | 136 |
129 await isolate.removeBreakpoint(bpt1); | 137 await cancelFutureSubscription(subscriptionFuture); |
130 print("Removed breakpoint $bpt1"); | 138 }, |
131 await r1Ref.reload(); | 139 (Isolate isolate) async { |
132 expect(r1Ref.activationBreakpoint, equals(null)); | 140 var rootLib = await isolate.rootLibrary.load(); |
133 print("testeeDoNamed()"); | |
134 res = await rootLib.evaluate("testeeDoNamed()"); | |
135 expect(res is Instance, isTrue); // Not error. | |
136 expect(breaksHit, equals(1)); | |
137 | 141 |
138 await cancelFutureSubscription(subscriptionFuture); | 142 var breaksHit = 0; |
139 }, | |
140 | 143 |
141 (Isolate isolate) async { | 144 var subscriptionFuture = |
142 var rootLib = await isolate.rootLibrary.load(); | 145 isolate.vm.listenEventStream(VM.kDebugStream, (ServiceEvent event) { |
| 146 if (event.kind == ServiceEvent.kPauseBreakpoint) { |
| 147 print("Hit breakpoint ${event.breakpoint}"); |
| 148 breaksHit++; |
| 149 isolate.resume(); |
| 150 } |
| 151 }); |
143 | 152 |
144 var breaksHit = 0; | 153 valueOfField(String name) async { |
| 154 var field = rootLib.variables.singleWhere((v) => v.name == name); |
| 155 await field.load(); |
| 156 return field.staticValue; |
| 157 } |
145 | 158 |
146 var subscriptionFuture = isolate.vm.listenEventStream( | 159 var r1Ref = await valueOfField('r1'); |
147 VM.kDebugStream, (ServiceEvent event) { | 160 var r2Ref = await valueOfField('r2'); |
148 if (event.kind == ServiceEvent.kPauseBreakpoint) { | |
149 print("Hit breakpoint ${event.breakpoint}"); | |
150 breaksHit++; | |
151 isolate.resume(); | |
152 } | |
153 }); | |
154 | 161 |
155 valueOfField(String name) async { | 162 var bpt1 = await isolate.addBreakOnActivation(r1Ref); |
156 var field = rootLib.variables.singleWhere((v) => v.name == name); | 163 print("Added breakpoint $bpt1"); |
157 await field.load(); | 164 expect(bpt1 is Breakpoint, isTrue); |
158 return field.staticValue; | 165 expect(breaksHit, equals(0)); |
159 } | 166 await r1Ref.reload(); |
160 var r1Ref = await valueOfField('r1'); | 167 expect(r1Ref.activationBreakpoint, equals(bpt1)); |
161 var r2Ref = await valueOfField('r2'); | 168 print("testeeDo()"); |
| 169 var res = await rootLib.evaluate("testeeDo()"); |
| 170 expect(res is Instance, isTrue); // Not error. |
| 171 expect(breaksHit, equals(1)); |
162 | 172 |
163 var bpt1 = await isolate.addBreakOnActivation(r1Ref); | 173 var bpt2 = await isolate.addBreakOnActivation(r2Ref); |
164 print("Added breakpoint $bpt1"); | 174 print("Added breakpoint $bpt2"); |
165 expect(bpt1 is Breakpoint, isTrue); | 175 expect(bpt2 is Breakpoint, isTrue); |
166 expect(breaksHit, equals(0)); | 176 expect(breaksHit, equals(1)); |
167 await r1Ref.reload(); | 177 await r2Ref.reload(); |
168 expect(r1Ref.activationBreakpoint, equals(bpt1)); | 178 expect(r2Ref.activationBreakpoint, equals(bpt2)); |
169 print("testeeDo()"); | 179 print("testeeDo()"); |
170 var res = await rootLib.evaluate("testeeDo()"); | 180 res = await rootLib.evaluate("testeeDo()"); |
171 expect(res is Instance, isTrue); // Not error. | 181 expect(res is Instance, isTrue); // Not error. |
172 expect(breaksHit, equals(1)); | 182 expect(breaksHit, equals(3)); |
173 | 183 |
174 var bpt2 = await isolate.addBreakOnActivation(r2Ref); | 184 await isolate.removeBreakpoint(bpt1); |
175 print("Added breakpoint $bpt2"); | 185 print("Removed breakpoint $bpt1"); |
176 expect(bpt2 is Breakpoint, isTrue); | 186 await r1Ref.reload(); |
177 expect(breaksHit, equals(1)); | 187 expect(r1Ref.activationBreakpoint, equals(null)); |
178 await r2Ref.reload(); | 188 print("testeeDo()"); |
179 expect(r2Ref.activationBreakpoint, equals(bpt2)); | 189 res = await rootLib.evaluate("testeeDo()"); |
180 print("testeeDo()"); | 190 expect(res is Instance, isTrue); // Not error. |
181 res = await rootLib.evaluate("testeeDo()"); | 191 expect(breaksHit, equals(4)); |
182 expect(res is Instance, isTrue); // Not error. | |
183 expect(breaksHit, equals(3)); | |
184 | 192 |
185 await isolate.removeBreakpoint(bpt1); | 193 await isolate.removeBreakpoint(bpt2); |
186 print("Removed breakpoint $bpt1"); | 194 print("Removed breakpoint $bpt2"); |
187 await r1Ref.reload(); | 195 await r2Ref.reload(); |
188 expect(r1Ref.activationBreakpoint, equals(null)); | 196 expect(r2Ref.activationBreakpoint, equals(null)); |
189 print("testeeDo()"); | 197 print("testeeDo()"); |
190 res = await rootLib.evaluate("testeeDo()"); | 198 res = await rootLib.evaluate("testeeDo()"); |
191 expect(res is Instance, isTrue); // Not error. | 199 expect(res is Instance, isTrue); // Not error. |
192 expect(breaksHit, equals(4)); | 200 expect(breaksHit, equals(4)); |
193 | 201 |
194 await isolate.removeBreakpoint(bpt2); | 202 await cancelFutureSubscription(subscriptionFuture); |
195 print("Removed breakpoint $bpt2"); | 203 }, |
196 await r2Ref.reload(); | |
197 expect(r2Ref.activationBreakpoint, equals(null)); | |
198 print("testeeDo()"); | |
199 res = await rootLib.evaluate("testeeDo()"); | |
200 expect(res is Instance, isTrue); // Not error. | |
201 expect(breaksHit, equals(4)); | |
202 | |
203 await cancelFutureSubscription(subscriptionFuture); | |
204 }, | |
205 | |
206 ]; | 204 ]; |
207 | 205 |
208 main(args) => runIsolateTests(args, tests, testeeBefore: testeeSetup); | 206 main(args) => runIsolateTests(args, tests, testeeBefore: testeeSetup); |
OLD | NEW |