Converted Observatory metrics-page element

runtime/observatory/lib/src/app/page.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.
 
 part of app;
 
 final _allocationProfileRepository = new AllocationProfileRepository();
 final _breakpointRepository = new BreakpointRepository();
 final _classSampleProfileRepository = new ClassSampleProfileRepository();
 final _classRepository = new ClassRepository();
 final _contextRepository = new ContextRepository();
 final _evalRepository = new EvalRepository();
 final _fieldRepository = new FieldRepository();
 final _functionRepository = new FunctionRepository();
 final _heapSnapshotRepository = new HeapSnapshotRepository();
 final _icdataRepository = new ICDataRepository();
 final _inboundReferencesRepository = new InboundReferencesRepository();
 final _instanceRepository = new InstanceRepository();
 final _isolateRepository = new IsolateRepository();
 final _isolateSampleProfileRepository = new IsolateSampleProfileRepository();
 final _libraryRepository = new LibraryRepository();
 final _megamorphicCacheRepository = new MegamorphicCacheRepository();
+final _metricRepository = new MetricRepository();
 final _objectRepository = new ObjectRepository();
 final _objectPoolRepository = new ObjectPoolRepository();
 final _objectstoreRepository = new ObjectStoreRepository();
 final _persistentHandlesRepository = new PersistentHandlesRepository();
 final _portsRepository = new PortsRepository();
 final _scriptRepository = new ScriptRepository();
 final _stronglyReachangleInstancesRepository =
     new StronglyReachableInstancesRepository();
 final _topRetainingInstancesRepository = new TopRetainingInstancesRepository();
 final _typeArgumentsRepository = new TypeArgumentsRepository();
@@ skipping 604 matching lines @@
     });
   }
 
   void onInstall() {
     if (element == null) {
       element = container;
     }
   }
 }
 
-
 class LoggingPage extends SimplePage {
   LoggingPage(app) : super('logging', 'logging-page', app);
 
   void _visit(Uri uri) {
     super._visit(uri);
     getIsolate(uri).then((isolate) {
       if (element != null) {
         /// Update the page.
         LoggingPageElement page = element;
         page.isolate = isolate;
@@ skipping 60 matching lines @@
                                   uri.queryParameters['isolateId'],
                                   Uri.parse(uri.queryParameters['originalUri']))
     ];
     assert(element != null);
     assert(canVisit(uri));
   }
 
   bool canVisit(Uri uri) => uri.path == 'isolate-reconnect';
 }
 
-class MetricsPage extends Page {
-  // Page state, retained as long as ObservatoryApplication.
-  String selectedMetricId;
+class MetricsPage extends MatchingPage {
+  MetricsPage(app) : super('metrics', app);
 
-  final Map<int, MetricPoller> pollers = new Map<int, MetricPoller>();
+  final DivElement container = new DivElement();
 
-  // 8 seconds, 4 seconds, 2 seconds, 1 second, and one hundred milliseconds.
-  static final List<int> POLL_PERIODS = [8000,
-                                         4000,
-                                         2000,
-                                         1000,
-                                         100];
+  Isolate lastIsolate;
 
-  MetricsPage(app) : super(app) {
-    for (var i = 0; i < POLL_PERIODS.length; i++) {
-      pollers[POLL_PERIODS[i]] = new MetricPoller(POLL_PERIODS[i]);
-    }
+  void _visit(Uri uri) {
+    super._visit(uri);
+    getIsolate(uri).then((isolate) async {
+      lastIsolate = isolate;
+      container.children = const [];
+      await _metricRepository.startSampling(isolate);
+      container.children = [
+        new MetricsPageElement(isolate.vm, isolate, app.events,
+                               app.notifications, _metricRepository,
+                               queue: app.queue)
+      ];
+    });
   }
 
   void onInstall() {
     if (element == null) {
-      element = new Element.tag('metrics-page');
-      (element as MetricsPageElement).page = this;
+      element = container;
     }
-    assert(element != null);
   }
 
-  void setRefreshPeriod(int refreshPeriod, ServiceMetric metric) {
-    if (metric.poller != null) {
-      if (metric.poller.pollPeriod.inMilliseconds == refreshPeriod) {
-        return;
-      }
-      // Remove from current poller.
-      metric.poller.metrics.remove(metric);
-      metric.poller = null;
-    }
-    if (refreshPeriod == 0) {
-      return;
-    }
-    var poller = pollers[refreshPeriod];
-    if (poller != null) {
-      poller.metrics.add(metric);
-      metric.poller = poller;
-      return;
-    }
-    throw new FallThroughError();
+  @override
+  void onUninstall() {
+    _metricRepository.stopSampling(lastIsolate);
   }
-
-  void _visit(Uri uri) {
-    assert(element != null);
-    assert(canVisit(uri));
-    app.vm.getIsolate(uri.queryParameters['isolateId']).then((i) {
-      (element as MetricsPageElement).isolate = i;
-    });
-  }
-
-  bool canVisit(Uri uri) => uri.path == 'metrics';
 }
 
 class TimelinePage extends Page {
   TimelinePage(app) : super(app);
 
   void onInstall() {
     if (element == null) {
       element = new Element.tag('timeline-page');
     }
     assert(element != null);
   }
 
   void _visit(Uri uri) {
     assert(element != null);
     assert(canVisit(uri));
   }
 
   bool canVisit(Uri uri) => uri.path == 'timeline';
 }