OLD | NEW |
1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2016, 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 'dart:async'; | 5 import 'dart:async'; |
6 import 'dart:convert'; | 6 import 'dart:convert'; |
7 import 'dart:io'; | 7 import 'dart:io'; |
8 import 'dart:math'; | 8 import 'dart:math'; |
9 | 9 |
10 import 'package:analysis_server/plugin/protocol/protocol.dart'; | 10 import 'package:analysis_server/plugin/protocol/protocol.dart'; |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
58 Future setUp() { | 58 Future setUp() { |
59 onAnalysisErrors.listen((AnalysisErrorsParams params) { | 59 onAnalysisErrors.listen((AnalysisErrorsParams params) { |
60 currentAnalysisErrors[params.file] = params.errors; | 60 currentAnalysisErrors[params.file] = params.errors; |
61 }); | 61 }); |
62 onServerError.listen((ServerErrorParams params) { | 62 onServerError.listen((ServerErrorParams params) { |
63 // A server error should never happen during an integration test. | 63 // A server error should never happen during an integration test. |
64 fail('${params.message}\n${params.stackTrace}'); | 64 fail('${params.message}\n${params.stackTrace}'); |
65 }); | 65 }); |
66 Completer serverConnected = new Completer(); | 66 Completer serverConnected = new Completer(); |
67 onServerConnected.listen((_) { | 67 onServerConnected.listen((_) { |
68 expect(serverConnected.isCompleted, isFalse); | 68 outOfTestExpect(serverConnected.isCompleted, isFalse); |
69 serverConnected.complete(); | 69 serverConnected.complete(); |
70 }); | 70 }); |
71 return startServer(servicesPort: vmServicePort).then((_) { | 71 return startServer(servicesPort: vmServicePort).then((_) { |
72 server.listenToOutput(dispatchNotification); | 72 server.listenToOutput(dispatchNotification); |
73 server.exitCode.then((_) { | 73 server.exitCode.then((_) { |
74 skipShutdown = true; | 74 skipShutdown = true; |
75 }); | 75 }); |
76 return serverConnected.future; | 76 return serverConnected.future; |
77 }); | 77 }); |
78 } | 78 } |
(...skipping 23 matching lines...) Expand all Loading... |
102 /** | 102 /** |
103 * 1. Start Analysis Server. | 103 * 1. Start Analysis Server. |
104 * 2. Set the analysis [roots]. | 104 * 2. Set the analysis [roots]. |
105 * 3. Wait for analysis to complete. | 105 * 3. Wait for analysis to complete. |
106 * 4. Record the heap size after analysis is finished. | 106 * 4. Record the heap size after analysis is finished. |
107 * 5. Shutdown. | 107 * 5. Shutdown. |
108 * 6. Go to (1). | 108 * 6. Go to (1). |
109 */ | 109 */ |
110 static Future<List<int>> start_waitInitialAnalysis_shutdown( | 110 static Future<List<int>> start_waitInitialAnalysis_shutdown( |
111 {List<String> roots, int numOfRepeats}) async { | 111 {List<String> roots, int numOfRepeats}) async { |
112 expect(roots, isNotNull, reason: 'roots'); | 112 outOfTestExpect(roots, isNotNull, reason: 'roots'); |
113 expect(numOfRepeats, isNotNull, reason: 'numOfRepeats'); | 113 outOfTestExpect(numOfRepeats, isNotNull, reason: 'numOfRepeats'); |
114 // Repeat. | 114 // Repeat. |
115 List<int> sizes = <int>[]; | 115 List<int> sizes = <int>[]; |
116 for (int i = 0; i < numOfRepeats; i++) { | 116 for (int i = 0; i < numOfRepeats; i++) { |
117 AnalysisServerMemoryUsageTest test = new AnalysisServerMemoryUsageTest(); | 117 AnalysisServerMemoryUsageTest test = new AnalysisServerMemoryUsageTest(); |
118 // Initialize Analysis Server. | 118 // Initialize Analysis Server. |
119 await test.setUp(); | 119 await test.setUp(); |
120 await test.subscribeToStatusNotifications(); | 120 await test.subscribeToStatusNotifications(); |
121 // Set roots and analyze. | 121 // Set roots and analyze. |
122 await test.sendAnalysisSetAnalysisRoots(roots, []); | 122 await test.sendAnalysisSetAnalysisRoots(roots, []); |
123 await test.analysisFinished; | 123 await test.analysisFinished; |
124 sizes.add(test.getMemoryUsage()); | 124 sizes.add(test.getMemoryUsage()); |
125 // Stop the server. | 125 // Stop the server. |
126 await test.shutdown(); | 126 await test.shutdown(); |
127 } | 127 } |
128 return sizes; | 128 return sizes; |
129 } | 129 } |
130 } | 130 } |
OLD | NEW |