Report analysis exceptions using the 'exceptions' stream or 'completeError'.

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 614 matching lines @@
   /**
    * 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) async {
     nd.AnalysisResult result = priorityFileResults[path];
     if (result != null) {
       return result;
     }
-    nd.AnalysisDriver driver = getAnalysisDriver(path);
-    return driver?.getResult(path);
+    try {
+      nd.AnalysisDriver driver = getAnalysisDriver(path);
+      return await driver?.getResult(path);
+    } catch (e) {
+      // Ignore the exception.
+      // We don't want to log the same exception again and again.
+      return null;
+    }
   }
 
   CompilationUnitElement getCompilationUnitElement(String file) {
     ContextSourcePair pair = getContextSourcePair(file);
     if (pair == null) {
       return null;
     }
     // prepare AnalysisContext and Source
     AnalysisContext context = pair.context;
     Source unitSource = pair.source;
@@ skipping 557 matching lines @@
       if (drivers.isNotEmpty) {
         Set<String> allNewFiles =
             subscriptions.values.expand((files) => files).toSet();
         for (String file in allNewFiles) {
           nd.AnalysisDriver driver = drivers.firstWhere(
               (driver) => driver.addedFiles.contains(file),
               orElse: () => drivers.first);
           // 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.
-          driver.getResult(file);
+          driver.getResult(file).catchError((exception, stackTrace) {});
         }
       }
       return;
     }
     // send notifications for already analyzed sources
     subscriptions.forEach((service, Set<String> newFiles) {
       Set<String> oldFiles = analysisServices[service];
       Set<String> todoFiles =
           oldFiles != null ? newFiles.difference(oldFiles) : newFiles;
       for (String file in todoFiles) {
@@ skipping 616 matching lines @@
           _runDelayed(() {
             sendAnalysisNotificationOverrides(analysisServer, path, unit);
           });
         }
       }
       // TODO(scheglov) Implement more notifications.
       // IMPLEMENTED
       // OCCURRENCES (not used in IDEA)
       // OUTLINE (not used in IDEA)
     });
+    analysisDriver.exceptions.listen((nd.ExceptionResult result) {
+      AnalysisEngine.instance.logger
+          .logError('Analysis failed: ${result.path}', result.exception);
+    });
     analysisServer.driverMap[folder] = analysisDriver;
     return analysisDriver;
   }
 
   @override
   AnalysisContext addContext(Folder folder, AnalysisOptions options) {
     ContextBuilder builder = createContextBuilder(folder, options);
     AnalysisContext context = builder.buildContext(folder.path);
 
     analysisServer.folderMap[folder] = context;
@@ skipping 224 matching lines @@
    */
   static PerformanceTag splitStore = new PerformanceTag('splitStore');
 }
 
 class _NullStringSink implements StringSink {
   void write(Object obj) {}
   void writeAll(Iterable objects, [String separator = ""]) {}
   void writeCharCode(int charCode) {}
   void writeln([Object obj = ""]) {}
 }