| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 part of vmservice_io; | 5 part of vmservice_io; |
| 6 | 6 |
| 7 final bool silentObservatory = const bool.fromEnvironment('SILENT_OBSERVATORY'); | 7 final bool silentObservatory = const bool.fromEnvironment('SILENT_OBSERVATORY'); |
| 8 | 8 |
| 9 void serverPrint(String s) { | 9 void serverPrint(String s) { |
| 10 if (silentObservatory) { | 10 if (silentObservatory) { |
| (...skipping 343 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 354 } | 354 } |
| 355 | 355 |
| 356 // poll for the network for ~10 seconds. | 356 // poll for the network for ~10 seconds. |
| 357 int attempts = 0; | 357 int attempts = 0; |
| 358 final int maxAttempts = 10; | 358 final int maxAttempts = 10; |
| 359 while (!await poll()) { | 359 while (!await poll()) { |
| 360 attempts++; | 360 attempts++; |
| 361 serverPrint("Observatory server failed to start after $attempts tries"); | 361 serverPrint("Observatory server failed to start after $attempts tries"); |
| 362 if (attempts > maxAttempts) { | 362 if (attempts > maxAttempts) { |
| 363 serverPrint('Could not start Observatory HTTP server:\n' | 363 serverPrint('Could not start Observatory HTTP server:\n' |
| 364 '$pollError\n$pollStack\n'); | 364 '$pollError\n$pollStack\n'); |
| 365 _notifyServerState(""); | 365 _notifyServerState(""); |
| 366 onServerAddressChange(null); | 366 onServerAddressChange(null); |
| 367 return this; | 367 return this; |
| 368 } | 368 } |
| 369 await new Future<Null>.delayed(const Duration(seconds: 1)); | 369 await new Future<Null>.delayed(const Duration(seconds: 1)); |
| 370 } | 370 } |
| 371 _server.listen(_requestHandler, cancelOnError: true); | 371 _server.listen(_requestHandler, cancelOnError: true); |
| 372 serverPrint('Observatory listening on $serverAddress'); | 372 serverPrint('Observatory listening on $serverAddress'); |
| 373 if (Platform.isFuchsia) { | 373 if (Platform.isFuchsia) { |
| 374 // Create a file with the port number. | 374 // Create a file with the port number. |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 415 _server = null; | 415 _server = null; |
| 416 serverPrint('Could not shutdown Observatory HTTP server:\n$e\n$st\n'); | 416 serverPrint('Could not shutdown Observatory HTTP server:\n$e\n$st\n'); |
| 417 _notifyServerState(""); | 417 _notifyServerState(""); |
| 418 onServerAddressChange(null); | 418 onServerAddressChange(null); |
| 419 return this; | 419 return this; |
| 420 }); | 420 }); |
| 421 } | 421 } |
| 422 } | 422 } |
| 423 | 423 |
| 424 void _notifyServerState(String uri) native "VMServiceIO_NotifyServerState"; | 424 void _notifyServerState(String uri) native "VMServiceIO_NotifyServerState"; |
| OLD | NEW |