| // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
| // for details. All rights reserved. Use of this source code is governed by a |
| // BSD-style license that can be found in the LICENSE file. |
| |
| import 'dart:async'; |
| import 'dart:collection'; |
| import 'dart:core'; |
| import 'dart:io' as io; |
| import 'dart:math' show max; |
| |
| import 'package:analysis_server/protocol/protocol.dart'; |
| import 'package:analysis_server/protocol/protocol_generated.dart' |
| hide AnalysisOptions; |
| import 'package:analysis_server/src/analysis_logger.dart'; |
| import 'package:analysis_server/src/channel/channel.dart'; |
| import 'package:analysis_server/src/collections.dart'; |
| import 'package:analysis_server/src/computer/computer_highlights.dart'; |
| import 'package:analysis_server/src/computer/computer_highlights2.dart'; |
| import 'package:analysis_server/src/computer/computer_outline.dart'; |
| import 'package:analysis_server/src/computer/new_notifications.dart'; |
| import 'package:analysis_server/src/context_manager.dart'; |
| import 'package:analysis_server/src/domain_analysis.dart'; |
| import 'package:analysis_server/src/domain_analytics.dart'; |
| import 'package:analysis_server/src/domain_completion.dart'; |
| import 'package:analysis_server/src/domain_diagnostic.dart'; |
| import 'package:analysis_server/src/domain_execution.dart'; |
| import 'package:analysis_server/src/domain_kythe.dart'; |
| import 'package:analysis_server/src/domain_server.dart'; |
| import 'package:analysis_server/src/domains/analysis/navigation_dart.dart'; |
| import 'package:analysis_server/src/domains/analysis/occurrences.dart'; |
| import 'package:analysis_server/src/domains/analysis/occurrences_dart.dart'; |
| import 'package:analysis_server/src/edit/edit_domain.dart'; |
| import 'package:analysis_server/src/operation/operation_analysis.dart'; |
| import 'package:analysis_server/src/plugin/notification_manager.dart'; |
| import 'package:analysis_server/src/plugin/plugin_manager.dart'; |
| import 'package:analysis_server/src/plugin/plugin_watcher.dart'; |
| import 'package:analysis_server/src/protocol_server.dart' as server; |
| import 'package:analysis_server/src/search/search_domain.dart'; |
| import 'package:analysis_server/src/server/diagnostic_server.dart'; |
| import 'package:analysis_server/src/services/correction/namespace.dart'; |
| import 'package:analysis_server/src/services/search/search_engine.dart'; |
| import 'package:analysis_server/src/services/search/search_engine_internal.dart'; |
| import 'package:analysis_server/src/utilities/null_string_sink.dart'; |
| import 'package:analyzer/context/context_root.dart'; |
| import 'package:analyzer/dart/ast/ast.dart'; |
| import 'package:analyzer/dart/element/element.dart'; |
| import 'package:analyzer/exception/exception.dart'; |
| import 'package:analyzer/file_system/file_system.dart'; |
| import 'package:analyzer/file_system/physical_file_system.dart'; |
| import 'package:analyzer/instrumentation/instrumentation.dart'; |
| import 'package:analyzer/plugin/resolver_provider.dart'; |
| import 'package:analyzer/source/pub_package_map_provider.dart'; |
| import 'package:analyzer/src/context/builder.dart'; |
| import 'package:analyzer/src/dart/analysis/ast_provider_driver.dart'; |
| import 'package:analyzer/src/dart/analysis/driver.dart' as nd; |
| import 'package:analyzer/src/dart/analysis/file_state.dart' as nd; |
| import 'package:analyzer/src/dart/analysis/status.dart' as nd; |
| import 'package:analyzer/src/dart/ast/utilities.dart'; |
| import 'package:analyzer/src/dart/element/ast_provider.dart'; |
| import 'package:analyzer/src/generated/engine.dart'; |
| import 'package:analyzer/src/generated/sdk.dart'; |
| import 'package:analyzer/src/generated/source.dart'; |
| import 'package:analyzer/src/generated/source_io.dart'; |
| import 'package:analyzer/src/generated/utilities_general.dart'; |
| import 'package:analyzer/src/util/glob.dart'; |
| import 'package:analyzer_plugin/protocol/protocol_common.dart' hide Element; |
| import 'package:analyzer_plugin/src/utilities/navigation/navigation.dart'; |
| import 'package:front_end/src/base/performace_logger.dart'; |
| import 'package:front_end/src/byte_store/byte_store.dart'; |
| import 'package:front_end/src/byte_store/file_byte_store.dart'; |
| import 'package:telemetry/crash_reporting.dart'; |
| import 'package:telemetry/telemetry.dart' as telemetry; |
| import 'package:watcher/watcher.dart'; |
| |
| typedef void OptionUpdater(AnalysisOptionsImpl options); |
| |
| /** |
| * Enum representing reasons why analysis might be done for a given file. |
| */ |
| class AnalysisDoneReason { |
| /** |
| * Analysis of the file completed successfully. |
| */ |
| static const AnalysisDoneReason COMPLETE = |
| const AnalysisDoneReason._('COMPLETE'); |
| |
| /** |
| * Analysis of the file was aborted because the context was removed. |
| */ |
| static const AnalysisDoneReason CONTEXT_REMOVED = |
| const AnalysisDoneReason._('CONTEXT_REMOVED'); |
| |
| /** |
| * Textual description of this [AnalysisDoneReason]. |
| */ |
| final String text; |
| |
| const AnalysisDoneReason._(this.text); |
| } |
| |
| /** |
| * Instances of the class [AnalysisServer] implement a server that listens on a |
| * [CommunicationChannel] for analysis requests and process them. |
| */ |
| class AnalysisServer { |
| /** |
| * The version of the analysis server. The value should be replaced |
| * automatically during the build. |
| */ |
| static final String VERSION = '1.18.4'; |
| |
| /** |
| * The options of this server instance. |
| */ |
| AnalysisServerOptions options; |
| |
| /** |
| * The channel from which requests are received and to which responses should |
| * be sent. |
| */ |
| final ServerCommunicationChannel channel; |
| |
| /** |
| * The object used to manage sending a subset of notifications to the client. |
| * The subset of notifications are those to which plugins may contribute. |
| * This field is `null` when the new plugin support is disabled. |
| */ |
| final NotificationManager notificationManager; |
| |
| /** |
| * The object used to manage the execution of plugins. |
| */ |
| PluginManager pluginManager; |
| |
| /** |
| * The [ResourceProvider] using which paths are converted into [Resource]s. |
| */ |
| final ResourceProvider resourceProvider; |
| |
| /** |
| * The [SearchEngine] for this server, may be `null` if indexing is disabled. |
| */ |
| SearchEngine searchEngine; |
| |
| /** |
| * A list of the globs used to determine which files should be analyzed. The |
| * list is lazily created and should be accessed using [analyzedFilesGlobs]. |
| */ |
| List<Glob> _analyzedFilesGlobs = null; |
| |
| /** |
| * The [ContextManager] that handles the mapping from analysis roots to |
| * context directories. |
| */ |
| ContextManager contextManager; |
| |
| /** |
| * A flag indicating whether the server is running. When false, contexts |
| * will no longer be added to [contextWorkQueue], and [performOperation] will |
| * discard any tasks it finds on [contextWorkQueue]. |
| */ |
| bool running; |
| |
| /** |
| * A flag indicating the value of the 'analyzing' parameter sent in the last |
| * status message to the client. |
| */ |
| bool statusAnalyzing = false; |
| |
| /** |
| * A list of the request handlers used to handle the requests sent to this |
| * server. |
| */ |
| List<RequestHandler> handlers; |
| |
| /** |
| * The object used to manage the SDK's known to this server. |
| */ |
| DartSdkManager sdkManager; |
| |
| /** |
| * The instrumentation service that is to be used by this analysis server. |
| */ |
| final InstrumentationService instrumentationService; |
| |
| /** |
| * A set of the [ServerService]s to send notifications for. |
| */ |
| Set<ServerService> serverServices = new HashSet<ServerService>(); |
| |
| /** |
| * A set of the [GeneralAnalysisService]s to send notifications for. |
| */ |
| Set<GeneralAnalysisService> generalAnalysisServices = |
| new HashSet<GeneralAnalysisService>(); |
| |
| /** |
| * A table mapping [AnalysisService]s to the file paths for which these |
| * notifications should be sent. |
| */ |
| Map<AnalysisService, Set<String>> analysisServices = |
| new HashMap<AnalysisService, Set<String>>(); |
| |
| /** |
| * Performance information before initial analysis is complete. |
| */ |
| ServerPerformance performanceDuringStartup = new ServerPerformance(); |
| |
| /** |
| * Performance information after initial analysis is complete |
| * or `null` if the initial analysis is not yet complete |
| */ |
| ServerPerformance performanceAfterStartup; |
| |
| /** |
| * A [RecentBuffer] of the most recent exceptions encountered by the analysis |
| * server. |
| */ |
| final RecentBuffer<ServerException> exceptions = new RecentBuffer(10); |
| |
| /** |
| * The class into which performance information is currently being recorded. |
| * During startup, this will be the same as [performanceDuringStartup] |
| * and after startup is complete, this switches to [performanceAfterStartup]. |
| */ |
| ServerPerformance _performance; |
| |
| /** |
| * The [Completer] that completes when analysis is complete. |
| */ |
| Completer _onAnalysisCompleteCompleter; |
| |
| /** |
| * The controller that is notified when analysis is started. |
| */ |
| StreamController<bool> _onAnalysisStartedController; |
| |
| /** |
| * The controller that is notified when a single file has been analyzed. |
| */ |
| StreamController<ChangeNotice> _onFileAnalyzedController; |
| |
| /** |
| * The content overlay for all analysis drivers. |
| */ |
| final nd.FileContentOverlay fileContentOverlay = new nd.FileContentOverlay(); |
| |
| /** |
| * The current state of overlays from the client. This is used as the |
| * content cache for all contexts. |
| */ |
| final ContentCache overlayState = new ContentCache(); |
| |
| /** |
| * If the "analysis.analyzedFiles" notification is currently being subscribed |
| * to (see [generalAnalysisServices]), and at least one such notification has |
| * been sent since the subscription was enabled, the set of analyzed files |
| * that was delivered in the most recently sent notification. Otherwise |
| * `null`. |
| */ |
| Set<String> prevAnalyzedFiles; |
| |
| /** |
| * The default options used to create new analysis contexts. This object is |
| * also referenced by the ContextManager. |
| */ |
| final AnalysisOptionsImpl defaultContextOptions = new AnalysisOptionsImpl(); |
| |
| /** |
| * The file resolver provider used to override the way file URI's are |
| * resolved in some contexts. |
| */ |
| ResolverProvider fileResolverProvider; |
| |
| /** |
| * The package resolver provider used to override the way package URI's are |
| * resolved in some contexts. |
| */ |
| ResolverProvider packageResolverProvider; |
| |
| PerformanceLog _analysisPerformanceLogger; |
| |
| ByteStore byteStore; |
| nd.AnalysisDriverScheduler analysisDriverScheduler; |
| /** |
| * This exists as a temporary stopgap for plugins, until the official plugin |
| * API is complete. |
| */ |
| StreamController<String> _onFileAddedController; |
| |
| /** |
| * This exists as a temporary stopgap for plugins, until the official plugin |
| * API is complete. |
| */ |
| StreamController<String> _onFileChangedController; |
| |
| /** |
| * This exists as a temporary stopgap for plugins, until the official plugin |
| * API is complete. |
| */ |
| Function onResultErrorSupplementor; |
| |
| /** |
| * This exists as a temporary stopgap for plugins, until the official plugin |
| * API is complete. |
| */ |
| Function onNoAnalysisResult; |
| |
| /** |
| * This exists as a temporary stopgap for plugins, until the official plugin |
| * API is complete. |
| */ |
| Function onNoAnalysisCompletion; |
| |
| /** |
| * The set of the files that are currently priority. |
| */ |
| final Set<String> priorityFiles = new Set<String>(); |
| |
| /** |
| * The DiagnosticServer for this AnalysisServer. If available, it can be used |
| * to start an http diagnostics server or return the port for an existing |
| * server. |
| */ |
| DiagnosticServer diagnosticServer; |
| |
| /** |
| * Initialize a newly created server to receive requests from and send |
| * responses to the given [channel]. |
| * |
| * If [rethrowExceptions] is true, then any exceptions thrown by analysis are |
| * propagated up the call stack. The default is true to allow analysis |
| * exceptions to show up in unit tests, but it should be set to false when |
| * running a full analysis server. |
| */ |
| AnalysisServer( |
| this.channel, |
| this.resourceProvider, |
| PubPackageMapProvider packageMapProvider, |
| this.options, |
| this.sdkManager, |
| this.instrumentationService, |
| {this.diagnosticServer, |
| ResolverProvider fileResolverProvider: null, |
| ResolverProvider packageResolverProvider: null}) |
| : notificationManager = |
| new NotificationManager(channel, resourceProvider) { |
| _performance = performanceDuringStartup; |
| |
| pluginManager = new PluginManager( |
| resourceProvider, |
| _getByteStorePath(), |
| sdkManager.defaultSdkDirectory, |
| notificationManager, |
| instrumentationService); |
| PluginWatcher pluginWatcher = |
| new PluginWatcher(resourceProvider, pluginManager); |
| |
| defaultContextOptions.generateImplicitErrors = false; |
| |
| { |
| String name = options.newAnalysisDriverLog; |
| StringSink sink = new NullStringSink(); |
| if (name != null) { |
| if (name == 'stdout') { |
| sink = io.stdout; |
| } else if (name.startsWith('file:')) { |
| String path = name.substring('file:'.length); |
| sink = new io.File(path).openWrite(mode: io.FileMode.APPEND); |
| } |
| } |
| _analysisPerformanceLogger = new PerformanceLog(sink); |
| } |
| byteStore = _createByteStore(); |
| analysisDriverScheduler = new nd.AnalysisDriverScheduler( |
| _analysisPerformanceLogger, |
| driverWatcher: pluginWatcher); |
| analysisDriverScheduler.status.listen(sendStatusNotificationNew); |
| analysisDriverScheduler.start(); |
| |
| contextManager = new ContextManagerImpl( |
| resourceProvider, |
| sdkManager, |
| packageResolverProvider, |
| packageMapProvider, |
| analyzedFilesGlobs, |
| instrumentationService, |
| defaultContextOptions); |
| this.fileResolverProvider = fileResolverProvider; |
| this.packageResolverProvider = packageResolverProvider; |
| ServerContextManagerCallbacks contextManagerCallbacks = |
| new ServerContextManagerCallbacks(this, resourceProvider); |
| contextManager.callbacks = contextManagerCallbacks; |
| AnalysisEngine.instance.logger = new AnalysisLogger(this); |
| _onAnalysisStartedController = new StreamController.broadcast(); |
| _onFileAnalyzedController = new StreamController.broadcast(); |
| // temporary plugin support: |
| _onFileAddedController = new StreamController.broadcast(); |
| // temporary plugin support: |
| _onFileChangedController = new StreamController.broadcast(); |
| running = true; |
| onAnalysisStarted.first.then((_) { |
| onAnalysisComplete.then((_) { |
| performanceAfterStartup = new ServerPerformance(); |
| _performance = performanceAfterStartup; |
| }); |
| }); |
| searchEngine = new SearchEngineImpl(driverMap.values); |
| Notification notification = new ServerConnectedParams(VERSION, io.pid, |
| sessionId: instrumentationService.sessionId) |
| .toNotification(); |
| channel.sendNotification(notification); |
| channel.listen(handleRequest, onDone: done, onError: error); |
| handlers = <server.RequestHandler>[ |
| new ServerDomainHandler(this), |
| new AnalysisDomainHandler(this), |
| new EditDomainHandler(this), |
| new SearchDomainHandler(this), |
| new CompletionDomainHandler(this), |
| new ExecutionDomainHandler(this), |
| new DiagnosticDomainHandler(this), |
| new AnalyticsDomainHandler(this), |
| new KytheDomainHandler(this) |
| ]; |
| } |
| |
| /** |
| * Return a list of the globs used to determine which files should be analyzed. |
| */ |
| List<Glob> get analyzedFilesGlobs { |
| if (_analyzedFilesGlobs == null) { |
| _analyzedFilesGlobs = <Glob>[]; |
| List<String> patterns = <String>[ |
| '**/*.${AnalysisEngine.SUFFIX_DART}', |
| '**/*.${AnalysisEngine.SUFFIX_HTML}', |
| '**/*.${AnalysisEngine.SUFFIX_HTM}', |
| '**/${AnalysisEngine.ANALYSIS_OPTIONS_FILE}', |
| '**/${AnalysisEngine.ANALYSIS_OPTIONS_YAML_FILE}' |
| ]; |
| for (String pattern in patterns) { |
| try { |
| _analyzedFilesGlobs |
| .add(new Glob(resourceProvider.pathContext.separator, pattern)); |
| } catch (exception, stackTrace) { |
| AnalysisEngine.instance.logger.logError( |
| 'Invalid glob pattern: "$pattern"', |
| new CaughtException(exception, stackTrace)); |
| } |
| } |
| } |
| return _analyzedFilesGlobs; |
| } |
| |
| /** |
| * A table mapping [Folder]s to the [AnalysisDriver]s associated with them. |
| */ |
| Map<Folder, nd.AnalysisDriver> get driverMap => contextManager.driverMap; |
| |
| /** |
| * The [Future] that completes when analysis is complete. |
| */ |
| Future get onAnalysisComplete { |
| if (isAnalysisComplete()) { |
| return new Future.value(); |
| } |
| if (_onAnalysisCompleteCompleter == null) { |
| _onAnalysisCompleteCompleter = new Completer(); |
| } |
| return _onAnalysisCompleteCompleter.future; |
| } |
| |
| /** |
| * The stream that is notified with `true` when analysis is started. |
| */ |
| Stream<bool> get onAnalysisStarted { |
| return _onAnalysisStartedController.stream; |
| } |
| |
| /** |
| * The stream that is notified when a single file has been added. This exists |
| * as a temporary stopgap for plugins, until the official plugin API is |
| * complete. |
| */ |
| Stream get onFileAdded => _onFileAddedController.stream; |
| |
| /** |
| * The stream that is notified when a single file has been analyzed. |
| */ |
| Stream get onFileAnalyzed => _onFileAnalyzedController.stream; |
| |
| /** |
| * The stream that is notified when a single file has been changed. This |
| * exists as a temporary stopgap for plugins, until the official plugin API is |
| * complete. |
| */ |
| Stream get onFileChanged => _onFileChangedController.stream; |
| |
| /** |
| * Return the total time the server's been alive. |
| */ |
| Duration get uptime { |
| DateTime start = new DateTime.fromMillisecondsSinceEpoch( |
| performanceDuringStartup.startTime); |
| return new DateTime.now().difference(start); |
| } |
| |
| /** |
| * The socket from which requests are being read has been closed. |
| */ |
| void done() { |
| running = false; |
| } |
| |
| /** |
| * There was an error related to the socket from which requests are being |
| * read. |
| */ |
| void error(argument) { |
| running = false; |
| } |
| |
| /** |
| * If the given notice applies to a file contained within an analysis root, |
| * notify interested parties that the file has been (at least partially) |
| * analyzed. |
| */ |
| void fileAnalyzed(ChangeNotice notice) { |
| if (contextManager.isInAnalysisRoot(notice.source.fullName)) { |
| _onFileAnalyzedController.add(notice); |
| } |
| } |
| |
| /** |
| * Return one of the SDKs that has been created, or `null` if no SDKs have |
| * been created yet. |
| */ |
| DartSdk findSdk() { |
| DartSdk sdk = sdkManager.anySdk; |
| if (sdk != null) { |
| return sdk; |
| } |
| // TODO(brianwilkerson) Should we create an SDK using the default options? |
| return null; |
| } |
| |
| /** |
| * Return an analysis driver to which the file with the given [path] is |
| * added if one exists, otherwise a driver in which the file was analyzed if |
| * one exists, otherwise the first driver, otherwise `null`. |
| */ |
| nd.AnalysisDriver getAnalysisDriver(String path) { |
| List<nd.AnalysisDriver> drivers = driverMap.values.toList(); |
| if (drivers.isNotEmpty) { |
| // Sort the drivers so that more deeply nested contexts will be checked |
| // before enclosing contexts. |
| drivers.sort((first, second) => |
| second.contextRoot.root.length - first.contextRoot.root.length); |
| nd.AnalysisDriver driver = drivers.firstWhere( |
| (driver) => driver.contextRoot.containsFile(path), |
| orElse: () => null); |
| driver ??= drivers.firstWhere( |
| (driver) => driver.knownFiles.contains(path), |
| orElse: () => null); |
| driver ??= drivers.first; |
| return driver; |
| } |
| return null; |
| } |
| |
| /** |
| * Return the analysis result for the file with the given [path]. The file is |
| * analyzed in one of the analysis drivers to which the file was added, |
| * otherwise in the first driver, otherwise `null` is returned. |
| */ |
| Future<nd.AnalysisResult> getAnalysisResult(String path, |
| {bool sendCachedToStream: false}) async { |
| if (!AnalysisEngine.isDartFileName(path)) { |
| return null; |
| } |
| |
| try { |
| nd.AnalysisDriver driver = getAnalysisDriver(path); |
| return await driver?.getResult(path, |
| sendCachedToStream: sendCachedToStream); |
| } catch (e) { |
| // Ignore the exception. |
| // We don't want to log the same exception again and again. |
| return null; |
| } |
| } |
| |
| /** |
| * Return the [AstProvider] for the given [path]. |
| */ |
| AstProvider getAstProvider(String path) { |
| nd.AnalysisDriver analysisDriver = getAnalysisDriver(path); |
| return new AstProviderForDriver(analysisDriver); |
| } |
| |
| /** |
| * Return the cached analysis result for the file with the given [path]. |
| * If there is no cached result, return `null`. |
| */ |
| nd.AnalysisResult getCachedAnalysisResult(String path) { |
| if (!AnalysisEngine.isDartFileName(path)) { |
| return null; |
| } |
| |
| nd.AnalysisDriver driver = getAnalysisDriver(path); |
| return driver?.getCachedResult(path); |
| } |
| |
| /** |
| * Return the [nd.AnalysisDriver] for the "innermost" context whose associated |
| * folder is or contains the given path. ("innermost" refers to the nesting |
| * of contexts, so if there is a context for path /foo and a context for |
| * path /foo/bar, then the innermost context containing /foo/bar/baz.dart is |
| * the context for /foo/bar.) |
| * |
| * If no context contains the given path, `null` is returned. |
| */ |
| nd.AnalysisDriver getContainingDriver(String path) { |
| return contextManager.getDriverFor(path); |
| } |
| |
| /** |
| * Return a [Future] that completes with the [Element] at the given |
| * [offset] of the given [file], or with `null` if there is no node at the |
| * [offset] or the node does not have an element. |
| */ |
| Future<Element> getElementAtOffset(String file, int offset) async { |
| AstNode node = await getNodeAtOffset(file, offset); |
| return getElementOfNode(node); |
| } |
| |
| /** |
| * Return the [Element] of the given [node], or `null` if [node] is `null` or |
| * does not have an element. |
| */ |
| Element getElementOfNode(AstNode node) { |
| if (node == null) { |
| return null; |
| } |
| if (node is SimpleIdentifier && node.parent is LibraryIdentifier) { |
| node = node.parent; |
| } |
| if (node is LibraryIdentifier) { |
| node = node.parent; |
| } |
| if (node is StringLiteral && node.parent is UriBasedDirective) { |
| return null; |
| } |
| Element element = ElementLocator.locate(node); |
| if (node is SimpleIdentifier && element is PrefixElement) { |
| element = getImportElement(node); |
| } |
| return element; |
| } |
| |
| /** |
| * Return a [Future] that completes with the resolved [AstNode] at the |
| * given [offset] of the given [file], or with `null` if there is no node as |
| * the [offset]. |
| */ |
| Future<AstNode> getNodeAtOffset(String file, int offset) async { |
| nd.AnalysisResult result = await getAnalysisResult(file); |
| CompilationUnit unit = result?.unit; |
| if (unit != null) { |
| return new NodeLocator(offset).searchWithin(unit); |
| } |
| return null; |
| } |
| |
| /** |
| * Return a [Future] that completes with the resolved [CompilationUnit] for |
| * the Dart file with the given [path], or with `null` if the file is not a |
| * Dart file or cannot be resolved. |
| */ |
| Future<CompilationUnit> getResolvedCompilationUnit(String path) async { |
| nd.AnalysisResult result = await getAnalysisResult(path); |
| return result?.unit; |
| } |
| |
| /** |
| * Handle a [request] that was read from the communication channel. |
| */ |
| void handleRequest(Request request) { |
| _performance.logRequest(request); |
| runZoned(() { |
| ServerPerformanceStatistics.serverRequests.makeCurrentWhile(() { |
| int count = handlers.length; |
| for (int i = 0; i < count; i++) { |
| try { |
| Response response = handlers[i].handleRequest(request); |
| if (response == Response.DELAYED_RESPONSE) { |
| return; |
| } |
| if (response != null) { |
| channel.sendResponse(response); |
| return; |
| } |
| } on RequestFailure catch (exception) { |
| channel.sendResponse(exception.response); |
| return; |
| } catch (exception, stackTrace) { |
| RequestError error = new RequestError( |
| RequestErrorCode.SERVER_ERROR, exception.toString()); |
| if (stackTrace != null) { |
| error.stackTrace = stackTrace.toString(); |
| } |
| Response response = new Response(request.id, error: error); |
| channel.sendResponse(response); |
| return; |
| } |
| } |
| channel.sendResponse(new Response.unknownRequest(request)); |
| }); |
| }, onError: (exception, stackTrace) { |
| sendServerErrorNotification( |
| 'Failed to handle request: ${request.toJson()}', |
| exception, |
| stackTrace, |
| fatal: true); |
| }); |
| } |
| |
| /** |
| * Returns `true` if there is a subscription for the given [service] and |
| * [file]. |
| */ |
| bool hasAnalysisSubscription(AnalysisService service, String file) { |
| Set<String> files = analysisServices[service]; |
| return files != null && files.contains(file); |
| } |
| |
| /** |
| * Return `true` if analysis is complete. |
| */ |
| bool isAnalysisComplete() { |
| return !analysisDriverScheduler.isAnalyzing; |
| } |
| |
| /** |
| * Return `true` if the given path is a valid `FilePath`. |
| * |
| * This means that it is absolute and normalized. |
| */ |
| bool isValidFilePath(String path) { |
| return resourceProvider.absolutePathContext.isValid(path); |
| } |
| |
| /** |
| * Trigger reanalysis of all files in the given list of analysis [roots], or |
| * everything if the analysis roots is `null`. |
| */ |
| void reanalyze(List<Resource> roots) { |
| // Instruct the contextDirectoryManager to rebuild all contexts from |
| // scratch. |
| contextManager.refresh(roots); |
| } |
| |
| /** |
| * Send the given [notification] to the client. |
| */ |
| void sendNotification(Notification notification) { |
| channel.sendNotification(notification); |
| } |
| |
| /** |
| * Send the given [response] to the client. |
| */ |
| void sendResponse(Response response) { |
| channel.sendResponse(response); |
| } |
| |
| /** |
| * Sends a `server.error` notification. |
| */ |
| void sendServerErrorNotification(String message, exception, stackTrace, |
| {bool fatal: false}) { |
| StringBuffer buffer = new StringBuffer(); |
| buffer.write(exception ?? 'null exception'); |
| if (stackTrace != null) { |
| buffer.writeln(); |
| buffer.write(stackTrace); |
| } else if (exception is! CaughtException) { |
| stackTrace = StackTrace.current; |
| buffer.writeln(); |
| buffer.write(stackTrace); |
| } |
| |
| // send the notification |
| channel.sendNotification( |
| new ServerErrorParams(fatal, message, buffer.toString()) |
| .toNotification()); |
| |
| // send to crash reporting |
| if (options.crashReportSender != null) { |
| // Catch and ignore any exceptions when reporting exceptions (network |
| // errors or other). |
| options.crashReportSender |
| .sendReport(exception, stackTrace: stackTrace) |
| .catchError((_) {}); |
| } |
| |
| // remember the last few exceptions |
| if (exception is CaughtException) { |
| stackTrace ??= exception.stackTrace; |
| } |
| exceptions.add(new ServerException(message, exception, stackTrace, fatal)); |
| } |
| |
| /** |
| * Send status notification to the client. The state of analysis is given by |
| * the [status] information. |
| */ |
| void sendStatusNotificationNew(nd.AnalysisStatus status) { |
| if (status.isAnalyzing) { |
| _onAnalysisStartedController.add(true); |
| } |
| if (_onAnalysisCompleteCompleter != null && !status.isAnalyzing) { |
| _onAnalysisCompleteCompleter.complete(); |
| _onAnalysisCompleteCompleter = null; |
| } |
| // Perform on-idle actions. |
| if (!status.isAnalyzing) { |
| if (generalAnalysisServices |
| .contains(GeneralAnalysisService.ANALYZED_FILES)) { |
| sendAnalysisNotificationAnalyzedFiles(this); |
| } |
| _scheduleAnalysisImplementedNotification(); |
| } |
| // Only send status when subscribed. |
| if (!serverServices.contains(ServerService.STATUS)) { |
| return; |
| } |
| // Only send status when it changes |
| if (statusAnalyzing == status.isAnalyzing) { |
| return; |
| } |
| statusAnalyzing = status.isAnalyzing; |
| AnalysisStatus analysis = new AnalysisStatus(status.isAnalyzing); |
| channel.sendNotification( |
| new ServerStatusParams(analysis: analysis).toNotification()); |
| } |
| |
| /** |
| * Implementation for `analysis.setAnalysisRoots`. |
| * |
| * TODO(scheglov) implement complete projects/contexts semantics. |
| * |
| * The current implementation is intentionally simplified and expected |
| * that only folders are given each given folder corresponds to the exactly |
| * one context. |
| * |
| * So, we can start working in parallel on adding services and improving |
| * projects/contexts support. |
| */ |
| void setAnalysisRoots(String requestId, List<String> includedPaths, |
| List<String> excludedPaths, Map<String, String> packageRoots) { |
| if (notificationManager != null) { |
| notificationManager.setAnalysisRoots(includedPaths, excludedPaths); |
| } |
| try { |
| contextManager.setRoots(includedPaths, excludedPaths, packageRoots); |
| } on UnimplementedError catch (e) { |
| throw new RequestFailure( |
| new Response.unsupportedFeature(requestId, e.message)); |
| } |
| } |
| |
| /** |
| * Implementation for `analysis.setSubscriptions`. |
| */ |
| void setAnalysisSubscriptions( |
| Map<AnalysisService, Set<String>> subscriptions) { |
| if (notificationManager != null) { |
| notificationManager.setSubscriptions(subscriptions); |
| } |
| this.analysisServices = subscriptions; |
| Set<String> allNewFiles = |
| subscriptions.values.expand((files) => files).toSet(); |
| for (String file in allNewFiles) { |
| // The result will be produced by the "results" stream with |
| // the fully resolved unit, and processed with sending analysis |
| // notifications as it happens after content changes. |
| if (AnalysisEngine.isDartFileName(file)) { |
| getAnalysisResult(file, sendCachedToStream: true); |
| } |
| } |
| } |
| |
| /** |
| * Implementation for `analysis.setGeneralSubscriptions`. |
| */ |
| void setGeneralAnalysisSubscriptions( |
| List<GeneralAnalysisService> subscriptions) { |
| Set<GeneralAnalysisService> newServices = subscriptions.toSet(); |
| if (newServices.contains(GeneralAnalysisService.ANALYZED_FILES) && |
| !generalAnalysisServices |
| .contains(GeneralAnalysisService.ANALYZED_FILES) && |
| isAnalysisComplete()) { |
| sendAnalysisNotificationAnalyzedFiles(this); |
| } else if (!newServices.contains(GeneralAnalysisService.ANALYZED_FILES) && |
| generalAnalysisServices |
| .contains(GeneralAnalysisService.ANALYZED_FILES)) { |
| prevAnalyzedFiles = null; |
| } |
| generalAnalysisServices = newServices; |
| } |
| |
| /** |
| * Set the priority files to the given [files]. |
| */ |
| void setPriorityFiles(String requestId, List<String> files) { |
| priorityFiles.clear(); |
| priorityFiles.addAll(files); |
| // Set priority files in drivers. |
| driverMap.values.forEach((driver) { |
| driver.priorityFiles = files; |
| }); |
| } |
| |
| /** |
| * Returns `true` if errors should be reported for [file] with the given |
| * absolute path. |
| */ |
| bool shouldSendErrorsNotificationFor(String file) { |
| return contextManager.isInAnalysisRoot(file); |
| } |
| |
| Future<Null> shutdown() async { |
| running = false; |
| |
| await options.analytics |
| ?.waitForLastPing(timeout: new Duration(milliseconds: 200)); |
| options.analytics?.close(); |
| |
| // Defer closing the channel and shutting down the instrumentation server so |
| // that the shutdown response can be sent and logged. |
| new Future(() { |
| instrumentationService.shutdown(); |
| channel.close(); |
| }); |
| } |
| |
| /** |
| * Implementation for `analysis.updateContent`. |
| */ |
| void updateContent(String id, Map<String, dynamic> changes) { |
| changes.forEach((file, change) { |
| // Prepare the new contents. |
| String oldContents = fileContentOverlay[file]; |
| String newContents; |
| if (change is AddContentOverlay) { |
| newContents = change.content; |
| } else if (change is ChangeContentOverlay) { |
| if (oldContents == null) { |
| // The client may only send a ChangeContentOverlay if there is |
| // already an existing overlay for the source. |
| throw new RequestFailure(new Response(id, |
| error: new RequestError(RequestErrorCode.INVALID_OVERLAY_CHANGE, |
| 'Invalid overlay change'))); |
| } |
| try { |
| newContents = SourceEdit.applySequence(oldContents, change.edits); |
| } on RangeError { |
| throw new RequestFailure(new Response(id, |
| error: new RequestError(RequestErrorCode.INVALID_OVERLAY_CHANGE, |
| 'Invalid overlay change'))); |
| } |
| } else if (change is RemoveContentOverlay) { |
| newContents = null; |
| } else { |
| // Protocol parsing should have ensured that we never get here. |
| throw new AnalysisException('Illegal change type'); |
| } |
| |
| fileContentOverlay[file] = newContents; |
| |
| driverMap.values.forEach((driver) { |
| driver.changeFile(file); |
| }); |
| |
| // temporary plugin support: |
| _onFileChangedController.add(file); |
| |
| // If the file did not exist, and is "overlay only", it still should be |
| // analyzed. Add it to driver to which it should have been added. |
| contextManager.getDriverFor(file)?.addFile(file); |
| |
| // TODO(scheglov) implement other cases |
| }); |
| } |
| |
| /** |
| * Use the given updaters to update the values of the options in every |
| * existing analysis context. |
| */ |
| void updateOptions(List<OptionUpdater> optionUpdaters) { |
| // TODO(scheglov) implement for the new analysis driver |
| // // |
| // // Update existing contexts. |
| // // |
| // for (AnalysisContext context in analysisContexts) { |
| // AnalysisOptionsImpl options = |
| // new AnalysisOptionsImpl.from(context.analysisOptions); |
| // optionUpdaters.forEach((OptionUpdater optionUpdater) { |
| // optionUpdater(options); |
| // }); |
| // context.analysisOptions = options; |
| // // TODO(brianwilkerson) As far as I can tell, this doesn't cause analysis |
| // // to be scheduled for this context. |
| // } |
| // // |
| // // Update the defaults used to create new contexts. |
| // // |
| // optionUpdaters.forEach((OptionUpdater optionUpdater) { |
| // optionUpdater(defaultContextOptions); |
| // }); |
| } |
| |
| void _computingPackageMap(bool computing) { |
| if (serverServices.contains(ServerService.STATUS)) { |
| PubStatus pubStatus = new PubStatus(computing); |
| ServerStatusParams params = new ServerStatusParams(pub: pubStatus); |
| sendNotification(params.toNotification()); |
| } |
| } |
| |
| /** |
| * If the state location can be accessed, return the file byte store, |
| * otherwise return the memory byte store. |
| */ |
| ByteStore _createByteStore() { |
| const int M = 1024 * 1024 /*1 MiB*/; |
| const int G = 1024 * 1024 * 1024 /*1 GiB*/; |
| if (resourceProvider is PhysicalResourceProvider) { |
| Folder stateLocation = |
| resourceProvider.getStateLocation('.analysis-driver'); |
| if (stateLocation != null) { |
| return new MemoryCachingByteStore( |
| new EvictingFileByteStore(stateLocation.path, G), 64 * M); |
| } |
| } |
| return new MemoryCachingByteStore(new NullByteStore(), 64 * M); |
| } |
| |
| /** |
| * Return the path to the location of the byte store on disk, or `null` if |
| * there is no on-disk byte store. |
| */ |
| String _getByteStorePath() { |
| if (resourceProvider is PhysicalResourceProvider) { |
| Folder stateLocation = |
| resourceProvider.getStateLocation('.analysis-driver'); |
| if (stateLocation != null) { |
| return stateLocation.path; |
| } |
| } |
| return null; |
| } |
| |
| bool _hasAnalysisServiceSubscription(AnalysisService service, String file) { |
| return analysisServices[service]?.contains(file) ?? false; |
| } |
| |
| _scheduleAnalysisImplementedNotification() async { |
| Set<String> files = analysisServices[AnalysisService.IMPLEMENTED]; |
| if (files != null) { |
| scheduleImplementedNotification(this, files); |
| } |
| } |
| } |
| |
| /** |
| * Various IDE options. |
| */ |
| class AnalysisServerOptions { |
| bool useAnalysisHighlight2 = false; |
| |
| String fileReadMode = 'as-is'; |
| String newAnalysisDriverLog; |
| |
| String clientId; |
| String clientVersion; |
| |
| /** |
| * Base path where to cache data. |
| */ |
| String cacheFolder; |
| |
| /** |
| * The analytics instance; note, this object can be `null`, and should be |
| * accessed via a null-aware operator. |
| */ |
| telemetry.Analytics analytics; |
| |
| /** |
| * The crash report sender instance; note, this object can be `null`, and |
| * should be accessed via a null-aware operator. |
| */ |
| CrashReportSender crashReportSender; |
| } |
| |
| /** |
| * A [PriorityChangeEvent] indicates the set the priority files has changed. |
| */ |
| class PriorityChangeEvent { |
| final Source firstSource; |
| |
| PriorityChangeEvent(this.firstSource); |
| } |
| |
| class ServerContextManagerCallbacks extends ContextManagerCallbacks { |
| final AnalysisServer analysisServer; |
| |
| /** |
| * The [ResourceProvider] by which paths are converted into [Resource]s. |
| */ |
| final ResourceProvider resourceProvider; |
| |
| ServerContextManagerCallbacks(this.analysisServer, this.resourceProvider); |
| |
| @override |
| NotificationManager get notificationManager => |
| analysisServer.notificationManager; |
| |
| @override |
| nd.AnalysisDriver addAnalysisDriver( |
| Folder folder, ContextRoot contextRoot, AnalysisOptions options) { |
| ContextBuilder builder = createContextBuilder(folder, options); |
| nd.AnalysisDriver analysisDriver = builder.buildDriver(contextRoot); |
| analysisDriver.results.listen((result) { |
| NotificationManager notificationManager = |
| analysisServer.notificationManager; |
| String path = result.path; |
| if (analysisServer.shouldSendErrorsNotificationFor(path)) { |
| if (notificationManager != null) { |
| notificationManager.recordAnalysisErrors( |
| NotificationManager.serverId, |
| path, |
| server.doAnalysisError_listFromEngine( |
| result.driver.analysisOptions, |
| result.lineInfo, |
| result.errors)); |
| } else { |
| new_sendErrorNotification(analysisServer, result); |
| } |
| } |
| CompilationUnit unit = result.unit; |
| if (unit != null) { |
| if (notificationManager != null) { |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.HIGHLIGHTS, path)) { |
| _runDelayed(() { |
| notificationManager.recordHighlightRegions( |
| NotificationManager.serverId, |
| path, |
| _computeHighlightRegions(unit)); |
| }); |
| } |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.NAVIGATION, path)) { |
| _runDelayed(() { |
| notificationManager.recordNavigationParams( |
| NotificationManager.serverId, |
| path, |
| _computeNavigationParams(path, unit)); |
| }); |
| } |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.OCCURRENCES, path)) { |
| _runDelayed(() { |
| notificationManager.recordOccurrences( |
| NotificationManager.serverId, |
| path, |
| _computeOccurrences(unit)); |
| }); |
| } |
| // if (analysisServer._hasAnalysisServiceSubscription( |
| // AnalysisService.OUTLINE, path)) { |
| // _runDelayed(() { |
| // // TODO(brianwilkerson) Change NotificationManager to store params |
| // // so that fileKind and libraryName can be recorded / passed along. |
| // notificationManager.recordOutlines(NotificationManager.serverId, |
| // path, _computeOutlineParams(path, unit, result.lineInfo)); |
| // }); |
| // } |
| } else { |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.HIGHLIGHTS, path)) { |
| _runDelayed(() { |
| sendAnalysisNotificationHighlights(analysisServer, path, unit); |
| }); |
| } |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.NAVIGATION, path)) { |
| _runDelayed(() { |
| new_sendDartNotificationNavigation(analysisServer, result); |
| }); |
| } |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.OCCURRENCES, path)) { |
| _runDelayed(() { |
| new_sendDartNotificationOccurrences(analysisServer, result); |
| }); |
| } |
| } |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.CLOSING_LABELS, path)) { |
| _runDelayed(() { |
| sendAnalysisNotificationClosingLabels( |
| analysisServer, path, result.lineInfo, unit); |
| }); |
| } |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.OUTLINE, path)) { |
| _runDelayed(() { |
| SourceKind sourceKind = |
| unit.directives.any((d) => d is PartOfDirective) |
| ? SourceKind.PART |
| : SourceKind.LIBRARY; |
| sendAnalysisNotificationOutline( |
| analysisServer, path, result.lineInfo, sourceKind, unit); |
| }); |
| } |
| if (analysisServer._hasAnalysisServiceSubscription( |
| AnalysisService.OVERRIDES, path)) { |
| _runDelayed(() { |
| sendAnalysisNotificationOverrides(analysisServer, path, unit); |
| }); |
| } |
| // TODO(scheglov) Implement notifications for AnalysisService.IMPLEMENTED. |
| } |
| }); |
| analysisDriver.exceptions.listen((nd.ExceptionResult result) { |
| String message = 'Analysis failed: ${result.path}'; |
| if (result.contextKey != null) { |
| message += ' context: ${result.contextKey}'; |
| } |
| AnalysisEngine.instance.logger.logError(message, result.exception); |
| }); |
| analysisServer.driverMap[folder] = analysisDriver; |
| return analysisDriver; |
| } |
| |
| @override |
| void applyChangesToContext(Folder contextFolder, ChangeSet changeSet) { |
| nd.AnalysisDriver analysisDriver = analysisServer.driverMap[contextFolder]; |
| if (analysisDriver != null) { |
| changeSet.addedSources.forEach((source) { |
| analysisDriver.addFile(source.fullName); |
| // temporary plugin support: |
| analysisServer._onFileAddedController.add(source.fullName); |
| }); |
| changeSet.changedSources.forEach((source) { |
| analysisDriver.changeFile(source.fullName); |
| // temporary plugin support: |
| analysisServer._onFileChangedController.add(source.fullName); |
| }); |
| changeSet.removedSources.forEach((source) { |
| analysisDriver.removeFile(source.fullName); |
| }); |
| } |
| } |
| |
| @override |
| void applyFileRemoved(nd.AnalysisDriver driver, String file) { |
| driver.removeFile(file); |
| sendAnalysisNotificationFlushResults(analysisServer, [file]); |
| } |
| |
| @override |
| void broadcastWatchEvent(WatchEvent event) { |
| analysisServer.pluginManager.broadcastWatchEvent(event); |
| } |
| |
| @override |
| void computingPackageMap(bool computing) => |
| analysisServer._computingPackageMap(computing); |
| |
| @override |
| ContextBuilder createContextBuilder(Folder folder, AnalysisOptions options) { |
| String defaultPackageFilePath = null; |
| String defaultPackagesDirectoryPath = null; |
| String path = (analysisServer.contextManager as ContextManagerImpl) |
| .normalizedPackageRoots[folder.path]; |
| if (path != null) { |
| Resource resource = resourceProvider.getResource(path); |
| if (resource.exists) { |
| if (resource is File) { |
| defaultPackageFilePath = path; |
| } else { |
| defaultPackagesDirectoryPath = path; |
| } |
| } |
| } |
| |
| ContextBuilderOptions builderOptions = new ContextBuilderOptions(); |
| builderOptions.defaultOptions = options; |
| builderOptions.defaultPackageFilePath = defaultPackageFilePath; |
| builderOptions.defaultPackagesDirectoryPath = defaultPackagesDirectoryPath; |
| ContextBuilder builder = new ContextBuilder(resourceProvider, |
| analysisServer.sdkManager, analysisServer.overlayState, |
| options: builderOptions); |
| builder.fileResolverProvider = analysisServer.fileResolverProvider; |
| builder.packageResolverProvider = analysisServer.packageResolverProvider; |
| builder.analysisDriverScheduler = analysisServer.analysisDriverScheduler; |
| builder.performanceLog = analysisServer._analysisPerformanceLogger; |
| builder.byteStore = analysisServer.byteStore; |
| builder.fileContentOverlay = analysisServer.fileContentOverlay; |
| return builder; |
| } |
| |
| @override |
| void moveContext(Folder from, Folder to) { |
| // There is nothing to do. |
| // This method is mostly for tests. |
| // Context managers manage folders and contexts themselves. |
| } |
| |
| @override |
| void removeContext(Folder folder, List<String> flushedFiles) { |
| sendAnalysisNotificationFlushResults(analysisServer, flushedFiles); |
| nd.AnalysisDriver driver = analysisServer.driverMap.remove(folder); |
| driver.dispose(); |
| } |
| |
| List<HighlightRegion> _computeHighlightRegions(CompilationUnit unit) { |
| if (analysisServer.options.useAnalysisHighlight2) { |
| return new DartUnitHighlightsComputer2(unit).compute(); |
| } else { |
| return new DartUnitHighlightsComputer(unit).compute(); |
| } |
| } |
| |
| String _computeLibraryName(CompilationUnit unit) { |
| for (Directive directive in unit.directives) { |
| if (directive is LibraryDirective && directive.name != null) { |
| return directive.name.name; |
| } |
| } |
| for (Directive directive in unit.directives) { |
| if (directive is PartOfDirective && directive.libraryName != null) { |
| return directive.libraryName.name; |
| } |
| } |
| return null; |
| } |
| |
| server.AnalysisNavigationParams _computeNavigationParams( |
| String path, CompilationUnit unit) { |
| NavigationCollectorImpl collector = new NavigationCollectorImpl(); |
| computeDartNavigation(collector, unit, null, null); |
| collector.createRegions(); |
| return new server.AnalysisNavigationParams( |
| path, collector.regions, collector.targets, collector.files); |
| } |
| |
| List<Occurrences> _computeOccurrences(CompilationUnit unit) { |
| OccurrencesCollectorImpl collector = new OccurrencesCollectorImpl(); |
| addDartOccurrences(collector, unit); |
| return collector.allOccurrences; |
| } |
| |
| // ignore: unused_element |
| server.AnalysisOutlineParams _computeOutlineParams( |
| String path, CompilationUnit unit, LineInfo lineInfo) { |
| // compute FileKind |
| SourceKind sourceKind = unit.directives.any((d) => d is PartOfDirective) |
| ? SourceKind.PART |
| : SourceKind.LIBRARY; |
| server.FileKind fileKind = server.FileKind.LIBRARY; |
| if (sourceKind == SourceKind.LIBRARY) { |
| fileKind = server.FileKind.LIBRARY; |
| } else if (sourceKind == SourceKind.PART) { |
| fileKind = server.FileKind.PART; |
| } |
| // compute library name |
| String libraryName = _computeLibraryName(unit); |
| // compute Outline |
| DartUnitOutlineComputer computer = |
| new DartUnitOutlineComputer(path, lineInfo, unit); |
| server.Outline outline = computer.compute(); |
| return new server.AnalysisOutlineParams(path, fileKind, outline, |
| libraryName: libraryName); |
| } |
| |
| /** |
| * Run [f] in a new [Future]. |
| * |
| * This method is used to delay sending notifications. If there is a more |
| * important consumer of an analysis results, specifically a code completion |
| * computer, we want it to run before spending time of sending notifications. |
| * |
| * TODO(scheglov) Consider replacing this with full priority based scheduler. |
| * |
| * TODO(scheglov) Alternatively, if code completion work in a way that does |
| * not produce (at first) fully resolved unit, but only part of it - a single |
| * method, or a top-level declaration, we would not have this problem - the |
| * completion computer would be the only consumer of the partial analysis |
| * result. |
| */ |
| void _runDelayed(f()) { |
| new Future(f); |
| } |
| } |
| |
| /** |
| * Used to record server exceptions. |
| */ |
| class ServerException { |
| final String message; |
| final dynamic exception; |
| final StackTrace stackTrace; |
| final bool fatal; |
| |
| ServerException(this.message, this.exception, this.stackTrace, this.fatal); |
| |
| @override |
| String toString() => message; |
| } |
| |
| /** |
| * A class used by [AnalysisServer] to record performance information |
| * such as request latency. |
| */ |
| class ServerPerformance { |
| /** |
| * The creation time and the time when performance information |
| * started to be recorded here. |
| */ |
| int startTime = new DateTime.now().millisecondsSinceEpoch; |
| |
| /** |
| * The number of requests. |
| */ |
| int requestCount = 0; |
| |
| /** |
| * The total latency (milliseconds) for all recorded requests. |
| */ |
| int requestLatency = 0; |
| |
| /** |
| * The maximum latency (milliseconds) for all recorded requests. |
| */ |
| int maxLatency = 0; |
| |
| /** |
| * The number of requests with latency > 150 milliseconds. |
| */ |
| int slowRequestCount = 0; |
| |
| /** |
| * Log performance information about the given request. |
| */ |
| void logRequest(Request request) { |
| ++requestCount; |
| if (request.clientRequestTime != null) { |
| int latency = |
| new DateTime.now().millisecondsSinceEpoch - request.clientRequestTime; |
| requestLatency += latency; |
| maxLatency = max(maxLatency, latency); |
| if (latency > 150) { |
| ++slowRequestCount; |
| } |
| } |
| } |
| } |
| |
| /** |
| * Container with global [AnalysisServer] performance statistics. |
| */ |
| class ServerPerformanceStatistics { |
| /** |
| * The [PerformanceTag] for `package:analysis_server`. |
| */ |
| static PerformanceTag server = new PerformanceTag('server'); |
| |
| /** |
| * The [PerformanceTag] for time spent in [ExecutionDomainHandler]. |
| */ |
| static PerformanceTag executionNotifications = |
| new PerformanceTag('executionNotifications'); |
| |
| /** |
| * The [PerformanceTag] for time spent performing a _DartIndexOperation. |
| */ |
| static PerformanceTag indexOperation = new PerformanceTag('indexOperation'); |
| |
| /** |
| * The [PerformanceTag] for time spent between calls to |
| * AnalysisServer.performOperation when the server is not idle. |
| */ |
| static PerformanceTag intertask = new PerformanceTag('intertask'); |
| |
| /** |
| * The [PerformanceTag] for time spent between calls to |
| * AnalysisServer.performOperation when the server is idle. |
| */ |
| static PerformanceTag idle = new PerformanceTag('idle'); |
| |
| /** |
| * The [PerformanceTag] for time spent in |
| * PerformAnalysisOperation._sendNotices. |
| */ |
| static PerformanceTag notices = server.createChild('notices'); |
| |
| /** |
| * The [PerformanceTag] for time spent running pub. |
| */ |
| static PerformanceTag pub = server.createChild('pub'); |
| |
| /** |
| * The [PerformanceTag] for time spent in server communication channels. |
| */ |
| static PerformanceTag serverChannel = server.createChild('channel'); |
| |
| /** |
| * The [PerformanceTag] for time spent in server request handlers. |
| */ |
| static PerformanceTag serverRequests = server.createChild('requests'); |
| |
| /** |
| * The [PerformanceTag] for time spent in split store microtasks. |
| */ |
| static PerformanceTag splitStore = new PerformanceTag('splitStore'); |
| } |
