Add instrumentation (issue 22572)

pkg/analysis_server/lib/src/context_manager.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 context.directory.manager;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:analysis_server/src/analysis_server.dart';
 import 'package:analyzer/file_system/file_system.dart';
+import 'package:analyzer/instrumentation/instrumentation.dart';
 import 'package:analyzer/source/package_map_provider.dart';
 import 'package:analyzer/source/package_map_resolver.dart';
 import 'package:analyzer/src/generated/engine.dart';
 import 'package:analyzer/src/generated/java_io.dart';
 import 'package:analyzer/src/generated/source.dart';
 import 'package:analyzer/src/generated/source_io.dart';
 import 'package:path/path.dart' as pathos;
 import 'package:watcher/watcher.dart';
 
 
@@ skipping 57 matching lines @@
    * and non-folders have been removed.
    */
   Map<String, String> normalizedPackageRoots = <String, String>{};
 
   /**
    * Provider which is used to determine the mapping from package name to
    * package folder.
    */
   final PackageMapProvider _packageMapProvider;
 
-  ContextManager(this.resourceProvider, this._packageMapProvider) {
+  /**
+   * The instrumentation service used to report instrumentation data.
+   */
+  final InstrumentationService _instrumentationService;
+
+  ContextManager(this.resourceProvider, this._packageMapProvider,
+      this._instrumentationService) {
     pathContext = resourceProvider.pathContext;
   }
 
   /**
    * Create and return a new analysis context.
    */
   AnalysisContext addContext(Folder folder, UriResolver packageUriResolver);
 
   /**
    * Called when the set of files associated with a context have changed (or
@@ skipping 253 matching lines @@
         folder,
         pubspecFile,
         children,
         normalizedPackageRoots[folder.path]);
     _contexts[folder] = info;
     info.changeSubscription = folder.changes.listen((WatchEvent event) {
       _handleWatchEvent(folder, info, event);
     });
     UriResolver packageUriResolver = _computePackageUriResolver(folder, info);
     info.context = addContext(folder, packageUriResolver);
+    info.context.name = folder.path;
     return info;
   }
 
   /**
    * Creates a new context associated with [folder].
    *
    * If there are subfolders with 'pubspec.yaml' files, separate contexts
    * are created for them, and excluded from the context associated with
    * [folder].
    *
@@ skipping 80 matching lines @@
       ChangeSet changeSet = new ChangeSet();
       extractedSources.forEach((path, source) {
         oldInfo.sources.remove(path);
         changeSet.removedSource(source);
       });
       applyChangesToContext(oldInfo.folder, changeSet);
     }
   }
 
   void _handleWatchEvent(Folder folder, _ContextInfo info, WatchEvent event) {
+    _instrumentationService.logWatchEvent(
+        folder.path,
+        event.path,
+        event.type.toString());
     String path = event.path;
     // maybe excluded globally
     if (_isExcluded(path)) {
       return;
     }
     // maybe excluded from the context, so other context will handle it
     if (info.excludes(path)) {
       return;
     }
     // handle the change
@@ skipping 229 matching lines @@
     return excludes(resource.path);
   }
 
   /**
    * Returns `true` if [path] is the pubspec file of this context.
    */
   bool isPubspec(String path) {
     return path == pubspecPath;
   }
 }