Merge notifications computing into the 'notices' tag.

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';
@@ skipping 66 matching lines @@
   // errors
   if (server.shouldSendErrorsNotificationFor(file)) {
     server.scheduleOperation(
         new _NotificationErrorsOperation(file, lineInfo, errors));
   }
 }
 
 
 void sendAnalysisNotificationErrors(AnalysisServer server, String file,
     LineInfo lineInfo, List<AnalysisError> errors) {
-  try {
+  _sendNotification(server, () {
     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);
-  }
+  });
 }
 
-
 void sendAnalysisNotificationHighlights(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  try {
+  _sendNotification(server, () {
     var regions = new DartUnitHighlightsComputer(dartUnit).compute();
     var params = new protocol.AnalysisHighlightsParams(file, regions);
     server.sendNotification(params.toNotification());
-  } catch (exception, stackTrace) {
-    server.sendServerErrorNotification(exception, stackTrace);
-  }
+  });
 }
 
 
 void sendAnalysisNotificationNavigation(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  try {
+  _sendNotification(server, () {
     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);
-  }
+  });
 }
 
 
 void sendAnalysisNotificationOccurrences(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  try {
+  _sendNotification(server, () {
     var occurrences = new DartUnitOccurrencesComputer(dartUnit).compute();
     var params = new protocol.AnalysisOccurrencesParams(file, occurrences);
     server.sendNotification(params.toNotification());
-  } catch (exception, stackTrace) {
-    server.sendServerErrorNotification(exception, stackTrace);
-  }
+  });
 }
 
 
 void sendAnalysisNotificationOutline(AnalysisServer server, String file,
     LineInfo lineInfo, CompilationUnit dartUnit) {
-  try {
+  _sendNotification(server, () {
     var computer = new DartUnitOutlineComputer(file, lineInfo, dartUnit);
     var outline = computer.compute();
     var params = new protocol.AnalysisOutlineParams(file, outline);
     server.sendNotification(params.toNotification());
-  } catch (exception, stackTrace) {
-    server.sendServerErrorNotification(exception, stackTrace);
-  }
+  });
 }
 
 
 void sendAnalysisNotificationOverrides(AnalysisServer server, String file,
     CompilationUnit dartUnit) {
-  try {
+  _sendNotification(server, () {
     var overrides = new DartUnitOverridesComputer(dartUnit).compute();
     var params = new protocol.AnalysisOverridesParams(file, overrides);
     server.sendNotification(params.toNotification());
-  } catch (exception, stackTrace) {
-    server.sendServerErrorNotification(exception, stackTrace);
-  }
+  });
 }
 
 
+/**
+ * Runs the given notification producing function [f], catching exceptions.
+ */
+void _sendNotification(AnalysisServer server, f()) {
+  ServerPerformanceStatistics.notices.makeCurrentWhile(() {
+    try {
+      f();
+    } catch (exception, stackTrace) {
+      server.sendServerErrorNotification(exception, stackTrace);
+    }
+  });
+}
+
+
 /**
  * Instances of [PerformAnalysisOperation] perform a single analysis task.
  */
 class PerformAnalysisOperation extends ServerOperation {
   static const int IDLE_CACHE_SIZE = AnalysisOptionsImpl.DEFAULT_CACHE_SIZE;
   static const int WORKING_CACHE_SIZE = 512;
 
   final AnalysisContext context;
   final bool isContinue;
 
@@ skipping 244 matching lines @@
 abstract class _SingleFileOperation extends SourceSensitiveOperation {
   final String file;
 
   _SingleFileOperation(this.file);
 
   @override
   bool shouldBeDiscardedOnSourceChange(Source source) {
     return source.fullName == file;
   }
 }