Change all sources associated with changed files (issue 22680)

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:math' show max;
 
@@ skipping 1002 matching lines @@
         }
       } else if (change is RemoveContentOverlay) {
         newContents = null;
       } else {
         // Protocol parsing should have ensured that we never get here.
         throw new AnalysisException('Illegal change type');
       }
       overlayState.setContents(source, newContents);
       // Update all contexts.
       for (InternalAnalysisContext context in folderMap.values) {
-        if (context.handleContentsChanged(
-            source, oldContents, newContents, true)) {
-          schedulePerformAnalysisOperation(context);
-        } else {
-          // When the client sends any change for a source, we should resend
-          // subscribed notifications, even if there were no changes in the
-          // source contents.
-          // TODO(scheglov) consider checking if there are subscriptions.
-          if (AnalysisEngine.isDartFileName(file)) {
-            List<CompilationUnit> dartUnits =
-                context.ensureResolvedDartUnits(source);
-            if (dartUnits != null) {
-              AnalysisErrorInfo errorInfo = context.getErrors(source);
-              for (var dartUnit in dartUnits) {
-                scheduleNotificationOperations(this, file, errorInfo.lineInfo,
-                    context, null, dartUnit, errorInfo.errors);
-                scheduleIndexOperation(this, file, context, dartUnit);
+        List<Source> sources = context.getSourcesWithFullName(file);
+        sources.forEach((Source source) {
+          if (context.handleContentsChanged(
+              source, oldContents, newContents, true)) {
+            schedulePerformAnalysisOperation(context);
+          } else {
+            // When the client sends any change for a source, we should resend
+            // subscribed notifications, even if there were no changes in the
+            // source contents.
+            // TODO(scheglov) consider checking if there are subscriptions.
+            if (AnalysisEngine.isDartFileName(file)) {
+              List<CompilationUnit> dartUnits =
+                  context.ensureResolvedDartUnits(source);
+              if (dartUnits != null) {
+                AnalysisErrorInfo errorInfo = context.getErrors(source);
+                for (var dartUnit in dartUnits) {
+                  scheduleNotificationOperations(this, file, errorInfo.lineInfo,
+                      context, null, dartUnit, errorInfo.errors);
+                  scheduleIndexOperation(this, file, context, dartUnit);
+                }
+              } else {
+                schedulePerformAnalysisOperation(context);
               }
-            } else {
-              schedulePerformAnalysisOperation(context);
             }
           }
-        }
+        });
       }
     });
   }
 
   /**
    * Use the given updaters to update the values of the options in every
    * existing analysis context.
    */
   void updateOptions(List<OptionUpdater> optionUpdaters) {
     //
@@ skipping 308 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');
 }