Add some message scheduler data to the collected report

Change-Id: I086b741a90955a2753efbabdf1c3cb321de98ee0
Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/432903
Commit-Queue: Brian Wilkerson <[email protected]>
Reviewed-by: Samuel Rawlins <[email protected]>

Author: bwilkerson

pkg/analysis_server/lib/src/status/pages/collect_report_page.dart

@@ -14,6 +14,7 @@ import 'package:analysis_server/src/legacy_analysis_server.dart';
 import 'package:analysis_server/src/lsp/lsp_analysis_server.dart'
     show LspAnalysisServer;
 import 'package:analysis_server/src/scheduler/message_scheduler.dart';
+import 'package:analysis_server/src/scheduler/scheduler_tracking_listener.dart';
 import 'package:analysis_server/src/status/diagnostics.dart';
 import 'package:analysis_server/src/status/pages.dart';
 import 'package:analysis_server/src/status/utilities/library_cycle_extensions.dart';
@@ -252,6 +253,53 @@ class CollectReportPage extends DiagnosticPage {
   void _collectMessageSchedulerData(Map<String, Object?> collectedData) {
     collectedData['allowOverlappingHandlers'] =
         MessageScheduler.allowOverlappingHandlers;
+
+    var now = DateTime.now().millisecondsSinceEpoch;
+    var listener = server.messageScheduler.listener;
+    if (listener is! SchedulerTrackingListener) {
+      return;
+    }
+
+    Map<String, Object?> buildMessageData(
+      MessageData data, {
+      required bool isActive,
+    }) {
+      Map<String, Object?> messageData = {};
+      messageData['id'] = data.message.id;
+      messageData['pendingMessageCount'] = data.pendingMessageCount;
+      messageData['pendingDuration'] =
+          (data.activeTime ?? now) - data.pendingTime;
+      if (isActive) {
+        messageData['activeMessageCount'] = data.activeMessageCount;
+        messageData['runningDuration'] = now - data.activeTime!;
+      }
+      return messageData;
+    }
+
+    var (:pending, :active) = listener.pendingAndActiveMessages;
+    if (pending.isNotEmpty) {
+      pending.sort(
+        (first, second) => first.pendingTime.compareTo(second.pendingTime),
+      );
+      var pendingMessages = <Map<String, Object?>>[];
+      for (var data in pending) {
+        pendingMessages.add(buildMessageData(data, isActive: false));
+      }
+      collectedData['pendingMessages'] = pendingMessages;
+    }
+
+    if (active.isNotEmpty) {
+      active.sort(
+        (first, second) => first.activeTime!.compareTo(second.activeTime!),
+      );
+      var activeMessages = <Map<String, Object?>>[];
+      for (var data in active) {
+        activeMessages.add(buildMessageData(data, isActive: true));
+      }
+      collectedData['activeMessages'] = activeMessages;
+    }
+
+    collectedData['completedMessageLog'] = listener.completedMessageLog;
   }
 
   Future<void> _collectObservatoryData(

pkg/analysis_server/lib/src/status/pages/message_scheduler_page.dart

@@ -20,6 +20,7 @@ class MessageSchedulerPage extends DiagnosticPageWithNav {
 
   @override
   Future<void> generateContent(Map<String, String> params) async {
+    var now = DateTime.now().millisecondsSinceEpoch;
     var listener = server.messageScheduler.listener;
 
     h3('Status');
@@ -38,14 +39,11 @@ class MessageSchedulerPage extends DiagnosticPageWithNav {
       p(data.message.id);
       buf.write('<blockquote>');
       p('Pending messages ahead of this: ${data.pendingMessageCount}');
-      p(
-        'Time spent on pending queue: ${(data.activeTime ?? DateTime.now().millisecondsSinceEpoch) - data.pendingTime}',
-      );
+      var pendingDuration = (data.activeTime ?? now) - data.pendingTime;
+      p('Time spent on pending queue: $pendingDuration');
       if (isActive) {
         p('Active messages ahead of this: ${data.activeMessageCount}');
-        p(
-          'Time spent running: ${DateTime.now().millisecondsSinceEpoch - data.activeTime!}',
-        );
+        p('Time spent running: ${now - data.activeTime!}');
       }
       buf.write('</blockquote>');
     }