Add context information to driver and add hooks for plugin management

pkg/analysis_server/lib/src/analysis_server.dart

 // 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.
 
 library analysis.server;
 
 import 'dart:async';
 import 'dart:collection';
 import 'dart:core';
 import 'dart:io' as io;
@@ skipping 10 matching lines @@
 import 'package:analysis_server/src/context_manager.dart';
 import 'package:analysis_server/src/domains/analysis/navigation.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/ide_options.dart';
 import 'package:analysis_server/src/operation/operation.dart';
 import 'package:analysis_server/src/operation/operation_analysis.dart';
 import 'package:analysis_server/src/operation/operation_queue.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/plugin/server_plugin.dart';
 import 'package:analysis_server/src/protocol_server.dart' as server;
 import 'package:analysis_server/src/server/diagnostic_server.dart';
 import 'package:analysis_server/src/services/correction/namespace.dart';
 import 'package:analysis_server/src/services/index/index.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/services/search/search_engine_internal2.dart';
 import 'package:analysis_server/src/single_context_manager.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/ast/standard_resolution_map.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';
@@ skipping 77 matching lines @@
   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 [Index] for this server, may be `null` if indexing is disabled.
    */
   final Index index;
 
   /**
@@ skipping 236 matching lines @@
       this.sdkManager,
       this.instrumentationService,
       {this.diagnosticServer,
       ResolverProvider fileResolverProvider: null,
       ResolverProvider packageResolverProvider: null,
       bool useSingleContextManager: false,
       this.rethrowExceptions: true})
       : notificationManager =
             new NotificationManager(channel, resourceProvider) {
     _performance = performanceDuringStartup;
+
+    pluginManager = new PluginManager(resourceProvider, _getByteStorePath(),
+        notificationManager, instrumentationService);
+    PluginWatcher pluginWatcher =
+        new PluginWatcher(resourceProvider, pluginManager);
+
     defaultContextOptions.incremental = true;
     defaultContextOptions.incrementalApi =
         options.enableIncrementalResolutionApi;
     defaultContextOptions.incrementalValidation =
         options.enableIncrementalResolutionValidation;
     defaultContextOptions.finerGrainedInvalidation =
         options.finerGrainedInvalidation;
     defaultContextOptions.generateImplicitErrors = false;
     operationQueue = new ServerOperationQueue();
 
     {
       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 nd.PerformanceLog(sink);
     }
     byteStore = _createByteStore();
-    analysisDriverScheduler =
-        new nd.AnalysisDriverScheduler(_analysisPerformanceLogger);
+    analysisDriverScheduler = new nd.AnalysisDriverScheduler(
+        _analysisPerformanceLogger,
+        driverWatcher: pluginWatcher);
     analysisDriverScheduler.status.listen(sendStatusNotificationNew);
     analysisDriverScheduler.start();
 
     if (useSingleContextManager) {
       contextManager = new SingleContextManager(resourceProvider, sdkManager,
           packageResolverProvider, analyzedFilesGlobs, defaultContextOptions);
     } else {
       contextManager = new ContextManagerImpl(
           resourceProvider,
           sdkManager,
@@ skipping 1297 matching lines @@
           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;
+  }
+
+  /**
    * Return a set of all contexts whose associated folder is contained within,
    * or equal to, one of the resources in the given list of [resources].
    */
   Set<AnalysisContext> _getContexts(List<Resource> resources) {
     Set<AnalysisContext> contexts = new HashSet<AnalysisContext>();
     resources.forEach((Resource resource) {
       if (resource is Folder) {
         contexts.addAll(contextManager.contextsInAnalysisRoot(resource));
       }
     });
@@ skipping 148 matching lines @@
   final AnalysisServer analysisServer;
 
   /**
    * The [ResourceProvider] by which paths are converted into [Resource]s.
    */
   final ResourceProvider resourceProvider;
 
   ServerContextManagerCallbacks(this.analysisServer, this.resourceProvider);
 
   @override
-  nd.AnalysisDriver addAnalysisDriver(Folder folder, AnalysisOptions options) {
+  nd.AnalysisDriver addAnalysisDriver(
+      Folder folder, ContextRoot contextRoot, AnalysisOptions options) {
     ContextBuilder builder = createContextBuilder(folder, options);
-    nd.AnalysisDriver analysisDriver = builder.buildDriver(folder.path);
+    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(
@@ skipping 390 matching lines @@
   /**
    * The [PerformanceTag] for time spent in server request handlers.
    */
   static PerformanceTag serverRequests = new PerformanceTag('serverRequests');
 
   /**
    * The [PerformanceTag] for time spent in split store microtasks.
    */
   static PerformanceTag splitStore = new PerformanceTag('splitStore');
 }