Catch and report exceptions in computers.

pkg/analysis_server/lib/src/operation/operation_analysis.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 operation.analysis;
 
 import 'package:analysis_server/src/analysis_server.dart';
 import 'package:analysis_server/src/computer/computer_highlights.dart';
 import 'package:analysis_server/src/computer/computer_navigation.dart';
 import 'package:analysis_server/src/computer/computer_occurrences.dart';
 import 'package:analysis_server/src/computer/computer_outline.dart';
 import 'package:analysis_server/src/computer/computer_overrides.dart';
 import 'package:analysis_server/src/operation/operation.dart';
 import 'package:analysis_server/src/protocol_server.dart' as protocol;
 import 'package:analysis_server/src/services/index/index.dart';
 import 'package:analyzer/src/generated/ast.dart';
 import 'package:analyzer/src/generated/engine.dart';
 import 'package:analyzer/src/generated/error.dart';
 import 'package:analyzer/src/generated/html.dart';
 import 'package:analyzer/src/generated/source.dart';
 
 
 void sendAnalysisNotificationErrors(AnalysisServer server, String file,
     LineInfo lineInfo, List<AnalysisError> errors) {
-  if (errors == null) {
-    errors = <AnalysisError>[];
+  try {
+    if (errors == null) {
+      errors = <AnalysisError>[];
+    }
+    var serverErrors =
+        protocol.doAnalysisError_listFromEngine(lineInfo, errors);
+    var params = new protocol.AnalysisErrorsParams(file, serverErrors);
+    server.sendNotification(params.toNotification());
+  } catch (exception, stackTrace) {
+    server.sendServerErrorNotification(exception, stackTrace, fatal: false);
   }
-  var serverErrors = protocol.doAnalysisError_listFromEngine(lineInfo, errors);
-  var params = new protocol.AnalysisErrorsParams(file, serverErrors);
-  server.sendNotification(params.toNotification());
 }
 
 
 void sendAnalysisNotificationHighlights(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  var regions = new DartUnitHighlightsComputer(dartUnit).compute();
-  var params = new protocol.AnalysisHighlightsParams(file, regions);
-  server.sendNotification(params.toNotification());
+  try {
+    var regions = new DartUnitHighlightsComputer(dartUnit).compute();
+    var params = new protocol.AnalysisHighlightsParams(file, regions);
+    server.sendNotification(params.toNotification());
+  } catch (exception, stackTrace) {
+    server.sendServerErrorNotification(exception, stackTrace, fatal: false);
+  }
 }
 
 
 void sendAnalysisNotificationNavigation(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  var computer = new DartUnitNavigationComputer(dartUnit);
-  computer.compute();
-  var params = new protocol.AnalysisNavigationParams(
-      file,
-      computer.regions,
-      computer.targets,
-      computer.files);
-  server.sendNotification(params.toNotification());
+  try {
+    var computer = new DartUnitNavigationComputer(dartUnit);
+    computer.compute();
+    var params = new protocol.AnalysisNavigationParams(
+        file,
+        computer.regions,
+        computer.targets,
+        computer.files);
+    server.sendNotification(params.toNotification());
+  } catch (exception, stackTrace) {
+    server.sendServerErrorNotification(exception, stackTrace, fatal: false);
+  }
 }
 
 
 void sendAnalysisNotificationOccurrences(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  var occurrences = new DartUnitOccurrencesComputer(dartUnit).compute();
-  var params = new protocol.AnalysisOccurrencesParams(file, occurrences);
-  server.sendNotification(params.toNotification());
+  try {
+    var occurrences = new DartUnitOccurrencesComputer(dartUnit).compute();
+    var params = new protocol.AnalysisOccurrencesParams(file, occurrences);
+    server.sendNotification(params.toNotification());
+  } catch (exception, stackTrace) {
+    server.sendServerErrorNotification(exception, stackTrace, fatal: false);
+  }
 }
 
 
 void sendAnalysisNotificationOutline(AnalysisServer server, Source source,
     LineInfo lineInfo, CompilationUnit dartUnit) {
-  var outline =
-      new DartUnitOutlineComputer(source, lineInfo, dartUnit).compute();
-  var params = new protocol.AnalysisOutlineParams(source.fullName, outline);
-  server.sendNotification(params.toNotification());
+  try {
+    var computer = new DartUnitOutlineComputer(source, lineInfo, dartUnit);
+    var outline = computer.compute();
+    var params = new protocol.AnalysisOutlineParams(source.fullName, outline);
+    server.sendNotification(params.toNotification());
+  } catch (exception, stackTrace) {
+    server.sendServerErrorNotification(exception, stackTrace, fatal: false);
+  }
 }
 
 
 void sendAnalysisNotificationOverrides(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  var overrides = new DartUnitOverridesComputer(dartUnit).compute();
-  var params = new protocol.AnalysisOverridesParams(file, overrides);
-  server.sendNotification(params.toNotification());
+  try {
+    var overrides = new DartUnitOverridesComputer(dartUnit).compute();
+    var params = new protocol.AnalysisOverridesParams(file, overrides);
+    server.sendNotification(params.toNotification());
+  } catch (exception, stackTrace) {
+    server.sendServerErrorNotification(exception, stackTrace, fatal: false);
+  }
 }
 
 
 /**
  * Instances of [PerformAnalysisOperation] perform a single analysis task.
  */
 class PerformAnalysisOperation extends ServerOperation {
   final AnalysisContext context;
   final bool isContinue;
 
@@ skipping 22 matching lines @@
     AnalysisResult result = context.performAnalysisTask();
     List<ChangeNotice> notices = result.changeNotices;
     if (notices == null) {
       server.sendContextAnalysisDoneNotifications(
           context,
           AnalysisDoneReason.COMPLETE);
       return;
     }
     // process results
     sendNotices(server, notices);
-    updateIndex(server.index, notices);
+    updateIndex(server, notices);
     // continue analysis
     server.addOperation(new PerformAnalysisOperation(context, true));
   }
 
   /**
    * Send the information in the given list of notices back to the client.
    */
   void sendNotices(AnalysisServer server, List<ChangeNotice> notices) {
     for (int i = 0; i < notices.length; i++) {
       ChangeNotice notice = notices[i];
@@ skipping 33 matching lines @@
         sendAnalysisNotificationErrors(
             server,
             file,
             notice.lineInfo,
             notice.errors);
       }
       server.fileAnalyzed(notice);
     }
   }
 
-  void updateIndex(Index index, List<ChangeNotice> notices) {
+  void updateIndex(AnalysisServer server, List<ChangeNotice> notices) {
+    Index index = server.index;
     if (index == null) {
       return;
     }
     for (ChangeNotice notice in notices) {
       // Dart
-      {
+      try {
         CompilationUnit dartUnit = notice.compilationUnit;
         if (dartUnit != null) {
           index.indexUnit(context, dartUnit);
         }
+      } catch (exception, stackTrace) {
+        server.sendServerErrorNotification(exception, stackTrace, fatal: false);
       }
       // HTML
-      {
+      try {
         HtmlUnit htmlUnit = notice.htmlUnit;
         if (htmlUnit != null) {
           index.indexHtmlUnit(context, htmlUnit);
         }
+      } catch (exception, stackTrace) {
+        server.sendServerErrorNotification(exception, stackTrace, fatal: false);
       }
     }
   }
 }